Public Member Functions | Public Attributes | List of all members
TestLogFileManager Class Reference
Inheritance diagram for TestLogFileManager:
Inheritance graph

Public Member Functions

FileObject< LogCollectionreadBatch (size_t batch_size) override
 TestLogFileManager ()
void write (const LogCollection &data) override
- Public Member Functions inherited from Aws::FileManagement::FileManager< LogCollection >
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< LogCollection >
std::mutex active_delete_stale_data_mutex_
std::shared_ptr< DataManagerStrategyfile_manager_strategy_
std::shared_ptr< StatusMonitor > file_status_monitor_
std::vector< FileManagement::DataTokenstale_data_
size_t total_logs_uploaded_

Detailed Description

Test File Manager

Definition at line 112 of file pipeline_test.cpp.

Constructor & Destructor Documentation

TestLogFileManager::TestLogFileManager ( )

Definition at line 116 of file pipeline_test.cpp.

Member Function Documentation

FileObject<LogCollection> TestLogFileManager::readBatch ( size_t  batch_size)

Implements Aws::FileManagement::DataReader< T >.

Definition at line 126 of file pipeline_test.cpp.

void TestLogFileManager::write ( const LogCollection data)

Definition at line 120 of file pipeline_test.cpp.

Member Data Documentation

std::condition_variable TestLogFileManager::cv

Definition at line 135 of file pipeline_test.cpp.

std::atomic<size_t> TestLogFileManager::last_data_size {}

Definition at line 134 of file pipeline_test.cpp.

std::mutex TestLogFileManager::mtx

Definition at line 136 of file pipeline_test.cpp.

std::atomic<int> TestLogFileManager::written_count {}

Definition at line 133 of file pipeline_test.cpp.

The documentation for this class was generated from the following file:

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