containers

Documentation

Index

• func ConntrackGetActualDestination(src, dst netaddr.IPPort) (netaddr.IPPort, error)
• func ConntrackInit() error
• func ContainerdInit() error
• func DockerdInit() error
• func JournaldInit() error
• func JournaldSubscribe(cg *cgroup.Cgroup, ch chan<- logparser.LogEntry) error
• func JournaldUnsubscribe(cg *cgroup.Cgroup)
• func TaskstatsInit() error
• func TaskstatsPID(pid uint32) (*taskstats.Stats, error)
• func TaskstatsTGID(pid uint32) (*taskstats.Stats, error)
• type AddrPair
• type Container
  • func NewContainer(cg *cgroup.Cgroup, md *ContainerMetadata) *Container
  • func (c *Container) Close()
  • func (c *Container) Collect(ch chan<- prometheus.Metric)
  • func (c *Container) Dead(now time.Time) bool
  • func (c *Container) Describe(ch chan<- *prometheus.Desc)
• type ContainerID
• type ContainerMetadata
  • func ContainerdInspect(containerID string) (*ContainerMetadata, error)
  • func DockerdInspect(containerID string) (*ContainerMetadata, error)
• type Delays
• type LogParser
  • func (p *LogParser) Stop()
• type Registry
  • func NewRegistry(reg prometheus.Registerer, kernelVersion string) (*Registry, error)
  • func (r *Registry) Close()
• type Volume

Functions

func ConntrackGetActualDestination

func ConntrackGetActualDestination(src, dst netaddr.IPPort) (netaddr.IPPort, error)

func ConntrackInit

func ConntrackInit() error

func ContainerdInit

func ContainerdInit() error

func DockerdInit

func DockerdInit() error

func JournaldInit

func JournaldInit() error

func JournaldSubscribe

func JournaldSubscribe(cg *cgroup.Cgroup, ch chan<- logparser.LogEntry) error

func JournaldUnsubscribe

func JournaldUnsubscribe(cg *cgroup.Cgroup)

func TaskstatsInit

func TaskstatsInit() error

func TaskstatsPID

func TaskstatsPID(pid uint32) (*taskstats.Stats, error)

func TaskstatsTGID

func TaskstatsTGID(pid uint32) (*taskstats.Stats, error)

Types

type AddrPair

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

type Container

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

func NewContainer

func NewContainer(cg *cgroup.Cgroup, md *ContainerMetadata) *Container

func (*Container) Close

func (c *Container) Close()

func (*Container) Collect

func (c *Container) Collect(ch chan<- prometheus.Metric)

func (*Container) Dead

func (c *Container) Dead(now time.Time) bool

func (*Container) Describe

func (c *Container) Describe(ch chan<- *prometheus.Desc)

type ContainerID

type ContainerID string

type ContainerMetadata

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

func ContainerdInspect

func ContainerdInspect(containerID string) (*ContainerMetadata, error)

func DockerdInspect

func DockerdInspect(containerID string) (*ContainerMetadata, error)

type Delays

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

type LogParser

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

func (*LogParser) Stop

func (p *LogParser) Stop()

type Registry

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

func NewRegistry

func NewRegistry(reg prometheus.Registerer, kernelVersion string) (*Registry, error)

func (*Registry) Close

func (r *Registry) Close()

type Volume

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