collector

package

Go to main page

Versions in this module

v0

v0.5.1

Jan 8, 2025

Changes in this version

type Collector

+ func NewCrayPMCCollector(logger *slog.Logger) (Collector, error)

+ type PMCDomain struct

+ Name string

+ Path string

+ func GetCrayPMCDomains(fs sysfs.FS) ([]PMCDomain, error)

+ func (pd PMCDomain) GetEnergyJoules() (uint64, error)

+ func (pd PMCDomain) GetPowerLimitWatts() (uint64, error)

+ func (pd PMCDomain) GetPowerWatts() (uint64, error)

+ func (pd PMCDomain) GetTempCelsius() (uint64, error)

v0.5.0

Dec 13, 2024

Changes in this version

type Collector

+ func NewRedfishCollector(logger *slog.Logger) (Collector, error)

v0.5.0-rc.2

Oct 31, 2024

v0.5.0-rc.1

Oct 29, 2024

v0.4.1

Oct 25, 2024

v0.4.0

Oct 23, 2024

Changes in this version

+ func NewRDMACollector(logger log.Logger, cgManager *cgroupManager) (*rdmaCollector, error)

+ func TargetsHandlerFor(discoverer *CEEMSAlloyTargetDiscoverer, opts promhttp.HandlerOpts) http.Handler

+ type Address struct

+ Bus string

+ Domain string

+ Function string

+ Slot string

+ Type string

+ UUID string

+ XMLName xml.Name

+ type BusID struct

+ func (b *BusID) Compare(bTest BusID) bool

+ func (b BusID) String() string

+ type CEEMSAlloyTargetDiscoverer struct

+ func NewAlloyTargetDiscoverer(logger log.Logger) (*CEEMSAlloyTargetDiscoverer, error)

+ func (d *CEEMSAlloyTargetDiscoverer) Discover() ([]Target, error)

type Collector

+ func NewLibvirtCollector(logger log.Logger) (Collector, error)

type Config

+ Discoverer *CEEMSAlloyTargetDiscoverer

type Device

+ func (d *Device) CompareBusID(id string) bool

+ func (d Device) String() string

+ type DeviceAttrs struct

+ Shared DeviceAttrsShared

+ XMLName xml.Name

+ type DeviceAttrsShared struct

+ CECount uint64

+ DecCount uint64

+ EncCount uint64

+ SMCount uint64

+ XMLName xml.Name

+ type Devices struct

+ HostDevs []HostDev

+ type Domain struct

+ Devices Devices

+ Name string

+ UUID string

+ type GPU struct

+ ID string

+ MIGDevices MIGDevices

+ MIGMode MIGMode

+ MinorNumber string

+ ProductArch string

+ ProductBrand string

+ ProductName string

+ UUID string

+ VirtMode VirtMode

+ XMLName xml.Name

+ type HostDev struct

+ Address Address

+ Display string

+ Managed string

+ Mode string

+ Model string

+ Source Source

+ Type string

+ XMLName xml.Name

+ type MIGDevice struct

+ Bar1Memory Memory

+ ComputeInstID uint64

+ DeviceAttrs DeviceAttrs

+ FBMemory Memory

+ GPUInstID uint64

+ Index uint64

+ XMLName xml.Name

+ type MIGDevices struct

+ Devices []MIGDevice

+ XMLName xml.Name

+ type MIGInstance struct

+ type MIGMode struct

+ CurrentMIG string

+ XMLName xml.Name

+ type Memory struct

+ Total string

+ type NVIDIASMILog struct

+ GPUs []GPU

+ XMLName xml.Name

+ type Source struct

+ Address Address

+ XMLName xml.Name

+ type Target struct

+ Labels map[string]string

+ Targets []string

+ type VirtMode struct

+ HostMode string

+ Mode string

+ XMLName xml.Name

type WebConfig

+ TargetsPath string

v0.3.1

Oct 3, 2024

Changes in this version

+ func KernelStringToNumeric(ver string) int64

+ func KernelVersion() (int64, error)

+ func NewCgroupCollector(logger log.Logger, cgManager *cgroupManager, opts cgroupOpts) (*cgroupCollector, error)

+ func NewCgroupManager(name string) (*cgroupManager, error)

+ func NewEbpfCollector(logger log.Logger, cgManager *cgroupManager) (*ebpfCollector, error)

type Config

+ Collector *CEEMSCollector

+ type Ksyms struct

+ func NewKsyms() (*Ksyms, error)

+ func (k *Ksyms) GetArchSpecificName(name string) (string, error)

+ func (k *Ksyms) IsAvailable(name string) bool

v0.3.0

Sep 10, 2024

Changes in this version

type CEEMSCollector

+ func (n CEEMSCollector) Close(ctx context.Context) error

+ type CEEMSExporterServer struct

+ func NewCEEMSExporterServer(c *Config) (*CEEMSExporterServer, error)

+ func (s *CEEMSExporterServer) Shutdown(ctx context.Context) error

+ func (s *CEEMSExporterServer) Start() error

type Collector

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

+ Stop func(ctx context.Context) error

+ type Config struct

+ Logger log.Logger

+ Web WebConfig

+ type WebConfig struct

+ Addresses []string

+ EnableDebugServer bool

+ IncludeExporterMetrics bool

+ LandingConfig *web.LandingConfig

+ MaxRequests int

+ MetricsPath string

+ WebConfigFile string

+ WebSystemdSocket bool

v0.2.1

Aug 17, 2024

v0.2.0

Aug 11, 2024

Changes in this version

+ var ErrIPMIUnavailable = errors.New("IPMI Power readings not Active")

v0.1.1

Jul 24, 2024

v0.1.0

Jul 4, 2024

Changes in this version

+ const CEEMSExporterAppName

+ const Namespace

+ var CEEMSExporterApp = ...

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

+ func DisableDefaultCollectors()

+ func GetAMDGPUDevices(rocmSmiPath string, logger log.Logger) (map[int]Device, error)

+ func GetGPUDevices(gpuType string, logger log.Logger) (map[int]Device, error)

+ func GetNvidiaGPUDevices(nvidiaSmiPath string, logger log.Logger) (map[int]Device, error)

+ func IsNoDataError(err error) bool

+ func LoadCgroupsV2Metrics(name string, cgroupfsPath string, controllers []string) (map[string]float64, error)

+ func RegisterCollector(collector string, isDefaultEnabled bool, ...)

+ func SanitizeMetricName(metricName string) string

+ type CEEMSCollector struct

+ Collectors map[string]Collector

+ func NewCEEMSCollector(logger log.Logger, filters ...string) (*CEEMSCollector, error)

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

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

+ type CEEMSExporter struct

+ App kingpin.Application

+ func NewCEEMSExporter() (*CEEMSExporter, error)

+ func (b *CEEMSExporter) Main() error

+ type CgroupMetric struct

+ type Collector interface

+ Update func(ch chan<- prometheus.Metric) error

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

+ func NewEmissionsCollector(logger log.Logger) (Collector, error)

+ func NewIPMICollector(logger log.Logger) (Collector, error)

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

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

+ func NewSlurmCollector(logger log.Logger) (Collector, error)

+ type Device struct

+ type JobProps struct

v0.1.0-rc.6

Apr 4, 2024

v0.1.0-rc.5

Mar 2, 2024

v0.1.0-rc.4

Feb 18, 2024

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