 |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
|
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
| 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 enum name | Datacratic::ZmqNamedProxy | [protected] |
| connectionType (defined in Datacratic::ZmqNamedProxy) | 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 | |
| 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] |
| 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 &source) | Datacratic::ZmqNamedProxy | [inline, virtual] |
| onDisconnect(const std::string &source) | Datacratic::ZmqNamedProxy | [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::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [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 | |
| totalSleepSeconds() const | Datacratic::MessageLoop | [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 | |
| ~ZmqNamedProxy() (defined in Datacratic::ZmqNamedProxy) | Datacratic::ZmqNamedProxy | [inline] |
1.7.6.1
