9#include <userver/logging/fwd.hpp>
10#include <userver/utils/strong_typedef.hpp>
12#include <userver/storages/redis/command_control.hpp>
13#include <userver/storages/redis/fwd.hpp>
15USERVER_NAMESPACE_BEGIN
17namespace storages::
redis {
21enum class ConnectionSecurity { kNone, kTLS };
24 std::string host =
"localhost";
27 bool read_only =
false;
28 ConnectionSecurity connection_security = ConnectionSecurity::kNone;
29 using HostVector = std::vector<std::string>;
30 std::size_t database_index = 0;
32 ConnectionInfo() =
default;
37 bool read_only =
false,
38 ConnectionSecurity security = ConnectionSecurity::kNone,
39 std::size_t db_index = 0
41 : host{std::move(host)},
43 password{std::move(password)},
45 connection_security(security),
46 database_index(db_index) {}
52 double inprogress = 0.0;
53 double timeouts = 0.0;
56using ScanCursor = int64_t;
59 bool buffering_enabled{
false};
60 size_t commands_buffering_threshold{0};
61 std::chrono::microseconds watch_command_timer_interval{0};
64 return buffering_enabled == o.buffering_enabled &&
65 commands_buffering_threshold == o.commands_buffering_threshold &&
66 watch_command_timer_interval == o.watch_command_timer_interval;
71 enum class Level { kCluster, kShard, kInstance };
74 bool timings_enabled{
true};
75 bool command_timings_enabled{
false};
76 bool request_sizes_enabled{
false};
77 bool reply_sizes_enabled{
false};
80 return timings_enabled == rhs.timings_enabled && command_timings_enabled == rhs.command_timings_enabled &&
81 request_sizes_enabled == rhs.request_sizes_enabled && reply_sizes_enabled == rhs.reply_sizes_enabled;
84 constexpr bool operator!=(
const DynamicSettings& rhs)
const {
return !(*
this == rhs); }
88 Level level{Level::kInstance};
90 constexpr bool operator==(
const StaticSettings& rhs)
const {
return level == rhs.level; }
92 constexpr bool operator!=(
const StaticSettings& rhs)
const {
return !(*
this == rhs); }
99 : static_settings(static_settings), dynamic_settings(dynamic_settings) {}
100 MetricsSettings() =
default;
107 return static_settings == rhs.static_settings && dynamic_settings == rhs.dynamic_settings;
110 constexpr bool operator!=(
const MetricsSettings& rhs)
const {
return !(*
this == rhs); }
112 Level GetMetricsLevel()
const {
return static_settings.level; }
113 bool IsTimingsEnabled()
const {
return dynamic_settings.timings_enabled; }
114 bool IsCommandTimingsEnabled()
const {
return dynamic_settings.command_timings_enabled; }
115 bool IsRequestSizesEnabled()
const {
return dynamic_settings.request_sizes_enabled; }
116 bool IsReplySizesEnabled()
const {
return dynamic_settings.reply_sizes_enabled; }
120 bool per_shard_stats_enabled{
true};
123 return per_shard_stats_enabled == rhs.per_shard_stats_enabled;
130 bool enable_monitoring{
false};
131 bool restrict_requests{
false};