18 #include <aws/core/Aws.h> 19 #include <aws/logs/model/InputLogEvent.h> 38 namespace CloudWatchLogs {
71 const std::string &input,
72 const std::chrono::milliseconds &milliseconds)
override {
74 Aws::CloudWatchLogs::Model::InputLogEvent log_event;
76 log_event.SetMessage(input.c_str());
77 log_event.SetTimestamp(milliseconds.count());
89 const std::string &input)
override {
91 Aws::CloudWatchLogs::Model::InputLogEvent log_event;
93 log_event.SetMessage(input.c_str());
virtual std::chrono::milliseconds getCurrentTimestamp()
CloudWatchService(std::shared_ptr< Publisher< std::list< T >>> publisher, std::shared_ptr< DataBatcher< T >> batcher)
Aws::CloudWatchLogs::Model::InputLogEvent convertInputToBatched(const std::string &input, const std::chrono::milliseconds &milliseconds) override
std::shared_ptr< FileUploadStreamer< std::list< T > > > file_upload_streamer_
LogService(std::shared_ptr< Publisher< LogCollection >> log_publisher, std::shared_ptr< DataBatcher< LogType >> log_batcher, std::shared_ptr< Aws::FileManagement::FileUploadStreamer< LogCollection >> log_file_upload_streamer=nullptr)
Aws::CloudWatchLogs::Model::InputLogEvent convertInputToBatched(const std::string &input) override