RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
Datacratic::ZmqNamedEndpoint Member List
This is the complete list of members for Datacratic::ZmqNamedEndpoint, including all inherited members.
acceptEventHandlerDatacratic::ZmqNamedEndpoint
activate()Datacratic::NamedEndpoint
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
addrToIp(const std::string &addr)Datacratic::NamedEndpoint [static]
addrToString(const sockaddr *addr)Datacratic::NamedEndpoint [static]
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
bind(const std::string &address)Datacratic::ZmqNamedEndpoint [inline]
bindTcp(PortRange const &portRange=PortRange(), std::string host="")Datacratic::ZmqNamedEndpoint
checkNeedsPoll()Datacratic::MessageLoop
close() (defined in Datacratic::Epoller)Datacratic::Epoller
closeEventHandlerDatacratic::ZmqNamedEndpoint
connected(MessageLoop *parent)Datacratic::AsyncEventSource [inline, virtual]
ConnectionEventHandler typedef (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
debug(bool debugOn)Datacratic::MessageLoop [virtual]
disconnect()Datacratic::AsyncEventSource
disconnectEventHandlerDatacratic::ZmqNamedEndpoint
Epoller() (defined in Datacratic::Epoller)Datacratic::Epoller
getInterfaces(const std::set< int > &families=std::set< int >({AF_INET}), int flagsRequired=IFF_UP, int flagsExcluded=0)Datacratic::NamedEndpoint [static]
getPublishedUris() const (defined in Datacratic::NamedEndpoint)Datacratic::NamedEndpoint
getSocketUnsafe() const Datacratic::ZmqNamedEndpoint [inline]
handleAcceptEvent(std::string boundAddress)Datacratic::ZmqNamedEndpoint [inline, virtual]
handleCloseEvent(std::string boundAddress)Datacratic::ZmqNamedEndpoint [inline, virtual]
handleDisconnectEvent(std::string boundAddress)Datacratic::ZmqNamedEndpoint [inline, virtual]
HandleEvent typedef (defined in Datacratic::Epoller)Datacratic::Epoller
handleEventDatacratic::Epoller
handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent())Datacratic::Epoller
handleMessage(std::vector< std::string > &&message) (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint [inline, virtual]
handleRawMessage(std::vector< zmq::message_t > &&message)Datacratic::ZmqNamedEndpoint [inline, virtual]
init(std::shared_ptr< ConfigurationService > config, int socketType, const std::string &endpointName) (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
Datacratic::NamedEndpoint::init(std::shared_ptr< ConfigurationService > config, const std::string &endpointName)Datacratic::NamedEndpoint
init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)Datacratic::MessageLoop
init(int maxFds) (defined in Datacratic::Epoller)Datacratic::Epoller
messageHandler (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
MessageHandler typedef (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)Datacratic::MessageLoop
needsPollDatacratic::AsyncEventSource
numActiveConnections(std::string addr="") const Datacratic::ZmqNamedEndpoint [inline]
numBoundAddresses() const Datacratic::ZmqNamedEndpoint [inline]
OnEvent typedef (defined in Datacratic::Epoller)Datacratic::Epoller
parent_Datacratic::AsyncEventSource
poll() const Datacratic::MessageLoop [virtual]
processOne()Datacratic::MessageLoop [virtual]
publishAddress(const std::string &address, const Json::Value &addressConfig)Datacratic::NamedEndpoint
RawMessageHandler typedef (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
rawMessageHandler (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
removeFd(int fd)Datacratic::Epoller
removeSource(AsyncEventSource *source)Datacratic::MessageLoop
restartFdOneShot(int fd, void *data=0)Datacratic::Epoller
selectFd() const Datacratic::Epoller [inline, virtual]
sendMessage(Args &&...args) (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint [inline]
sendMessage(const std::vector< std::string > &message) (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint [inline]
sendMessage(std::vector< zmq::message_t > &&message)Datacratic::ZmqNamedEndpoint [inline]
shutdown() (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint [inline]
singleThreaded() const Datacratic::AsyncEventSource [inline, virtual]
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
totalSleepSeconds() const Datacratic::MessageLoop [inline]
unbindAll()Datacratic::ZmqNamedEndpoint [inline]
ZmqNamedEndpoint(std::shared_ptr< zmq::context_t > context) (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint
~AsyncEventSource() (defined in Datacratic::AsyncEventSource)Datacratic::AsyncEventSource [inline, virtual]
~Epoller() (defined in Datacratic::Epoller)Datacratic::Epoller
~MessageLoop() (defined in Datacratic::MessageLoop)Datacratic::MessageLoop
~ZmqNamedEndpoint() (defined in Datacratic::ZmqNamedEndpoint)Datacratic::ZmqNamedEndpoint [inline]
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator