Class: JetstreamBridge::Consumer::ProcessingState

Inherits:
Object
  • Object
show all
Defined in:
lib/jetstream_bridge/consumer/consumer_state.rb

Overview

Tracks processing counters and idle-backoff state.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(idle_backoff:, iterations: 0) ⇒ ProcessingState

Returns a new instance of ProcessingState.

Parameters:

  • idle_backoff (Float) —

    Initial idle backoff duration (seconds)

  • iterations (Integer) (defaults to: 0) —

    Starting iteration count



14
15
16
17
 
# File 'lib/jetstream_bridge/consumer/consumer_state.rb', line 14

def initialize(idle_backoff:, iterations: 0)
  @idle_backoff = idle_backoff
  @iterations = iterations
end

Instance Attribute Details

#idle_backoff ⇒ Float

Returns Current idle backoff duration in seconds.

Returns:

  • (Float) —

    Current idle backoff duration in seconds



8
9
10
 
# File 'lib/jetstream_bridge/consumer/consumer_state.rb', line 8

def idle_backoff
  @idle_backoff
end

#iterations ⇒ Integer

Returns Total number of processing loop iterations.

Returns:

  • (Integer) —

    Total number of processing loop iterations



10
11
12
 
# File 'lib/jetstream_bridge/consumer/consumer_state.rb', line 10

def iterations
  @iterations
end