metrics

Documentation

Index

• func AcknowledgedMessage(msg creator.Message, topic string)
• func Address(host string, port int) string
• func Close() error
• func ConsumerCount(topic string)
• func ConsumerLatency(dur time.Duration, topic string)
• 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, topic string)
• func ProducerChannelLength(count int, topic string)
• func ProducerCount(topic string)
• func ReportTime(startTime time.Time, tags []string, metricName string, rate float64)
• func ReporterType() string
• func SentMessage(msg creator.Message, topic string)
• func SetReporter(reporter StatsdReporter)
• func Setup(cfg config.Prometheus)
• func SetupStatsD(cfg config.Statsd)
• type NopReporter
  • 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
• type StatsdReporter

Functions

func AcknowledgedMessage

func AcknowledgedMessage(msg creator.Message, topic string)

func Address

func Address(host string, port int) string

func Close

func Close() error

func ConsumerCount

func ConsumerCount(topic string)

func ConsumerLatency

func ConsumerLatency(dur time.Duration, topic string)

func Count

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

func Gauge

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

func Incr

func Incr(metric string, tags []string)

func ProduceLatency

func ProduceLatency(dur time.Duration, topic string)

func ProducerChannelLength

func ProducerChannelLength(count int, topic string)

func ProducerCount

func ProducerCount(topic string)

func ReportTime

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

func ReporterType

func ReporterType() string

func SentMessage

func SentMessage(msg creator.Message, topic string)

func SetReporter

func SetReporter(reporter StatsdReporter)

func Setup

func Setup(cfg config.Prometheus)

func SetupStatsD

func SetupStatsD(cfg config.Statsd)

Types

type NopReporter

type NopReporter struct{}

func (*NopReporter) Close

func (m *NopReporter) Close() error

func (*NopReporter) Count

func (m *NopReporter) Count(name string, value int64, tags []string, rate float64) error

func (*NopReporter) Gauge

func (m *NopReporter) Gauge(name string, value float64, tags []string, rate float64) error

func (*NopReporter) Incr

func (m *NopReporter) Incr(name string, tags []string, rate float64) error

func (*NopReporter) Timing

func (m *NopReporter) Timing(name string, value time.Duration, tags []string, rate float64) error

type StatsdConfig

type StatsdConfig struct {
	Host    string
	Port    int
	Enabled bool
	Service string
	Tags    []string
}

type StatsdReporter

type StatsdReporter interface {
	Timing(name string, value time.Duration, tags []string, rate float64) error
	Incr(name string, tags []string, rate float64) error
	Count(name string, value int64, tags []string, rate float64) error
	Gauge(name string, value float64, tags []string, rate float64) error
	Close() error
}