metrics_collector_parameter_helper.hpp

Go to the documentation of this file.

/*
 * Copyright 2019 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 <cloudwatch_metrics_common/cloudwatch_options.h>
#include <aws_common/sdk_utils/aws_error.h>
#include <aws_common/sdk_utils/parameter_reader.h>
#include <ros/ros.h>
#include <unordered_set>
#include <iostream>


namespace Aws {
namespace CloudWatchMetrics {
namespace Utils {

const std::string kNodeParamMonitorTopicsListKey("aws_monitored_metric_topics");
const std::string kNodeParamMetricNamespaceKey = "aws_metrics_namespace";
const std::string kNodeParamDefaultMetricDimensionsKey  = "aws_default_metric_dimensions";
const std::string kNodeName = "cloudwatch_metrics_collector";
const char kNodeParamPublishFrequencyKey[] = "publish_frequency";

constexpr char kNodeParamBatchMaxQueueSize[] = "batch_max_queue_size";
constexpr char kNodeParamBatchTriggerPublishSize[] = "batch_trigger_publish_size";
constexpr char kNodeParamFileMaxQueueSize[] = "file_max_queue_size";
constexpr char kNodeParamFileUploadBatchSize[] = "file_upload_batch_size";
constexpr char kNodeParamStreamMaxQueueSize[] = "stream_max_queue_size";

constexpr char kNodeParamFileExtension[] = "file_extension";
constexpr char kNodeParamFilePrefix[] = "file_prefix";
constexpr char kNodeParamMaximumFileSize[] = "maximum_file_size";
constexpr char kNodeParamStorageDirectory[] = "storage_directory";
constexpr char kNodeParamStorageLimit[] = "storage_limit";

constexpr int kNodeSubQueueSize = 100;
constexpr int kNodePublishFrequencyDefaultValue = 10;
const int kNodeMetricServiceTimeSec = 1;
const std::string kNodeDefaultMetricNamespace = "ROS";
const std::string kNodeDefaulMetricsTopic = "metrics";
constexpr int kNodeDefaultMetricDatumStorageResolution = 60;
const std::string kNodeParamMetricDatumStorageResolutionKey = "storage_resolution";
const std::set<int> kNodeParamMetricDatumStorageResolutionValidValues = {1, 60};


void ReadPublishFrequency(
        const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
        double & publish_frequency);

void ReadMetricNamespace(
        const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
        std::string & metric_namespace);

void ReadMetricDimensions(
        const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
        Aws::String & dimensions_param,
        std::map<std::string, std::string> & metric_dims);
void ReadStorageResolution(
        const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
        int & storage_resolution);

void ReadTopics(std::vector<std::string> & topics);

void ReadCloudWatchOptions(
  const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
  Aws::CloudWatchMetrics::CloudWatchOptions & cloudwatch_options);

void ReadUploaderOptions(
  const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
  Aws::DataFlow::UploaderOptions & uploader_options);

void ReadFileManagerStrategyOptions(
  const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
  Aws::FileManagement::FileManagerStrategyOptions & file_manager_strategy_options);

void ReadOption(
  const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
  const std::string & option_key,
  const std::string & default_value,
  std::string & option_value);

void ReadOption(
  const std::shared_ptr<Aws::Client::ParameterReaderInterface>& parameter_reader,
  const std::string & option_key,
  const size_t & default_value,
  size_t & option_value);

}  // namespace Utils
}  // namespace CloudWatchMetrics
}  // namespace Aws