psutil

Documentation

Index

• Variables
• type BaseNetIoCounters
  • func NewBaseNetIoCounters(factory *collector.ValueRingFactory) BaseNetIoCounters
  • func (counters *BaseNetIoCounters) Add(stat *psnet.IOCountersStat)
  • func (counters *BaseNetIoCounters) AddToHead(stat *psnet.IOCountersStat)
  • func (counters *BaseNetIoCounters) FlushHead()
  • func (counters *BaseNetIoCounters) Metrics(prefix string) collector.MetricReaderMap
• type CpuCollector
  • func (col *CpuCollector) Init() ([]collector.Collector, error)
  • func (col *CpuCollector) Metrics() collector.MetricReaderMap
  • func (col *CpuCollector) Update() (err error)
• type DiskIOCollector
  • func (col *DiskIOCollector) Init() ([]collector.Collector, error)
  • func (col *DiskIOCollector) MetricsChanged() error
  • func (col *DiskIOCollector) Update() error
• type DiskUsageCollector
  • func (col *DiskUsageCollector) Init() ([]collector.Collector, error)
  • func (col *DiskUsageCollector) MetricsChanged() error
  • func (col *DiskUsageCollector) Update() error
• type LoadCollector
  • func (col *LoadCollector) Metrics() collector.MetricReaderMap
  • func (col *LoadCollector) Update() error
• type MemCollector
  • func (col *MemCollector) Metrics() collector.MetricReaderMap
  • func (col *MemCollector) Update() error
• type MultiProcessCollector
  • func (multi *MultiProcessCollector) Depends() []collector.Collector
  • func (multi *MultiProcessCollector) Init() ([]collector.Collector, error)
  • func (multi *MultiProcessCollector) MetricsChanged() error
  • func (multi *MultiProcessCollector) Update() error
  • func (multi *MultiProcessCollector) UpdateProcesses()
• type NetCollector
  • func (col *NetCollector) Init() ([]collector.Collector, error)
  • func (col *NetCollector) MetricsChanged() error
  • func (col *NetCollector) Update() error
• type NetIoCounters
  • func NewNetIoCounters(factory *collector.ValueRingFactory) NetIoCounters
  • func (counters *NetIoCounters) Add(stat *psnet.IOCountersStat)
  • func (counters *NetIoCounters) AddToHead(stat *psnet.IOCountersStat)
  • func (counters *NetIoCounters) FlushHead()
  • func (counters *NetIoCounters) Metrics(prefix string) collector.MetricReaderMap
• type NetProtoCollector
  • func (col *NetProtoCollector) Init() ([]collector.Collector, error)
  • func (col *NetProtoCollector) Metrics() collector.MetricReaderMap
  • func (col *NetProtoCollector) MetricsChanged() error
  • func (col *NetProtoCollector) Update() (err error)
• type PidCollector
  • func (col *PidCollector) Metrics() collector.MetricReaderMap
  • func (col *PidCollector) Update() (err error)
• type ProcessCollector
  • func (col *ProcessCollector) Child(name string, impl processSubCollectorImpl) *processSubCollector
  • func (col *ProcessCollector) Depends() []collector.Collector
  • func (col *ProcessCollector) Init() ([]collector.Collector, error)
  • func (col *ProcessCollector) Metrics() collector.MetricReaderMap
  • func (col *ProcessCollector) Update() error
• type ProcessCollectorDescription
• type RootCollector
  • func NewPsutilRootCollector(factory *collector.ValueRingFactory) *RootCollector
  • func (col *RootCollector) Init() ([]collector.Collector, error)
  • func (col *RootCollector) NewMultiProcessCollector(name string) *MultiProcessCollector
  • func (col *RootCollector) NewProcessCollector(filter []*regexp.Regexp, name string, printErrors bool, ...) *ProcessCollector

Variables

var (
	PcapNics []string
)

var (
	PidUpdateInterval = 60 * time.Second
)

Types

type BaseNetIoCounters

type BaseNetIoCounters struct {
	Bytes     *collector.ValueRing
	Packets   *collector.ValueRing
	RxBytes   *collector.ValueRing
	RxPackets *collector.ValueRing
	TxBytes   *collector.ValueRing
	TxPackets *collector.ValueRing
}

func NewBaseNetIoCounters

func NewBaseNetIoCounters(factory *collector.ValueRingFactory) BaseNetIoCounters

func (*BaseNetIoCounters) Add

func (counters *BaseNetIoCounters) Add(stat *psnet.IOCountersStat)

func (*BaseNetIoCounters) AddToHead

func (counters *BaseNetIoCounters) AddToHead(stat *psnet.IOCountersStat)

func (*BaseNetIoCounters) FlushHead

func (counters *BaseNetIoCounters) FlushHead()

func (*BaseNetIoCounters) Metrics

func (counters *BaseNetIoCounters) Metrics(prefix string) collector.MetricReaderMap

type CpuCollector

type CpuCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*CpuCollector) Init

func (col *CpuCollector) Init() ([]collector.Collector, error)

func (*CpuCollector) Metrics

func (col *CpuCollector) Metrics() collector.MetricReaderMap

func (*CpuCollector) Update

func (col *CpuCollector) Update() (err error)

type DiskIOCollector

type DiskIOCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*DiskIOCollector) Init

func (col *DiskIOCollector) Init() ([]collector.Collector, error)

func (*DiskIOCollector) MetricsChanged

func (col *DiskIOCollector) MetricsChanged() error

func (*DiskIOCollector) Update

func (col *DiskIOCollector) Update() error

type DiskUsageCollector

type DiskUsageCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*DiskUsageCollector) Init

func (col *DiskUsageCollector) Init() ([]collector.Collector, error)

func (*DiskUsageCollector) MetricsChanged

func (col *DiskUsageCollector) MetricsChanged() error

func (*DiskUsageCollector) Update

func (col *DiskUsageCollector) Update() error

type LoadCollector

type LoadCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*LoadCollector) Metrics

func (col *LoadCollector) Metrics() collector.MetricReaderMap

func (*LoadCollector) Update

func (col *LoadCollector) Update() error

type MemCollector

type MemCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*MemCollector) Metrics

func (col *MemCollector) Metrics() collector.MetricReaderMap

func (*MemCollector) Update

func (col *MemCollector) Update() error

type MultiProcessCollector

type MultiProcessCollector struct {
	collector.AbstractCollector

	Processes []ProcessCollectorDescription
	// contains filtered or unexported fields
}

func (*MultiProcessCollector) Depends

func (multi *MultiProcessCollector) Depends() []collector.Collector

func (*MultiProcessCollector) Init

func (multi *MultiProcessCollector) Init() ([]collector.Collector, error)

func (*MultiProcessCollector) MetricsChanged

func (multi *MultiProcessCollector) MetricsChanged() error

func (*MultiProcessCollector) Update

func (multi *MultiProcessCollector) Update() error

func (*MultiProcessCollector) UpdateProcesses

func (multi *MultiProcessCollector) UpdateProcesses()

type NetCollector

type NetCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*NetCollector) Init

func (col *NetCollector) Init() ([]collector.Collector, error)

func (*NetCollector) MetricsChanged

func (col *NetCollector) MetricsChanged() error

func (*NetCollector) Update

func (col *NetCollector) Update() error

type NetIoCounters

type NetIoCounters struct {
	BaseNetIoCounters
	Errors  *collector.ValueRing
	Dropped *collector.ValueRing
}

func NewNetIoCounters

func NewNetIoCounters(factory *collector.ValueRingFactory) NetIoCounters

func (*NetIoCounters) Add

func (counters *NetIoCounters) Add(stat *psnet.IOCountersStat)

func (*NetIoCounters) AddToHead

func (counters *NetIoCounters) AddToHead(stat *psnet.IOCountersStat)

func (*NetIoCounters) FlushHead

func (counters *NetIoCounters) FlushHead()

func (*NetIoCounters) Metrics

func (counters *NetIoCounters) Metrics(prefix string) collector.MetricReaderMap

type NetProtoCollector

type NetProtoCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*NetProtoCollector) Init

func (col *NetProtoCollector) Init() ([]collector.Collector, error)

func (*NetProtoCollector) Metrics

func (col *NetProtoCollector) Metrics() collector.MetricReaderMap

func (*NetProtoCollector) MetricsChanged

func (col *NetProtoCollector) MetricsChanged() error

func (*NetProtoCollector) Update

func (col *NetProtoCollector) Update() (err error)

type PidCollector

type PidCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*PidCollector) Metrics

func (col *PidCollector) Metrics() collector.MetricReaderMap

func (*PidCollector) Update

func (col *PidCollector) Update() (err error)

type ProcessCollector

type ProcessCollector struct {
	collector.AbstractCollector
	// contains filtered or unexported fields
}

func (*ProcessCollector) Child

func (col *ProcessCollector) Child(name string, impl processSubCollectorImpl) *processSubCollector

func (*ProcessCollector) Depends

func (col *ProcessCollector) Depends() []collector.Collector

func (*ProcessCollector) Init

func (col *ProcessCollector) Init() ([]collector.Collector, error)

func (*ProcessCollector) Metrics

func (col *ProcessCollector) Metrics() collector.MetricReaderMap

func (*ProcessCollector) Update

func (col *ProcessCollector) Update() error

type ProcessCollectorDescription

type ProcessCollectorDescription struct {
	Name                  string
	Filter                []*regexp.Regexp
	PrintErrors           bool
	IncludeChildProcesses bool
}

type RootCollector

type RootCollector struct {
	collector.AbstractCollector

	Factory *collector.ValueRingFactory
	// contains filtered or unexported fields
}

func NewPsutilRootCollector

func NewPsutilRootCollector(factory *collector.ValueRingFactory) *RootCollector

func (*RootCollector) Init

func (col *RootCollector) Init() ([]collector.Collector, error)

func (*RootCollector) NewMultiProcessCollector

func (col *RootCollector) NewMultiProcessCollector(name string) *MultiProcessCollector

func (*RootCollector) NewProcessCollector

func (col *RootCollector) NewProcessCollector(filter []*regexp.Regexp, name string, printErrors bool, includeChildProcesses bool) *ProcessCollector