module Kafka::Statsd

Reports operational metrics to a Statsd agent.

require "kafka/statsd"

# Default is "ruby_kafka".
Kafka::Statsd.namespace = "custom-namespace"

# Default is "127.0.0.1".
Kafka::Statsd.host = "statsd.something.com"

# Default is 8125.
Kafka::Statsd.port = 1234

Once the file has been required, no further configuration is needed – all operational metrics are automatically emitted.

Constants

DEFAULT_HOST
DEFAULT_NAMESPACE
DEFAULT_PORT

Public Class Methods

host=(host) click to toggle source
# File lib/kafka/statsd.rb, line 37
def self.host=(host)
  statsd.host = host
  statsd.connect if statsd.respond_to?(:connect)
end
namespace=(namespace) click to toggle source
# File lib/kafka/statsd.rb, line 47
def self.namespace=(namespace)
  statsd.namespace = namespace
end
port=(port) click to toggle source
# File lib/kafka/statsd.rb, line 42
def self.port=(port)
  statsd.port = port
  statsd.connect if statsd.respond_to?(:connect)
end
statsd() click to toggle source
# File lib/kafka/statsd.rb, line 33
def self.statsd
  @statsd ||= ::Statsd.new(DEFAULT_HOST, DEFAULT_PORT).tap { |sd| sd.namespace = DEFAULT_NAMESPACE }
end