class Kafka::Datadog::ConnectionSubscriber
Public Instance Methods
request(event)
click to toggle source
# File lib/kafka/datadog.rb, line 111 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) tags = { client: client, api: api, broker: broker } timing("api.latency", event.duration, tags: tags) increment("api.calls", tags: tags) histogram("api.request_size", request_size, tags: tags) histogram("api.response_size", response_size, tags: tags) if event.payload.key?(:exception) increment("api.errors", tags: tags) end end