Inheritance diagram for TestMetricFileManager:
Public Member Functions | |
| FileObject< MetricDatumCollection > | readBatch (size_t batch_size) override |
| TestMetricFileManager () | |
| void | write (const MetricDatumCollection &data) override |
 Public Member Functions inherited from Aws::FileManagement::FileManager< MetricDatumCollection > | |
| void | deleteStaleData () |
| FileManager () | |
| FileManager (std::shared_ptr< DataManagerStrategy > file_manager_strategy) | |
| FileManager (const FileManagerStrategyOptions &options) | |
| void | fileUploadCompleteStatus (const Aws::DataFlow::UploadStatus &upload_status, const FileObject< T > &log_messages) override |
| bool | isDataAvailableToRead () override |
| DataToken | read (std::string &data) |
| void | setStatusMonitor (std::shared_ptr< StatusMonitor > status_monitor) override |
| bool | shutdown () override |
| bool | start () override |
| virtual void | write (const T &data)=0 |
| virtual | ~FileManager ()=default |
| Public Member Functions inherited from Service | |
| ServiceState | getState () |
| virtual std::string | getStatusString () |
| Service () | |
| virtual | ~Service ()=default |
| Public Member Functions inherited from Waiter | |
| void | notify () |
| void | wait () |
| void | wait_for (std::chrono::seconds seconds) |
| void | wait_for_millis (std::chrono::milliseconds millis) |
| Waiter () | |
| ~Waiter ()=default | |
Public Attributes | |
| std::condition_variable | cv |
| std::atomic< size_t > | last_data_size {} |
| std::mutex | mtx |
| std::atomic< int > | written_count {} |
Additional Inherited Members | |
| Protected Member Functions inherited from Service | |
| void | setState (ServiceState new_state) |
| Protected Attributes inherited from Aws::FileManagement::FileManager< MetricDatumCollection > | |
| std::mutex | active_delete_stale_data_mutex_ |
| std::shared_ptr< DataManagerStrategy > | file_manager_strategy_ |
| std::shared_ptr< StatusMonitor > | file_status_monitor_ |
| std::vector< FileManagement::DataToken > | stale_data_ |
| size_t | total_logs_uploaded_ |
Detailed Description
Test File Manager
Definition at line 116 of file metric_pipeline_test.cpp.
Constructor & Destructor Documentation
|
inline |
Definition at line 120 of file metric_pipeline_test.cpp.
Member Function Documentation
|
inlineoverridevirtual |
Implements Aws::FileManagement::DataReader< T >.
Definition at line 130 of file metric_pipeline_test.cpp.
|
inlineoverride |
Definition at line 124 of file metric_pipeline_test.cpp.
Member Data Documentation
| std::condition_variable TestMetricFileManager::cv |
Definition at line 139 of file metric_pipeline_test.cpp.
| std::atomic<size_t> TestMetricFileManager::last_data_size {} |
Definition at line 138 of file metric_pipeline_test.cpp.
|
mutable |
Definition at line 140 of file metric_pipeline_test.cpp.
| std::atomic<int> TestMetricFileManager::written_count {} |
Definition at line 137 of file metric_pipeline_test.cpp.
The documentation for this class was generated from the following file: