processes

Documentation

Index

• Constants
• func DumpMetrics(w io.Writer) error
• func FindContainerIDByCGroup(pid int32) (string, int)
• type CRIPodFinder
  • func NewCRIPodFinder(runtimeEndPoint string, timeout time.Duration, scanner procscanner.ProcScanner) (*CRIPodFinder, error)
  • func (cpf *CRIPodFinder) FindPodByPID(pid int32) (string, error)
  • func (cpf *CRIPodFinder) FindPods() (map[string]*PodInfo, error)
• type Collector
  • func NewCollectorFromConf(conf *Config) (*Collector, error)
  • func NewSelfCollector() (*Collector, error)
  • func (co Collector) Collect(ch chan<- prometheus.Metric)
  • func (co Collector) Describe(ch chan<- *prometheus.Desc)
• type Config
  • func NewConfig() *Config
  • func NewConfigFromFile(confFile string) (*Config, error)
  • func (c *Config) Validate() error
• type DomainMonitor
  • func (dm *DomainMonitor) Update() (PodInfoMap, error)
• type Monitor
  • func NewDomainMonitor(podFinder PodFinder) (Monitor, error)
  • func NewSelfMonitor() (Monitor, error)
• type PodFinder
• type PodInfo
• type PodInfoMap
• type PodMap
  • func (pods PodMap) MapProcsToPods(pf PodFinder, procs map[string][]int32) (PodMap, error)
• type SelfMonitor
  • func (sm *SelfMonitor) Update() (PodInfoMap, error)

Constants

const (
	MissingCGroup = iota
	MalformedCGroup
	UnknownCGroup
	DockerCGroup
)

Classifiers for CGroup found

const (
	DefaultTimeout = 10 * time.Second
	DefaultProcDir = "/proc"
)

const FreshnessThreshold = 1 * time.Second

Functions

func DumpMetrics

func DumpMetrics(w io.Writer) error

DumpMetrics dump the current metrics in the text format in the given writer.

func FindContainerIDByCGroup

func FindContainerIDByCGroup(pid int32) (string, int)

FindContainerIDByCGroup fetches cgroup information for the given PID Returns the cgroup name and the CGroup classifier Should the pid belong to more than one cgroup: returns the first one, in kernel order.

Types

type CRIPodFinder

type CRIPodFinder struct {
	ProcDir string
	// contains filtered or unexported fields
}

func NewCRIPodFinder

func NewCRIPodFinder(runtimeEndPoint string, timeout time.Duration, scanner procscanner.ProcScanner) (*CRIPodFinder, error)

func (*CRIPodFinder) FindPodByPID

func (cpf *CRIPodFinder) FindPodByPID(pid int32) (string, error)

func (*CRIPodFinder) FindPods

func (cpf *CRIPodFinder) FindPods() (map[string]*PodInfo, error)

type Collector

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

func NewCollectorFromConf

func NewCollectorFromConf(conf *Config) (*Collector, error)

func NewSelfCollector

func NewSelfCollector() (*Collector, error)

func (Collector) Collect

func (co Collector) Collect(ch chan<- prometheus.Metric)

Note that Collect could be called concurrently

func (Collector) Describe

func (co Collector) Describe(ch chan<- *prometheus.Desc)

type Config

type Config struct {
	Targets       []procscanner.ProcTarget `json:"targets"`
	ListenAddress string                   `json:"listenaddress"`
	CRIEndPoint   string                   `json:"criendpoint"`
	Hostname      string                   `json:"hostname"`
	DebugMode     bool                     `json:"debugmode"`
}

Config encodes the configuration of the monitoring package

func NewConfig

func NewConfig() *Config

NewConfig creates a new Config object with the current defaults

func NewConfigFromFile

func NewConfigFromFile(confFile string) (*Config, error)

NewConfigFromFile creates a new Config object with the settings taken from the given file. Should the file not specify a setting, the value is the default one (see NewCOnfig)

func (*Config) Validate

func (c *Config) Validate() error

Validate returns nil if the current configuration is consistent and legal, an error otherwise

type DomainMonitor

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

func (*DomainMonitor) Update

func (dm *DomainMonitor) Update() (PodInfoMap, error)

type Monitor

type Monitor interface {
	Update() (PodInfoMap, error)
}

func NewDomainMonitor

func NewDomainMonitor(podFinder PodFinder) (Monitor, error)

func NewSelfMonitor

func NewSelfMonitor() (Monitor, error)

type PodFinder

type PodFinder interface {
	FindPods() (map[string]*PodInfo, error)
	FindPodByPID(pid int32) (string, error)
}

type PodInfo

type PodInfo struct {
	Procs []*process.Process
}

type PodInfoMap

type PodInfoMap map[string]*PodInfo

type PodMap

type PodMap map[string]*PodInfo

func (PodMap) MapProcsToPods

func (pods PodMap) MapProcsToPods(pf PodFinder, procs map[string][]int32) (PodMap, error)

type SelfMonitor

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

func (*SelfMonitor) Update

func (sm *SelfMonitor) Update() (PodInfoMap, error)