RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
RTBKIT::MonitorProviderClient Member List
This is the complete list of members for RTBKIT::MonitorProviderClient, 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
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
Guard typedefRTBKIT::MonitorProviderClient
HandleEvent typedef (defined in Datacratic::Epoller)Datacratic::Epoller
handleEventDatacratic::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]
inhibit_RTBKIT::MonitorProviderClient
init(std::shared_ptr< ConfigurationService > &config, const std::string &serviceName="monitor") (defined in RTBKIT::MonitorProviderClient)RTBKIT::MonitorProviderClient
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
MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)Datacratic::MessageLoop
MonitorProviderClient(const std::shared_ptr< zmq::context_t > &context, MonitorProvider &provider) (defined in RTBKIT::MonitorProviderClient)RTBKIT::MonitorProviderClient
needsPollDatacratic::AsyncEventSource
numMessagesOutstanding() const (defined in Datacratic::RestProxy)Datacratic::RestProxy [inline]
numMessagesOutstanding_ (defined in Datacratic::RestProxy)Datacratic::RestProxy [protected]
onDoneRTBKIT::MonitorProviderClient
OnDone typedef (defined in Datacratic::RestProxy)Datacratic::RestProxy
OnEvent typedef (defined in Datacratic::Epoller)Datacratic::Epoller
onResponseReceived(std::exception_ptr ext, int responseCode, const std::string &body)RTBKIT::MonitorProviderClient
operationQueue (defined in Datacratic::RestProxy)Datacratic::RestProxy [protected]
outstanding (defined in Datacratic::RestProxy)Datacratic::RestProxy [protected]
parent_Datacratic::AsyncEventSource
pendingRequestRTBKIT::MonitorProviderClient
poll() const Datacratic::MessageLoop [virtual]
postStatus()RTBKIT::MonitorProviderClient
processOne()Datacratic::MessageLoop [virtual]
provider_RTBKIT::MonitorProviderClient
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::MonitorProviderClient)RTBKIT::MonitorProviderClient [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
restUrlPath_RTBKIT::MonitorProviderClient
selectFd() const Datacratic::Epoller [inline, virtual]
serviceName_ (defined in Datacratic::RestProxy)Datacratic::RestProxy [protected]
shutdown()RTBKIT::MonitorProviderClient
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
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
~MonitorProviderClient() (defined in RTBKIT::MonitorProviderClient)RTBKIT::MonitorProviderClient
~RestProxy() (defined in Datacratic::RestProxy)Datacratic::RestProxy
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator