TestPublisher Class Reference

Inheritance diagram for TestPublisher:

Public Member Functions
Aws::DataFlow::UploadStatus	getLastUploadStatus ()
void	setForceFailure (bool nv)
void	setForceInvalidDataFailure (bool nv)
bool	shutdown () override
bool	start () override
	TestPublisher ()
	~TestPublisher () override=default
Public Member Functions inherited from Publisher< std::list< Aws::CloudWatchLogs::Model::InputLogEvent > >
virtual void	addPublisherStateListener (const std::function< void(const PublisherState &)> &listener)
Aws::DataFlow::UploadStatus	attemptPublish (std::list< Aws::CloudWatchLogs::Model::InputLogEvent > &data) override
bool	canPublish ()
std::chrono::milliseconds	getLastPublishDuration ()
int	getPublishAttempts ()
PublisherState	getPublisherState ()
int	getPublishSuccesses ()
float	getPublishSuccessPercentage ()
	Publisher ()
bool	shutdown () override
	~Publisher () override=default
Public Member Functions inherited from Aws::DataFlow::IPublisher< T >
virtual UploadStatus	attemptPublish (T &batch_data)=0
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

Protected Member Functions
Aws::DataFlow::UploadStatus	attemptPublish (std::list< Aws::CloudWatchLogs::Model::InputLogEvent > &data) override
Aws::DataFlow::UploadStatus	publishData (std::list< Aws::CloudWatchLogs::Model::InputLogEvent > &) override
Protected Member Functions inherited from Service
void	setState (ServiceState new_state)

Protected Attributes
bool	force_failure
bool	force_invalid_data_failure
Aws::DataFlow::UploadStatus	last_upload_status

Detailed Description

Test the publisher interface while ignoring all of the CloudWatch specific infrastructure.

Definition at line 47 of file pipeline_test.cpp.

Constructor & Destructor Documentation

TestPublisher()

TestPublisher::TestPublisher ( )

inline

Definition at line 50 of file pipeline_test.cpp.

~TestPublisher()

TestPublisher::~TestPublisher ( )

overridedefault

Member Function Documentation

attemptPublish()

Aws::DataFlow::UploadStatus TestPublisher::attemptPublish ( std::list< Aws::CloudWatchLogs::Model::InputLogEvent > &  data )

inlineoverrideprotected

Definition at line 83 of file pipeline_test.cpp.

getLastUploadStatus()

Aws::DataFlow::UploadStatus TestPublisher::getLastUploadStatus ( )

inline

Definition at line 76 of file pipeline_test.cpp.

publishData()

Aws::DataFlow::UploadStatus TestPublisher::publishData ( std::list< Aws::CloudWatchLogs::Model::InputLogEvent > &  )

inlineoverrideprotectedvirtual

Implements Publisher< std::list< Aws::CloudWatchLogs::Model::InputLogEvent > >.

Definition at line 91 of file pipeline_test.cpp.

setForceFailure()

void TestPublisher::setForceFailure ( bool  nv )

inline

Definition at line 68 of file pipeline_test.cpp.

setForceInvalidDataFailure()

void TestPublisher::setForceInvalidDataFailure ( bool  nv )

inline

Definition at line 72 of file pipeline_test.cpp.

shutdown()

bool TestPublisher::shutdown ( )

inlineoverridevirtual

Reimplemented from Service.

Definition at line 62 of file pipeline_test.cpp.

start()

bool TestPublisher::start ( )

inlineoverridevirtual

Reimplemented from Service.

Definition at line 57 of file pipeline_test.cpp.

Member Data Documentation

force_failure

bool TestPublisher::force_failure

protected

Definition at line 104 of file pipeline_test.cpp.

force_invalid_data_failure

bool TestPublisher::force_invalid_data_failure

protected

Definition at line 105 of file pipeline_test.cpp.

last_upload_status

Aws::DataFlow::UploadStatus TestPublisher::last_upload_status

protected

Definition at line 106 of file pipeline_test.cpp.

---

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

• pipeline_test.cpp