RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
addCallback(boost::function< void(std::string, std::string)> callback, const boost::regex &allowChannels=boost::regex(), const boost::regex &denyChannels=boost::regex(), double logProbability=1.0) | Datacratic::Logger | |
addChildServiceStatus(Json::Value &result) const | Datacratic::ServiceBase | [virtual] |
addOutput(std::shared_ptr< LogOutput > output, const boost::regex &allowChannels=boost::regex(), const boost::regex &denyChannels=boost::regex(), double logProbability=1.0) | Datacratic::Logger | |
children_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
clearOutputs() | Datacratic::Logger | |
connectAllServiceProviders(const std::string &serviceClass, const std::string &epName) (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
DataLogger(std::shared_ptr< Datacratic::ServiceProxies > proxies) (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
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] |
getProviderIndicators() const (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | [virtual] |
getProviderName() const | RTBKIT::DataLogger | [virtual] |
getServices() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
getServiceStatus() const | Datacratic::ServiceBase | [virtual] |
getStats() (defined in Datacratic::Logger) | Datacratic::Logger | |
getZmqContext() const (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
handleListenerMessage(std::vector< std::string > const &message) (defined in Datacratic::Logger) | Datacratic::Logger | |
handleMessage(std::vector< zmq::message_t > &&message) (defined in Datacratic::Logger) | Datacratic::Logger | |
handleRawListenerMessage(std::vector< std::string > const &message) (defined in Datacratic::Logger) | Datacratic::Logger | |
init() (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
logException(std::exception_ptr exc, const std::string &context) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
Logger() | Datacratic::Logger | |
Logger(zmq::context_t &contextRef) (defined in Datacratic::Logger) | Datacratic::Logger | |
Logger(std::shared_ptr< zmq::context_t > &context) (defined in Datacratic::Logger) | Datacratic::Logger | |
logMessage(const std::string &channel, Args...args) (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
logMessage(const std::string &channel, int numElements, GetEl getElement) (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
logMessageNoTimestamp(const std::string &channel, Args...args) (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
logMessageNoTimestamp(const std::vector< std::string > &message) (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
logTo(const std::string &uri, const boost::regex &allowChannels=boost::regex(), const boost::regex &denyChannels=boost::regex(), double logProbability=1.0) | Datacratic::Logger | |
messageLoop (defined in Datacratic::Logger) | Datacratic::Logger | |
monitorProviderClient (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
multipleSubscriber (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
numMessagesDone() const (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
numMessagesSent() const (defined in Datacratic::Logger) | Datacratic::Logger | [inline] |
operator()(const std::string &channel, Args...args) | Datacratic::Logger | [inline] |
parent_ (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [protected] |
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 | |
replay(const std::string &filename, ssize_t maxEvents=-1) | Datacratic::Logger | |
replayDirect(const std::string &filename, ssize_t maxEvents=-1) const | Datacratic::Logger | |
resetStats() (defined in Datacratic::Logger) | Datacratic::Logger | |
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] |
setServices(std::shared_ptr< ServiceProxies > services) (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [inline] |
shutdown() (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
start(std::function< void()> onStop=0) (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
subscribe(const std::string &uri, const std::vector< std::string > &channels, const std::string &identity="") | Datacratic::Logger | |
unregisterServiceProvider(const std::string &name, const std::vector< std::string > &serviceClasses) | Datacratic::ServiceBase | |
waitUntilFinished() (defined in Datacratic::Logger) | Datacratic::Logger | |
~DataLogger() (defined in RTBKIT::DataLogger) | RTBKIT::DataLogger | |
~Logger() (defined in Datacratic::Logger) | Datacratic::Logger | |
~ServiceBase() (defined in Datacratic::ServiceBase) | Datacratic::ServiceBase | [virtual] |