redis_config.hpp

#pragma once
 
#include <userver/dynamic_config/value.hpp>
#include <userver/formats/parse/to.hpp>
#include <userver/storages/redis/impl/base.hpp>
#include <userver/storages/redis/impl/wait_connected_mode.hpp>
 
USERVER_NAMESPACE_BEGIN
 
namespace redis {
CommandControl Parse(const formats::json::Value& elem,
                     formats::parse::To<CommandControl>);
 
CommandControl::Strategy Parse(const formats::json::Value& elem,
                               formats::parse::To<CommandControl::Strategy>);
 
WaitConnectedMode Parse(const formats::json::Value& elem,
                        formats::parse::To<WaitConnectedMode>);
 
RedisWaitConnected Parse(const formats::json::Value& elem,
                         formats::parse::To<RedisWaitConnected>);
 
CommandsBufferingSettings Parse(const formats::json::Value& elem,
                                formats::parse::To<CommandsBufferingSettings>);
 
MetricsSettings Parse(const formats::json::Value& elem,
                      formats::parse::To<MetricsSettings>);
 
ReplicationMonitoringSettings Parse(
    const formats::json::Value& elem,
    formats::parse::To<ReplicationMonitoringSettings>);
 
PubsubMetricsSettings Parse(const formats::json::Value& elem,
                            formats::parse::To<PubsubMetricsSettings>);
}  // namespace redis
 
namespace storages::redis {
 
class Config {
 public:
  dynamic_config::Value<USERVER_NAMESPACE::redis::CommandControl>
      default_command_control;
  dynamic_config::Value<USERVER_NAMESPACE::redis::CommandControl>
      subscriber_default_command_control;
  dynamic_config::Value<size_t> subscriptions_rebalance_min_interval_seconds;
  dynamic_config::Value<USERVER_NAMESPACE::redis::RedisWaitConnected>
      redis_wait_connected;
  dynamic_config::Value<USERVER_NAMESPACE::redis::CommandsBufferingSettings>
      commands_buffering_settings;
  dynamic_config::Value<USERVER_NAMESPACE::redis::MetricsSettings>
      metrics_settings;
  dynamic_config::Value<USERVER_NAMESPACE::redis::PubsubMetricsSettings>
      pubsub_metrics_settings;
  dynamic_config::ValueDict<
      USERVER_NAMESPACE::redis::ReplicationMonitoringSettings>
      replication_monitoring_settings;
  dynamic_config::Value<bool> redis_cluster_autotopology_enabled;
 
  Config(const dynamic_config::DocsMap& docs_map)
      : default_command_control{"REDIS_DEFAULT_COMMAND_CONTROL", docs_map},
        subscriber_default_command_control{
            "REDIS_SUBSCRIBER_DEFAULT_COMMAND_CONTROL", docs_map},
        subscriptions_rebalance_min_interval_seconds{
            "REDIS_SUBSCRIPTIONS_REBALANCE_MIN_INTERVAL_SECONDS", docs_map},
        redis_wait_connected{"REDIS_WAIT_CONNECTED", docs_map},
        commands_buffering_settings{"REDIS_COMMANDS_BUFFERING_SETTINGS",
                                    docs_map},
        metrics_settings{"REDIS_METRICS_SETTINGS", docs_map},
        pubsub_metrics_settings{"REDIS_PUBSUB_METRICS_SETTINGS", docs_map},
        replication_monitoring_settings{"REDIS_REPLICA_MONITORING_SETTINGS",
                                        docs_map},
        redis_cluster_autotopology_enabled{
            "REDIS_CLUSTER_AUTOTOPOLOGY_ENABLED_V2", docs_map} {}
};
 
}  // namespace storages::redis
 
USERVER_NAMESPACE_END