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