DataBatcher< T > Member List

This is the complete list of members for DataBatcher< T >, including all inherited members.

batchData(const T &data_to_batch)DataBatcher< T >inlinevirtual
batched_data_DataBatcher< T >protected
DataBatcher(size_t max_allowable_batch_size=DataBatcher::kDefaultMaxBatchSize, size_t trigger_size=DataBatcher::kDefaultTriggerSize, std::chrono::microseconds try_enqueue_duration=std::chrono::duration_cast< std::chrono::microseconds >(std::chrono::seconds(2)))DataBatcher< T >inline
emptyCollection()DataBatcher< T >inlineprotectedvirtual
getCurrentBatchSize()DataBatcher< T >inline
getMaxAllowableBatchSize()DataBatcher< T >inline
getState()Serviceinline
getStatusString()Serviceinlinevirtual
getTriggerBatchSize()DataBatcher< T >inline
getTryEnqueueDuration()DataBatcher< T >inline
kDefaultMaxBatchSizeDataBatcher< T >static
kDefaultTriggerSizeDataBatcher< T >static
max_allowable_batch_size_DataBatcher< T >private
mtxDataBatcher< T >mutableprotected
publishBatchedData()=0DataBatcher< T >pure virtual
resetBatchedData()DataBatcher< T >inline
resetTriggerBatchSize()DataBatcher< T >inline
Service()Serviceinline
setMaxAllowableBatchSize(int new_value)DataBatcher< T >inline
setState(ServiceState new_state)Serviceinlineprotected
setTriggerBatchSize(size_t new_value)DataBatcher< T >inline
setTryEnqueueDuration(std::chrono::microseconds duration)DataBatcher< T >inline
shutdown() overrideDataBatcher< T >inlinevirtual
start()Serviceinlinevirtual
trigger_batch_size_DataBatcher< T >private
try_enqueue_duration_DataBatcher< T >private
validateConfigurableSizes(size_t batch_max_queue_size, size_t batch_trigger_publish_size)DataBatcher< T >inlinestatic
~DataBatcher() override=defaultDataBatcher< T >
~Service()=defaultServicevirtual


dataflow_lite
Author(s): AWS RoboMaker
autogenerated on Fri May 7 2021 02:18:22