, including all inherited members.
| acceptEventHandler | Datacratic::ZmqNamedEndpoint | |
| activate() | Datacratic::NamedEndpoint | |
| addFd(int fd, void *data=0) | Datacratic::Epoller | |
| addFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
| addPeriodic(const std::string &name, double timePeriodSeconds, std::function< void(uint64_t)> toRun, int priority=0) | Datacratic::MessageLoop | |
| addPeriodicDeferred(const std::string &name, double timePeriodSeconds, std::function< void(uint64_t)> toRun, int priority=0) | Datacratic::MessageLoop | |
| addrToIp(const std::string &addr) | Datacratic::NamedEndpoint | [static] |
| addrToString(const sockaddr *addr) | Datacratic::NamedEndpoint | [static] |
| addSource(const std::string &name, AsyncEventSource &source, int priority=0) | Datacratic::MessageLoop | |
| addSource(const std::string &name, std::shared_ptr< AsyncEventSource > source, int priority=0) | Datacratic::MessageLoop | |
| addSourceDeferred(const std::string &name, AsyncEventSource &source, int priority=0) | Datacratic::MessageLoop | |
| addSourceDeferred(const std::string &name, std::shared_ptr< AsyncEventSource > source, int priority=0) | Datacratic::MessageLoop | |
| afterSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
| beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| bind(const std::string &address) | Datacratic::ZmqNamedEndpoint | [inline] |
| bindTcp(PortRange const &portRange=PortRange(), std::string host="") | Datacratic::ZmqNamedEndpoint | |
| checkNeedsPoll() | Datacratic::MessageLoop | |
| clientMessageHandler (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | |
| ClientMessageHandler typedef (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | |
| close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| closeEventHandler | Datacratic::ZmqNamedEndpoint | |
| connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
| ConnectionEventHandler typedef (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| deadClientDelay | Datacratic::ZmqNamedClientBus | |
| debug(bool debugOn) | Datacratic::MessageLoop | [virtual] |
| disconnect() | Datacratic::AsyncEventSource | |
| disconnectEventHandler | Datacratic::ZmqNamedEndpoint | |
| Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| getInterfaces(const std::set< int > &families=std::set< int >({AF_INET}), int flagsRequired=IFF_UP, int flagsExcluded=0) | Datacratic::NamedEndpoint | [static] |
| getPublishedUris() const (defined in Datacratic::NamedEndpoint) | Datacratic::NamedEndpoint | |
| getSocketUnsafe() const | Datacratic::ZmqNamedEndpoint | [inline] |
| handleAcceptEvent(std::string boundAddress) | Datacratic::ZmqNamedEndpoint | [inline, virtual] |
| handleClientMessage(const std::vector< std::string > &message) (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline, virtual] |
| handleCloseEvent(std::string boundAddress) | Datacratic::ZmqNamedEndpoint | [inline, virtual] |
| handleDisconnectEvent(std::string boundAddress) | Datacratic::ZmqNamedEndpoint | [inline, virtual] |
| HandleEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| handleEvent | Datacratic::Epoller | |
| handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent()) | Datacratic::Epoller | |
| handleMessage(std::vector< std::string > &&message) (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline, virtual] |
| handleRawMessage(std::vector< zmq::message_t > &&message) | Datacratic::ZmqNamedEndpoint | [inline, virtual] |
| init(std::shared_ptr< ConfigurationService > config, const std::string &endpointName) | Datacratic::ZmqNamedClientBus | [inline] |
| init(std::shared_ptr< ConfigurationService > config, int socketType, const std::string &endpointName) (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| MessageHandler typedef (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| messageHandler (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| needsPoll | Datacratic::AsyncEventSource | |
| numActiveConnections(std::string addr="") const | Datacratic::ZmqNamedEndpoint | [inline] |
| numBoundAddresses() const | Datacratic::ZmqNamedEndpoint | [inline] |
| onConnection | Datacratic::ZmqNamedClientBus | |
| onDisconnection | Datacratic::ZmqNamedClientBus | |
| OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| parent_ | Datacratic::AsyncEventSource | |
| poll() const | Datacratic::MessageLoop | [virtual] |
| processOne() | Datacratic::MessageLoop | [virtual] |
| publishAddress(const std::string &address, const Json::Value &addressConfig) | Datacratic::NamedEndpoint | |
| rawMessageHandler (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| RawMessageHandler typedef (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| removeFd(int fd) | Datacratic::Epoller | |
| removeSource(AsyncEventSource *source) | Datacratic::MessageLoop | |
| restartFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
| selectFd() const | Datacratic::Epoller | [inline, virtual] |
| sendMessage(const std::string &address, const std::string &topic, Args &&...args) (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline] |
| sendMessage(Args &&...args) (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | [inline] |
| sendMessage(const std::vector< std::string > &message) (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | [inline] |
| Datacratic::ZmqNamedEndpoint::sendMessage(std::vector< zmq::message_t > &&message) | Datacratic::ZmqNamedEndpoint | [inline] |
| shutdown() (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline] |
| singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
| start(std::function< void()> onStop=std::function< void()>()) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| startSubordinateThread(const SubordinateThreadFn &mainFn) | Datacratic::MessageLoop | |
| startSync() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| SubordinateThreadFn typedef (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
| unbindAll() | Datacratic::ZmqNamedEndpoint | [inline] |
| ZmqNamedClientBus(std::shared_ptr< zmq::context_t > context, double deadClientDelay=5.0) (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline] |
| ZmqNamedEndpoint(std::shared_ptr< zmq::context_t > context) (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | |
| ~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
| ~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| ~MessageLoop() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| ~ZmqNamedClientBus() (defined in Datacratic::ZmqNamedClientBus) | Datacratic::ZmqNamedClientBus | [inline, virtual] |
| ~ZmqNamedEndpoint() (defined in Datacratic::ZmqNamedEndpoint) | Datacratic::ZmqNamedEndpoint | [inline] |
1.7.6.1
