package stats

import "github.com/docker/cli/components/engine/daemon/stats"

Index ¶

• type Collector
• func NewCollector(supervisor supervisor, interval time.Duration) *Collector
• func (s *Collector) Collect(c *container.Container) chan interface{}
• func (s *Collector) Run()
• func (s *Collector) StopCollection(c *container.Container)
• func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{})

Types ¶

type Collector ¶

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

Collector manages and provides container resource stats

func NewCollector ¶

func NewCollector(supervisor supervisor, interval time.Duration) *Collector

NewCollector creates a stats collector that will poll the supervisor with the specified interval

func (*Collector) Collect ¶

func (s *Collector) Collect(c *container.Container) chan interface{}

Collect registers the container with the collector and adds it to the event loop for collection on the specified interval returning a channel for the subscriber to receive on.

func (*Collector) Run ¶

func (s *Collector) Run()

Run starts the collectors and will indefinitely collect stats from the supervisor

func (*Collector) StopCollection ¶

func (s *Collector) StopCollection(c *container.Container)

StopCollection closes the channels for all subscribers and removes the container from metrics collection.

func (*Collector) Unsubscribe ¶

func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{})

Unsubscribe removes a specific subscriber from receiving updates for a container's stats.

Source Files ¶

collector.go collector_unix.go types.go