collector

Documentation

Overview

Package collector includes all individual collectors to gather and export system metrics.

Index

• Variables
• func BusinessMonitorHttpHandle(w http.ResponseWriter, r *http.Request)
• func DisableDefaultCollectors()
• func InitNewLogger(logger log.Logger)
• func IsNoDataError(err error) bool
• func LogMonitorHttpHandle(w http.ResponseWriter, r *http.Request)
• func LogMonitorRowsHttpHandle(w http.ResponseWriter, r *http.Request)
• func ProcessMonitorHttpHandle(w http.ResponseWriter, r *http.Request)
• func StartBusinessAggCron()
• type Collector
  • func BusinessMonitorCollector(logger log.Logger) (Collector, error)
  • func NewARPCollector(logger log.Logger) (Collector, error)
  • func NewBcacheCollector(logger log.Logger) (Collector, error)
  • func NewBondingCollector(logger log.Logger) (Collector, error)
  • func NewBtrfsCollector(logger log.Logger) (Collector, error)
  • func NewBuddyinfoCollector(logger log.Logger) (Collector, error)
  • func NewCPUCollector(logger log.Logger) (Collector, error)
  • func NewCPUFreqCollector(logger log.Logger) (Collector, error)
  • func NewConntrackCollector(logger log.Logger) (Collector, error)
  • func NewDiskstatsCollector(logger log.Logger) (Collector, error)
  • func NewEdacCollector(logger log.Logger) (Collector, error)
  • func NewEntropyCollector(logger log.Logger) (Collector, error)
  • func NewFileFDStatCollector(logger log.Logger) (Collector, error)
  • func NewFilesystemCollector(logger log.Logger) (Collector, error)
  • func NewHwMonCollector(logger log.Logger) (Collector, error)
  • func NewIPVSCollector(logger log.Logger) (Collector, error)
  • func NewInfiniBandCollector(logger log.Logger) (Collector, error)
  • func NewInterruptsCollector(logger log.Logger) (Collector, error)
  • func NewKsmdCollector(logger log.Logger) (Collector, error)
  • func NewLoadavgCollector(logger log.Logger) (Collector, error)
  • func NewLogMonitorCollector(logger log.Logger) (Collector, error)
  • func NewLogindCollector(logger log.Logger) (Collector, error)
  • func NewMdadmCollector(logger log.Logger) (Collector, error)
  • func NewMeminfoCollector(logger log.Logger) (Collector, error)
  • func NewMeminfoNumaCollector(logger log.Logger) (Collector, error)
  • func NewMountStatsCollector(logger log.Logger) (Collector, error)
  • func NewNFSdCollector(logger log.Logger) (Collector, error)
  • func NewNetClassCollector(logger log.Logger) (Collector, error)
  • func NewNetDevCollector(logger log.Logger) (Collector, error)
  • func NewNetStatCollector(logger log.Logger) (Collector, error)
  • func NewNfsCollector(logger log.Logger) (Collector, error)
  • func NewNtpCollector(logger log.Logger) (Collector, error)
  • func NewPerfCollector(logger log.Logger) (Collector, error)
  • func NewPowerSupplyClassCollector(logger log.Logger) (Collector, error)
  • func NewPressureStatsCollector(logger log.Logger) (Collector, error)
  • func NewProcessMonitorCollector(logger log.Logger) (Collector, error)
  • func NewProcessStatCollector(logger log.Logger) (Collector, error)
  • func NewQdiscStatCollector(logger log.Logger) (Collector, error)
  • func NewRaplCollector(logger log.Logger) (Collector, error)
  • func NewRunitCollector(logger log.Logger) (Collector, error)
  • func NewSchedstatCollector(logger log.Logger) (Collector, error)
  • func NewSockStatCollector(logger log.Logger) (Collector, error)
  • func NewSoftnetCollector(logger log.Logger) (Collector, error)
  • func NewStatCollector(logger log.Logger) (Collector, error)
  • func NewSupervisordCollector(logger log.Logger) (Collector, error)
  • func NewSystemdCollector(logger log.Logger) (Collector, error)
  • func NewTCPStatCollector(logger log.Logger) (Collector, error)
  • func NewTextFileCollector(logger log.Logger) (Collector, error)
  • func NewThermalZoneCollector(logger log.Logger) (Collector, error)
  • func NewTimeCollector(logger log.Logger) (Collector, error)
  • func NewTimexCollector(logger log.Logger) (Collector, error)
  • func NewUDPqueuesCollector(logger log.Logger) (Collector, error)
  • func NewWifiCollector(logger log.Logger) (Collector, error)
  • func NewXFSCollector(logger log.Logger) (Collector, error)
  • func NewZFSCollector(logger log.Logger) (Collector, error)
  • func NewvmStatCollector(logger log.Logger) (Collector, error)
• type NodeCollector
  • func NewNodeCollector(logger log.Logger, filters ...string) (*NodeCollector, error)
  • func (n NodeCollector) Collect(ch chan<- prometheus.Metric)
  • func (n NodeCollector) Describe(ch chan<- *prometheus.Desc)

Variables

var BusinessCollectorStore businessCollectorStore

var ErrNoData = errors.New("collector returned no data")

ErrNoData indicates the collector found no data to collect, but had no other error.

var LogCollectorStore logCollectorStore

var ProcessCacheObj processCache

Functions

func BusinessMonitorHttpHandle

func BusinessMonitorHttpHandle(w http.ResponseWriter, r *http.Request)

func DisableDefaultCollectors

func DisableDefaultCollectors()

DisableDefaultCollectors sets the collector state to false for all collectors which have not been explicitly enabled on the command line.

func InitNewLogger

func InitNewLogger(logger log.Logger)

func IsNoDataError

func IsNoDataError(err error) bool

func LogMonitorHttpHandle

func LogMonitorHttpHandle(w http.ResponseWriter, r *http.Request)

func LogMonitorRowsHttpHandle

func LogMonitorRowsHttpHandle(w http.ResponseWriter, r *http.Request)

func ProcessMonitorHttpHandle

func ProcessMonitorHttpHandle(w http.ResponseWriter, r *http.Request)

func StartBusinessAggCron

func StartBusinessAggCron()

Types

type Collector

type Collector interface {
	// Get new metrics and expose them via prometheus registry.
	Update(ch chan<- prometheus.Metric) error
}

Collector is the interface a collector has to implement.

func BusinessMonitorCollector

func BusinessMonitorCollector(logger log.Logger) (Collector, error)

func NewARPCollector

func NewARPCollector(logger log.Logger) (Collector, error)

NewARPCollector returns a new Collector exposing ARP stats.

func NewBcacheCollector

func NewBcacheCollector(logger log.Logger) (Collector, error)

NewBcacheCollector returns a newly allocated bcacheCollector. It exposes a number of Linux bcache statistics.

func NewBondingCollector

func NewBondingCollector(logger log.Logger) (Collector, error)

NewBondingCollector returns a newly allocated bondingCollector. It exposes the number of configured and active slave of linux bonding interfaces.

func NewBtrfsCollector

func NewBtrfsCollector(logger log.Logger) (Collector, error)

NewBtrfsCollector returns a new Collector exposing Btrfs statistics.

func NewBuddyinfoCollector

func NewBuddyinfoCollector(logger log.Logger) (Collector, error)

NewBuddyinfoCollector returns a new Collector exposing buddyinfo stats.

func NewCPUCollector

func NewCPUCollector(logger log.Logger) (Collector, error)

NewCPUCollector returns a new Collector exposing kernel/system statistics.

func NewCPUFreqCollector

func NewCPUFreqCollector(logger log.Logger) (Collector, error)

NewCPUFreqCollector returns a new Collector exposing kernel/system statistics.

func NewConntrackCollector

func NewConntrackCollector(logger log.Logger) (Collector, error)

NewConntrackCollector returns a new Collector exposing conntrack stats.

func NewDiskstatsCollector

func NewDiskstatsCollector(logger log.Logger) (Collector, error)

NewDiskstatsCollector returns a new Collector exposing disk device stats. Docs from https://www.kernel.org/doc/Documentation/iostats.txt

func NewEdacCollector

func NewEdacCollector(logger log.Logger) (Collector, error)

NewEdacCollector returns a new Collector exposing edac stats.

func NewEntropyCollector

func NewEntropyCollector(logger log.Logger) (Collector, error)

NewEntropyCollector returns a new Collector exposing entropy stats.

func NewFileFDStatCollector

func NewFileFDStatCollector(logger log.Logger) (Collector, error)

NewFileFDStatCollector returns a new Collector exposing file-nr stats.

func NewFilesystemCollector

func NewFilesystemCollector(logger log.Logger) (Collector, error)

NewFilesystemCollector returns a new Collector exposing filesystems stats.

func NewHwMonCollector

func NewHwMonCollector(logger log.Logger) (Collector, error)

NewHwMonCollector returns a new Collector exposing /sys/class/hwmon stats (similar to lm-sensors).

func NewIPVSCollector

func NewIPVSCollector(logger log.Logger) (Collector, error)

NewIPVSCollector sets up a new collector for IPVS metrics. It accepts the "procfs" config parameter to override the default proc location (/proc).

func NewInfiniBandCollector

func NewInfiniBandCollector(logger log.Logger) (Collector, error)

NewInfiniBandCollector returns a new Collector exposing InfiniBand stats.

func NewInterruptsCollector

func NewInterruptsCollector(logger log.Logger) (Collector, error)

NewInterruptsCollector returns a new Collector exposing interrupts stats.

func NewKsmdCollector

func NewKsmdCollector(logger log.Logger) (Collector, error)

NewKsmdCollector returns a new Collector exposing kernel/system statistics.

func NewLoadavgCollector

func NewLoadavgCollector(logger log.Logger) (Collector, error)

NewLoadavgCollector returns a new Collector exposing load average stats.

func NewLogMonitorCollector

func NewLogMonitorCollector(logger log.Logger) (Collector, error)

func NewLogindCollector

func NewLogindCollector(logger log.Logger) (Collector, error)

NewLogindCollector returns a new Collector exposing logind statistics.

func NewMdadmCollector

func NewMdadmCollector(logger log.Logger) (Collector, error)

NewMdadmCollector returns a new Collector exposing raid statistics.

func NewMeminfoCollector

func NewMeminfoCollector(logger log.Logger) (Collector, error)

NewMeminfoCollector returns a new Collector exposing memory stats.

func NewMeminfoNumaCollector

func NewMeminfoNumaCollector(logger log.Logger) (Collector, error)

NewMeminfoNumaCollector returns a new Collector exposing memory stats.

func NewMountStatsCollector

func NewMountStatsCollector(logger log.Logger) (Collector, error)

NewMountStatsCollector returns a new Collector exposing NFS statistics.

func NewNFSdCollector

func NewNFSdCollector(logger log.Logger) (Collector, error)

NewNFSdCollector returns a new Collector exposing /proc/net/rpc/nfsd statistics.

func NewNetClassCollector

func NewNetClassCollector(logger log.Logger) (Collector, error)

NewNetClassCollector returns a new Collector exposing network class stats.

func NewNetDevCollector

func NewNetDevCollector(logger log.Logger) (Collector, error)

NewNetDevCollector returns a new Collector exposing network device stats.

func NewNetStatCollector

func NewNetStatCollector(logger log.Logger) (Collector, error)

NewNetStatCollector takes and returns a new Collector exposing network stats.

func NewNfsCollector

func NewNfsCollector(logger log.Logger) (Collector, error)

NewNfsCollector returns a new Collector exposing NFS statistics.

func NewNtpCollector

func NewNtpCollector(logger log.Logger) (Collector, error)

NewNtpCollector returns a new Collector exposing sanity of local NTP server. Default definition of "local" is: - collector.ntp.server address is a loopback address (or collector.ntp.server-is-mine flag is turned on) - the server is reachable with outgoin IP_TTL = 1

func NewPerfCollector

func NewPerfCollector(logger log.Logger) (Collector, error)

NewPerfCollector returns a new perf based collector, it creates a profiler per CPU.

func NewPowerSupplyClassCollector

func NewPowerSupplyClassCollector(logger log.Logger) (Collector, error)

func NewPressureStatsCollector

func NewPressureStatsCollector(logger log.Logger) (Collector, error)

NewPressureStatsCollector returns a Collector exposing pressure stall information

func NewProcessMonitorCollector

func NewProcessMonitorCollector(logger log.Logger) (Collector, error)

func NewProcessStatCollector

func NewProcessStatCollector(logger log.Logger) (Collector, error)

NewProcessStatCollector returns a new Collector exposing process data read from the proc filesystem.

func NewQdiscStatCollector

func NewQdiscStatCollector(logger log.Logger) (Collector, error)

NewQdiscStatCollector returns a new Collector exposing queuing discipline statistics.

func NewRaplCollector

func NewRaplCollector(logger log.Logger) (Collector, error)

NewRaplCollector returns a new Collector exposing RAPL metrics.

func NewRunitCollector

func NewRunitCollector(logger log.Logger) (Collector, error)

NewRunitCollector returns a new Collector exposing runit statistics.

func NewSchedstatCollector

func NewSchedstatCollector(logger log.Logger) (Collector, error)

NewSchedstatCollector returns a new Collector exposing task scheduler statistics

func NewSockStatCollector

func NewSockStatCollector(logger log.Logger) (Collector, error)

NewSockStatCollector returns a new Collector exposing socket stats.

func NewSoftnetCollector

func NewSoftnetCollector(logger log.Logger) (Collector, error)

NewSoftnetCollector returns a new Collector exposing softnet metrics.

func NewStatCollector

func NewStatCollector(logger log.Logger) (Collector, error)

NewStatCollector returns a new Collector exposing kernel/system statistics.

func NewSupervisordCollector

func NewSupervisordCollector(logger log.Logger) (Collector, error)

NewSupervisordCollector returns a new Collector exposing supervisord statistics.

func NewSystemdCollector

func NewSystemdCollector(logger log.Logger) (Collector, error)

NewSystemdCollector returns a new Collector exposing systemd statistics.

func NewTCPStatCollector

func NewTCPStatCollector(logger log.Logger) (Collector, error)

NewTCPStatCollector returns a new Collector exposing network stats.

func NewTextFileCollector

func NewTextFileCollector(logger log.Logger) (Collector, error)

NewTextFileCollector returns a new Collector exposing metrics read from files in the given textfile directory.

func NewThermalZoneCollector

func NewThermalZoneCollector(logger log.Logger) (Collector, error)

NewThermalZoneCollector returns a new Collector exposing kernel/system statistics.

func NewTimeCollector

func NewTimeCollector(logger log.Logger) (Collector, error)

NewTimeCollector returns a new Collector exposing the current system time in seconds since epoch.

func NewTimexCollector

func NewTimexCollector(logger log.Logger) (Collector, error)

NewTimexCollector returns a new Collector exposing adjtime(3) stats.

func NewUDPqueuesCollector

func NewUDPqueuesCollector(logger log.Logger) (Collector, error)

NewUDPqueuesCollector returns a new Collector exposing network udp queued bytes.

func NewWifiCollector

func NewWifiCollector(logger log.Logger) (Collector, error)

NewWifiCollector returns a new Collector exposing Wifi statistics.

func NewXFSCollector

func NewXFSCollector(logger log.Logger) (Collector, error)

NewXFSCollector returns a new Collector exposing XFS statistics.

func NewZFSCollector

func NewZFSCollector(logger log.Logger) (Collector, error)

NewZFSCollector returns a new Collector exposing ZFS statistics.

func NewvmStatCollector

func NewvmStatCollector(logger log.Logger) (Collector, error)

NewvmStatCollector returns a new Collector exposing vmstat stats.

type NodeCollector

type NodeCollector struct {
	Collectors map[string]Collector
	// contains filtered or unexported fields
}

NodeCollector implements the prometheus.Collector interface.

func NewNodeCollector

func NewNodeCollector(logger log.Logger, filters ...string) (*NodeCollector, error)

NewNodeCollector creates a new NodeCollector.

func (NodeCollector) Collect

func (n NodeCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (NodeCollector) Describe

func (n NodeCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface.