Versions in this module Expand all Collapse all v1 v1.2.0 Dec 12, 2019 Changes in this version + func AcknowledgedMessage(msg creator.Message, topic string) + func Address(host string, port int) string + func Close() error + func ConsumerChannelLength(count int) + func ConsumerCount() + func ConsumerLatency(dur time.Duration) + func ConsumerMessageProcessingTime(dur time.Duration) + func ConsumerMessageReadTime(dur time.Duration) + func Count(name string, value int64, tags []string) + func Gauge(name string, value float64, tags []string) + func Incr(metric string, tags []string) + func ProduceLatency(dur time.Duration) + func ProducerChannelLength(count int) + func ProducerCount() + func ReportTime(startTime time.Time, tags []string, metricName string) + func ReporterType() string + func SentMessage(msg creator.Message) + func SetReporter(reporter StatsdReporter) + func Setup(cfg config.Prometheus, producerCfg config.Producer) + func SetupPProf(cfg config.PProf) + func SetupStatsD(cfg config.Statsd) + type NopReporter struct + func (m *NopReporter) Close() error + func (m *NopReporter) Count(name string, value int64, tags []string, rate float64) error + func (m *NopReporter) Gauge(name string, value float64, tags []string, rate float64) error + func (m *NopReporter) Incr(name string, tags []string, rate float64) error + func (m *NopReporter) Timing(name string, value time.Duration, tags []string, rate float64) error + type StatsdConfig struct + Enabled bool + Host string + Port int + Service string + Tags []string + type StatsdReporter interface + Close func() error + Count func(name string, value int64, tags []string, rate float64) error + Gauge func(name string, value float64, tags []string, rate float64) error + Incr func(name string, tags []string, rate float64) error + Timing func(name string, value time.Duration, tags []string, rate float64) error