node

Documentation

Index

• type Collector
  • func New(cfg Collector, nodeInfo collectors.NodeInfo) (Collector, chan producers.MetricsMessage)
  • func (c *Collector) RunPoller()

Types

type Collector

type Collector struct {
	PollPeriod  time.Duration `yaml:"poll_period,omitempty"`
	MetricsChan chan producers.MetricsMessage
	// contains filtered or unexported fields
}

Collector defines the collector type for system-level metrics.

func New

func New(cfg Collector, nodeInfo collectors.NodeInfo) (Collector, chan producers.MetricsMessage)

New returns a new instance of the node metrics collector and a metrics chan.

func (*Collector) RunPoller

func (c *Collector) RunPoller()

RunPoller periodiclly polls the HTTP APIs of a Mesos agent. This function should be run in its own goroutine.