cloudwatch_logs_facade.h

Go to the documentation of this file.

/*
 * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License").
 * You may not use this file except in compliance with the License.
 * A copy of the License is located at
 *
 *  http://aws.amazon.com/apache2.0
 *
 * or in the "license" file accompanying this file. This file is distributed
 * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 * express or implied. See the License for the specific language governing
 * permissions and limitations under the License.
 */

#pragma once

#include <aws/core/Aws.h>
#include <aws/logs/CloudWatchLogsClient.h>
#include <aws/logs/model/InputLogEvent.h>
#include <aws/logs/model/PutLogEventsRequest.h>
#include <cloudwatch_logs_common/definitions/ros_cloudwatch_logs_errors.h>
#include <cloudwatch_logs_common/definitions/definitions.h>

namespace Aws {
namespace CloudWatchLogs {
namespace Utils {

class CloudWatchLogsFacade
{
public:
  // NOLINTNEXTLINE(google-explicit-constructor, hicpp-explicit-conversions)
  CloudWatchLogsFacade(const Aws::Client::ClientConfiguration & client_config);

  // NOLINTNEXTLINE(google-explicit-constructor, hicpp-explicit-conversions)
  CloudWatchLogsFacade(const std::shared_ptr<Aws::CloudWatchLogs::CloudWatchLogsClient>& cw_client);

  virtual ~CloudWatchLogsFacade() = default;

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors SendLogsToCloudWatch(
    Aws::String & next_token, const std::string & log_group, const std::string & log_stream,
    LogCollection & logs);

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors CreateLogGroup(
    const std::string & log_group);

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors CheckLogGroupExists(
    const std::string & log_group);

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors CreateLogStream(
    const std::string & log_group, const std::string & log_stream);

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors CheckLogStreamExists(
    const std::string & log_group, const std::string & log_stream,
    Aws::CloudWatchLogs::Model::LogStream * log_stream_object);

  virtual Aws::CloudWatchLogs::ROSCloudWatchLogsErrors GetLogStreamToken(
    const std::string & log_group, const std::string & log_stream, Aws::String & next_token);

protected:

  CloudWatchLogsFacade() = default;
  std::shared_ptr<Aws::CloudWatchLogs::CloudWatchLogsClient> cw_client_;

private:
  Aws::CloudWatchLogs::ROSCloudWatchLogsErrors SendLogsRequest(
    const Aws::CloudWatchLogs::Model::PutLogEventsRequest & request, Aws::String & next_token);

  // The last time PutLogEvents was called, used to track rate limiting
  std::chrono::milliseconds last_put_time_{0};

};

}  // namespace Utils
}  // namespace CloudWatchLogs
}  // namespace Aws