 |
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.
|
| acceptAuctionProbability | RTBKIT::HttpExchangeConnector | [protected] |
| acceptError(const std::string &error) (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | [inline, protected, virtual] |
| acceptor | Datacratic::PassiveEndpoint | [protected] |
| AcceptorT (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | [friend] |
| addChildServiceStatus(Json::Value &result) const | Datacratic::ServiceBase | [virtual] |
| addFd(int fd, void *data=0) | Datacratic::Epoller | |
| addFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
| afterSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| alive | Datacratic::EndpointBase | [protected] |
| associateHandler(const std::shared_ptr< TransportBase > &transport) | Datacratic::PassiveEndpoint | [inline, protected, virtual] |
| AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
| auctionResource (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| auctionVerb (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| backlog (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| beforeSleep (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| bidRequestCreativeFilter(const BidRequest &request, const AgentConfig &config, const void *info) const | RTBKIT::ExchangeConnector | [virtual] |
| bidRequestPostFilter(const BidRequest &request, const AgentConfig &config, const void *info) const | RTBKIT::ExchangeConnector | [virtual] |
| bidRequestPreFilter(const BidRequest &request, const AgentConfig &config, const void *info) const | RTBKIT::ExchangeConnector | [virtual] |
| bindHost (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| checkFinished() const | Datacratic::EndpointBase | [inline, protected] |
| children_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| close() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| closePeer() (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | [inline, virtual] |
| configure(const Json::Value ¶meters) | RTBKIT::HttpExchangeConnector | [virtual] |
| configureHttp(int numThreads, const PortRange &listenPort, const std::string &bindHost="*", bool performNameLookup=false, int backlog=DEF_BACKLOG, const std::string &auctionResource="/auctions", const std::string &auctionVerb="POST") | RTBKIT::HttpExchangeConnector | |
| connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
| Connections typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| create(const std::string &exchangeType, ServiceBase &owner, const std::string &name) | RTBKIT::ExchangeConnector | [static] |
| debug(bool debugOn) | Datacratic::AsyncEventSource | [inline, virtual] |
| debug_ | Datacratic::AsyncEventSource | |
| disconnect() | Datacratic::AsyncEventSource | |
| doAsync(const std::shared_ptr< TransportBase > &transport, const boost::function< void()> &callback, const char *nameOfCallback) | Datacratic::EndpointBase | [protected] |
| DumpingExchangeConnector(const std::string &name, std::shared_ptr< ServiceProxies > proxies) (defined in DumpingExchangeConnector) | DumpingExchangeConnector | [inline] |
| dumpState() const | Datacratic::EndpointBase | [virtual] |
| enabledUntil | RTBKIT::HttpExchangeConnector | [protected] |
| enableUntil(Date date) | RTBKIT::HttpExchangeConnector | [inline, virtual] |
| EndpointBase(const std::string &name) (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
| Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| 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] |
| ExchangeConnector(const std::string &name, ServiceBase &parent) (defined in RTBKIT::ExchangeConnector) | RTBKIT::ExchangeConnector | |
| ExchangeConnector(const std::string &name, std::shared_ptr< ServiceProxies >=std::shared_ptr< ServiceProxies >()) (defined in RTBKIT::ExchangeConnector) | RTBKIT::ExchangeConnector | |
| exchangeName() const | DumpingExchangeConnector | [inline, virtual] |
| Factory typedef | RTBKIT::ExchangeConnector | |
| getCampaignCompatibility(const AgentConfig &config, bool includeReasons) const | RTBKIT::HttpExchangeConnector | [virtual] |
| getCreativeCompatibility(const Creative &creative, bool includeReasons) const | RTBKIT::HttpExchangeConnector | [virtual] |
| getDroppedAuctionResponse(const HttpAuctionHandler &connection, const Auction &auction, const std::string &reason) const | DumpingExchangeConnector | [inline, virtual] |
| getErrorResponse(const HttpAuctionHandler &connection, const Auction &auction, const std::string &errorMessage) const | DumpingExchangeConnector | [inline, virtual] |
| getResponse(const HttpAuctionHandler &connection, const HttpHeader &requestHeader, const Auction &auction) const (defined in DumpingExchangeConnector) | DumpingExchangeConnector | [inline, virtual] |
| RTBKIT::HttpExchangeConnector::getResponse(const HttpAuctionHandler &connection, const HttpHeader &requestHeader, const Auction &auction) const | RTBKIT::HttpExchangeConnector | [virtual] |
| getRoundTripTimeMs(HttpAuctionHandler &connection, const HttpHeader &header) (defined in DumpingExchangeConnector) | DumpingExchangeConnector | [inline, virtual] |
| RTBKIT::HttpExchangeConnector::getRoundTripTimeMs(HttpAuctionHandler &connection, const HttpHeader &header) | RTBKIT::HttpExchangeConnector | [virtual] |
| getServices() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| getServiceStatus() const | RTBKIT::HttpExchangeConnector | [virtual] |
| getTimeAvailableMs(HttpAuctionHandler &connection, const HttpHeader &header, const std::string &payload) (defined in DumpingExchangeConnector) | DumpingExchangeConnector | [inline, virtual] |
| RTBKIT::HttpExchangeConnector::getTimeAvailableMs(HttpAuctionHandler &connection, const HttpHeader &header, const std::string &payload) | RTBKIT::HttpExchangeConnector | [virtual] |
| getZmqContext() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| Guard typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| handleEvent | Datacratic::Epoller | |
| HandleEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent()) | Datacratic::Epoller | |
| HandlerFactory typedef | RTBKIT::HttpExchangeConnector | [protected] |
| handlerFactory (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| handleUnknownRequest(HttpAuctionHandler &connection, const HttpHeader &header, const std::string &payload) const | RTBKIT::HttpExchangeConnector | [virtual] |
| hostname() const | Datacratic::PassiveEndpoint | [inline, virtual] |
| HttpEndpoint(const std::string &name) (defined in Datacratic::HttpEndpoint) | Datacratic::HttpEndpoint | |
| HttpExchangeConnector(const std::string &name, ServiceBase &parent) (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | |
| HttpExchangeConnector(const std::string &name, std::shared_ptr< ServiceProxies > proxies) (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | |
| idle | Datacratic::EndpointBase | [mutable, protected] |
| init(PortRange const &portRange=PortRange(), const std::string &hostname="localhost", int threads=1, bool synchronous=true, bool nameLookup=true, int backlog=DEF_BACKLOG) | Datacratic::PassiveEndpoint | |
| init(int maxFds) (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| isEnabled(Date now=Date::now()) const | RTBKIT::HttpExchangeConnector | [inline] |
| listen(PortRange const &portRange, const std::string &host, bool nameLookup=true, int backlog=DEF_BACKLOG) | Datacratic::PassiveEndpoint | [inline, virtual] |
| listenPort (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| Lock typedef (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [protected] |
| lock (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [mutable, protected] |
| logException(std::exception_ptr exc, const std::string &context) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| makeNewHandler() (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected, virtual] |
| makeNewHandlerShared() (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected, virtual] |
| makeRealTime(int priority=1) | Datacratic::EndpointBase | |
| modifyIdle | Datacratic::EndpointBase | [mutable, protected] |
| name() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline] |
| nameLookup_ (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | [protected] |
| needsPoll | Datacratic::AsyncEventSource | |
| notifyCloseTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::EndpointBase | [protected, virtual] |
| notifyNewTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::EndpointBase | [protected, virtual] |
| notifyRecycleTransport(const std::shared_ptr< TransportBase > &transport) | Datacratic::EndpointBase | [protected, virtual] |
| numConnections() const | Datacratic::EndpointBase | [virtual] |
| numConnectionsByHost() const | Datacratic::EndpointBase | [virtual] |
| numServingRequest() const | RTBKIT::HttpExchangeConnector | [inline] |
| numServingRequest_ | RTBKIT::HttpExchangeConnector | [protected] |
| numThreads | RTBKIT::HttpExchangeConnector | [protected] |
| onAcceptError | Datacratic::PassiveEndpoint | |
| OnAuction typedef | RTBKIT::ExchangeConnector | |
| onAuctionDone (defined in RTBKIT::ExchangeConnector) | RTBKIT::ExchangeConnector | |
| onCheckFinished | Datacratic::EndpointBase | |
| OnEvent typedef (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| onMakeNewHandler | Datacratic::PassiveEndpoint | |
| onNewAuction | RTBKIT::ExchangeConnector | |
| OnTimeout typedef | RTBKIT::HttpExchangeConnector | [protected] |
| onTimeout (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| onTransportClose (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
| OnTransportEvent typedef | Datacratic::EndpointBase | |
| onTransportOpen (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | |
| parent_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
| Datacratic::HttpEndpoint::parent_ | Datacratic::AsyncEventSource | |
| parseBidRequest(HttpAuctionHandler &connection, const HttpHeader &header, const std::string &payload) (defined in DumpingExchangeConnector) | DumpingExchangeConnector | [inline, virtual] |
| RTBKIT::HttpExchangeConnector::parseBidRequest(HttpAuctionHandler &connection, const HttpHeader &header, const std::string &payload) | RTBKIT::HttpExchangeConnector | [virtual] |
| PassiveEndpoint(const std::string &name) (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | |
| PassiveEndpointT(const std::string &name) (defined in Datacratic::PassiveEndpointT< SocketTransport >) | Datacratic::PassiveEndpointT< SocketTransport > | [inline] |
| performNameLookup (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | [protected] |
| pingTimesByHostMs | RTBKIT::HttpExchangeConnector | [protected] |
| pingTimeUnknownHostsMs | RTBKIT::HttpExchangeConnector | [protected] |
| poll() const | Datacratic::Epoller | [virtual] |
| port() const | Datacratic::PassiveEndpoint | [inline, virtual] |
| processOne() | Datacratic::Epoller | [inline, virtual] |
| 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] |
| registerFactory(const std::string &exchange, Factory factory) | RTBKIT::ExchangeConnector | [static] |
| registerServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
| removeFd(int fd) | Datacratic::Epoller | |
| restartFdOneShot(int fd, void *data=0) | Datacratic::Epoller | |
| restartPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| 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] |
| setAcceptBidRequestProbability(double prob) | RTBKIT::HttpExchangeConnector | [inline, virtual] |
| setServices(std::shared_ptr< ServiceProxies > services) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
| shutdown() | RTBKIT::HttpExchangeConnector | [virtual] |
| singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
| sleepUntilIdle() const | Datacratic::EndpointBase | |
| spinup(int num_threads, bool synchronous) | Datacratic::EndpointBase | [virtual] |
| start() | RTBKIT::HttpExchangeConnector | [virtual] |
| startPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| stopPolling(TransportBase *transport) | Datacratic::EndpointBase | [protected, virtual] |
| threadsActive() const (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [inline] |
| unregisterServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
| useThisThread() | Datacratic::EndpointBase | |
| ~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |
| ~EndpointBase() (defined in Datacratic::EndpointBase) | Datacratic::EndpointBase | [virtual] |
| ~Epoller() (defined in Datacratic::Epoller) | Datacratic::Epoller | |
| ~ExchangeConnector() (defined in RTBKIT::ExchangeConnector) | RTBKIT::ExchangeConnector | [virtual] |
| ~HttpEndpoint() (defined in Datacratic::HttpEndpoint) | Datacratic::HttpEndpoint | [virtual] |
| ~HttpExchangeConnector() (defined in RTBKIT::HttpExchangeConnector) | RTBKIT::HttpExchangeConnector | |
| ~PassiveEndpoint() (defined in Datacratic::PassiveEndpoint) | Datacratic::PassiveEndpoint | [virtual] |
| ~PassiveEndpointT() (defined in Datacratic::PassiveEndpointT< SocketTransport >) | Datacratic::PassiveEndpointT< SocketTransport > | [inline, virtual] |
| ~ServiceBase() (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [virtual] |
1.7.6.1
