RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
addAccount(const AccountKey &account, const OnBudgetResult &onResult) | RTBKIT::SlaveBudgetController | [virtual] |
addAccountSync(const AccountKey &account) (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | [virtual] |
addBudget(const std::string &topLevelAccount, CurrencyPool amount, const OnBudgetResult &onResult) | RTBKIT::SlaveBudgetController | [virtual] |
addBudgetSync(const std::string &topLevelAccount, CurrencyPool amount) (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | [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 | |
AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
BudgetController() (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | |
budgetLimits (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | |
budgetResultCallback(const OnBudgetResult &onResult) (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | [static] |
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 | |
getAccount(const AccountKey &account, std::function< void(std::exception_ptr, Account &&)> onResult) (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | [virtual] |
getAccountList(const AccountKey &prefix, int depth, std::function< void(std::exception_ptr, std::vector< AccountKey > &&)> onResult) (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | [virtual] |
getAccountListSync(const AccountKey &prefix, int depth) (defined in RTBKIT::Accountant) | RTBKIT::Accountant | [virtual] |
getAccountSummary(const AccountKey &account, int depth, std::function< void(std::exception_ptr, AccountSummary &&)> onResult) (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | [virtual] |
getAccountSummarySync(const AccountKey &account, int depth) (defined in RTBKIT::Accountant) | RTBKIT::Accountant | [virtual] |
getAccountSync(const AccountKey &account) (defined in RTBKIT::Accountant) | RTBKIT::Accountant | [virtual] |
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 &serviceClass="rtbBanker") | RTBKIT::SlaveBudgetController | [inline] |
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 | |
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::BudgetController) | RTBKIT::BudgetController | |
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 | |
selectFd() const | Datacratic::Epoller | [inline, virtual] |
serviceName_ (defined in Datacratic::RestProxy) | Datacratic::RestProxy | [protected] |
setBudget(const std::string &topLevelAccount, CurrencyPool amount, const OnBudgetResult &onResult) | RTBKIT::SlaveBudgetController | [virtual] |
setBudgetSync(const std::string &topLevelAccount, CurrencyPool amount) (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | [virtual] |
shutdown() (defined in Datacratic::RestProxy) | Datacratic::RestProxy | |
singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
SlaveBudgetController() (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | |
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() (defined in RTBKIT::Accountant) | RTBKIT::Accountant | [inline, virtual] |
topupTransfer(const AccountKey &account, CurrencyPool amount, const OnBudgetResult &onResult) | RTBKIT::SlaveBudgetController | [virtual] |
topupTransferSync(const AccountKey &account, CurrencyPool amount) (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | [virtual] |
totalSleepSeconds() const | Datacratic::MessageLoop | [inline] |
~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
~BudgetController() (defined in RTBKIT::BudgetController) | RTBKIT::BudgetController | [virtual] |
~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
~MessageLoop() (defined in Datacratic::MessageLoop) | Datacratic::MessageLoop | |
~RestProxy() (defined in Datacratic::RestProxy) | Datacratic::RestProxy | |
~SlaveBudgetController() (defined in RTBKIT::SlaveBudgetController) | RTBKIT::SlaveBudgetController | [inline] |