collectors

package

Go to main page

Versions in this module

v0

v0.6.7

Dec 4, 2023

Changes in this version

type LikwidCollectorMetricConfig

+ SendCoreTotalVal bool

+ SendNodeTotalVal bool

+ SendSocketTotalVal bool

v0.6.6

Aug 29, 2023

v0.6.5

Mar 20, 2023

v0.6.4

Dec 20, 2022

Changes in this version

+ const LIKWID_DEF_LOCKFILE

type LikwidCollector

+ func (m *LikwidCollector) ReadThread(interval time.Duration, output chan lp.CCMetric)

type LikwidCollectorConfig

+ LockfilePath string

v0.6.3

Dec 14, 2022

Changes in this version

type LikwidCollector

+ func (m *LikwidCollector) ReInit() error

+ type NfsIOStatCollector struct

+ func (c *NfsIOStatCollector) Initialized() bool

+ func (c *NfsIOStatCollector) Name() string

+ func (c *NfsIOStatCollector) Parallel() bool

+ func (m *NfsIOStatCollector) Close()

+ func (m *NfsIOStatCollector) Init(config json.RawMessage) error

+ func (m *NfsIOStatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type NfsIOStatCollectorConfig struct

+ ExcludeFilesystem []string

+ ExcludeMetrics []string

+ UseServerAddressAsSType bool

+ type RAPLCollector struct

+ RAPLZoneInfo []RAPLZoneInfo

+ func (c *RAPLCollector) Initialized() bool

+ func (c *RAPLCollector) Name() string

+ func (c *RAPLCollector) Parallel() bool

+ func (m *RAPLCollector) Close()

+ func (m *RAPLCollector) Init(config json.RawMessage) error

+ func (m *RAPLCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type RAPLZoneInfo struct

v0.6.2

Oct 13, 2022

Changes in this version

+ const SCHEDSTATFILE

+ type SchedstatCollector struct

+ func (c *SchedstatCollector) Initialized() bool

+ func (c *SchedstatCollector) Name() string

+ func (c *SchedstatCollector) Parallel() bool

+ func (m *SchedstatCollector) Close()

+ func (m *SchedstatCollector) Init(config json.RawMessage) error

+ func (m *SchedstatCollector) ParseProcLine(linefields []string, tags map[string]string, output chan lp.CCMetric, ...)

+ func (m *SchedstatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type SchedstatCollectorConfig struct

+ ExcludeMetrics []string

+ type SelfCollector struct

+ func (c *SelfCollector) Initialized() bool

+ func (c *SelfCollector) Name() string

+ func (c *SelfCollector) Parallel() bool

+ func (m *SelfCollector) Close()

+ func (m *SelfCollector) Init(config json.RawMessage) error

+ func (m *SelfCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type SelfCollectorConfig struct

+ CgoCalls bool

+ GoRoutines bool

+ MemStats bool

+ Rusage bool

v0.6.1

Jul 12, 2022

v0.6.0

Jun 9, 2022

Changes in this version

type BeegfsMetaCollector

+ func (c *BeegfsMetaCollector) Parallel() bool

type BeegfsStorageCollector

+ func (c *BeegfsStorageCollector) Parallel() bool

type CPUFreqCollector

+ func (c *CPUFreqCollector) Parallel() bool

type CPUFreqCpuInfoCollector

+ func (c *CPUFreqCpuInfoCollector) Parallel() bool

type CpustatCollector

+ func (c *CpustatCollector) Parallel() bool

type CustomCmdCollector

+ func (c *CustomCmdCollector) Parallel() bool

type DiskstatCollector

+ func (c *DiskstatCollector) Parallel() bool

type GpfsCollector

+ func (c *GpfsCollector) Parallel() bool

type IOstatCollector

+ func (c *IOstatCollector) Parallel() bool

type InfinibandCollector

+ func (c *InfinibandCollector) Parallel() bool

type IpmiCollector

+ func (c *IpmiCollector) Parallel() bool

type LikwidCollector

+ func (c *LikwidCollector) Parallel() bool

type LoadavgCollector

+ func (c *LoadavgCollector) Parallel() bool

type LustreCollector

+ func (c *LustreCollector) Parallel() bool

type MemstatCollector

+ func (c *MemstatCollector) Parallel() bool

type MetricCollector

+ Parallel func() bool

type NUMAStatsCollector

+ func (c *NUMAStatsCollector) Parallel() bool

type NetstatCollector

+ func (c *NetstatCollector) Parallel() bool

type NvidiaCollector

+ func (c *NvidiaCollector) Parallel() bool

type NvidiaCollectorConfig

+ AddBoardNumberMeta bool

+ AddSerialMeta bool

+ AddUuidMeta bool

+ ProcessMigDevices bool

+ UsePciInfoAsTypeId bool

+ UseSliceForMigDevices bool

+ UseUuidForMigDevices bool

+ type RocmSmiCollector struct

+ func (c *RocmSmiCollector) Initialized() bool

+ func (c *RocmSmiCollector) Name() string

+ func (c *RocmSmiCollector) Parallel() bool

+ func (m *RocmSmiCollector) Close()

+ func (m *RocmSmiCollector) Init(config json.RawMessage) error

+ func (m *RocmSmiCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type RocmSmiCollectorConfig struct

+ AddPciInfoTag bool

+ AddSerialMeta bool

+ ExcludeDevices []string

+ ExcludeMetrics []string

+ UsePciInfoAsTypeId bool

+ type RocmSmiCollectorDevice struct

type SampleCollector

+ func (c *SampleCollector) Parallel() bool

type SampleTimerCollector

+ func (c *SampleTimerCollector) Parallel() bool

type TempCollector

+ func (c *TempCollector) Parallel() bool

type TopProcsCollector

+ func (c *TopProcsCollector) Parallel() bool

v0.5.1

Apr 4, 2022

Changes in this version

+ const CPUSTATFILE

+ const CUSTOMCMDPATH

+ const DEFAULT_BEEGFS_CMD

+ const DEFAULT_GPFS_CMD

+ const DEFAULT_NUM_PROCS

+ const IB_BASEPATH

+ const IOSTATFILE

+ const IOSTAT_SYSFSPATH

+ const IPMISENSORS_PATH

+ const IPMITOOL_PATH

+ const LCTL_CMD

+ const LCTL_OPTION

+ const LIKWID_DEF_ACCESSMODE

+ const LIKWID_LIB_DL_FLAGS

+ const LIKWID_LIB_NAME

+ const LOADAVGFILE

+ const LUSTRE_SYSFS

+ const MAX_NUM_PROCS

+ const MEMSTATFILE

+ const MOUNTFILE

+ const NETSTATFILE

+ const NFSSTAT_EXEC

+ const NUMA_MEMSTAT_BASE

+ var AvailableCollectors = map[string]MetricCollector

+ var DefaultTime = func() time.Time

+ var LustreAbsMetrics = []LustreMetricDefinition

+ var LustreDeriveMetrics = []LustreMetricDefinition

+ var LustreDiffMetrics = []LustreMetricDefinition

+ func CpuList() []int

+ func RemoveFromStringList(s []string, r string) ([]string, error)

+ func SocketList() []int

+ type BeegfsMetaCollector struct

+ func (c *BeegfsMetaCollector) Initialized() bool

+ func (c *BeegfsMetaCollector) Name() string

+ func (m *BeegfsMetaCollector) Close()

+ func (m *BeegfsMetaCollector) Init(config json.RawMessage) error

+ func (m *BeegfsMetaCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type BeegfsMetaCollectorConfig struct

+ Beegfs string

+ ExcludeFilesystem []string

+ ExcludeMetrics []string

+ type BeegfsStorageCollector struct

+ func (c *BeegfsStorageCollector) Initialized() bool

+ func (c *BeegfsStorageCollector) Name() string

+ func (m *BeegfsStorageCollector) Close()

+ func (m *BeegfsStorageCollector) Init(config json.RawMessage) error

+ func (m *BeegfsStorageCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type BeegfsStorageCollectorConfig struct

+ Beegfs string

+ ExcludeFilesystem []string

+ ExcludeMetrics []string

+ type CPUFreqCollector struct

+ func (c *CPUFreqCollector) Initialized() bool

+ func (c *CPUFreqCollector) Name() string

+ func (m *CPUFreqCollector) Close()

+ func (m *CPUFreqCollector) Init(config json.RawMessage) error

+ func (m *CPUFreqCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type CPUFreqCollectorTopology struct

+ type CPUFreqCpuInfoCollector struct

+ func (c *CPUFreqCpuInfoCollector) Initialized() bool

+ func (c *CPUFreqCpuInfoCollector) Name() string

+ func (m *CPUFreqCpuInfoCollector) Close()

+ func (m *CPUFreqCpuInfoCollector) Init(config json.RawMessage) error

+ func (m *CPUFreqCpuInfoCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type CPUFreqCpuInfoCollectorTopology struct

+ type CollectorManager interface

+ AddOutput func(output chan lp.CCMetric)

+ Close func()

+ Init func(ticker mct.MultiChanTicker, duration time.Duration, wg *sync.WaitGroup, ...) error

+ Start func()

+ func New(ticker mct.MultiChanTicker, duration time.Duration, wg *sync.WaitGroup, ...) (CollectorManager, error)

+ type CpustatCollector struct

+ func (c *CpustatCollector) Initialized() bool

+ func (c *CpustatCollector) Name() string

+ func (m *CpustatCollector) Close()

+ func (m *CpustatCollector) Init(config json.RawMessage) error

+ func (m *CpustatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type CpustatCollectorConfig struct

+ ExcludeMetrics []string

+ type CustomCmdCollector struct

+ func (c *CustomCmdCollector) Initialized() bool

+ func (c *CustomCmdCollector) Name() string

+ func (m *CustomCmdCollector) Close()

+ func (m *CustomCmdCollector) Init(config json.RawMessage) error

+ func (m *CustomCmdCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type CustomCmdCollectorConfig struct

+ Commands []string

+ ExcludeMetrics []string

+ Files []string

+ type DiskstatCollector struct

+ func (c *DiskstatCollector) Initialized() bool

+ func (c *DiskstatCollector) Name() string

+ func (m *DiskstatCollector) Close()

+ func (m *DiskstatCollector) Init(config json.RawMessage) error

+ func (m *DiskstatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type DiskstatCollectorConfig struct

+ ExcludeMetrics []string

+ type GpfsCollector struct

+ func (c *GpfsCollector) Initialized() bool

+ func (c *GpfsCollector) Name() string

+ func (m *GpfsCollector) Close()

+ func (m *GpfsCollector) Init(config json.RawMessage) error

+ func (m *GpfsCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type GpfsCollectorLastState struct

+ type IOstatCollector struct

+ func (c *IOstatCollector) Initialized() bool

+ func (c *IOstatCollector) Name() string

+ func (m *IOstatCollector) Close()

+ func (m *IOstatCollector) Init(config json.RawMessage) error

+ func (m *IOstatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type IOstatCollectorConfig struct

+ ExcludeMetrics []string

+ type IOstatCollectorEntry struct

+ type InfinibandCollector struct

+ func (c *InfinibandCollector) Initialized() bool

+ func (c *InfinibandCollector) Name() string

+ func (m *InfinibandCollector) Close()

+ func (m *InfinibandCollector) Init(config json.RawMessage) error

+ func (m *InfinibandCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type InfinibandCollectorInfo struct

+ LID string

+ type InfinibandCollectorMetric struct

+ type IpmiCollector struct

+ func (c *IpmiCollector) Initialized() bool

+ func (c *IpmiCollector) Name() string

+ func (m *IpmiCollector) Close()

+ func (m *IpmiCollector) Init(config json.RawMessage) error

+ func (m *IpmiCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type IpmiCollectorConfig struct

+ ExcludeDevices []string

+ IpmisensorsPath string

+ IpmitoolPath string

+ type LikwidCollector struct

+ func (c *LikwidCollector) Initialized() bool

+ func (c *LikwidCollector) Name() string

+ func (m *LikwidCollector) Close()

+ func (m *LikwidCollector) Init(config json.RawMessage) error

+ func (m *LikwidCollector) LateInit() error

+ func (m *LikwidCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type LikwidCollectorConfig struct

+ AccessMode string

+ DaemonPath string

+ Eventsets []LikwidCollectorEventsetConfig

+ ForceOverwrite bool

+ InvalidToZero bool

+ LibraryPath string

+ Metrics []LikwidCollectorMetricConfig

+ type LikwidCollectorEventsetConfig struct

+ Events map[string]string

+ Metrics []LikwidCollectorMetricConfig

+ type LikwidCollectorMetricConfig struct

+ Calc string

+ Name string

+ Publish bool

+ Type string

+ Unit string

+ type LikwidEventsetConfig struct

+ type LikwidMetric struct

+ type LoadavgCollector struct

+ func (c *LoadavgCollector) Initialized() bool

+ func (c *LoadavgCollector) Name() string

+ func (m *LoadavgCollector) Close()

+ func (m *LoadavgCollector) Init(config json.RawMessage) error

+ func (m *LoadavgCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type LustreCollector struct

+ func (c *LustreCollector) Initialized() bool

+ func (c *LustreCollector) Name() string

+ func (m *LustreCollector) Close()

+ func (m *LustreCollector) Init(config json.RawMessage) error

+ func (m *LustreCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type LustreCollectorConfig struct

+ ExcludeMetrics []string

+ LCtlCommand string

+ SendAbsoluteValues bool

+ SendDerivedValues bool

+ SendDiffValues bool

+ Sudo bool

+ type LustreMetricDefinition struct

+ type MemstatCollector struct

+ func (c *MemstatCollector) Initialized() bool

+ func (c *MemstatCollector) Name() string

+ func (m *MemstatCollector) Close()

+ func (m *MemstatCollector) Init(config json.RawMessage) error

+ func (m *MemstatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type MemstatCollectorConfig struct

+ ExcludeMetrics []string

+ NodeStats bool

+ NumaStats bool

+ type MemstatCollectorNode struct

+ type MemstatStats struct

+ type MetricCollector interface

+ Close func()

+ Init func(config json.RawMessage) error

+ Initialized func() bool

+ Name func() string

+ Read func(duration time.Duration, output chan lp.CCMetric)

+ type NUMAStatsCollector struct

+ func (c *NUMAStatsCollector) Initialized() bool

+ func (c *NUMAStatsCollector) Name() string

+ func (m *NUMAStatsCollector) Close()

+ func (m *NUMAStatsCollector) Init(config json.RawMessage) error

+ func (m *NUMAStatsCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type NUMAStatsCollectorTopolgy struct

+ type NetstatCollector struct

+ func (c *NetstatCollector) Initialized() bool

+ func (c *NetstatCollector) Name() string

+ func (m *NetstatCollector) Close()

+ func (m *NetstatCollector) Init(config json.RawMessage) error

+ func (m *NetstatCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type NetstatCollectorConfig struct

+ IncludeDevices []string

+ SendAbsoluteValues bool

+ SendDerivedValues bool

+ type NetstatCollectorMetric struct

+ type Nfs3Collector struct

+ func (m *Nfs3Collector) Close()

+ func (m *Nfs3Collector) Init(config json.RawMessage) error

+ func (m *Nfs3Collector) MainInit(config json.RawMessage) error

+ func (m *Nfs3Collector) Read(interval time.Duration, output chan lp.CCMetric)

+ type Nfs4Collector struct

+ func (m *Nfs4Collector) Close()

+ func (m *Nfs4Collector) Init(config json.RawMessage) error

+ func (m *Nfs4Collector) MainInit(config json.RawMessage) error

+ func (m *Nfs4Collector) Read(interval time.Duration, output chan lp.CCMetric)

+ type NfsCollectorData struct

+ type NvidiaCollector struct

+ func (c *NvidiaCollector) Initialized() bool

+ func (c *NvidiaCollector) Name() string

+ func (m *NvidiaCollector) CatchPanic()

+ func (m *NvidiaCollector) Close()

+ func (m *NvidiaCollector) Init(config json.RawMessage) error

+ func (m *NvidiaCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type NvidiaCollectorConfig struct

+ AddPciInfoTag bool

+ ExcludeDevices []string

+ ExcludeMetrics []string

+ type NvidiaCollectorDevice struct

+ type SampleCollector struct

+ func (c *SampleCollector) Initialized() bool

+ func (c *SampleCollector) Name() string

+ func (m *SampleCollector) Close()

+ func (m *SampleCollector) Init(config json.RawMessage) error

+ func (m *SampleCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type SampleCollectorConfig struct

+ Interval string

+ type SampleTimerCollector struct

+ func (c *SampleTimerCollector) Initialized() bool

+ func (c *SampleTimerCollector) Name() string

+ func (m *SampleTimerCollector) Close()

+ func (m *SampleTimerCollector) Init(name string, config json.RawMessage) error

+ func (m *SampleTimerCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ func (m *SampleTimerCollector) ReadMetrics(timestamp time.Time)

+ type SampleTimerCollectorConfig struct

+ Interval string

+ type TempCollector struct

+ func (c *TempCollector) Initialized() bool

+ func (c *TempCollector) Name() string

+ func (m *TempCollector) Close()

+ func (m *TempCollector) Init(config json.RawMessage) error

+ func (m *TempCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type TempCollectorSensor struct

+ type TopProcsCollector struct

+ func (c *TopProcsCollector) Initialized() bool

+ func (c *TopProcsCollector) Name() string

+ func (m *TopProcsCollector) Close()

+ func (m *TopProcsCollector) Init(config json.RawMessage) error

+ func (m *TopProcsCollector) Read(interval time.Duration, output chan lp.CCMetric)

+ type TopProcsCollectorConfig struct

+ Num_procs int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL