metrics

Dec 19, 2019

Changes in this version

+ func SetupPProf(cfg config.PProf)

Dec 2, 2019

Changes in this version

+ func ConsumerChannelLength(count int)

+ func ConsumerMessageProcessingTime(dur time.Duration)

+ func ConsumerMessageReadTime(dur time.Duration)

Sep 13, 2019

Changes in this version

+ func Address(host string, port int) string

+ func Close() error

+ func Count(name string, value int64, tags []string)

+ func Gauge(name string, value float64, tags []string)

+ func Incr(metric string, tags []string)

+ func ReportTime(startTime time.Time, tags []string, metricName string, rate float64)

+ func ReporterType() string

+ func SetReporter(reporter StatsdReporter)

+ 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

Sep 11, 2019

Changes in this version

+ func ConsumerCount(topic string)

+ func ProducerChannelLength(count int, topic string)

+ func ProducerCount(topic string)

Sep 6, 2019

Changes in this version

+ func AcknowledgedMessage(msg creator.Message)

+ func ConsumerLatency(dur time.Duration)

+ func ProduceLatency(dur time.Duration)

+ func SentMessage(msg creator.Message)

+ func Setup(cfg config.Prometheus)