neic-glass3  1.4.6
glass3::brokerInput Member List

This is the complete list of members for glass3::brokerInput, including all inherited members.

BaseClass()glass3::util::BaseClass
brokerInput()glass3::brokerInput
brokerInput(const std::shared_ptr< const json::Object > &config)glass3::brokerInputexplicit
clear() overrideglass3::brokerInputvirtual
fetchRawData(std::string *pOutType) overrideglass3::brokerInputprotectedvirtual
getAllLastHealthy(size_t *pThreadId)glass3::util::ThreadBaseClass
getConfig()glass3::util::BaseClass
getDefaultAgencyId()glass3::util::BaseClass
getDefaultAuthor()glass3::util::BaseClass
getHealthCheckInterval()glass3::util::ThreadBaseClass
getInputData() overrideglass3::input::Inputvirtual
getInputDataCount() overrideglass3::input::Inputvirtual
getInputDataMaxSize()glass3::input::Input
getNumThreads()glass3::util::ThreadBaseClass
getSetup()glass3::util::BaseClass
getSleepTime()glass3::util::ThreadBaseClass
getTerminate()glass3::util::ThreadBaseClass
getThreadName()glass3::util::ThreadBaseClass
getWorkThreadsState()glass3::util::ThreadBaseClass
healthCheck()glass3::util::ThreadBaseClassvirtual
Input()glass3::input::Input
Input(std::shared_ptr< const json::Object > config)glass3::input::Inputexplicit
logConsumer(const std::string &message)glass3::brokerInputprotected
m_bIsSetupglass3::util::BaseClassprotected
m_Configglass3::util::BaseClassprotected
m_DefaultAgencyIDglass3::util::BaseClassprotected
m_DefaultAuthorglass3::util::BaseClassprotected
m_ThreadHealthMapglass3::util::ThreadBaseClassprotected
m_WorkThreadsglass3::util::ThreadBaseClassprotected
parse(std::string inputType, std::string inputMessage)glass3::input::Inputprotectedvirtual
setDefaultAgencyId(const std::string &id)glass3::util::BaseClass
setDefaultAuthor(const std::string &author)glass3::util::BaseClass
setHealthCheckInterval(int interval)glass3::util::ThreadBaseClass
setInputDataMaxSize(int size)glass3::input::Input
setLastHealthy(std::time_t now)glass3::util::ThreadBaseClassprotected
setNumThreads(int numThreads)glass3::util::ThreadBaseClass
setSleepTime(int sleepTimeMS)glass3::util::ThreadBaseClass
setThreadHealth(bool health=true)glass3::util::ThreadBaseClass
setup(std::shared_ptr< const json::Object > config) overrideglass3::brokerInputvirtual
setWorkThreadsState(glass3::util::ThreadState state)glass3::util::ThreadBaseClassprotected
start()glass3::util::ThreadBaseClassvirtual
stop()glass3::util::ThreadBaseClassvirtual
ThreadBaseClass()glass3::util::ThreadBaseClass
ThreadBaseClass(std::string threadName, int sleepTimeMS=100, int numThreads=1, int checkInterval=300)glass3::util::ThreadBaseClass
work() overrideglass3::input::Inputprotectedvirtual
workLoop()glass3::util::ThreadBaseClassprotected
~BaseClass()glass3::util::BaseClassvirtual
~brokerInput()glass3::brokerInput
~Input()glass3::input::Input
~ThreadBaseClass()glass3::util::ThreadBaseClass