void transfer_from_protobuf_msg()

in aws/kinesis/core/configuration.h [1047:1094]

• 46 lines of code
• 5 McCabe index (conditional complexity)

  void transfer_from_protobuf_msg(const aws::kinesis::protobuf::Message& m) {
    if (!m.has_configuration()) {
      throw std::runtime_error("Not a configuration message");
    }
    auto c = m.configuration();
    aggregation_enabled(c.aggregation_enabled());
    aggregation_max_count(c.aggregation_max_count());
    aggregation_max_size(c.aggregation_max_size());
    cloudwatch_endpoint(c.cloudwatch_endpoint());
    cloudwatch_port(c.cloudwatch_port());
    collection_max_count(c.collection_max_count());
    collection_max_size(c.collection_max_size());
    connect_timeout(c.connect_timeout());
    enable_core_dumps(c.enable_core_dumps());
    fail_if_throttled(c.fail_if_throttled());
    kinesis_endpoint(c.kinesis_endpoint());
    kinesis_port(c.kinesis_port());
    log_level(c.log_level());
    max_connections(c.max_connections());
    metrics_granularity(c.metrics_granularity());
    metrics_level(c.metrics_level());
    metrics_namespace(c.metrics_namespace());
    metrics_upload_delay(c.metrics_upload_delay());
    min_connections(c.min_connections());
    rate_limit(c.rate_limit());
    record_max_buffered_time(c.record_max_buffered_time());
    record_ttl(c.record_ttl());
    region(c.region());
    request_timeout(c.request_timeout());
    verify_certificate(c.verify_certificate());
    proxy_host(c.proxy_host());
    proxy_port(c.proxy_port());
    proxy_user_name(c.proxy_user_name());
    proxy_password(c.proxy_password());
    if (c.thread_config() == ::aws::kinesis::protobuf::Configuration_ThreadConfig::Configuration_ThreadConfig_POOLED) {
      use_thread_pool(true);
      thread_pool_size(c.thread_pool_size());
    } else if (c.thread_config() == ::aws::kinesis::protobuf::Configuration_ThreadConfig_PER_REQUEST) {
      use_thread_pool(false);
    }

    for (auto i = 0; i < c.additional_metric_dims_size(); i++) {
      auto ad = c.additional_metric_dims(i);
      additional_metrics_dims_.push_back(
          std::make_tuple(ad.key(), ad.value(), ad.granularity()));
    }

  }