stats

type Aggregator ¶

type Aggregator interface {
	Aggregate(operation string, key string, value float64, tags string)
}

StatsBuffer implements a buffering and flushing mechanism to buffer statsd messages that are collected via the process manager. Flush happens when buffer is full or a certain time passes since last flush.

The StatsBuffer.Handler should be registers as StatsFlushHandler on the process manager object.

func NewRedisStatsAggregator(address string, password string, capacity int, flushInt time.Duration) (Aggregator, error)

type Operation ¶

type Operation string

const (
	Counter    Operation = "A"
	Difference Operation = "D"
)

type Stats ¶

type Stats struct {
	Operation Operation
	Key       string
	Value     float64
	Tags      string
}