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