mm

type Aggregator struct {
	// contains filtered or unexported fields
}

type Binding struct {
	// contains filtered or unexported fields
}

type Collection struct {
	proto.ServiceInstance
	Ts      int64 // UTC Unix timestamp
	Metrics []Metric
}

type Config struct {
	proto.ServiceInstance      // info about external service being monitored
	Collect               uint // how often monitor collects metrics (seconds)
	Report                uint // how often aggregator reports metrics (seconds)
}

type InstanceStats struct {
	proto.ServiceInstance
	Stats map[string]*Stats // keyed on metric name
}

type Manager struct {
	// contains filtered or unexported fields
}

type Metric struct {
	Name   string // mysql/status/Threads_running
	Type   string // gauge, counter, string
	Number float64
	String string
}

type Monitor interface {
	Start(tickChan chan time.Time, collectionChan chan *Collection) error
	Stop() error
	Status() map[string]string
	TickChan() chan time.Time
	Config() interface{}
}

type MonitorFactory interface {
	Make(service string, instanceId uint, data []byte) (Monitor, error)
}

type Report struct {
	Ts       time.Time // start, UTC
	Duration uint      // seconds
	Stats    []*InstanceStats
}

type Stats struct {
	Cnt   int
	Min   float64
	Pct5  float64
	Avg   float64
	Med   float64
	Pct95 float64
	Max   float64
	// contains filtered or unexported fields
}