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

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 ( )

Definition at line 50 of file pipeline_test.cpp.

TestPublisher::~TestPublisher ( )

Member Function Documentation

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

Definition at line 83 of file pipeline_test.cpp.

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

Definition at line 76 of file pipeline_test.cpp.

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

Definition at line 68 of file pipeline_test.cpp.

void TestPublisher::setForceInvalidDataFailure ( bool  nv)

Definition at line 72 of file pipeline_test.cpp.

bool TestPublisher::shutdown ( )

Reimplemented from Service.

Definition at line 62 of file pipeline_test.cpp.

bool TestPublisher::start ( )

Reimplemented from Service.

Definition at line 57 of file pipeline_test.cpp.

Member Data Documentation

bool TestPublisher::force_failure

Definition at line 104 of file pipeline_test.cpp.

bool TestPublisher::force_invalid_data_failure

Definition at line 105 of file pipeline_test.cpp.

Aws::DataFlow::UploadStatus TestPublisher::last_upload_status

Definition at line 106 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