Sha256: e65223657d0cf4139e06003b08b93a0f35ab8ae87b683ef39c11e90f874c547b

Contents?: true

Size: 456 Bytes

Versions: 28

Compression:

Stored size: 456 Bytes

Contents

# frozen_string_literal: true

module Karafka
  # App status monitor
  class Status
    include Singleton

    # Available states and their transitions
    STATES = {
      initializing: :initialize!,
      running: :run!,
      stopped: :stop!
    }.freeze

    STATES.each do |state, transition|
      define_method :"#{state}?" do
        @status == state
      end

      define_method transition do
        @status = state
      end
    end
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
karafka-1.2.13 lib/karafka/status.rb
karafka-1.2.12 lib/karafka/status.rb
karafka-1.2.11 lib/karafka/status.rb
karafka-1.2.10 lib/karafka/status.rb
karafka-1.2.9 lib/karafka/status.rb
karafka-1.2.8 lib/karafka/status.rb
karafka-1.2.7 lib/karafka/status.rb
karafka-1.2.6 lib/karafka/status.rb
karafka-1.2.5 lib/karafka/status.rb
karafka-1.2.4 lib/karafka/status.rb
karafka-1.2.3 lib/karafka/status.rb
karafka-1.2.2 lib/karafka/status.rb
karafka-1.2.1 lib/karafka/status.rb
karafka-1.2.0 lib/karafka/status.rb
karafka-1.2.0.beta4 lib/karafka/status.rb
karafka-1.2.0.beta3 lib/karafka/status.rb
karafka-1.2.0.beta2 lib/karafka/status.rb
karafka-1.2.0.beta1 lib/karafka/status.rb
karafka-1.1.2 lib/karafka/status.rb
karafka-1.1.1 lib/karafka/status.rb