badmetrics

Documentation

Index

• type BadMetrics
  • func New(maxAge time.Duration) *BadMetrics
  • func (b *BadMetrics) Add(metric []byte, msg []byte, err error)
  • func (b *BadMetrics) Get(expiry time.Duration) []Record
• type ByMetric
  • func (a ByMetric) Len() int
  • func (a ByMetric) Less(i, j int) bool
  • func (a ByMetric) Swap(i, j int)
• type Record

Types

type BadMetrics

type BadMetrics struct {
	In chan Record
	// contains filtered or unexported fields
}

func New

func New(maxAge time.Duration) *BadMetrics

maxAge is the age after which we expire old records (in practice a bit later)

func (*BadMetrics) Add

func (b *BadMetrics) Add(metric []byte, msg []byte, err error)

func (*BadMetrics) Get

func (b *BadMetrics) Get(expiry time.Duration) []Record

type ByMetric

type ByMetric []Record

ByMetric implements sort.Interface for []Record based on the Metric field.

func (ByMetric) Len

func (a ByMetric) Len() int

func (ByMetric) Less

func (a ByMetric) Less(i, j int) bool

func (ByMetric) Swap

func (a ByMetric) Swap(i, j int)

type Record

type Record struct {
	Metric   string // the key parsed, or "" if parse failure
	LastMsg  string // metric line read
	LastErr  string
	LastSeen time.Time
}