Go to the documentation of this file.
13 int get(std::string container,
int key);
14 void put(std::string container,
int key,
int value);
15 void erase(std::string container,
int key);
void reset()
Definition: basic_data_connector.cpp:69
CacheServer server
Definition: cache_server.cpp:236
Definition: basic_data_connector.h:6
static ssize_t loop_read(int fd, void *data, size_t size)
Definition: requests.h:105
po::variables_map config
Definition: application.cpp:25
void erase(std::string container, int key)
Definition: basic_data_connector.cpp:86
void createContainer(std::string container)
Definition: basic_data_connector.cpp:96
char container[10]
Definition: requests.h:14
std::queue< T > queue
Definition: application.cpp:80
int key
Definition: requests.h:24
void insert(std::vector< T > &objects)
Definition: application.cpp:95
DataConnectorInterface * getDataConnector()
Definition: application.cpp:62
void put(std::string container, int key, int value)
Definition: basic_data_connector.cpp:76
void start(int c=0)
Definition: application.cpp:100
int main(int ac, char *av[])
Definition: application.cpp:133
Definition: requests.h:22
Definition: requests.h:27
void initConfig(int ac, char *av[])
Definition: application.cpp:27
std::function< void(T)> executor
Definition: application.cpp:79
RequestType
Definition: requests.h:37
Definition: application.cpp:78
Definition: postgres_data_connector.h:8
int key
Definition: requests.h:33
void threadRunner()
Definition: application.cpp:107
int get(std::string container, int key)
Definition: basic_data_connector.cpp:49
static ssize_t loop_write(int fd, const void *data, size_t size)
Definition: requests.h:82
std::mutex queueLock
Definition: application.cpp:81
Definition: requests.h:31
unordered_map< int, int > db
Definition: application.cpp:24
std::string ip
Definition: basic_data_connector.h:7
int key
Definition: requests.h:15
int port
Definition: basic_data_connector.h:8
void insert(T obj)
Definition: application.cpp:90
Definition: data_connector_interface.h:4
int getConnection()
Definition: basic_data_connector.cpp:28
DataConnector
Definition: data_connectors.h:4
WorkerPool(std::function< void(T)> executor, int threadCount=0, bool exitWhenDone=true)
Definition: application.cpp:86
int threadCount
Definition: application.cpp:83
add_library(basic_data_connector basic_data_connector.cpp) target_include_directories(basic_data_connector PUBLIC $
Definition: CMakeLists.txt:1
char container[10]
Definition: requests.h:32
#define TIMECHECK(x, message, limit)
Definition: basic_data_connector.cpp:15
int value
Definition: requests.h:28
void join()
Definition: application.cpp:128
BasicDataConnector(std::string ip, int port)
Definition: basic_data_connector.h:12
char container[10]
Definition: requests.h:23
std::vector< std::thread > threads
Definition: application.cpp:82
Definition: requests.h:13