 |
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 | |
| addSpendAccount(const AccountKey &account, CurrencyPool accountFloat, std::function< void(std::exception_ptr, ShadowAccount &&)> onDone) | RTBKIT::SlaveBanker | [virtual] |
| addSpendAccountSync(const AccountKey &account, CurrencyPool accountFloat=CurrencyPool()) (defined in RTBKIT::Banker) | RTBKIT::Banker | [virtual] |
| afterSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
| attachBid(const AccountKey &account, const std::string &item, Amount amountAuthorized) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| authorizeBid(const AccountKey &account, const std::string &item, Amount amount) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| Banker() (defined in RTBKIT::Banker) | RTBKIT::Banker | [inline] |
| beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| cancelBid(const AccountKey &account, const std::string &item) (defined in RTBKIT::Banker) | RTBKIT::Banker | [inline, virtual] |
| checkNeedsPoll() | Datacratic::MessageLoop | |
| close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| commitBid(const AccountKey &account, const std::string &item, Amount amountPaid, const LineItems &lineItems) | RTBKIT::SlaveBanker | [inline, virtual] |
| commitDetachedBid(const AccountKey &account, Amount amountAuthorized, Amount amountPaid, const LineItems &lineItems) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| 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] |
| detachBid(const AccountKey &account, const std::string &item) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| disconnect() | Datacratic::AsyncEventSource | |
| Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| forceWinBid(const AccountKey &account, Amount amountPaid, const LineItems &lineItems) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| getAccount(const AccountKey &account) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline] |
| getAccountStateDebug(AccountKey accountKey) const | RTBKIT::SlaveBanker | [inline] |
| 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 | |
| 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 &accountSuffix, const std::string &serviceClass="rtbBanker") | RTBKIT::SlaveBanker | |
| 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 | |
| logBidEvents(const Datacratic::EventRecorder &eventRecorder) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline, virtual] |
| MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| needsPoll | Datacratic::AsyncEventSource | |
| numMessagesOutstanding() const (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [inline] |
| numMessagesOutstanding_ (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [protected] |
| OnBudgetResult typedef (defined in RTBKIT::Banker) | RTBKIT::Banker | |
| OnDone typedef (defined in Datacratic::RestProxy) | Datacratic::RestProxy | |
| OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| operationQueue (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [protected] |
| outstanding (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [protected] |
| parent_ | Datacratic::AsyncEventSource | |
| 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 ¶ms=RestParams(), const std::string &payload="") | Datacratic::RestProxy | |
| removeFd(int fd) | Datacratic::Epoller | |
| removeSource(AsyncEventSource *source) | Datacratic::MessageLoop | |
| 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 | |
| sanityCheck(const std::string &campaign) const (defined in RTBKIT::Banker) | RTBKIT::Banker | [inline, protected, virtual] |
| selectFd() const | Datacratic::Epoller | [inline, virtual] |
| serviceName_ (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [protected] |
| shutdown() (defined in Datacratic::RestProxy) | Datacratic::RestProxy | |
| singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
| SlaveBanker(std::shared_ptr< zmq::context_t > context) (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | |
| SlaveBanker(std::shared_ptr< zmq::context_t > context, std::shared_ptr< ConfigurationService > config, const std::string &accountSuffix, const std::string &bankerServiceClass="rtbBanker") (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | |
| 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 | |
| sync() | RTBKIT::Banker | [inline, virtual] |
| syncAccount(const AccountKey &account, std::function< void(std::exception_ptr, ShadowAccount &&)> onDone) | RTBKIT::SlaveBanker | |
| syncAccountSync(const AccountKey &account) | RTBKIT::SlaveBanker | |
| syncAll(std::function< void(std::exception_ptr)> onDone=std::function< void(std::exception_ptr)>()) | RTBKIT::SlaveBanker | |
| syncAllSync() | RTBKIT::SlaveBanker | |
| totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
| winBid(const AccountKey &account, const std::string &item, Amount amountPaid, const LineItems &lineItems=LineItems()) (defined in RTBKIT::Banker) | RTBKIT::Banker | [inline, virtual] |
| ~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
| ~Banker() (defined in RTBKIT::Banker) | RTBKIT::Banker | [virtual] |
| ~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| ~MessageLoop() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| ~RestProxy() (defined in Datacratic::RestProxy) | Datacratic::RestProxy | |
| ~SlaveBanker() (defined in RTBKIT::SlaveBanker) | RTBKIT::SlaveBanker | [inline] |
1.7.6.1
