34 #ifndef __CPP_REDIS_READ_SIZE 35 #define __CPP_REDIS_READ_SIZE 4096 47 #ifndef __CPP_REDIS_USE_CUSTOM_TCP_CLIENT 88 const std::string& host =
"127.0.0.1",
89 std::size_t port = 6379,
90 const disconnection_handler_t& disconnection_handler =
nullptr,
91 const reply_callback_t& reply_callback =
nullptr,
92 std::uint32_t timeout_msecs = 0);
99 void disconnect(
bool wait_for_removal =
false);
143 std::string
build_command(
const std::vector<std::string>& redis_cmd);
155 std::shared_ptr<cpp_redis::network::tcp_client_iface>
m_client;
void disconnect(bool wait_for_removal=false)
void tcp_client_receive_handler(const tcp_client_iface::read_result &result)
Definition: redis_connection.hpp:45
std::function< void(redis_connection &)> disconnection_handler_t
Definition: redis_connection.hpp:71
std::function< void(redis_connection &, reply &)> reply_callback_t
Definition: redis_connection.hpp:76
std::shared_ptr< cpp_redis::network::tcp_client_iface > m_client
Definition: redis_connection.hpp:155
redis_connection & send(const std::vector< std::string > &redis_cmd)
std::mutex m_buffer_mutex
Definition: redis_connection.hpp:180
disconnection_handler_t m_disconnection_handler
Definition: redis_connection.hpp:165
void call_disconnection_handler(void)
bool is_connected(void) const
redis_connection & operator=(const redis_connection &)=delete
assignment operator
reply_callback_t m_reply_callback
Definition: redis_connection.hpp:160
void connect(const std::string &host="127.0.0.1", std::size_t port=6379, const disconnection_handler_t &disconnection_handler=nullptr, const reply_callback_t &reply_callback=nullptr, std::uint32_t timeout_msecs=0)
Definition: reply_builder.hpp:40
redis_connection & commit(void)
std::string build_command(const std::vector< std::string > &redis_cmd)
builders::reply_builder m_builder
Definition: redis_connection.hpp:170
redis_connection(void)
ctor
void tcp_client_disconnection_handler(void)
~redis_connection(void)
dtor
std::string m_buffer
Definition: redis_connection.hpp:175
Definition: tcp_client.hpp:37
Definition: tcp_client_iface.hpp:70
Definition: array_builder.hpp:29