Class: Kafka::Statsd::FetcherSubscriber

Inherits:

StatsdSubscriber

• Object
• ActiveSupport::Subscriber
• StatsdSubscriber
• Kafka::Statsd::FetcherSubscriber

Defined in:

lib/kafka/statsd.rb

Instance Method Summary

• #loop(event) ⇒ Object

Instance Method Details

#loop(event) ⇒ Object

# File 'lib/kafka/statsd.rb', line 276

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