Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Ui
      module Controllers
        # Consumers (consuming processes - `karafka server`) processes display consumer
        class Consumers < Base
          # List page with consumers
          # @note For now we load all and paginate over the squashed data.
          def index
            @current_state = Models::State.current!
            @counters = Models::Counters.new(@current_state)
            @processes, @next_page = Lib::PaginateArray.new.call(
              Models::Processes.active(@current_state),
              @params.current_page
            )

            respond
          end
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
karafka-web-0.6.3	lib/karafka/web/ui/controllers/consumers.rb
karafka-web-0.6.1	lib/karafka/web/ui/controllers/consumers.rb
karafka-web-0.6.0	lib/karafka/web/ui/controllers/consumers.rb