stats

Documentation

Index

• func FDStats() (usedFD int64, maxFD int64, err error)
• func TimeLoadPerc(ts *signalutils.Timeseries, loadTime time.Duration) (float64, bool)
• func ValuesAvg(ts *signalutils.Timeseries, timeSpan time.Duration) (float64, bool)
• type CPUStats
  • func NewCPUStats(ctx context.Context, timeseriesMaxSpan time.Duration, sampleFreq float64) *CPUStats
  • func (c *CPUStats) CPUCount() (int, error)
• type CPUTimes
• type DiskMetrics
• type DiskStats
  • func NewDiskStats(ctx context.Context, timeseriesSize time.Duration, ...) *DiskStats
  • func (d *DiskStats) TopByteRate(read bool) []*DiskMetrics
  • func (d *DiskStats) TopIOUtil(read bool) []*DiskMetrics
  • func (d *DiskStats) TopOpRate(read bool) []*DiskMetrics
• type FDMetrics
• type IOCounters
• type MemStats
  • func NewMemStats(ctx context.Context, timeseriesMaxSpan time.Duration, sampleFreq float64) *MemStats
• type NICMetrics
• type NetIOCounters
• type NetStats
  • func NewNetStats(ctx context.Context, timeseriesSize time.Duration, ...) *NetStats
  • func (d *NetStats) TopByteRate(recv bool) []*NICMetrics
  • func (d *NetStats) TopErrorsRate(in bool) []*NICMetrics
  • func (d *NetStats) TopPacketRate(recv bool) []*NICMetrics
• type PartitionMetrics
• type ProcessMetrics
• type ProcessStats
  • func NewProcessStats(ctx context.Context, timeseriesMaxSpan time.Duration, ...) *ProcessStats
  • func (p *ProcessStats) TopCPUIOWait() []*ProcessMetrics
  • func (p *ProcessStats) TopCPULoad() []*ProcessMetrics
  • func (p *ProcessStats) TopFD() []*ProcessMetrics
  • func (p *ProcessStats) TopIOByteRate(read bool) []*ProcessMetrics
  • func (p *ProcessStats) TopIOOpRate(read bool) []*ProcessMetrics
  • func (p *ProcessStats) TopMemSwap() []*ProcessMetrics
  • func (p *ProcessStats) TopMemUsed() []*ProcessMetrics
  • func (p *ProcessStats) TopNetByteRate(recv bool) []*ProcessMetrics
  • func (p *ProcessStats) TopNetConnCount() []*ProcessMetrics
  • func (p *ProcessStats) TopNetErrRate(in bool) []*ProcessMetrics
  • func (p *ProcessStats) TopNetPacketRate(recv bool) []*ProcessMetrics

Functions

func FDStats

func FDStats() (usedFD int64, maxFD int64, err error)

func TimeLoadPerc

func TimeLoadPerc(ts *signalutils.Timeseries, loadTime time.Duration) (float64, bool)

func ValuesAvg

func ValuesAvg(ts *signalutils.Timeseries, timeSpan time.Duration) (float64, bool)

Types

type CPUStats

type CPUStats struct {
	Total *CPUTimes
	CPU   []*CPUTimes
}

func NewCPUStats

func NewCPUStats(ctx context.Context, timeseriesMaxSpan time.Duration, sampleFreq float64) *CPUStats

func (*CPUStats) CPUCount

func (c *CPUStats) CPUCount() (int, error)

type CPUTimes

type CPUTimes struct {
	Idle   signalutils.Timeseries
	System signalutils.Timeseries
	User   signalutils.Timeseries
	IOWait signalutils.Timeseries
	Steal  signalutils.Timeseries
}

type DiskMetrics

type DiskMetrics struct {
	Name           string
	SerialNumber   string
	IoTime         signalutils.Timeseries
	ReadBytes      signalutils.TimeseriesCounterRate
	ReadCount      signalutils.TimeseriesCounterRate
	ReadTime       signalutils.Timeseries
	WriteBytes     signalutils.TimeseriesCounterRate
	WriteCount     signalutils.TimeseriesCounterRate
	WriteTime      signalutils.Timeseries
	IopsInProgress signalutils.Timeseries
}

type DiskStats

type DiskStats struct {
	Disks      map[string]*DiskMetrics
	Partitions map[string]*PartitionMetrics
	FD         *FDMetrics
	// contains filtered or unexported fields
}

func NewDiskStats

func NewDiskStats(ctx context.Context, timeseriesSize time.Duration, ioRateLoadDuration time.Duration, sampleFreq float64) *DiskStats

func (*DiskStats) TopByteRate

func (d *DiskStats) TopByteRate(read bool) []*DiskMetrics

func (*DiskStats) TopIOUtil

func (d *DiskStats) TopIOUtil(read bool) []*DiskMetrics

func (*DiskStats) TopOpRate

func (d *DiskStats) TopOpRate(read bool) []*DiskMetrics

type FDMetrics

type FDMetrics struct {
	UsedFD signalutils.Timeseries
	MaxFD  int64
}

type IOCounters

type IOCounters struct {
	ReadCount  signalutils.TimeseriesCounterRate
	WriteCount signalutils.TimeseriesCounterRate
	ReadBytes  signalutils.TimeseriesCounterRate
	WriteBytes signalutils.TimeseriesCounterRate
}

type MemStats

type MemStats struct {
	Total     uint64
	Available signalutils.Timeseries
	Used      signalutils.Timeseries
	Free      signalutils.Timeseries
	SwapIn    signalutils.TimeseriesCounterRate
	SwapOut   signalutils.TimeseriesCounterRate
	SwapTotal uint64
	SwapUsed  signalutils.Timeseries
	SwapFree  signalutils.Timeseries
}

func NewMemStats

func NewMemStats(ctx context.Context, timeseriesMaxSpan time.Duration, sampleFreq float64) *MemStats

type NICMetrics

type NICMetrics struct {
	Name        string
	BytesRecv   signalutils.TimeseriesCounterRate
	BytesSent   signalutils.TimeseriesCounterRate
	PacketsRecv signalutils.TimeseriesCounterRate
	PacketsSent signalutils.TimeseriesCounterRate
	ErrIn       signalutils.TimeseriesCounterRate
	ErrOut      signalutils.TimeseriesCounterRate
}

type NetIOCounters

type NetIOCounters struct {
	InterfaceName string
	BytesSent     signalutils.TimeseriesCounterRate
	BytesRecv     signalutils.TimeseriesCounterRate
	PacketsSent   signalutils.TimeseriesCounterRate
	PacketsRecv   signalutils.TimeseriesCounterRate
	ErrIn         signalutils.TimeseriesCounterRate
	ErrOut        signalutils.TimeseriesCounterRate
}

type NetStats

type NetStats struct {
	NICs map[string]*NICMetrics
	// contains filtered or unexported fields
}

func NewNetStats

func NewNetStats(ctx context.Context, timeseriesSize time.Duration, ioRateLoadDuration time.Duration, sampleFreq float64) *NetStats

func (*NetStats) TopByteRate

func (d *NetStats) TopByteRate(recv bool) []*NICMetrics

func (*NetStats) TopErrorsRate

func (d *NetStats) TopErrorsRate(in bool) []*NICMetrics

func (*NetStats) TopPacketRate

func (d *NetStats) TopPacketRate(recv bool) []*NICMetrics

type PartitionMetrics

type PartitionMetrics struct {
	Path        string
	Fstype      string
	Total       uint64
	Free        signalutils.Timeseries
	InodesTotal uint64
	InodesFree  signalutils.Timeseries
}

type ProcessMetrics

type ProcessMetrics struct {
	Pid                int32
	Name               string
	Cmdline            string
	LastSeen           time.Time
	CPUTimes           *CPUTimes
	Connections        signalutils.Timeseries
	TotalNetIOCounters *NetIOCounters
	NetIOCounters      map[string]*NetIOCounters
	IOCounters         *IOCounters
	MemoryPercent      signalutils.Timeseries
	MemoryTotal        signalutils.Timeseries
	MemorySwap         signalutils.Timeseries
	FD                 signalutils.Timeseries
	OpenFiles          signalutils.Timeseries
}

type ProcessStats

type ProcessStats struct {
	Processes map[int32]*ProcessMetrics
	// contains filtered or unexported fields
}

func NewProcessStats

func NewProcessStats(ctx context.Context, timeseriesMaxSpan time.Duration, ioLoadRateTimeSpan time.Duration, cpuLoadTimeSpan time.Duration, memAvgTimeSpan time.Duration, sampleFreq float64) *ProcessStats

func (*ProcessStats) TopCPUIOWait

func (p *ProcessStats) TopCPUIOWait() []*ProcessMetrics

func (*ProcessStats) TopCPULoad

func (p *ProcessStats) TopCPULoad() []*ProcessMetrics

func (*ProcessStats) TopFD

func (p *ProcessStats) TopFD() []*ProcessMetrics

func (*ProcessStats) TopIOByteRate

func (p *ProcessStats) TopIOByteRate(read bool) []*ProcessMetrics

func (*ProcessStats) TopIOOpRate

func (p *ProcessStats) TopIOOpRate(read bool) []*ProcessMetrics

func (*ProcessStats) TopMemSwap

func (p *ProcessStats) TopMemSwap() []*ProcessMetrics

func (*ProcessStats) TopMemUsed

func (p *ProcessStats) TopMemUsed() []*ProcessMetrics

func (*ProcessStats) TopNetByteRate

func (p *ProcessStats) TopNetByteRate(recv bool) []*ProcessMetrics

func (*ProcessStats) TopNetConnCount

func (p *ProcessStats) TopNetConnCount() []*ProcessMetrics

func (*ProcessStats) TopNetErrRate

func (p *ProcessStats) TopNetErrRate(in bool) []*ProcessMetrics

func (*ProcessStats) TopNetPacketRate

func (p *ProcessStats) TopNetPacketRate(recv bool) []*ProcessMetrics