Skip to content

Commit

Permalink
Remove deprecated ruler_remote_write_queue_min_backoff, ruler_remote_…
Browse files Browse the repository at this point in the history
…write_queue_max_backoff and ruler_remote_write_queue_retry_on_ratelimit
  • Loading branch information
shantanualsi committed Nov 8, 2023
1 parent 0807c66 commit e179564
Show file tree
Hide file tree
Showing 9 changed files with 0 additions and 71 deletions.
12 changes: 0 additions & 12 deletions docs/sources/configure/_index.md
Original file line number Diff line number Diff line change
Expand Up @@ -2807,18 +2807,6 @@ The `limits_config` block configures global and per-tenant limits in Loki.
# will wait in buffer.
[ruler_remote_write_queue_batch_send_deadline: <duration>]

# Deprecated: Use 'ruler_remote_write_config' instead. Initial retry delay. Gets
# doubled for every retry.
[ruler_remote_write_queue_min_backoff: <duration>]

# Deprecated: Use 'ruler_remote_write_config' instead. Maximum retry delay.
[ruler_remote_write_queue_max_backoff: <duration>]

# Deprecated: Use 'ruler_remote_write_config' instead. Retry upon receiving a
# 429 status code from the remote-write storage. This is experimental and might
# change in the future.
[ruler_remote_write_queue_retry_on_ratelimit: <boolean>]

# Deprecated: Use 'ruler_remote_write_config' instead. Configures AWS's
# Signature Verification 4 signing process to sign every remote write request.
ruler_remote_write_sigv4_config:
Expand Down
2 changes: 0 additions & 2 deletions docs/sources/operations/overrides-exporter.md
Original file line number Diff line number Diff line change
Expand Up @@ -75,9 +75,7 @@ loki_overrides_defaults{limit_name="ruler_max_rule_groups_per_tenant"} 0
loki_overrides_defaults{limit_name="ruler_max_rules_per_rule_group"} 0
loki_overrides_defaults{limit_name="ruler_remote_write_queue_batch_send_deadline"} 0
loki_overrides_defaults{limit_name="ruler_remote_write_queue_capacity"} 0
loki_overrides_defaults{limit_name="ruler_remote_write_queue_max_backoff"} 0
loki_overrides_defaults{limit_name="ruler_remote_write_queue_max_samples_per_send"} 0
loki_overrides_defaults{limit_name="ruler_remote_write_queue_min_backoff"} 0
loki_overrides_defaults{limit_name="split_queries_by_interval"} 0
```

Expand Down
3 changes: 0 additions & 3 deletions pkg/ruler/compat.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,9 +43,6 @@ type RulesLimits interface {
RulerRemoteWriteQueueCapacity(userID string) int
RulerRemoteWriteQueueMaxSamplesPerSend(userID string) int
RulerRemoteWriteQueueBatchSendDeadline(userID string) time.Duration
RulerRemoteWriteQueueMinBackoff(userID string) time.Duration
RulerRemoteWriteQueueMaxBackoff(userID string) time.Duration
RulerRemoteWriteQueueRetryOnRateLimit(userID string) bool
RulerRemoteWriteSigV4Config(userID string) *sigv4.SigV4Config

RulerRemoteEvaluationTimeout(userID string) time.Duration
Expand Down
12 changes: 0 additions & 12 deletions pkg/ruler/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -262,22 +262,10 @@ func (r *walRegistry) getTenantRemoteWriteConfig(tenant string, base RemoteWrite
clt.QueueConfig.MaxSamplesPerSend = v
}

if v := r.overrides.RulerRemoteWriteQueueMinBackoff(tenant); v > 0 {
clt.QueueConfig.MinBackoff = model.Duration(v)
}

if v := r.overrides.RulerRemoteWriteQueueMaxBackoff(tenant); v > 0 {
clt.QueueConfig.MaxBackoff = model.Duration(v)
}

if v := r.overrides.RulerRemoteWriteQueueBatchSendDeadline(tenant); v > 0 {
clt.QueueConfig.BatchSendDeadline = model.Duration(v)
}

if v := r.overrides.RulerRemoteWriteQueueRetryOnRateLimit(tenant); v {
clt.QueueConfig.RetryOnRateLimit = v
}

if v := r.overrides.RulerRemoteWriteSigV4Config(tenant); v != nil {
clt.SigV4Config = v
}
Expand Down
24 changes: 0 additions & 24 deletions pkg/validation/limits.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,12 +138,6 @@ type Limits struct {
// deprecated use RulerRemoteWriteConfig instead
RulerRemoteWriteQueueBatchSendDeadline time.Duration `yaml:"ruler_remote_write_queue_batch_send_deadline" json:"ruler_remote_write_queue_batch_send_deadline" doc:"deprecated|description=Use 'ruler_remote_write_config' instead. Maximum time a sample will wait in buffer."`
// deprecated use RulerRemoteWriteConfig instead
RulerRemoteWriteQueueMinBackoff time.Duration `yaml:"ruler_remote_write_queue_min_backoff" json:"ruler_remote_write_queue_min_backoff" doc:"deprecated|description=Use 'ruler_remote_write_config' instead. Initial retry delay. Gets doubled for every retry."`
// deprecated use RulerRemoteWriteConfig instead
RulerRemoteWriteQueueMaxBackoff time.Duration `yaml:"ruler_remote_write_queue_max_backoff" json:"ruler_remote_write_queue_max_backoff" doc:"deprecated|description=Use 'ruler_remote_write_config' instead. Maximum retry delay."`
// deprecated use RulerRemoteWriteConfig instead
RulerRemoteWriteQueueRetryOnRateLimit bool `yaml:"ruler_remote_write_queue_retry_on_ratelimit" json:"ruler_remote_write_queue_retry_on_ratelimit" doc:"deprecated|description=Use 'ruler_remote_write_config' instead. Retry upon receiving a 429 status code from the remote-write storage. This is experimental and might change in the future."`
// deprecated use RulerRemoteWriteConfig instead
RulerRemoteWriteSigV4Config *sigv4.SigV4Config `yaml:"ruler_remote_write_sigv4_config" json:"ruler_remote_write_sigv4_config" doc:"deprecated|description=Use 'ruler_remote_write_config' instead. Configures AWS's Signature Verification 4 signing process to sign every remote write request."`

RulerRemoteWriteConfig map[string]config.RemoteWriteConfig `yaml:"ruler_remote_write_config,omitempty" json:"ruler_remote_write_config,omitempty" doc:"description=Configures global and per-tenant limits for remote write clients. A map with remote client id as key."`
Expand Down Expand Up @@ -639,24 +633,6 @@ func (o *Overrides) RulerRemoteWriteQueueBatchSendDeadline(userID string) time.D
return o.getOverridesForUser(userID).RulerRemoteWriteQueueBatchSendDeadline
}

// Deprecated: use RulerRemoteWriteConfig instead
// RulerRemoteWriteQueueMinBackoff returns the minimum time for an exponential backoff for a given user.
func (o *Overrides) RulerRemoteWriteQueueMinBackoff(userID string) time.Duration {
return o.getOverridesForUser(userID).RulerRemoteWriteQueueMinBackoff
}

// Deprecated: use RulerRemoteWriteConfig instead
// RulerRemoteWriteQueueMaxBackoff returns the maximum time for an exponential backoff for a given user.
func (o *Overrides) RulerRemoteWriteQueueMaxBackoff(userID string) time.Duration {
return o.getOverridesForUser(userID).RulerRemoteWriteQueueMaxBackoff
}

// Deprecated: use RulerRemoteWriteConfig instead
// RulerRemoteWriteQueueRetryOnRateLimit returns whether to retry failed remote-write requests (429 response) for a given user.
func (o *Overrides) RulerRemoteWriteQueueRetryOnRateLimit(userID string) bool {
return o.getOverridesForUser(userID).RulerRemoteWriteQueueRetryOnRateLimit
}

// Deprecated: use RulerRemoteWriteConfig instead
func (o *Overrides) RulerRemoteWriteSigV4Config(userID string) *sigv4.SigV4Config {
return o.getOverridesForUser(userID).RulerRemoteWriteSigV4Config
Expand Down
9 changes: 0 additions & 9 deletions tools/deprecated-config-checker/checker/checker_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,9 +52,6 @@ var (
"limits_config.ruler_remote_write_queue_capacity",
"limits_config.ruler_remote_write_queue_max_samples_per_send",
"limits_config.ruler_remote_write_queue_batch_send_deadline",
"limits_config.ruler_remote_write_queue_min_backoff",
"limits_config.ruler_remote_write_queue_max_backoff",
"limits_config.ruler_remote_write_queue_retry_on_ratelimit",
"limits_config.ruler_remote_write_sigv4_config",
"limits_config.per_tenant_override_config",
"limits_config.per_tenant_override_period",
Expand Down Expand Up @@ -87,9 +84,6 @@ var (
"overrides.foo.ruler_remote_write_queue_capacity",
"overrides.foo.ruler_remote_write_queue_max_samples_per_send",
"overrides.foo.ruler_remote_write_queue_batch_send_deadline",
"overrides.foo.ruler_remote_write_queue_min_backoff",
"overrides.foo.ruler_remote_write_queue_max_backoff",
"overrides.foo.ruler_remote_write_queue_retry_on_ratelimit",
"overrides.foo.ruler_remote_write_sigv4_config",
"overrides.foo.per_tenant_override_config",
"overrides.foo.per_tenant_override_period",
Expand All @@ -101,9 +95,6 @@ var (
"overrides.bar.ruler_remote_write_queue_capacity",
"overrides.bar.ruler_remote_write_queue_max_samples_per_send",
"overrides.bar.ruler_remote_write_queue_batch_send_deadline",
"overrides.bar.ruler_remote_write_queue_min_backoff",
"overrides.bar.ruler_remote_write_queue_max_backoff",
"overrides.bar.ruler_remote_write_queue_retry_on_ratelimit",
"overrides.bar.ruler_remote_write_sigv4_config",
"overrides.bar.per_tenant_override_config",
"overrides.bar.per_tenant_override_period",
Expand Down
3 changes: 0 additions & 3 deletions tools/deprecated-config-checker/deprecated-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,6 @@ limits_config:
ruler_remote_write_queue_capacity: "Use ruler_remote_write_config instead."
ruler_remote_write_queue_max_samples_per_send: "Use ruler_remote_write_config instead."
ruler_remote_write_queue_batch_send_deadline: "Use ruler_remote_write_config instead."
ruler_remote_write_queue_min_backoff: "Use ruler_remote_write_config instead."
ruler_remote_write_queue_max_backoff: "Use ruler_remote_write_config instead."
ruler_remote_write_queue_retry_on_ratelimit: "Use ruler_remote_write_config instead."
ruler_remote_write_sigv4_config: "Use ruler_remote_write_config instead."
per_tenant_override_config: "Feature renamed to 'runtime configuration', flag deprecated in favor of runtime_config.file"
per_tenant_override_period: "Feature renamed to 'runtime configuration', flag deprecated in favor of runtime_config.period"
Expand Down
3 changes: 0 additions & 3 deletions tools/deprecated-config-checker/test-fixtures/config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -123,9 +123,6 @@ limits_config:
ruler_remote_write_queue_capacity: 10 # DEPRECATED
ruler_remote_write_queue_max_samples_per_send: 50 # DEPRECATED
ruler_remote_write_queue_batch_send_deadline: 10m # DEPRECATED
ruler_remote_write_queue_min_backoff: 1m # DEPRECATED
ruler_remote_write_queue_max_backoff: 5m # DEPRECATED
ruler_remote_write_queue_retry_on_ratelimit: true # DEPRECATED
ruler_remote_write_sigv4_config: # DEPRECATED
region: "wherever"
per_tenant_override_config: ./overrides.yaml # DEPRECATED
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,6 @@ overrides:
ruler_remote_write_queue_capacity: 10 # DEPRECATED
ruler_remote_write_queue_max_samples_per_send: 50 # DEPRECATED
ruler_remote_write_queue_batch_send_deadline: 10m # DEPRECATED
ruler_remote_write_queue_min_backoff: 1m # DEPRECATED
ruler_remote_write_queue_max_backoff: 5m # DEPRECATED
ruler_remote_write_queue_retry_on_ratelimit: true # DEPRECATED
ruler_remote_write_sigv4_config: # DEPRECATED
region: "wherever"
per_tenant_override_config: ./overrides.yaml # DEPRECATED
Expand Down

0 comments on commit e179564

Please sign in to comment.