![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
addRoute(const std::string &topic, AsyncMessageHandler handler) (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | [inline] |
AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline] |
AsyncMessageHandler typedef (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
asyncMessageHandler (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
bind(const std::string &topic, const std::function< void(const std::vector< std::string > &args)> &handler) (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | [inline] |
connected(MessageLoop *parent) | Datacratic::AsyncEventSource | [inline, virtual] |
debug(bool debugOn) | Datacratic::AsyncEventSource | [inline, virtual] |
debug_ | Datacratic::AsyncEventSource | |
defaultHandler (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | |
disconnect() | Datacratic::AsyncEventSource | |
handleMessage(const std::vector< std::string > &message) | Datacratic::ZmqMessageRouter | [inline, virtual] |
handleSyncMessage(const std::vector< std::string > &message) | Datacratic::ZmqEventSource | [virtual] |
init(zmq::socket_t &socket, SocketLock *lock=nullptr) (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
messageHandlers (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | |
needsPoll | Datacratic::AsyncEventSource | |
parent_ | Datacratic::AsyncEventSource | |
poll() const | Datacratic::ZmqEventSource | [virtual] |
processOne() | Datacratic::ZmqEventSource | [virtual] |
routable (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | |
selectFd() const | Datacratic::ZmqEventSource | [virtual] |
singleThreaded() const | Datacratic::AsyncEventSource | [inline, virtual] |
socket() const (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | [inline] |
socket_ (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
SocketLock typedef (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
socketLock() const (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | [inline] |
socketLock_ (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
SyncMessageHandler typedef (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
syncMessageHandler (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
ZmqEventSource() (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
ZmqEventSource(zmq::socket_t &socket, SocketLock *lock=nullptr) (defined in Datacratic::ZmqEventSource) | Datacratic::ZmqEventSource | |
ZmqEventSource(zmq::socket_t &socket, const T &handler, SocketLock *lock=nullptr, typename std::enable_if<!std::is_convertible< decltype(std::declval< T >()(std::declval< std::vector< std::string > >())), std::vector< std::string > >::value, void >::type *=0) | Datacratic::ZmqEventSource | [inline] |
ZmqEventSource(zmq::socket_t &socket, const T &handler, SocketLock *lock=nullptr, typename std::enable_if< std::is_convertible< decltype(std::declval< T >()(std::declval< std::vector< std::string > >())), std::vector< std::string > >::value, void >::type *=0) | Datacratic::ZmqEventSource | [inline] |
ZmqMessageRouter(bool routable=true) (defined in Datacratic::ZmqMessageRouter) | Datacratic::ZmqMessageRouter | [inline] |
~AsyncEventSource() (defined in Datacratic::AsyncEventSource) | Datacratic::AsyncEventSource | [inline, virtual] |