![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
| addChildServiceStatus(Json::Value &result) const | Datacratic::ServiceBase | [virtual] |
| 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 | |
| agentName | RTBKIT::BiddingAgent | |
| AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
| awaitingStatus (defined in TestAgent) | TestAgent | |
| beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| BiddingAgent(std::shared_ptr< ServiceProxies > proxies, const std::string &name="bidding_agent") (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| BiddingAgent(ServiceBase &parent, const std::string &name="bidding_agent") (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| BiddingAgent(const BiddingAgent &other) (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| bidPrice_ (defined in TestAgent) | TestAgent | |
| BidRequestCb typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| BidRequestCbFn typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| checkNeedsPoll() | Datacratic::MessageLoop | |
| children_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| completePromise_ (defined in TestAgent) | TestAgent | |
| config (defined in TestAgent) | TestAgent | |
| configPromise_ (defined in TestAgent) | TestAgent | |
| configure() (defined in TestAgent) | TestAgent | [inline] |
| connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
| debug(bool debugOn) | Datacratic::MessageLoop | [virtual] |
| defaultAckHeartbeat(double) (defined in TestAgent) | TestAgent | [inline] |
| defaultBid(double timestamp, const Id &id, std::shared_ptr< BidRequest > br, const Json::Value &imp, double timeLeftMs) (defined in TestAgent) | TestAgent | |
| defaultError(double timestamp, const std::string &error, const std::vector< std::string > &message) (defined in TestAgent) | TestAgent | [inline] |
| defaultGotConfig(double) (defined in TestAgent) | TestAgent | [inline] |
| defaultLoss(const BiddingAgent::BidResultArgs &args) (defined in TestAgent) | TestAgent | [inline] |
| defaultNeedConfig(double) (defined in TestAgent) | TestAgent | [inline] |
| defaultNoBudget(const BiddingAgent::BidResultArgs &args) (defined in TestAgent) | TestAgent | |
| defaultWin(const BiddingAgent::BidResultArgs &args) (defined in TestAgent) | TestAgent | [inline] |
| DeliveryCb typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| DeliveryCbFn typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| disconnect() | Datacratic::AsyncEventSource | |
| doBid(const Id &id, const Json::Value &response, const Json::Value &metadata) (defined in TestAgent) | TestAgent | [inline] |
| RTBKIT::BiddingAgent::doBid(Id id, const Bids &bids, const Json::Value &meta=Json::Value()) | RTBKIT::BiddingAgent | |
| doConfig(const AgentConfig &config) | RTBKIT::BiddingAgent | |
| doConfigJson(Json::Value config) (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| doPong(const std::string &fromRouter, Date sent, Date received, const std::vector< std::string > &payload) | RTBKIT::BiddingAgent | |
| Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| ErrorCb typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| ErrorCbFn typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| eventPrefix_ (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [protected] |
| EventRecorder(const std::string &eventPrefix, const std::shared_ptr< EventService > &events) (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | |
| EventRecorder(const std::string &eventPrefix, const std::shared_ptr< ServiceProxies > &services) (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | |
| events_ (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [protected] |
| expectedNoBudgets_ (defined in TestAgent) | TestAgent | |
| expectedWins_ (defined in TestAgent) | TestAgent | |
| finishBid(const BiddingAgent::BidResultArgs &args) (defined in TestAgent) | TestAgent | |
| getCompleteFuture() (defined in TestAgent) | TestAgent | [inline] |
| getConfigFuture() (defined in TestAgent) | TestAgent | [inline] |
| getServices() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| getServiceStatus() const | Datacratic::ServiceBase | [virtual] |
| getZmqContext() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| Guard typedef (defined in TestAgent) | TestAgent | |
| 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 | |
| haveGotConfig (defined in TestAgent) | TestAgent | |
| init() (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| injectWins() (defined in TestAgent) | TestAgent | |
| Lock typedef (defined in TestAgent) | TestAgent | |
| lock (defined in TestAgent) | TestAgent | [mutable] |
| logException(std::exception_ptr exc, const std::string &context) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| needsPoll | Datacratic::AsyncEventSource | |
| numAuctions (defined in TestAgent) | TestAgent | |
| numBidRequests (defined in TestAgent) | TestAgent | |
| numBidsOutstanding (defined in TestAgent) | TestAgent | |
| numErrors (defined in TestAgent) | TestAgent | |
| numGotConfig (defined in TestAgent) | TestAgent | |
| numHeartbeats (defined in TestAgent) | TestAgent | |
| numLosses (defined in TestAgent) | TestAgent | |
| numNoBudgets (defined in TestAgent) | TestAgent | |
| numTooLates (defined in TestAgent) | TestAgent | |
| numWins (defined in TestAgent) | TestAgent | |
| onBidRequest | RTBKIT::BiddingAgent | |
| onClick | RTBKIT::BiddingAgent | |
| onDroppedBid | RTBKIT::BiddingAgent | |
| onError | RTBKIT::BiddingAgent | |
| OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| onImpression | RTBKIT::BiddingAgent | |
| onInvalidBid | RTBKIT::BiddingAgent | |
| onLoss | RTBKIT::BiddingAgent | |
| onNoBudget | RTBKIT::BiddingAgent | |
| onPing | RTBKIT::BiddingAgent | |
| onTooLate | RTBKIT::BiddingAgent | |
| onVisit | RTBKIT::BiddingAgent | |
| onWin | RTBKIT::BiddingAgent | |
| operator=(const BiddingAgent &other) (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| parent_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| Datacratic::MessageLoop::parent_ | Datacratic::AsyncEventSource | |
| PingCb typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| PingCbFn typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| poll() const | Datacratic::MessageLoop | [virtual] |
| processOne() | Datacratic::MessageLoop | [virtual] |
| recordBid(const Id &id) (defined in TestAgent) | TestAgent | [inline] |
| recordCount(float count, const std::string &event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordCount(float count, const char *event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordCount(float count, const char *event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordCount(float count, const std::string &event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordEvent(const char *eventName, EventType type=ET_COUNT, float value=1.0) const | Datacratic::EventRecorder | [inline] |
| recordEventFmt(EventType type, float value, const char *fmt,...) const JML_FORMAT_STRING(4 (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | |
| recordHit(const std::string &event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordHit(const char *event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordHit(const char *event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordHit(const std::string &event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordLevel(float level, const std::string &event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordLevel(float level, const char *event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordLevel(float level, const char *event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordLevel(float level, const std::string &event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordOutcome(float outcome, const std::string &event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordOutcome(float outcome, const char *event, Args...args) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordOutcome(float outcome, const char *event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| recordOutcome(float outcome, const std::string &event) const (defined in Datacratic::EventRecorder) | Datacratic::EventRecorder | [inline] |
| registerServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
| removeFd(int fd) | Datacratic::Epoller | |
| removeSource(AsyncEventSource *source) | Datacratic::MessageLoop | |
| restartFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
| ResultCb typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| ResultCbFn typedef (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| selectFd() const | Datacratic::Epoller | [inline, virtual] |
| ServiceBase(const std::string &serviceName, std::shared_ptr< ServiceProxies >=std::shared_ptr< ServiceProxies >()) | Datacratic::ServiceBase | |
| ServiceBase(const std::string &subServiceName, ServiceBase &parent) | Datacratic::ServiceBase | |
| serviceName() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| serviceName_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| services_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| setDefaultConfig() (defined in TestAgent) | TestAgent | [inline] |
| setServices(std::shared_ptr< ServiceProxies > services) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| setupCallbacks() (defined in TestAgent) | TestAgent | [inline] |
| shutdown() (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
| start() (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | [inline] |
| 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 | |
| step1Check() (defined in TestAgent) | TestAgent | |
| step2Check() (defined in TestAgent) | TestAgent | |
| step3Check() (defined in TestAgent) | TestAgent | |
| step_ (defined in TestAgent) | TestAgent | |
| strictMode(bool strict) | RTBKIT::BiddingAgent | [inline] |
| SubordinateThreadFn typedef (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| TestAgent(RouterTester &routerTester) (defined in TestAgent) | TestAgent | |
| tester_ (defined in TestAgent) | TestAgent | |
| totalRequests_ (defined in TestAgent) | TestAgent | |
| totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
| unregisterServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
| winPrice_ (defined in TestAgent) | TestAgent | |
| ~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
| ~BiddingAgent() (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
| ~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| ~MessageLoop() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
| ~ServiceBase() (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [virtual] |
1.7.6.1