Class: Karafka::Routing::Features::Pausing::Config

Inherits:
Struct
  • Object
show all
Defined in:
lib/karafka/routing/features/pausing/config.rb

Overview

Per-topic pause (backoff) configuration value object.

Defaults to the global config.pause.* settings unless overridden on a per-topic basis.

Unlike most feature configs, active here does not switch the behavior on or off - the pause/backoff always applies. It only marks whether these settings were explicitly set for this topic (true) or inherited from the global defaults (false).

Instance Attribute Summary collapse

Instance Attribute Details

#active ⇒ Object Also known as: active?

Returns the value of attribute active

Returns:

  • (Object) —

    the current value of active



14
15
16
 
# File 'lib/karafka/routing/features/pausing/config.rb', line 14

def active
  @active
end

#max_timeout ⇒ Object

Returns the value of attribute max_timeout

Returns:

  • (Object) —

    the current value of max_timeout



14
15
16
 
# File 'lib/karafka/routing/features/pausing/config.rb', line 14

def max_timeout
  @max_timeout
end

#timeout ⇒ Object

Returns the value of attribute timeout

Returns:

  • (Object) —

    the current value of timeout



14
15
16
 
# File 'lib/karafka/routing/features/pausing/config.rb', line 14

def timeout
  @timeout
end

#with_exponential_backoff ⇒ Object Also known as: with_exponential_backoff?

Returns the value of attribute with_exponential_backoff

Returns:

  • (Object) —

    the current value of with_exponential_backoff



14
15
16
 
# File 'lib/karafka/routing/features/pausing/config.rb', line 14

def with_exponential_backoff
  @with_exponential_backoff
end