Datacratic::ZmqNamedPublisher Member List

This is the complete list of members for Datacratic::ZmqNamedPublisher, including all inherited members.

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
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
bindTcp(PortRange const &portRange=PortRange(), std::string host="") (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
checkNeedsPoll()	Datacratic::MessageLoop
close() (defined in Datacratic::Epoller)	Datacratic::Epoller
connected(MessageLoop *parent)	Datacratic::AsyncEventSource	[inline, virtual]
debug(bool debugOn)	Datacratic::MessageLoop	[virtual]
disconnect()	Datacratic::AsyncEventSource
encodeAll(std::vector< zmq::message_t > &messages, Head head, Tail &&...tail) (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
encodeAll(std::vector< zmq::message_t > &messages, const std::vector< std::string > &head, Tail &&...tail) (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
encodeAll(std::vector< zmq::message_t > &messages) (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
Epoller() (defined in Datacratic::Epoller)	Datacratic::Epoller
HandleEvent typedef (defined in Datacratic::Epoller)	Datacratic::Epoller
handleEvent	Datacratic::Epoller
handleEvents(int usToWait=0, int nEvents=1, const HandleEvent &handleEvent=HandleEvent(), const OnEvent &beforeSleep=OnEvent(), const OnEvent &afterSleep=OnEvent())	Datacratic::Epoller
init(std::shared_ptr< ConfigurationService > config, const std::string &endpointName, const std::string &identity="") (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
init(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
init(int maxFds) (defined in Datacratic::Epoller)	Datacratic::Epoller
MessageLoop(int numThreads=1, double maxAddedLatency=0.0005) (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
needsPoll	Datacratic::AsyncEventSource
OnEvent typedef (defined in Datacratic::Epoller)	Datacratic::Epoller
parent_	Datacratic::AsyncEventSource
poll() const	Datacratic::MessageLoop	[virtual]
processOne()	Datacratic::MessageLoop	[virtual]
publish(const std::string &channel, Args &&...args) (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
removeFd(int fd)	Datacratic::Epoller
removeSource(AsyncEventSource *source)	Datacratic::MessageLoop
restartFdOneShot(int fd, void *data=0)	Datacratic::Epoller
selectFd() const	Datacratic::Epoller	[inline, virtual]
shutdown() (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[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]
ZmqNamedPublisher(std::shared_ptr< zmq::context_t > context, int messageBufferSize=10000) (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline]
~AsyncEventSource() (defined in Datacratic::AsyncEventSource)	Datacratic::AsyncEventSource	[inline, virtual]
~Epoller() (defined in Datacratic::Epoller)	Datacratic::Epoller
~MessageLoop() (defined in Datacratic::MessageLoop)	Datacratic::MessageLoop
~ZmqNamedPublisher() (defined in Datacratic::ZmqNamedPublisher)	Datacratic::ZmqNamedPublisher	[inline, virtual]