monitor

Documentation

Index

• func NewMetricCollector(masterClient *client.Client, etcdServer *etcdserver.EtcdServer) prometheus.Collector
• func Profiler(key string, startTime time.Time)
• func Register(masterClient *client.Client, etcdServer *etcdserver.EtcdServer, ...)
• func SliceMetric() map[string]*Digest
• type Digest
  • func NewDigest(Name string, Sum float64) *Digest
• type MonitorService
  • func (ms *MonitorService) Collect(ch chan<- prometheus.Metric)
  • func (collector *MonitorService) Describe(ch chan<- *prometheus.Desc)

Functions

func NewMetricCollector

func NewMetricCollector(masterClient *client.Client, etcdServer *etcdserver.EtcdServer) prometheus.Collector

func Profiler

func Profiler(key string, startTime time.Time)

func Register

func Register(masterClient *client.Client, etcdServer *etcdserver.EtcdServer, monitorPort uint16)

func SliceMetric

func SliceMetric() map[string]*Digest

Types

type Digest

type Digest struct {
	Name   string
	Sum    float64
	Digest tdigest.TDigest
	sync.Mutex
}

func NewDigest

func NewDigest(Name string, Sum float64) *Digest

type MonitorService

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

func (*MonitorService) Collect

func (ms *MonitorService) Collect(ch chan<- prometheus.Metric)

Collect returns the current state of all metrics of the collector.

func (*MonitorService) Describe

func (collector *MonitorService) Describe(ch chan<- *prometheus.Desc)

Describe returns all descriptions of the collector.