Repo-Init
 
Loading...
Searching...
No Matches
ZeroMQServer Member List

This is the complete list of members for ZeroMQServer, including all inherited members.

_checkFlagZeroMQServerprivate
_contextPtrZeroMQprivate
_isActiveZeroMQprivate
_isBindedZeroMQprivate
_m_messageCallbackZeroMQServerprivate
_monitorThreadZeroMQMonitorprivate
_serverThreadZeroMQServerprivate
_shouldStopZeroMQServerprivate
_socketAddrZeroMQprivate
_socketPtrZeroMQprivate
_statsZeroMQServerprivate
getAddress() constZeroMQinlineprivate
getContext() constZeroMQinlineprivate
getSocket() constZeroMQinlineprivate
init(const std::shared_ptr< zmq::context_t > &ctx, const zmq::socket_type &type, const std::string_view &addr, bool isBind)ZeroMQprivate
initialise()ZeroMQServer
messageCallback(FPTR_MessageCallback func)ZeroMQServerinline
messageCallback() constZeroMQServerinline
on_event(const std::string &messageStr, int level, const char *addr=nullptr)ZeroMQMonitorprivatestatic
on_event_accept_failed(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_accepted(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_bind_failed(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_close_failed(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_closed(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_connect_delayed(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_connect_retried(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_connected(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_disconnected(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_handshake_failed_auth(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_handshake_failed_no_detail(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_handshake_failed_protocol(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_handshake_succeeded(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_listening(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_event_unknown(const zmq_event_t &, const char *addr_) overrideZeroMQMonitorprivate
on_monitor_started() overrideZeroMQMonitorprivate
operator=(ZeroMQServer)=deleteZeroMQServer
operator=(ZeroMQServer &&)=deleteZeroMQServer
ZeroMQ::operator=(ZeroMQ)=deleteZeroMQprivate
ZeroMQ::operator=(ZeroMQ &&)=deleteZeroMQprivate
ZeroMQMonitor::operator=(ZeroMQMonitor)=deleteZeroMQMonitorprivate
ZeroMQMonitor::operator=(ZeroMQMonitor &&)=deleteZeroMQMonitorprivate
recvMessages()ZeroMQprivate
sendMessages(std::vector< zmq::message_t > &msg)ZeroMQprivate
shutdown()ZeroMQServer
start()ZeroMQprivate
startMonitoring(zmq::socket_t *socket, const std::string &monitorAddress)ZeroMQMonitorprivate
stop()ZeroMQprivate
stopMonitoring()ZeroMQMonitorprivate
threadFunc() noexceptZeroMQServerprivate
update()ZeroMQServerprivate
ZeroMQ(const zmq::socket_type &type, const std::string &addr, bool isBind)ZeroMQprivate
ZeroMQ(const std::shared_ptr< zmq::context_t > &ctx, const zmq::socket_type &type, const std::string &addr, bool isBind)ZeroMQprivate
ZeroMQ(const ZeroMQ &)=deleteZeroMQprivate
ZeroMQ(ZeroMQ &&)=deleteZeroMQprivate
ZeroMQMonitor()=defaultZeroMQMonitorprivate
ZeroMQMonitor(const ZeroMQMonitor &)=deleteZeroMQMonitorprivate
ZeroMQMonitor(ZeroMQMonitor &&)=deleteZeroMQMonitorprivate
ZeroMQServer(const std::string &hostAddr, std::shared_ptr< std::atomic_flag > checkFlag, const std::shared_ptr< prometheus::Registry > &reg=nullptr, const std::string &prependName="")ZeroMQServer
ZeroMQServer(const ZeroMQServer &)=deleteZeroMQServer
ZeroMQServer(ZeroMQServer &&)=deleteZeroMQServer
~ZeroMQ()ZeroMQprivate
~ZeroMQMonitor() overrideZeroMQMonitorinlineprivate
~ZeroMQServer() overrideZeroMQServerinline