RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
RTBKIT::Router Member List
This is the complete list of members for RTBKIT::Router, including all inherited members.
acceptAuctionProbabilityFnRTBKIT::Router
addAuction(std::shared_ptr< Auction > auction, Date timeout)RTBKIT::Router
addChildServiceStatus(Json::Value &result) const Datacratic::ServiceBase [virtual]
addExchange(ExchangeConnector *exchange)RTBKIT::Router [inline]
addExchange(ExchangeConnector &exchange)RTBKIT::Router [inline]
addExchange(std::unique_ptr< ExchangeConnector > &&exchange)RTBKIT::Router [inline]
agentEndpoint (defined in RTBKIT::Router)RTBKIT::Router
Agents typedefRTBKIT::Router
agents (defined in RTBKIT::Router)RTBKIT::Router
allAgentsRTBKIT::Router
allAgentsGcRTBKIT::Router [mutable]
auctionGraveyard (defined in RTBKIT::Router)RTBKIT::Router
augmentationLoop (defined in RTBKIT::Router)RTBKIT::Router
augmentAuction(const std::shared_ptr< AugmentationInfo > &info)RTBKIT::Router
banker (defined in RTBKIT::Router)RTBKIT::Router
bidsErrorRate (defined in RTBKIT::Router)RTBKIT::Router
bindAgents(std::string agentUri)RTBKIT::Router
bindAugmentors(const std::string &uri)RTBKIT::Router
bindTcp()RTBKIT::Router
blacklist (defined in RTBKIT::Router)RTBKIT::Router
budgetErrorRate (defined in RTBKIT::Router)RTBKIT::Router
checkDeadAgents() (defined in RTBKIT::Router)RTBKIT::Router
checkExpiredAuctions() (defined in RTBKIT::Router)RTBKIT::Router
children_ (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [protected]
cleanupThread (defined in RTBKIT::Router)RTBKIT::Router [protected]
configBuffer (defined in RTBKIT::Router)RTBKIT::Router
configListenerRTBKIT::Router
configure(const std::string &agent, AgentConfig &config)RTBKIT::Router
connectExchange(ExchangeConnector &exchange)RTBKIT::Router [inline]
connectPostAuctionLoop (defined in RTBKIT::Router)RTBKIT::Router
debugAuction(const Id &auction, const std::string &type, const std::vector< std::string > &args=std::vector< std::string >()) (defined in RTBKIT::Router)RTBKIT::Router [inline]
debugAuctionImpl(const Id &auction, const std::string &type, const std::vector< std::string > &args) (defined in RTBKIT::Router)RTBKIT::Router
debugInfo (defined in RTBKIT::Router)RTBKIT::Router
debugLock (defined in RTBKIT::Router)RTBKIT::Router [mutable]
debugSpot(const Id &auction, const Id &spot, const std::string &type, const std::vector< std::string > &args=std::vector< std::string >()) (defined in RTBKIT::Router)RTBKIT::Router [inline]
debugSpotImpl(const Id &auction, const Id &spot, const std::string &type, const std::vector< std::string > &args) (defined in RTBKIT::Router)RTBKIT::Router
doBid(const std::vector< std::string > &message)RTBKIT::Router
doConfig(const std::string &agent, std::shared_ptr< const AgentConfig > config)RTBKIT::Router
doDebugRTBKIT::Router
doPong(int level, const std::vector< std::string > &message)RTBKIT::Router
doShutdown() (defined in RTBKIT::Router)RTBKIT::Router
doStartBidding(const std::vector< std::string > &message)RTBKIT::Router
doStartBidding(const std::shared_ptr< AugmentationInfo > &augInfo)RTBKIT::Router
doStats(const std::vector< std::string > &message)RTBKIT::Router
doSubmitted(std::shared_ptr< Auction > auction)RTBKIT::Router
dumpAuction(const Id &auction) const (defined in RTBKIT::Router)RTBKIT::Router
dumpSpot(const Id &auction, const Id &spot) const (defined in RTBKIT::Router)RTBKIT::Router
dutyCycleCurrent (defined in RTBKIT::Router)RTBKIT::Router
dutyCycleHistory (defined in RTBKIT::Router)RTBKIT::Router
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]
exchangesRTBKIT::Router
expireDebugInfo() (defined in RTBKIT::Router)RTBKIT::Router
forAllExchanges(F functor)RTBKIT::Router [inline]
forEachAccountAgent(const AccountKey &account, const OnAgentFn &onAgent) const RTBKIT::Router
forEachAgent(const OnAgentFn &onAgent) const RTBKIT::Router
getAccountInfo(const AccountKey &account) const RTBKIT::Router
getAgentEntry(const std::string &agent) const RTBKIT::Router
getAgentInfo(const std::string &agent) const RTBKIT::Router
getAllAgentInfo() const RTBKIT::Router
getBanker() const (defined in RTBKIT::Router)RTBKIT::Router
getCurrentTime() const (defined in RTBKIT::Router)RTBKIT::Router [inline]
getProviderIndicators() const (defined in RTBKIT::Router)RTBKIT::Router [virtual]
getProviderName() const RTBKIT::Router [virtual]
getServices() const (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [inline]
getServiceStatus() const RTBKIT::Router [virtual]
getStats() const RTBKIT::Router
getZmqContext() const (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [inline]
globalBidProbability (defined in RTBKIT::Router)RTBKIT::Router
Guard typedef (defined in RTBKIT::Router)RTBKIT::Router [protected]
handleAgentMessage(const std::vector< std::string > &message) (defined in RTBKIT::Router)RTBKIT::Router
InFlight typedefRTBKIT::Router
inFlight (defined in RTBKIT::Router)RTBKIT::Router
init()RTBKIT::Router
initializedRTBKIT::Router
injectAuction(std::shared_ptr< Auction > auction, double lossTime=INFINITY)RTBKIT::Router
injectAuction(Auction::HandleAuction onAuctionFinished, std::shared_ptr< BidRequest > request, const std::string &requestStr, const std::string &requestStrFormat, double startTime=0.0, double expiryTime=0.0, double lossTime=INFINITY)RTBKIT::Router
issueTimestamp()RTBKIT::Router
Lock typedef (defined in RTBKIT::Router)RTBKIT::Router [protected]
lock (defined in RTBKIT::Router)RTBKIT::Router [mutable]
logException(std::exception_ptr exc, const std::string &context) (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [inline]
logger (defined in RTBKIT::Router)RTBKIT::Router
logMessage(const std::string &channel, Args...args)RTBKIT::Router [inline]
logMessageNoTimestamp(const std::string &channel, Args...args)RTBKIT::Router [inline]
logRouterError(const std::string &function, const std::string &exception, Args...args)RTBKIT::Router [inline]
monitorClient (defined in RTBKIT::Router)RTBKIT::Router
monitorProviderClient (defined in RTBKIT::Router)RTBKIT::Router
notifyFinishedAuction(const Id &auctionId)RTBKIT::Router
numAuctions (defined in RTBKIT::Router)RTBKIT::Router
numAuctionsAwaitingResult() const RTBKIT::Router
numAuctionsInProgress() const RTBKIT::Router
numAuctionsWithBid (defined in RTBKIT::Router)RTBKIT::Router
numBids (defined in RTBKIT::Router)RTBKIT::Router
numNoBidders (defined in RTBKIT::Router)RTBKIT::Router
numNonEmptyBids (defined in RTBKIT::Router)RTBKIT::Router
numNonIdle() const RTBKIT::Router [virtual]
numNoPotentialBidders (defined in RTBKIT::Router)RTBKIT::Router
OnAgentFn typedef (defined in RTBKIT::Router)RTBKIT::Router
onAuctionDone(std::shared_ptr< Auction > auction)RTBKIT::Router
onNewAuction(std::shared_ptr< Auction > auction)RTBKIT::Router
onSubmittedAuctionRTBKIT::Router
parent_ (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [protected]
postAuctionEndpoint (defined in RTBKIT::Router)RTBKIT::Router
preprocessAuction(const std::shared_ptr< Auction > &auction)RTBKIT::Router
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
returnErrorResponse(const std::vector< std::string > &message, const std::string &error) (defined in RTBKIT::Router)RTBKIT::Router
Router(ServiceBase &parent, const std::string &serviceName="router", double secondsUntilLossAssumed=2.0, bool connectPostAuctionLoop=true) (defined in RTBKIT::Router)RTBKIT::Router
Router(std::shared_ptr< ServiceProxies > services, const std::string &serviceName="router", double secondsUntilLossAssumed=2.0, bool connectPostAuctionLoop=true) (defined in RTBKIT::Router)RTBKIT::Router
run() (defined in RTBKIT::Router)RTBKIT::Router
runThread (defined in RTBKIT::Router)RTBKIT::Router [protected]
secondsUntilLossAssumed() const (defined in RTBKIT::Router)RTBKIT::Router [inline]
secondsUntilLossAssumed_ (defined in RTBKIT::Router)RTBKIT::Router
sendAgentMessage(const std::string &agent, const std::string &messageType, const Date &date, Args...args)RTBKIT::Router [inline]
sendBidResponse(const std::string &agent, const AgentInfo &info, BidStatus status, Date timestamp, const std::string &message, const Id &auctionId, int spotNum=-1, Amount price=Amount(), const Auction *auction=0, const std::string &bidData="", const Json::Value &metadata=Json::Value(), const std::string &augmentationsStr="")RTBKIT::Router
sendPings()RTBKIT::Router
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]
setAcceptAuctionProbability(double val)RTBKIT::Router [inline]
setBanker(const std::shared_ptr< Banker > &newBanker) (defined in RTBKIT::Router)RTBKIT::Router
setBidsErrorRate(double val)RTBKIT::Router [inline]
setBudgetErrorRate(double val)RTBKIT::Router [inline]
setGlobalBidProbability(double val)RTBKIT::Router [inline]
setSecondsUntilLossAssumed(double newValue) (defined in RTBKIT::Router)RTBKIT::Router [inline]
setServices(std::shared_ptr< ServiceProxies > services) (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [inline]
shutdown() (defined in RTBKIT::Router)RTBKIT::Router [virtual]
shutdown_ (defined in RTBKIT::Router)RTBKIT::Router [protected]
sleepUntilIdle()RTBKIT::Router [virtual]
slowModeCount (defined in RTBKIT::Router)RTBKIT::Router
slowModeLastAuction (defined in RTBKIT::Router)RTBKIT::Router
start(boost::function< void()> onStop=boost::function< void()>())RTBKIT::Router [virtual]
startBiddingBuffer (defined in RTBKIT::Router)RTBKIT::Router
startExchange(const std::string &exchangeType, const Json::Value &exchangeConfig)RTBKIT::Router
startExchange(const Json::Value &exchangeConfig)RTBKIT::Router
submittedBuffer (defined in RTBKIT::Router)RTBKIT::Router
submitToPostAuctionService(std::shared_ptr< Auction > auction, Id auctionId, const Auction::Response &bid)RTBKIT::Router [virtual]
throwException(const std::string &key, const std::string &fmt,...) __attribute__((__noreturn__))RTBKIT::Router
unconfigure(const std::string &agent, const AgentConfig &config)RTBKIT::Router
unregisterServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses)Datacratic::ServiceBase
unsafeDisableMonitor()RTBKIT::Router
updateAllAgents() (defined in RTBKIT::Router)RTBKIT::Router
wakeupMainLoop (defined in RTBKIT::Router)RTBKIT::Router
~Router() (defined in RTBKIT::Router)RTBKIT::Router
~ServiceBase() (defined in Datacratic::ServiceBase)Datacratic::ServiceBase [virtual]
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator