class Kafka::Statsd::ConnectionSubscriber

Public Instance Methods

request(event) click to toggle source
# File lib/kafka/statsd.rb, line 62
def request(event)
  client = event.payload.fetch(:client_id)
  api = event.payload.fetch(:api, "unknown")
  request_size = event.payload.fetch(:request_size, 0)
  response_size = event.payload.fetch(:response_size, 0)
  broker = event.payload.fetch(:broker_host)

  timing("api.#{client}.#{api}.#{broker}.latency", event.duration)
  increment("api.#{client}.#{api}.#{broker}.calls")

  timing("api.#{client}.#{api}.#{broker}.request_size", request_size)
  timing("api.#{client}.#{api}.#{broker}.response_size", response_size)

  if event.payload.key?(:exception)
    increment("api.#{client}.#{api}.#{broker}.errors")
  end
end