| _context | HCE::handlers::Handler | protected |
| _dumpDir | HCE::handlers::Handler | protected |
| _dumpIntervalAt | HCE::handlers::Handler | protected |
| _extendedReducerFO | HCE::handlers::DataReducerProxy | protected |
| _inprocAdminSock | HCE::handlers::Handler | protected |
| _inprocReducerInSock | HCE::handlers::DataReducerProxy | protected |
| _inprocReducerOutSock | HCE::handlers::DataReducerProxy | protected |
| _inProgress | HCE::handlers::Handler | protected |
| _logMask | HCE::handlers::Handler | protected |
| _logTimeFormat | HCE::handlers::Handler | protected |
| _propertyIntervalAt | HCE::handlers::Handler | protected |
| _reducerTtlTasksCleanupAt | HCE::handlers::DataReducerProxy | protected |
| _responses | HCE::handlers::DataReducerProxy | protected |
| createDirectories(const std::string &name) | HCE::handlers::Handler | inlineprotected |
| DataReducerProxy(std::string name, zmq::context_t &ctx, const std::string &clientIdentity, unsigned char nodeMode, int64_t startedAt, unsigned char logPriority, const std::string &iniFile) | HCE::handlers::DataReducerProxy | |
| defaultReducerReduceJson(std::string &messageId, std::string &messageBody) | HCE::handlers::DataReducerProxy | protected |
| defaultReducerReducePlainText(std::string &messageId, std::string &messageBody) | HCE::handlers::DataReducerProxy | protected |
| defaultReducerResponseItemAccumulate(std::map< std::string, DefaultReducerResponseItem * >::iterator &DefaultReducerResponseItemIterator, std::string &messageBody) | HCE::handlers::DataReducerProxy | protectedstatic |
| defaultReducerResponseItemCreate(std::string &messageId, std::string &messageBody) | HCE::handlers::DataReducerProxy | protected |
| defaultReducerResponseItemReduce(std::map< std::string, DefaultReducerResponseItem * >::iterator &DefaultReducerResponseItemIterator) | HCE::handlers::DataReducerProxy | protected |
| deinitialize(void) | HCE::handlers::DataReducerProxy | protectedvirtual |
| dumpProperties(void) | HCE::handlers::Handler | inlineprotected |
| dumpRunTimeVariables(void) | HCE::handlers::Handler | inlineprotected |
| getBindTriesDelay(void) | HCE::handlers::Handler | inlineprotected |
| getBindTriesMaxNumber(void) | HCE::handlers::Handler | inlineprotected |
| getClientIdentity(void) | HCE::handlers::Handler | inlineprotected |
| getClientsNumber(void) | HCE::handlers::DataReducerProxy | protected |
| getConnectionString(void) | HCE::handlers::Handler | inlineprotected |
| getDumpAllowRestore(void) | HCE::handlers::Handler | inlineprotected |
| getDumpFileName(void) | HCE::handlers::Handler | inlineprotected |
| getDumpInterval(void) | HCE::handlers::Handler | inlineprotected |
| getIniFile(void) | HCE::handlers::Handler | inlineprotected |
| getInProgress(void) const | HCE::handlers::Handler | inlineprotected |
| getLogPriority(void) | HCE::handlers::Handler | inlineprotected |
| getName(void) | HCE::handlers::Handler | inline |
| getNodeMode(void) | HCE::handlers::DataReducerProxy | protected |
| getPollTimeout(void) | HCE::handlers::Handler | inlineprotected |
| getProperties(void) | HCE::handlers::Handler | inlineprotected |
| getPropertyInformation(void) | HCE::handlers::DataReducerProxy | protectedvirtual |
| getPropertyInterval(void) | HCE::handlers::Handler | inlineprotected |
| getStartedAt(void) | HCE::handlers::Handler | inlineprotected |
| getStatFileName(void) | HCE::handlers::Handler | inlineprotected |
| getStatRequests(void) | HCE::handlers::DataReducerProxy | protected |
| getStatResponses(void) | HCE::handlers::DataReducerProxy | protected |
| handleAdminMessage(void) | HCE::handlers::Handler | inlineprotected |
| handleExternalMessage(void) | HCE::handlers::Handler | protected |
| handleInternalMessage(void) | HCE::handlers::DataReducerProxy | protected |
| Handler(const std::string &name, zmq::context_t &context, const std::string &clientIdentity, const std::string &connectionString, int64_t startedAt, unsigned char logPriority, const std::string &iniFile="") | HCE::handlers::Handler | inline |
| handlerProperties | HCE::handlers::Handler | protected |
| heartbit(void) | HCE::handlers::Handler | protected |
| initHandler(const std::string &iniFile, LoggerStream &logger) | HCE::handlers::Handler | inlineprotected |
| initialize(void) | HCE::handlers::DataReducerProxy | protectedvirtual |
| log | HCE::handlers::Handler | protected |
| logFlush(unsigned int priority=NODE_LOG_MODE_DEFAULT) | HCE::handlers::Handler | inlineprotected |
| logger | HCE::handlers::Handler | protected |
| logPeriodicStatistics(void) | HCE::handlers::Handler | protected |
| main(void *that) | HCE::handlers::Handler | inlinestatic |
| process(void) | HCE::handlers::DataReducerProxy | protectedvirtual |
| processAdminCommands(std::string &command, std::string ¶meters) | HCE::handlers::DataReducerProxy | protectedvirtual |
| processAdminMessage(zmsg &msg) | HCE::handlers::Handler | inlineprotected |
| processControlMessage(zmsg &msg) | HCE::handlers::Handler | protected |
| processDataMessage(zmsg &msg) | HCE::handlers::Handler | protected |
| rebuildAdminClientSocket(void) | HCE::handlers::Handler | inlineprotected |
| rebuildClientConnection(zmq::socket_t *&sock_p, const std::string &connectionString, const int type, const std::string &identity="") | HCE::handlers::Handler | inlineprotected |
| rebuildClientConnection(zmq::socket_t *&sock_p, const std::string &connectionString, const int type, const std::string &identity, int linger, const std::string &readyMessage="", const std::string &byeMessage=NODE_MSG_BYE) | HCE::handlers::Handler | inlineprotected |
| rebuildServerConnection(zmq::socket_t *&sock_p, const std::string &connectionString, const int type) | HCE::handlers::Handler | inlineprotected |
| reduceJson(std::string &messageId, std::string &messageBody) | HCE::handlers::DataReducerProxy | protected |
| reducerInit(void) | HCE::handlers::DataReducerProxy | protected |
| reducerTasksCleanupByTtl(void) | HCE::handlers::DataReducerProxy | protected |
| registerClient(const std::string &identity) | HCE::handlers::Handler | protected |
| sendByeMessage(zmq::socket_t *&sock_p, const std::string &identity="", const std::string &byeMessage=NODE_MSG_BYE) | HCE::handlers::Handler | inlineprotected |
| sendPeriodicProperties(void) | HCE::handlers::Handler | inlineprotected |
| setBindTriesDelay(const unsigned int &bindTriesDelay) | HCE::handlers::Handler | inlineprotected |
| setBindTriesMaxNumber(const unsigned int &bindTriesMaxNumber) | HCE::handlers::Handler | inlineprotected |
| setClientIdentity(const std::string &clientIdentity) | HCE::handlers::Handler | inlineprotected |
| setClientsNumber(unsigned int clientsNumber) | HCE::handlers::DataReducerProxy | protected |
| setConnectionString(const std::string &connectionString) | HCE::handlers::Handler | inlineprotected |
| setDumpAllowRestore(unsigned int dumpAllowRestore) | HCE::handlers::Handler | inlineprotected |
| setDumpInterval(unsigned int dumpInterval) | HCE::handlers::Handler | inlineprotected |
| setIniFile(const std::string &iniFile) | HCE::handlers::Handler | inlineprotected |
| setInProgress(bool in_progress) | HCE::handlers::Handler | inlineprotected |
| setLogPriority(unsigned int logPriority) | HCE::handlers::Handler | inlineprotected |
| setName(const std::string &name) | HCE::handlers::Handler | inlineprotected |
| setNodeMode(unsigned char nodeMode) | HCE::handlers::DataReducerProxy | protected |
| setPollTimeout(unsigned int pollTimeout) | HCE::handlers::Handler | inlineprotected |
| setPropertyInterval(unsigned int propertyInterval) | HCE::handlers::Handler | inlineprotected |
| setStartedAt(int64_t startedAt) | HCE::handlers::Handler | inlineprotected |
| setStatRequests(unsigned int statRequests) | HCE::handlers::DataReducerProxy | protected |
| setStatResponses(unsigned int statResponses) | HCE::handlers::DataReducerProxy | protected |
| shutdown(void) | HCE::handlers::Handler | inline |
| statProperties | HCE::handlers::Handler | protected |
| TTL_TASKS_CLEANUP_INTERVAL_DEFAULT | HCE::handlers::DataReducerProxy | |
| TTL_TASKS_CLEANUP_NUMBER_DEFAULT | HCE::handlers::DataReducerProxy | |
| TTL_TASKS_QUEUE_CLEANUP_NUMBER_DEFAULT | HCE::handlers::DataReducerProxy | |
| TTL_TASKS_QUEUE_CLEANUP_TIME | HCE::handlers::DataReducerProxy | |
| ~DataReducerProxy() | HCE::handlers::DataReducerProxy | |
| ~Handler() | HCE::handlers::Handler | inlinevirtual |