
Public Member Functions | |
| MOCK_METHOD0 (publishBatchedData, bool()) | |
Public Member Functions inherited from Aws::CloudWatchLogs::LogBatcher | |
| void | emptyCollection () override |
| LogBatcher (size_t max_allowable_batch_size=DataBatcher::kDefaultMaxBatchSize, size_t publish_trigger_size=DataBatcher::kDefaultTriggerSize) | |
| LogBatcher (const LogBatcher &other)=delete | |
| LogBatcher & | operator= (const LogBatcher &other)=delete |
| bool | publishBatchedData () override |
| virtual void | setLogFileManager (std::shared_ptr< Aws::FileManagement::FileManager< LogCollection >> log_file_manager) |
| bool | start () override |
| ~LogBatcher () override | |
Public Member Functions inherited from DataBatcher< LogType > | |
| virtual bool | batchData (const LogType &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< LogType > | |
| static void | validateConfigurableSizes (size_t batch_max_queue_size, size_t batch_trigger_publish_size) |
Static Public Attributes inherited from DataBatcher< LogType > | |
| 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< LogType > | |
| std::shared_ptr< std::list< LogType > > | batched_data_ |
| std::recursive_mutex | mtx |
Definition at line 53 of file log_node_test.cpp.
| LogBatcherMock::MOCK_METHOD0 | ( | publishBatchedData | , |
| bool() | |||
| ) |