class Kafka::Statsd::FetcherSubscriber
Public Instance Methods
loop(event)
click to toggle source
# File lib/kafka/statsd.rb, line 285 def loop(event) queue_size = event.payload.fetch(:queue_size) client = event.payload.fetch(:client_id) group_id = event.payload.fetch(:group_id) gauge("fetcher.#{client}.#{group_id}.queue_size", queue_size) end