class Kafka::Datadog::StatsdSubscriber

Private Instance Methods

emit(type, *args, tags: {}) click to toggle source
# File lib/kafka/datadog.rb, line 104
def emit(type, *args, tags: {})
  tags = tags.map {|k, v| "#{k}:#{v}" }.to_a

  Kafka::Datadog.statsd.send(type, *args, tags: tags)
end