Public Member Functions | |
MOCK_METHOD0 (publishBatchedData, bool()) | |
Public Member Functions inherited from Aws::CloudWatchMetrics::MetricBatcher | |
void | emptyCollection () override |
MetricBatcher (size_t max_allowable_batch_size=DataBatcher::kDefaultMaxBatchSize, size_t publish_trigger_size=DataBatcher::kDefaultTriggerSize) | |
MetricBatcher (const MetricBatcher &other)=delete | |
MetricBatcher & | operator= (const MetricBatcher &other)=delete |
bool | publishBatchedData () override |
virtual void | setMetricFileManager (std::shared_ptr< Aws::FileManagement::FileManager< MetricDatumCollection >> file_manager) |
bool | start () override |
~MetricBatcher () override | |
Public Member Functions inherited from DataBatcher< MetricDatum > | |
virtual bool | batchData (const MetricDatum &data_to_batch) |
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))) | |
size_t | getCurrentBatchSize () |
size_t | getMaxAllowableBatchSize () |
size_t | getTriggerBatchSize () |
std::chrono::microseconds | getTryEnqueueDuration () |
void | resetBatchedData () |
void | resetTriggerBatchSize () |
void | setMaxAllowableBatchSize (int new_value) |
void | setTriggerBatchSize (size_t new_value) |
void | setTryEnqueueDuration (std::chrono::microseconds duration) |
bool | shutdown () override |
~DataBatcher () override=default | |
Public Member Functions inherited from Service | |
ServiceState | getState () |
virtual std::string | getStatusString () |
Service () | |
virtual | ~Service ()=default |
Additional Inherited Members | |
Static Public Member Functions inherited from DataBatcher< MetricDatum > | |
static void | validateConfigurableSizes (size_t batch_max_queue_size, size_t batch_trigger_publish_size) |
Static Public Attributes inherited from DataBatcher< MetricDatum > | |
static const size_t | kDefaultMaxBatchSize |
static const size_t | kDefaultTriggerSize |
Protected Member Functions inherited from Service | |
void | setState (ServiceState new_state) |
Protected Attributes inherited from DataBatcher< MetricDatum > | |
std::shared_ptr< std::list< MetricDatum > > | batched_data_ |
std::recursive_mutex | mtx |
Definition at line 54 of file cloudwatch_metrics_collector_test.cpp.
MetricBatcherMock::MOCK_METHOD0 | ( | publishBatchedData | , |
bool() | |||
) |