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