collector

Documentation

Index

• type Collector
• type Docker
  • func NewDocker(client *api.Client, id string) *Docker
  • func (c *Docker) Logs() LogCollector
  • func (c *Docker) ReadCPU(stats *api.Stats)
  • func (c *Docker) ReadIO(stats *api.Stats)
  • func (c *Docker) ReadMem(stats *api.Stats)
  • func (c *Docker) ReadNet(stats *api.Stats)
  • func (c *Docker) Running() bool
  • func (c *Docker) Start()
  • func (c *Docker) Stop()
  • func (c *Docker) Stream() chan models.Metrics
• type DockerLogs
  • func (l *DockerLogs) Stop()
  • func (l *DockerLogs) Stream() chan models.Log
• type LogCollector
• type Mock
  • func NewMock(a int64) *Mock
  • func (c *Mock) Logs() LogCollector
  • func (c *Mock) Running() bool
  • func (c *Mock) Start()
  • func (c *Mock) Stop()
  • func (c *Mock) Stream() chan models.Metrics
• type MockLogs
  • func (l *MockLogs) Stop()
  • func (l *MockLogs) Stream() chan models.Log
• type Runc
  • func NewRunc(libc libcontainer.Container) *Runc
  • func (c *Runc) Logs() LogCollector
  • func (c *Runc) ReadCPU(stats *cgroups.Stats)
  • func (c *Runc) ReadIO(stats *cgroups.Stats)
  • func (c *Runc) ReadMem(stats *cgroups.Stats)
  • func (c *Runc) ReadNet(interfaces []*libcontainer.NetworkInterface)
  • func (c *Runc) Running() bool
  • func (c *Runc) Start()
  • func (c *Runc) Stop()
  • func (c *Runc) Stream() chan models.Metrics

Types

type Collector

type Collector interface {
	Stream() chan models.Metrics
	Logs() LogCollector
	Running() bool
	Start()
	Stop()
}

type Docker

type Docker struct {
	models.Metrics
	// contains filtered or unexported fields
}

Docker collector

func NewDocker

func NewDocker(client *api.Client, id string) *Docker

func (*Docker) Logs

func (c *Docker) Logs() LogCollector

func (*Docker) ReadCPU

func (c *Docker) ReadCPU(stats *api.Stats)

func (*Docker) ReadIO

func (c *Docker) ReadIO(stats *api.Stats)

func (*Docker) ReadMem

func (c *Docker) ReadMem(stats *api.Stats)

func (*Docker) ReadNet

func (c *Docker) ReadNet(stats *api.Stats)

func (*Docker) Running

func (c *Docker) Running() bool

func (*Docker) Start

func (c *Docker) Start()

func (*Docker) Stop

func (c *Docker) Stop()

Stop collector

func (*Docker) Stream

func (c *Docker) Stream() chan models.Metrics

type DockerLogs

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

func (*DockerLogs) Stop

func (l *DockerLogs) Stop()

func (*DockerLogs) Stream

func (l *DockerLogs) Stream() chan models.Log

type LogCollector

type LogCollector interface {
	Stream() chan models.Log
	Stop()
}

type Mock

type Mock struct {
	models.Metrics
	// contains filtered or unexported fields
}

Mock collector

func NewMock

func NewMock(a int64) *Mock

func (*Mock) Logs

func (c *Mock) Logs() LogCollector

func (*Mock) Running

func (c *Mock) Running() bool

func (*Mock) Start

func (c *Mock) Start()

func (*Mock) Stop

func (c *Mock) Stop()

func (*Mock) Stream

func (c *Mock) Stream() chan models.Metrics

type MockLogs

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

func (*MockLogs) Stop

func (l *MockLogs) Stop()

func (*MockLogs) Stream

func (l *MockLogs) Stream() chan models.Log

type Runc

type Runc struct {
	models.Metrics
	// contains filtered or unexported fields
}

Runc collector

func NewRunc

func NewRunc(libc libcontainer.Container) *Runc

func (*Runc) Logs

func (c *Runc) Logs() LogCollector

func (*Runc) ReadCPU

func (c *Runc) ReadCPU(stats *cgroups.Stats)

func (*Runc) ReadIO

func (c *Runc) ReadIO(stats *cgroups.Stats)

func (*Runc) ReadMem

func (c *Runc) ReadMem(stats *cgroups.Stats)

func (*Runc) ReadNet

func (c *Runc) ReadNet(interfaces []*libcontainer.NetworkInterface)

func (*Runc) Running

func (c *Runc) Running() bool

func (*Runc) Start

func (c *Runc) Start()

func (*Runc) Stop

func (c *Runc) Stop()

func (*Runc) Stream

func (c *Runc) Stream() chan models.Metrics