Class: Karafka::Pro::ScheduledMessages::State
- Inherits:
-
Object
- Object
- Karafka::Pro::ScheduledMessages::State
- Defined in:
- lib/karafka/pro/scheduled_messages/state.rb
Overview
Represents the loading/bootstrapping state of the given topic partition
Bootstrapping can be in the following states: - fresh - when we got an assignment but we did not load the schedule yet - loading - when we are in the process of bootstrapping the daily state and we consume historical messages to build the needed schedules. - loaded - state in which we finished loading all the schedules and we can dispatch messages when the time comes and we can process real-time incoming schedules and changes to schedules as they appear in the stream. - shutdown - the states are no longer available as the consumer has shut down
Instance Method Summary collapse
-
#initialize ⇒ State
constructor
A new instance of State.
-
#to_s ⇒ String
Current state string representation.
Constructor Details
#initialize ⇒ State
Returns a new instance of State.
30 31 32 |
# File 'lib/karafka/pro/scheduled_messages/state.rb', line 30 def initialize @state = 'fresh' end |
Instance Method Details
#to_s ⇒ String
Returns current state string representation.
45 46 47 |
# File 'lib/karafka/pro/scheduled_messages/state.rb', line 45 def to_s @state end |