Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Ui
      module Controllers
        # Consumers (consuming processes - `karafka server`) processes display consumer
        class Consumers < Base
          self.sortable_attributes = %w[
            name
            started_at
            lag_hybrid
          ].freeze

          # List page with consumers
          # @note For now we load all and paginate over the squashed data.
          def index
            @current_state = Models::ConsumersState.current!
            @counters = Models::Counters.new(@current_state)
            @processes, last_page = Ui::Lib::Paginations::Paginators::Arrays.call(
              refine(Models::Processes.active(@current_state)),
              @params.current_page
            )

            paginate(@params.current_page, !last_page)

            render
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
karafka-web-0.8.2	lib/karafka/web/ui/controllers/consumers.rb
karafka-web-0.8.1	lib/karafka/web/ui/controllers/consumers.rb