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 RTBKIT::TestAgent) | RTBKIT::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 | |
bidNull(double timestamp, const Id &id, std::shared_ptr< RTBKIT::BidRequest > br, const Bids &bids, double timeLeftMs, const Json::Value &augmentations) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
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] |
clear() (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
config (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
configure() (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
debug(bool debugOn) | Datacratic::MessageLoop | [virtual] |
defaultError(double timestamp, const std::string &error, const std::vector< std::string > &message) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
defaultLoss(const RTBKIT::BidResult &args) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
defaultNoBudget(const RTBKIT::BidResult &args) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
defaultTooLate(const RTBKIT::BidResult &args) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
defaultWin(const RTBKIT::BidResult &args) (defined in RTBKIT::TestAgent) | RTBKIT::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 Bids &bids, const Json::Value &metadata) (defined in RTBKIT::TestAgent) | RTBKIT::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] |
finishBid(int &counter, const RTBKIT::BidResult &args) (defined in RTBKIT::TestAgent) | RTBKIT::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 RTBKIT::TestAgent) | RTBKIT::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 | |
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 | |
lock (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [mutable] |
Lock typedef (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
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 | |
numBidRequests (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numBidsOutstanding (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numErrors (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numGotConfig (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numHeartbeats (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numLosses (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numNoBudgets (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numTooLates (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | |
numWins (defined in RTBKIT::TestAgent) | RTBKIT::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 RTBKIT::TestAgent) | RTBKIT::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 RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
setServices(std::shared_ptr< ServiceProxies > services) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
setupCallbacks() (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
shutdown() (defined in RTBKIT::BiddingAgent) | RTBKIT::BiddingAgent | |
singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
sleepUntilIdle(double waitTime=0.0) (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
start() (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [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 | |
strictMode(bool strict) | RTBKIT::BiddingAgent | [inline] |
SubordinateThreadFn typedef (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
TestAgent(std::shared_ptr< RTBKIT::ServiceProxies > proxies, const std::string &name="testAgent") (defined in RTBKIT::TestAgent) | RTBKIT::TestAgent | [inline] |
totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
unregisterServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
~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] |