class Kafka::Prometheus::FetcherSubscriber

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/kafka/prometheus.rb, line 299
def initialize
  super
  @queue_size = Prometheus.registry.gauge(:fetcher_queue_size, docstring: 'Queue size', labels: [:client, :group_id])
end

Public Instance Methods

loop(event) click to toggle source
# File lib/kafka/prometheus.rb, line 304
def loop(event)
  queue_size = event.payload.fetch(:queue_size)
  client = event.payload.fetch(:client_id)
  group_id = event.payload.fetch(:group_id)

  @queue_size.set(queue_size, labels: { client: client, group_id: group_id })
end