Sha256: 2009bb79ed02a3681f2cf9d6741665320c3ebfa348e32ecbd243ff05f2a7dcda
Contents?: true
Size: 761 Bytes
Versions: 17
Compression:
Stored size: 761 Bytes
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!
processes_total = Models::Processes.active(@current_state)
@counters = Lib::HashProxy.new(@current_state[:stats])
@processes, @next_page = Lib::PaginateArray.new.call(
processes_total,
@params.current_page
)
respond
end
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems