Fledge
An open source edge computing platform for industrial users
SendingProcess Member List

This is the complete list of members for SendingProcess, including all inherited members.

createConfigCategories(DefaultConfigCategory configCategory, std::string parent_name, std::string current_name, std::string current_description)SendingProcess
createNewStream()SendingProcess
createStream(int)SendingProcess
filterPipeline (defined in SendingProcess)SendingProcess
FledgeProcess(int argc, char **argv) (defined in FledgeProcess)FledgeProcess
getArgValue(const std::string &name) constFledgeProcessprotected
getDataBuffers() (defined in SendingProcess)SendingProcessinlinestatic
getDataSourceType() const (defined in SendingProcess)SendingProcessinline
getDuration() const (defined in SendingProcess)SendingProcessinline
getLastFetchId() const (defined in SendingProcess)SendingProcessinline
getLastSentId() const (defined in SendingProcess)SendingProcessinline
getLastSentReadingId()SendingProcess
getLoadBufferIndex() constSendingProcess
getLoadBufferIndexPtr() constSendingProcess
getLogger() constFledgeProcess
getManagementClient() constFledgeProcess
getMemoryBufferSize() const (defined in SendingProcess)SendingProcessinline
getName() const (defined in FledgeProcess)FledgeProcessinline
getPluginName() const (defined in SendingProcess)SendingProcessinline
getReadBlockSize() const (defined in SendingProcess)SendingProcessinline
getSentReadings() const (defined in SendingProcess)SendingProcessinline
getSleepTime() const (defined in SendingProcess)SendingProcessinline
getStartTime() const (defined in FledgeProcess)FledgeProcessinline
getStorageClient() constFledgeProcess
getStreamId() const (defined in SendingProcess)SendingProcessinline
getUpdateDb() const (defined in SendingProcess)SendingProcessinline
isRunning() const (defined in SendingProcess)SendingProcessinline
m_buffer (defined in SendingProcess)SendingProcess
m_dryRun (defined in FledgeProcess)FledgeProcessprotected
m_last_read_id (defined in SendingProcess)SendingProcess
m_plugin (defined in SendingProcess)SendingProcess
m_thread_load (defined in SendingProcess)SendingProcess
m_thread_send (defined in SendingProcess)SendingProcess
passToOnwardFilter(OUTPUT_HANDLE *outHandle, READINGSET *readings)SendingProcessstatic
resetSentReadings() (defined in SendingProcess)SendingProcessinline
run() const (defined in SendingProcess)SendingProcess
SendingProcess(int argc, char **argv)SendingProcess
setLastFetchId(unsigned long id) (defined in SendingProcess)SendingProcessinline
setLastSentId(unsigned long id) (defined in SendingProcess)SendingProcessinline
setLoadBufferData(unsigned long index, ReadingSet *readings) (defined in SendingProcess)SendingProcessstatic
setLoadBufferIndex(unsigned long loadBufferIdx)SendingProcess
setUpdateDb(bool val) (defined in SendingProcess)SendingProcessinline
stop() (defined in SendingProcess)SendingProcess
stopRunning() (defined in SendingProcess)SendingProcessinline
updateDatabaseCounters()SendingProcess
updateSentReadings(unsigned long num) (defined in SendingProcess)SendingProcessinline
useFilteredData(OUTPUT_HANDLE *outHandle, READINGSET *readings)SendingProcessstatic
~FledgeProcess() (defined in FledgeProcess)FledgeProcessvirtual
~SendingProcess()SendingProcess