collectors

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 12, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CollectIbswinfo = kingpin.Flag("collector.ibswinfo", "Enable ibswinfo data collection (BETA)").Default("false").Bool()

	IbswinfoExec = ibswinfo
)
View Source 
var (
	CollectHCA = kingpin.Flag("collector.hca", "Enable the HCA collector").Default("false").Bool()
)
View Source 
var (
	CollectSwitch = kingpin.Flag("collector.switch", "Enable the switch collector").Default("true").Bool()
)
View Source 
var (
	IbnetdiscoverExec = ibnetdiscover
)
View Source 
var (
	PerfqueryExec = perfquery
)

Functions

func ReadFixture 

func ReadFixture(outputType string, name string) (string, error)

Types

type HCACollector 

type HCACollector struct {
	Duration                     *prometheus.Desc
	Error                        *prometheus.Desc
	Timeout                      *prometheus.Desc
	PortXmitData                 *prometheus.Desc
	PortRcvData                  *prometheus.Desc
	PortXmitPkts                 *prometheus.Desc
	PortRcvPkts                  *prometheus.Desc
	PortUnicastXmitPkts          *prometheus.Desc
	PortUnicastRcvPkts           *prometheus.Desc
	PortMulticastXmitPkts        *prometheus.Desc
	PortMulticastRcvPkts         *prometheus.Desc
	SymbolErrorCounter           *prometheus.Desc
	LinkErrorRecoveryCounter     *prometheus.Desc
	LinkDownedCounter            *prometheus.Desc
	PortRcvErrors                *prometheus.Desc
	PortRcvRemotePhysicalErrors  *prometheus.Desc
	PortRcvSwitchRelayErrors     *prometheus.Desc
	PortXmitDiscards             *prometheus.Desc
	PortXmitConstraintErrors     *prometheus.Desc
	PortRcvConstraintErrors      *prometheus.Desc
	LocalLinkIntegrityErrors     *prometheus.Desc
	ExcessiveBufferOverrunErrors *prometheus.Desc
	VL15Dropped                  *prometheus.Desc
	PortXmitWait                 *prometheus.Desc
	QP1Dropped                   *prometheus.Desc
	PortLocalPhysicalErrors      *prometheus.Desc
	PortMalformedPktErrors       *prometheus.Desc
	PortBufferOverrunErrors      *prometheus.Desc
	PortDLIDMappingErrors        *prometheus.Desc
	PortVLMappingErrors          *prometheus.Desc
	PortLoopingErrors            *prometheus.Desc
	Rate                         *prometheus.Desc
	RawRate                      *prometheus.Desc
	Uplink                       *prometheus.Desc
	Info                         *prometheus.Desc
	// contains filtered or unexported fields
}

func NewHCACollector 

func NewHCACollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *HCACollector

func (*HCACollector) Collect 

func (h *HCACollector) Collect(ch chan<- prometheus.Metric)

func (*HCACollector) Describe 

func (h *HCACollector) Describe(ch chan<- *prometheus.Desc)

type HCAMetrics added in v0.9.0 

type HCAMetrics struct {
	// contains filtered or unexported fields
}

type IBNetDiscover 

type IBNetDiscover struct {
	// contains filtered or unexported fields
}

func NewIBNetDiscover 

func NewIBNetDiscover(runonce bool, logger log.Logger) *IBNetDiscover

func (*IBNetDiscover) Collect 

func (ib *IBNetDiscover) Collect(ch chan<- prometheus.Metric)

func (*IBNetDiscover) Describe 

func (ib *IBNetDiscover) Describe(ch chan<- *prometheus.Desc)

func (*IBNetDiscover) GetPorts 

func (ib *IBNetDiscover) GetPorts() (*[]InfinibandDevice, *[]InfinibandDevice, error)

type Ibswinfo added in v0.4.0 

type Ibswinfo struct {
	PartNumber      string
	SerialNumber    string
	PSID            string
	FirmwareVersion string
	Uptime          float64
	PowerSupplies   []SwitchPowerSupply
	Temp            float64
	FanStatus       string
	Fans            []SwitchFan
	// contains filtered or unexported fields
}

type IbswinfoCollector added in v0.4.0 

type IbswinfoCollector struct {
	Duration             *prometheus.Desc
	Error                *prometheus.Desc
	Timeout              *prometheus.Desc
	HardwareInfo         *prometheus.Desc
	Uptime               *prometheus.Desc
	PowerSupplyStatus    *prometheus.Desc
	PowerSupplyDCPower   *prometheus.Desc
	PowerSupplyFanStatus *prometheus.Desc
	PowerSupplyWatts     *prometheus.Desc
	Temp                 *prometheus.Desc
	FanStatus            *prometheus.Desc
	FanRPM               *prometheus.Desc
	// contains filtered or unexported fields
}

func NewIbswinfoCollector added in v0.4.0 

func NewIbswinfoCollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *IbswinfoCollector

func (*IbswinfoCollector) Collect added in v0.4.0 

func (s *IbswinfoCollector) Collect(ch chan<- prometheus.Metric)

func (*IbswinfoCollector) Describe added in v0.4.0 

func (s *IbswinfoCollector) Describe(ch chan<- *prometheus.Desc)

type InfinibandDevice 

type InfinibandDevice struct {
	Type    string
	LID     string
	GUID    string
	Rate    float64
	RawRate float64
	Name    string
	Uplinks map[string]InfinibandUplink
}
type InfinibandUplink struct {
	Type       string
	LID        string
	PortNumber string
	GUID       string
	Name       string
	Rate       float64
	RawRate    float64
}

type PerfQueryCounters 

type PerfQueryCounters struct {
	PortSelect string
	// From -x / extended counters
	PortXmitData                 float64
	PortRcvData                  float64
	PortXmitPkts                 float64
	PortRcvPkts                  float64
	PortUnicastXmitPkts          float64
	PortUnicastRcvPkts           float64
	PortMulticastXmitPkts        float64
	PortMulticastRcvPkts         float64
	SymbolErrorCounter           float64
	LinkErrorRecoveryCounter     float64
	LinkDownedCounter            float64
	PortRcvErrors                float64
	PortRcvRemotePhysicalErrors  float64
	PortRcvSwitchRelayErrors     float64
	PortXmitDiscards             float64
	PortXmitConstraintErrors     float64
	PortRcvConstraintErrors      float64
	LocalLinkIntegrityErrors     float64
	ExcessiveBufferOverrunErrors float64
	VL15Dropped                  float64
	PortXmitWait                 float64
	QP1Dropped                   float64
	// From -E / PortRcvErrorDetails
	PortLocalPhysicalErrors float64
	PortMalformedPktErrors  float64
	PortBufferOverrunErrors float64
	PortDLIDMappingErrors   float64
	PortVLMappingErrors     float64
	PortLoopingErrors       float64
	// contains filtered or unexported fields
}

type SwitchCollector 

type SwitchCollector struct {
	Duration                     *prometheus.Desc
	Error                        *prometheus.Desc
	Timeout                      *prometheus.Desc
	PortXmitData                 *prometheus.Desc
	PortRcvData                  *prometheus.Desc
	PortXmitPkts                 *prometheus.Desc
	PortRcvPkts                  *prometheus.Desc
	PortUnicastXmitPkts          *prometheus.Desc
	PortUnicastRcvPkts           *prometheus.Desc
	PortMulticastXmitPkts        *prometheus.Desc
	PortMulticastRcvPkts         *prometheus.Desc
	SymbolErrorCounter           *prometheus.Desc
	LinkErrorRecoveryCounter     *prometheus.Desc
	LinkDownedCounter            *prometheus.Desc
	PortRcvErrors                *prometheus.Desc
	PortRcvRemotePhysicalErrors  *prometheus.Desc
	PortRcvSwitchRelayErrors     *prometheus.Desc
	PortXmitDiscards             *prometheus.Desc
	PortXmitConstraintErrors     *prometheus.Desc
	PortRcvConstraintErrors      *prometheus.Desc
	LocalLinkIntegrityErrors     *prometheus.Desc
	ExcessiveBufferOverrunErrors *prometheus.Desc
	VL15Dropped                  *prometheus.Desc
	PortXmitWait                 *prometheus.Desc
	QP1Dropped                   *prometheus.Desc
	PortLocalPhysicalErrors      *prometheus.Desc
	PortMalformedPktErrors       *prometheus.Desc
	PortBufferOverrunErrors      *prometheus.Desc
	PortDLIDMappingErrors        *prometheus.Desc
	PortVLMappingErrors          *prometheus.Desc
	PortLoopingErrors            *prometheus.Desc
	Rate                         *prometheus.Desc
	RawRate                      *prometheus.Desc
	Uplink                       *prometheus.Desc
	Info                         *prometheus.Desc
	// contains filtered or unexported fields
}

func NewSwitchCollector 

func NewSwitchCollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *SwitchCollector

func (*SwitchCollector) Collect 

func (s *SwitchCollector) Collect(ch chan<- prometheus.Metric)

func (*SwitchCollector) Describe 

func (s *SwitchCollector) Describe(ch chan<- *prometheus.Desc)

type SwitchFan added in v0.4.0 

type SwitchFan struct {
	ID  string
	RPM float64
}

type SwitchMetrics added in v0.9.0 

type SwitchMetrics struct {
	// contains filtered or unexported fields
}

type SwitchPowerSupply added in v0.4.0 

type SwitchPowerSupply struct {
	ID        string
	Status    string
	DCPower   string
	FanStatus string
	PowerW    float64
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.