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