, including all inherited members.
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 | |
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 | |
checkNeedsPoll() | Datacratic::MessageLoop | |
close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
config (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
connect(const std::string &endpointName, ConnectionStyle style=CS_ASYNCHRONOUS) | Datacratic::ZmqNamedProxy | |
CONNECT_DIRECT enum value | Datacratic::ZmqNamedProxy | [protected] |
CONNECT_TO_CLASS enum value | Datacratic::ZmqNamedProxy | [protected] |
CONNECTED enum value (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
connectedService | Datacratic::ZmqNamedProxy | [protected] |
connectedUri | Datacratic::ZmqNamedProxy | [protected] |
connectHandler | Datacratic::ZmqNamedProxy | |
CONNECTION_PENDING enum value (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
ConnectionHandler typedef | Datacratic::ZmqNamedProxy | |
connectionState (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
ConnectionState enum name (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
connectionType (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
ConnectionType enum name | Datacratic::ZmqNamedProxy | [protected] |
connectToServiceClass(const std::string &serviceClass, const std::string &endpointName, ConnectionStyle style=CS_ASYNCHRONOUS) | Datacratic::ZmqNamedProxy | |
context_ (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
debug(bool debugOn) | Datacratic::MessageLoop | [virtual] |
disconnect() | Datacratic::ZmqNamedProxy | [inline] |
disconnectHandler | Datacratic::ZmqNamedProxy | |
endpointName | Datacratic::ZmqNamedProxy | [protected] |
endpointWatch (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
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(const std::vector< std::string > &message) (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline, virtual] |
init(std::shared_ptr< ConfigurationService > config, const std::string &identity="") (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline] |
init(std::shared_ptr< ConfigurationService > config, int socketType, const std::string &identity="") (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | |
init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | |
isConnected() const (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [inline] |
lastHeartbeat (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | |
messageHandler (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | |
MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
needsPoll | Datacratic::AsyncEventSource | |
NO_CONNECTION enum value | Datacratic::ZmqNamedProxy | [protected] |
NOT_CONNECTED enum value (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
onConfigChange(ConfigurationService::ChangeType change, const std::string &key, const Json::Value &newValue) | Datacratic::ZmqNamedProxy | |
onConnect(const std::string &where) | Datacratic::ZmqNamedClientBusProxy | [inline, virtual] |
onDisconnect(const std::string &where) | Datacratic::ZmqNamedClientBusProxy | [inline, virtual] |
onEndpointNodeChange(const std::string &path, ConfigurationService::ChangeType change) (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
onServiceNodeChange(const std::string &path, ConfigurationService::ChangeType change) (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
parent_ | Datacratic::AsyncEventSource | |
poll() const | Datacratic::MessageLoop | [virtual] |
processOne() | Datacratic::MessageLoop | [virtual] |
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(Args &&...args) (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [inline] |
serviceClass | Datacratic::ZmqNamedProxy | [protected] |
serviceWatch (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
shutdown() (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline] |
singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
socket() const | Datacratic::ZmqNamedProxy | [inline] |
socket_ (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [protected] |
socketLock() const (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [inline] |
socketLock_ (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [mutable, protected] |
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 | |
timeout (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | |
totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
ZmqNamedClientBusProxy() (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline] |
ZmqNamedClientBusProxy(std::shared_ptr< zmq::context_t > context) (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline] |
ZmqNamedProxy() (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | |
ZmqNamedProxy(std::shared_ptr< zmq::context_t > context) (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | |
~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
~MessageLoop() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
~ZmqNamedClientBusProxy() (defined in Datacratic::ZmqNamedClientBusProxy) | Datacratic::ZmqNamedClientBusProxy | [inline] |
~ZmqNamedProxy() (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [inline] |