RTBKIT::MonitorClient Member List

This is the complete list of members for RTBKIT::MonitorClient, 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
checkStatus()	RTBKIT::MonitorClient
checkTimeout_	RTBKIT::MonitorClient
close() (defined in Datacratic::Epoller)	Datacratic::Epoller
connected(MessageLoop *parent)	Datacratic::AsyncEventSource	[inline, virtual]
connection (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
currentOpId (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
debug(bool debugOn)	Datacratic::MessageLoop	[virtual]
disconnect()	Datacratic::AsyncEventSource
Epoller() (defined in Datacratic::Epoller)	Datacratic::Epoller
getStatus() const	RTBKIT::MonitorClient
Guard typedef	RTBKIT::MonitorClient
handleEvent	Datacratic::Epoller
HandleEvent typedef (defined in Datacratic::Epoller)	Datacratic::Epoller
handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent())	Datacratic::Epoller
handleOperation(const Operation &op) (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
handleZmqResponse(const std::vector< std::string > &message) (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
init(std::shared_ptr< ConfigurationService > &config, const std::string &serviceName="monitor") (defined in RTBKIT::MonitorClient)	RTBKIT::MonitorClient
Datacratic::RestProxy::init(std::shared_ptr< ConfigurationService > config, const std::string &serviceName)	Datacratic::RestProxy
init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
init(int maxFds) (defined in Datacratic::Epoller)	Datacratic::Epoller
initServiceClass(std::shared_ptr< ConfigurationService > config, const std::string &serviceClass, const std::string &endpointName)	Datacratic::RestProxy
lastCheck	RTBKIT::MonitorClient
lastStatus	RTBKIT::MonitorClient
MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
MonitorClient(const std::shared_ptr< zmq::context_t > &context, int checkTimeout=2) (defined in RTBKIT::MonitorClient)	RTBKIT::MonitorClient	[inline]
needsPoll	Datacratic::AsyncEventSource
numMessagesOutstanding() const (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[inline]
numMessagesOutstanding_ (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
OnDone typedef (defined in Datacratic::RestProxy)	Datacratic::RestProxy
onDone	RTBKIT::MonitorClient
OnEvent typedef (defined in Datacratic::Epoller)	Datacratic::Epoller
onResponseReceived(std::exception_ptr ext, int responseCode, const std::string &body)	RTBKIT::MonitorClient
operationQueue (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
outstanding (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
parent_	Datacratic::AsyncEventSource
pendingRequest	RTBKIT::MonitorClient
poll() const	Datacratic::MessageLoop	[virtual]
processOne()	Datacratic::MessageLoop	[virtual]
push(const RestRequest &request, const OnDone &onDone)	Datacratic::RestProxy
push(const OnDone &onDone, const std::string &method, const std::string &resource, const RestParams &params=RestParams(), const std::string &payload="")	Datacratic::RestProxy
removeFd(int fd)	Datacratic::Epoller
removeSource(AsyncEventSource *source)	Datacratic::MessageLoop
requestLock (defined in RTBKIT::MonitorClient)	RTBKIT::MonitorClient	[mutable]
restartFdOneShot(int fd, void *data=0)	Datacratic::Epoller
RestProxy() (defined in Datacratic::RestProxy)	Datacratic::RestProxy
RestProxy(const std::shared_ptr< zmq::context_t > &context) (defined in Datacratic::RestProxy)	Datacratic::RestProxy
selectFd() const	Datacratic::Epoller	[inline, virtual]
serviceName_ (defined in Datacratic::RestProxy)	Datacratic::RestProxy	[protected]
shutdown()	RTBKIT::MonitorClient
singleThreaded() const	Datacratic::AsyncEventSource	[inline, virtual]
sleepUntilIdle() (defined in Datacratic::RestProxy)	Datacratic::RestProxy
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
testMode	RTBKIT::MonitorClient
testResponse (defined in RTBKIT::MonitorClient)	RTBKIT::MonitorClient
totalSleepSeconds() const	Datacratic::MessageLoop	[inline]
~AsyncEventSource() (defined in Datacratic::AsyncEventSource)	Datacratic::AsyncEventSource	[inline, virtual]
~Epoller() (defined in Datacratic::Epoller)	Datacratic::Epoller
~MessageLoop() (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
~MonitorClient() (defined in RTBKIT::MonitorClient)	RTBKIT::MonitorClient
~RestProxy() (defined in Datacratic::RestProxy)	Datacratic::RestProxy