Inheritance diagram for TestLogFileManager:

[legend]

Public Member Functions
FileObject< LogCollection >	readBatch (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< 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 112 of file pipeline_test.cpp.

Constructor & Destructor Documentation

◆ TestLogFileManager()

TestLogFileManager::TestLogFileManager ( )

inline

Definition at line 116 of file pipeline_test.cpp.

Member Function Documentation

◆ readBatch()

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

inlineoverridevirtual

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

Definition at line 126 of file pipeline_test.cpp.

◆ write()

void TestLogFileManager::write ( const LogCollection & data )

inlineoverride

Definition at line 120 of file pipeline_test.cpp.

Member Data Documentation

◆ cv

std::condition_variable TestLogFileManager::cv

Definition at line 135 of file pipeline_test.cpp.

◆ last_data_size

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

Definition at line 134 of file pipeline_test.cpp.

◆ mtx

std::mutex TestLogFileManager::mtx

mutable

Definition at line 136 of file pipeline_test.cpp.

◆ written_count

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:

pipeline_test.cpp

Public Member Functions

Public Attributes

Additional Inherited Members