Sha256: 356990a9874ac9e1a56493c0bd198032871a255fe70b92d04309f936142122bd
Contents?: true
Size: 592 Bytes
Versions: 37
Compression:
Stored size: 592 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Ui
# Namespace for models representing pieces of data about Karafka setup
module Models
# Representation of data of a Karafka consumer group
class ConsumerGroup < Lib::HashProxy
# @return [Array<SubscriptionGroup>] Data of topics belonging to this consumer group
def subscription_groups
super
.values
.map { |sg_hash| SubscriptionGroup.new(sg_hash) }
.sort_by(&:id)
end
end
end
end
end
end
Version data entries
37 entries across 37 versions & 1 rubygems