acknowledgement_callback_t typedef | cpp_redis::subscriber | |
add_sentinel(const std::string &host, std::size_t port) | cpp_redis::subscriber | |
auth(const std::string &password, const reply_callback_t &reply_callback=nullptr) | cpp_redis::subscriber | |
call_acknowledgement_callback(const std::string &channel, const std::map< std::string, callback_holder > &channels, std::mutex &channels_mtx, int64_t nb_chans) | cpp_redis::subscriber | private |
cancel_reconnect(void) | cpp_redis::subscriber | |
clear_sentinels(void) | cpp_redis::subscriber | |
clear_subscriptions(void) | cpp_redis::subscriber | private |
commit(void) | cpp_redis::subscriber | |
connect(const std::string &host="127.0.0.1", std::size_t port=6379, const connect_callback_t &connect_callback=nullptr, std::uint32_t timeout_msecs=0, std::int32_t max_reconnects=0, std::uint32_t reconnect_interval_msecs=0) | cpp_redis::subscriber | |
connect(const std::string &name, const connect_callback_t &connect_callback=nullptr, std::uint32_t timeout_msecs=0, std::int32_t max_reconnects=0, std::uint32_t reconnect_interval_msecs=0) | cpp_redis::subscriber | |
connect_callback_t typedef | cpp_redis::subscriber | |
connect_state enum name | cpp_redis::subscriber | |
connection_disconnection_handler(network::redis_connection &connection) | cpp_redis::subscriber | private |
connection_receive_handler(network::redis_connection &connection, reply &reply) | cpp_redis::subscriber | private |
disconnect(bool wait_for_removal=false) | cpp_redis::subscriber | |
get_sentinel(void) const | cpp_redis::subscriber | |
get_sentinel(void) | cpp_redis::subscriber | |
handle_acknowledgement_reply(const std::vector< reply > &reply) | cpp_redis::subscriber | private |
handle_psubscribe_reply(const std::vector< reply > &reply) | cpp_redis::subscriber | private |
handle_subscribe_reply(const std::vector< reply > &reply) | cpp_redis::subscriber | private |
is_connected(void) const | cpp_redis::subscriber | |
is_reconnecting(void) const | cpp_redis::subscriber | |
m_auth_reply_callback | cpp_redis::subscriber | private |
m_cancel | cpp_redis::subscriber | private |
m_client | cpp_redis::subscriber | private |
m_connect_callback | cpp_redis::subscriber | private |
m_connect_timeout_msecs | cpp_redis::subscriber | private |
m_current_reconnect_attempts | cpp_redis::subscriber | private |
m_master_name | cpp_redis::subscriber | private |
m_max_reconnects | cpp_redis::subscriber | private |
m_password | cpp_redis::subscriber | private |
m_psubscribed_channels | cpp_redis::subscriber | private |
m_psubscribed_channels_mutex | cpp_redis::subscriber | private |
m_reconnect_interval_msecs | cpp_redis::subscriber | private |
m_reconnecting | cpp_redis::subscriber | private |
m_redis_port | cpp_redis::subscriber | private |
m_redis_server | cpp_redis::subscriber | private |
m_sentinel | cpp_redis::subscriber | private |
m_subscribed_channels | cpp_redis::subscriber | private |
m_subscribed_channels_mutex | cpp_redis::subscriber | private |
operator=(const subscriber &)=delete | cpp_redis::subscriber | |
psubscribe(const std::string &pattern, const subscribe_callback_t &callback, const acknowledgement_callback_t &acknowledgement_callback=nullptr) | cpp_redis::subscriber | |
punsubscribe(const std::string &pattern) | cpp_redis::subscriber | |
re_auth(void) | cpp_redis::subscriber | private |
re_subscribe(void) | cpp_redis::subscriber | private |
reconnect(void) | cpp_redis::subscriber | private |
reply_callback_t typedef | cpp_redis::subscriber | |
should_reconnect(void) const | cpp_redis::subscriber | private |
sleep_before_next_reconnect_attempt(void) | cpp_redis::subscriber | private |
subscribe(const std::string &channel, const subscribe_callback_t &callback, const acknowledgement_callback_t &acknowledgement_callback=nullptr) | cpp_redis::subscriber | |
subscribe_callback_t typedef | cpp_redis::subscriber | |
subscriber(void) | cpp_redis::subscriber | |
subscriber(const std::shared_ptr< network::tcp_client_iface > &tcp_client) | cpp_redis::subscriber | explicit |
subscriber(const subscriber &)=delete | cpp_redis::subscriber | |
unprotected_psubscribe(const std::string &pattern, const subscribe_callback_t &callback, const acknowledgement_callback_t &acknowledgement_callback) | cpp_redis::subscriber | private |
unprotected_subscribe(const std::string &channel, const subscribe_callback_t &callback, const acknowledgement_callback_t &acknowledgement_callback) | cpp_redis::subscriber | private |
unsubscribe(const std::string &channel) | cpp_redis::subscriber | |
~subscriber(void) | cpp_redis::subscriber | |