Documentation
¶
Index ¶
- Constants
- Variables
- func CpuList() []int
- func RemoveFromStringList(s []string, r string) ([]string, error)
- func SocketList() []int
- type BeegfsMetaCollector
- type BeegfsMetaCollectorConfig
- type BeegfsStorageCollector
- type BeegfsStorageCollectorConfig
- type CPUFreqCollector
- type CPUFreqCollectorTopology
- type CPUFreqCpuInfoCollector
- type CPUFreqCpuInfoCollectorTopology
- type CollectorManager
- type CpustatCollector
- type CpustatCollectorConfig
- type CustomCmdCollector
- type CustomCmdCollectorConfig
- type DiskstatCollector
- type DiskstatCollectorConfig
- type GpfsCollector
- type GpfsCollectorLastState
- type IOstatCollector
- type IOstatCollectorConfig
- type IOstatCollectorEntry
- type InfinibandCollector
- type InfinibandCollectorInfo
- type InfinibandCollectorMetric
- type IpmiCollector
- type IpmiCollectorConfig
- type LikwidCollector
- func (m *LikwidCollector) Close()
- func (m *LikwidCollector) Init(config json.RawMessage) error
- func (c *LikwidCollector) Initialized() bool
- func (m *LikwidCollector) LateInit() error
- func (c *LikwidCollector) Name() string
- func (m *LikwidCollector) Read(interval time.Duration, output chan lp.CCMetric)
- type LikwidCollectorConfig
- type LikwidCollectorEventsetConfig
- type LikwidCollectorMetricConfig
- type LikwidEventsetConfig
- type LikwidMetric
- type LoadavgCollector
- type LustreCollector
- type LustreCollectorConfig
- type LustreMetricDefinition
- type MemstatCollector
- type MemstatCollectorConfig
- type MemstatCollectorNode
- type MemstatStats
- type MetricCollector
- type NUMAStatsCollector
- type NUMAStatsCollectorTopolgy
- type NetstatCollector
- type NetstatCollectorConfig
- type NetstatCollectorMetric
- type Nfs3Collector
- type Nfs4Collector
- type NfsCollectorData
- type NvidiaCollector
- type NvidiaCollectorConfig
- type NvidiaCollectorDevice
- type SampleCollector
- type SampleCollectorConfig
- type SampleTimerCollector
- func (m *SampleTimerCollector) Close()
- func (m *SampleTimerCollector) Init(name string, config json.RawMessage) error
- func (c *SampleTimerCollector) Initialized() bool
- func (c *SampleTimerCollector) Name() string
- func (m *SampleTimerCollector) Read(interval time.Duration, output chan lp.CCMetric)
- func (m *SampleTimerCollector) ReadMetrics(timestamp time.Time)
- type SampleTimerCollectorConfig
- type TempCollector
- type TempCollectorSensor
- type TopProcsCollector
- type TopProcsCollectorConfig
Constants ¶
const ( LIKWID_LIB_NAME = "liblikwid.so" LIKWID_LIB_DL_FLAGS = dl.RTLD_LAZY | dl.RTLD_GLOBAL LIKWID_DEF_ACCESSMODE = "direct" )
const CPUSTATFILE = `/proc/stat`
const CUSTOMCMDPATH = `/home/unrz139/Work/cc-metric-collector/collectors/custom`
const DEFAULT_BEEGFS_CMD = "beegfs-ctl"
const DEFAULT_GPFS_CMD = "mmpmon"
const DEFAULT_NUM_PROCS = 2
const IB_BASEPATH = "/sys/class/infiniband/"
const IOSTATFILE = `/proc/diskstats`
const IOSTAT_SYSFSPATH = `/sys/block`
const IPMISENSORS_PATH = `ipmi-sensors`
const IPMITOOL_PATH = `ipmitool`
const LCTL_CMD = `lctl`
const LCTL_OPTION = `get_param`
const LOADAVGFILE = "/proc/loadavg"
LoadavgCollector collects: * load average of last 1, 5 & 15 minutes * number of processes currently runnable * total number of processes in system
See: https://www.kernel.org/doc/html/latest/filesystems/proc.html
const LUSTRE_SYSFS = `/sys/fs/lustre`
const MAX_NUM_PROCS = 10
const MEMSTATFILE = "/proc/meminfo"
const MOUNTFILE = `/proc/self/mounts`
const NETSTATFILE = "/proc/net/dev"
const NFSSTAT_EXEC = `nfsstat`
const NUMA_MEMSTAT_BASE = "/sys/devices/system/node"
Variables ¶
var AvailableCollectors = map[string]MetricCollector{ "likwid": new(LikwidCollector), "loadavg": new(LoadavgCollector), "memstat": new(MemstatCollector), "netstat": new(NetstatCollector), "ibstat": new(InfinibandCollector), "lustrestat": new(LustreCollector), "cpustat": new(CpustatCollector), "topprocs": new(TopProcsCollector), "nvidia": new(NvidiaCollector), "customcmd": new(CustomCmdCollector), "iostat": new(IOstatCollector), "diskstat": new(DiskstatCollector), "tempstat": new(TempCollector), "ipmistat": new(IpmiCollector), "gpfs": new(GpfsCollector), "cpufreq": new(CPUFreqCollector), "cpufreq_cpuinfo": new(CPUFreqCpuInfoCollector), "nfs3stat": new(Nfs3Collector), "nfs4stat": new(Nfs4Collector), "numastats": new(NUMAStatsCollector), "beegfs_meta": new(BeegfsMetaCollector), "beegfs_storage": new(BeegfsStorageCollector), }
Map of all available metric collectors
var DefaultTime = func() time.Time { return time.Unix(42, 0) }
var LustreAbsMetrics = []LustreMetricDefinition{ { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, }
var LustreDeriveMetrics = []LustreMetricDefinition{ { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, }
var LustreDiffMetrics = []LustreMetricDefinition{ { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, { // contains filtered or unexported fields }, }
Functions ¶
func CpuList ¶
func CpuList() []int
CpuList returns the list of physical CPUs (in contrast to logical CPUs) as read from /proc/cpuinfo
func RemoveFromStringList ¶
RemoveFromStringList removes the string r from the array of strings s If r is not contained in the array an error is returned
func SocketList ¶
func SocketList() []int
SocketList returns the list of physical sockets as read from /proc/cpuinfo
Types ¶
type BeegfsMetaCollector ¶
type BeegfsMetaCollector struct {
// contains filtered or unexported fields
}
func (*BeegfsMetaCollector) Close ¶
func (m *BeegfsMetaCollector) Close()
func (*BeegfsMetaCollector) Init ¶
func (m *BeegfsMetaCollector) Init(config json.RawMessage) error
func (*BeegfsMetaCollector) Initialized ¶
func (c *BeegfsMetaCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type BeegfsMetaCollectorConfig ¶
type BeegfsMetaCollectorConfig struct { Beegfs string `json:"beegfs_path"` ExcludeMetrics []string `json:"exclude_metrics,omitempty"` ExcludeFilesystem []string `json:"exclude_filesystem"` }
Struct for the collector-specific JSON config
type BeegfsStorageCollector ¶
type BeegfsStorageCollector struct {
// contains filtered or unexported fields
}
func (*BeegfsStorageCollector) Close ¶
func (m *BeegfsStorageCollector) Close()
func (*BeegfsStorageCollector) Init ¶
func (m *BeegfsStorageCollector) Init(config json.RawMessage) error
func (*BeegfsStorageCollector) Initialized ¶
func (c *BeegfsStorageCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type BeegfsStorageCollectorConfig ¶
type BeegfsStorageCollectorConfig struct { Beegfs string `json:"beegfs_path"` ExcludeMetrics []string `json:"exclude_metrics,omitempty"` ExcludeFilesystem []string `json:"exclude_filesystem"` }
Struct for the collector-specific JSON config
type CPUFreqCollector ¶
type CPUFreqCollector struct {
// contains filtered or unexported fields
}
CPUFreqCollector a metric collector to measure the current frequency of the CPUs as obtained from the hardware (in KHz) Only measure on the first hyper thread
See: https://www.kernel.org/doc/html/latest/admin-guide/pm/cpufreq.html
func (*CPUFreqCollector) Close ¶
func (m *CPUFreqCollector) Close()
func (*CPUFreqCollector) Init ¶
func (m *CPUFreqCollector) Init(config json.RawMessage) error
func (*CPUFreqCollector) Initialized ¶
func (c *CPUFreqCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type CPUFreqCollectorTopology ¶
type CPUFreqCollectorTopology struct {
// contains filtered or unexported fields
}
type CPUFreqCpuInfoCollector ¶
type CPUFreqCpuInfoCollector struct {
// contains filtered or unexported fields
}
func (*CPUFreqCpuInfoCollector) Close ¶
func (m *CPUFreqCpuInfoCollector) Close()
func (*CPUFreqCpuInfoCollector) Init ¶
func (m *CPUFreqCpuInfoCollector) Init(config json.RawMessage) error
func (*CPUFreqCpuInfoCollector) Initialized ¶
func (c *CPUFreqCpuInfoCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type CPUFreqCpuInfoCollectorTopology ¶
type CPUFreqCpuInfoCollectorTopology struct {
// contains filtered or unexported fields
}
CPUFreqCollector a metric collector to measure the current frequency of the CPUs as obtained from /proc/cpuinfo Only measure on the first hyperthread
type CollectorManager ¶
type CollectorManager interface { Init(ticker mct.MultiChanTicker, duration time.Duration, wg *sync.WaitGroup, collectConfigFile string) error AddOutput(output chan lp.CCMetric) Start() Close() }
Metric collector manager access functions
type CpustatCollector ¶
type CpustatCollector struct {
// contains filtered or unexported fields
}
func (*CpustatCollector) Close ¶
func (m *CpustatCollector) Close()
func (*CpustatCollector) Init ¶
func (m *CpustatCollector) Init(config json.RawMessage) error
func (*CpustatCollector) Initialized ¶
func (c *CpustatCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type CpustatCollectorConfig ¶
type CpustatCollectorConfig struct {
ExcludeMetrics []string `json:"exclude_metrics,omitempty"`
}
type CustomCmdCollector ¶
type CustomCmdCollector struct {
// contains filtered or unexported fields
}
func (*CustomCmdCollector) Close ¶
func (m *CustomCmdCollector) Close()
func (*CustomCmdCollector) Init ¶
func (m *CustomCmdCollector) Init(config json.RawMessage) error
func (*CustomCmdCollector) Initialized ¶
func (c *CustomCmdCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type DiskstatCollector ¶
type DiskstatCollector struct {
// contains filtered or unexported fields
}
func (*DiskstatCollector) Close ¶
func (m *DiskstatCollector) Close()
func (*DiskstatCollector) Init ¶
func (m *DiskstatCollector) Init(config json.RawMessage) error
func (*DiskstatCollector) Initialized ¶
func (c *DiskstatCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type DiskstatCollectorConfig ¶
type DiskstatCollectorConfig struct {
ExcludeMetrics []string `json:"exclude_metrics,omitempty"`
}
type GpfsCollector ¶
type GpfsCollector struct {
// contains filtered or unexported fields
}
func (*GpfsCollector) Close ¶
func (m *GpfsCollector) Close()
func (*GpfsCollector) Init ¶
func (m *GpfsCollector) Init(config json.RawMessage) error
func (*GpfsCollector) Initialized ¶
func (c *GpfsCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type GpfsCollectorLastState ¶
type GpfsCollectorLastState struct {
// contains filtered or unexported fields
}
type IOstatCollector ¶
type IOstatCollector struct {
// contains filtered or unexported fields
}
func (*IOstatCollector) Close ¶
func (m *IOstatCollector) Close()
func (*IOstatCollector) Init ¶
func (m *IOstatCollector) Init(config json.RawMessage) error
func (*IOstatCollector) Initialized ¶
func (c *IOstatCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type IOstatCollectorConfig ¶
type IOstatCollectorConfig struct {
ExcludeMetrics []string `json:"exclude_metrics,omitempty"`
}
type IOstatCollectorEntry ¶
type IOstatCollectorEntry struct {
// contains filtered or unexported fields
}
type InfinibandCollector ¶
type InfinibandCollector struct {
// contains filtered or unexported fields
}
func (*InfinibandCollector) Close ¶
func (m *InfinibandCollector) Close()
func (*InfinibandCollector) Init ¶
func (m *InfinibandCollector) Init(config json.RawMessage) error
Init initializes the Infiniband collector by walking through files below IB_BASEPATH
func (*InfinibandCollector) Initialized ¶
func (c *InfinibandCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type InfinibandCollectorInfo ¶
type InfinibandCollectorInfo struct { LID string // IB local Identifier (LID) // contains filtered or unexported fields }
type InfinibandCollectorMetric ¶
type InfinibandCollectorMetric struct {
// contains filtered or unexported fields
}
type IpmiCollector ¶
type IpmiCollector struct {
// contains filtered or unexported fields
}
func (*IpmiCollector) Close ¶
func (m *IpmiCollector) Close()
func (*IpmiCollector) Init ¶
func (m *IpmiCollector) Init(config json.RawMessage) error
func (*IpmiCollector) Initialized ¶
func (c *IpmiCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type IpmiCollectorConfig ¶
type LikwidCollector ¶
type LikwidCollector struct {
// contains filtered or unexported fields
}
func (*LikwidCollector) Close ¶
func (m *LikwidCollector) Close()
func (*LikwidCollector) Init ¶
func (m *LikwidCollector) Init(config json.RawMessage) error
func (*LikwidCollector) Initialized ¶
func (c *LikwidCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
func (*LikwidCollector) LateInit ¶
func (m *LikwidCollector) LateInit() error
type LikwidCollectorConfig ¶
type LikwidCollectorConfig struct { Eventsets []LikwidCollectorEventsetConfig `json:"eventsets"` Metrics []LikwidCollectorMetricConfig `json:"globalmetrics,omitempty"` ForceOverwrite bool `json:"force_overwrite,omitempty"` InvalidToZero bool `json:"invalid_to_zero,omitempty"` AccessMode string `json:"access_mode,omitempty"` DaemonPath string `json:"accessdaemon_path,omitempty"` LibraryPath string `json:"liblikwid_path,omitempty"` }
type LikwidCollectorEventsetConfig ¶
type LikwidCollectorEventsetConfig struct { Events map[string]string `json:"events"` Metrics []LikwidCollectorMetricConfig `json:"metrics"` }
type LikwidCollectorMetricConfig ¶
type LikwidCollectorMetricConfig struct { Name string `json:"name"` // Name of the metric Calc string `json:"calc"` // Calculation for the metric using Type string `json:"type"` // Metric type (aka node, socket, cpu, ...) Publish bool `json:"publish"` Unit string `json:"unit"` // Unit of metric if any }
type LikwidEventsetConfig ¶
type LikwidEventsetConfig struct {
// contains filtered or unexported fields
}
type LikwidMetric ¶
type LikwidMetric struct {
// contains filtered or unexported fields
}
type LoadavgCollector ¶
type LoadavgCollector struct {
// contains filtered or unexported fields
}
func (*LoadavgCollector) Close ¶
func (m *LoadavgCollector) Close()
func (*LoadavgCollector) Init ¶
func (m *LoadavgCollector) Init(config json.RawMessage) error
func (*LoadavgCollector) Initialized ¶
func (c *LoadavgCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type LustreCollector ¶
type LustreCollector struct {
// contains filtered or unexported fields
}
func (*LustreCollector) Close ¶
func (m *LustreCollector) Close()
func (*LustreCollector) Init ¶
func (m *LustreCollector) Init(config json.RawMessage) error
func (*LustreCollector) Initialized ¶
func (c *LustreCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type LustreCollectorConfig ¶
type LustreCollectorConfig struct { LCtlCommand string `json:"lctl_command,omitempty"` ExcludeMetrics []string `json:"exclude_metrics,omitempty"` Sudo bool `json:"use_sudo,omitempty"` SendAbsoluteValues bool `json:"send_abs_values,omitempty"` SendDerivedValues bool `json:"send_derived_values,omitempty"` SendDiffValues bool `json:"send_diff_values,omitempty"` }
type LustreMetricDefinition ¶
type LustreMetricDefinition struct {
// contains filtered or unexported fields
}
type MemstatCollector ¶
type MemstatCollector struct {
// contains filtered or unexported fields
}
func (*MemstatCollector) Close ¶
func (m *MemstatCollector) Close()
func (*MemstatCollector) Init ¶
func (m *MemstatCollector) Init(config json.RawMessage) error
func (*MemstatCollector) Initialized ¶
func (c *MemstatCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type MemstatCollectorConfig ¶
type MemstatCollectorNode ¶
type MemstatCollectorNode struct {
// contains filtered or unexported fields
}
type MemstatStats ¶
type MemstatStats struct {
// contains filtered or unexported fields
}
type MetricCollector ¶
type MetricCollector interface { Name() string // Name of the metric collector Init(config json.RawMessage) error // Initialize metric collector Initialized() bool // Is metric collector initialized? Read(duration time.Duration, output chan lp.CCMetric) // Read metrics from metric collector Close() // Close / finish metric collector }
type NUMAStatsCollector ¶
type NUMAStatsCollector struct {
// contains filtered or unexported fields
}
func (*NUMAStatsCollector) Close ¶
func (m *NUMAStatsCollector) Close()
func (*NUMAStatsCollector) Init ¶
func (m *NUMAStatsCollector) Init(config json.RawMessage) error
func (*NUMAStatsCollector) Initialized ¶
func (c *NUMAStatsCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type NUMAStatsCollectorTopolgy ¶
type NUMAStatsCollectorTopolgy struct {
// contains filtered or unexported fields
}
Numa policy hit/miss statistics
numa_hit:
A process wanted to allocate memory from this node, and succeeded.
numa_miss:
A process wanted to allocate memory from another node, but ended up with memory from this node.
numa_foreign:
A process wanted to allocate on this node, but ended up with memory from another node.
local_node:
A process ran on this node's CPU, and got memory from this node.
other_node:
A process ran on a different node's CPU and got memory from this node.
interleave_hit:
Interleaving wanted to allocate from this node and succeeded.
See: https://www.kernel.org/doc/html/latest/admin-guide/numastat.html
type NetstatCollector ¶
type NetstatCollector struct {
// contains filtered or unexported fields
}
func (*NetstatCollector) Close ¶
func (m *NetstatCollector) Close()
func (*NetstatCollector) Init ¶
func (m *NetstatCollector) Init(config json.RawMessage) error
func (*NetstatCollector) Initialized ¶
func (c *NetstatCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type NetstatCollectorConfig ¶
type NetstatCollectorMetric ¶
type NetstatCollectorMetric struct {
// contains filtered or unexported fields
}
type Nfs3Collector ¶
type Nfs3Collector struct {
// contains filtered or unexported fields
}
func (*Nfs3Collector) Init ¶
func (m *Nfs3Collector) Init(config json.RawMessage) error
func (*Nfs3Collector) MainInit ¶
func (m *Nfs3Collector) MainInit(config json.RawMessage) error
type Nfs4Collector ¶
type Nfs4Collector struct {
// contains filtered or unexported fields
}
func (*Nfs4Collector) Init ¶
func (m *Nfs4Collector) Init(config json.RawMessage) error
func (*Nfs4Collector) MainInit ¶
func (m *Nfs4Collector) MainInit(config json.RawMessage) error
type NfsCollectorData ¶
type NfsCollectorData struct {
// contains filtered or unexported fields
}
type NvidiaCollector ¶
type NvidiaCollector struct {
// contains filtered or unexported fields
}
func (*NvidiaCollector) CatchPanic ¶
func (m *NvidiaCollector) CatchPanic()
func (*NvidiaCollector) Close ¶
func (m *NvidiaCollector) Close()
func (*NvidiaCollector) Init ¶
func (m *NvidiaCollector) Init(config json.RawMessage) error
func (*NvidiaCollector) Initialized ¶
func (c *NvidiaCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type NvidiaCollectorConfig ¶
type NvidiaCollectorDevice ¶
type NvidiaCollectorDevice struct {
// contains filtered or unexported fields
}
type SampleCollector ¶
type SampleCollector struct {
// contains filtered or unexported fields
}
This contains all variables we need during execution and the variables defined by metricCollector (name, init, ...)
func (*SampleCollector) Close ¶
func (m *SampleCollector) Close()
Close metric collector: close network connection, close files, close libraries, ... Called once by the collector manager
func (*SampleCollector) Init ¶
func (m *SampleCollector) Init(config json.RawMessage) error
Init initializes the sample collector Called once by the collector manager All tags, meta data tags and metrics that do not change over the runtime should be set here
func (*SampleCollector) Initialized ¶
func (c *SampleCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type SampleCollectorConfig ¶
type SampleCollectorConfig struct {
Interval string `json:"interval"`
}
These are the fields we read from the JSON configuration
type SampleTimerCollector ¶
type SampleTimerCollector struct {
// contains filtered or unexported fields
}
This contains all variables we need during execution and the variables defined by metricCollector (name, init, ...)
func (*SampleTimerCollector) Close ¶
func (m *SampleTimerCollector) Close()
func (*SampleTimerCollector) Init ¶
func (m *SampleTimerCollector) Init(name string, config json.RawMessage) error
func (*SampleTimerCollector) Initialized ¶
func (c *SampleTimerCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
func (*SampleTimerCollector) Name ¶
func (c *SampleTimerCollector) Name() string
Name returns the name of the metric collector
func (*SampleTimerCollector) Read ¶
func (m *SampleTimerCollector) Read(interval time.Duration, output chan lp.CCMetric)
func (*SampleTimerCollector) ReadMetrics ¶
func (m *SampleTimerCollector) ReadMetrics(timestamp time.Time)
This function is called at each interval timer tick
type SampleTimerCollectorConfig ¶
type SampleTimerCollectorConfig struct {
Interval string `json:"interval"`
}
These are the fields we read from the JSON configuration
type TempCollector ¶
type TempCollector struct {
// contains filtered or unexported fields
}
func (*TempCollector) Close ¶
func (m *TempCollector) Close()
func (*TempCollector) Init ¶
func (m *TempCollector) Init(config json.RawMessage) error
func (*TempCollector) Initialized ¶
func (c *TempCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type TempCollectorSensor ¶
type TempCollectorSensor struct {
// contains filtered or unexported fields
}
type TopProcsCollector ¶
type TopProcsCollector struct {
// contains filtered or unexported fields
}
func (*TopProcsCollector) Close ¶
func (m *TopProcsCollector) Close()
func (*TopProcsCollector) Init ¶
func (m *TopProcsCollector) Init(config json.RawMessage) error
func (*TopProcsCollector) Initialized ¶
func (c *TopProcsCollector) Initialized() bool
Initialized indicates whether the metric collector has been initialized
type TopProcsCollectorConfig ¶
type TopProcsCollectorConfig struct {
Num_procs int `json:"num_procs"`
}
Source Files
¶
- beegfsmetaMetric.go
- beegfsstorageMetric.go
- collectorManager.go
- cpufreqCpuinfoMetric.go
- cpufreqMetric.go
- cpustatMetric.go
- customCmdMetric.go
- diskstatMetric.go
- gpfsMetric.go
- infinibandMetric.go
- iostatMetric.go
- ipmiMetric.go
- likwidMetric.go
- loadavgMetric.go
- lustreMetric.go
- memstatMetric.go
- metricCollector.go
- netstatMetric.go
- nfsMetric.go
- numastatsMetric.go
- nvidiaMetric.go
- sampleMetric.go
- sampleTimerMetric.go
- tempMetric.go
- topprocsMetric.go