collectors

Documentation

Index

• Variables
• func ReadFixture(outputType string, name string) (string, error)
• type HCACollector
  • func NewHCACollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *HCACollector
  • func (h *HCACollector) Collect(ch chan<- prometheus.Metric)
  • func (h *HCACollector) Describe(ch chan<- *prometheus.Desc)
• type IBNetDiscover
  • func NewIBNetDiscover(runonce bool, logger log.Logger) *IBNetDiscover
  • func (ib *IBNetDiscover) Collect(ch chan<- prometheus.Metric)
  • func (ib *IBNetDiscover) Describe(ch chan<- *prometheus.Desc)
  • func (ib *IBNetDiscover) GetPorts() (*[]InfinibandDevice, *[]InfinibandDevice, error)
• type Ibswinfo
• type IbswinfoCollector
  • func NewIbswinfoCollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *IbswinfoCollector
  • func (s *IbswinfoCollector) Collect(ch chan<- prometheus.Metric)
  • func (s *IbswinfoCollector) Describe(ch chan<- *prometheus.Desc)
• type InfinibandDevice
• type InfinibandUplink
• type PerfQueryCounters
• type SwitchCollector
  • func NewSwitchCollector(devices *[]InfinibandDevice, runonce bool, logger log.Logger) *SwitchCollector
  • func (s *SwitchCollector) Collect(ch chan<- prometheus.Metric)
  • func (s *SwitchCollector) Describe(ch chan<- *prometheus.Desc)
• type SwitchFan
• type SwitchPowerSupply

Variables

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

	IbswinfoExec = ibswinfo
)

var (
	CollectHCA = kingpin.Flag("collector.hca", "Enable the HCA collector").Default("false").Bool()
)

var (
	CollectSwitch = kingpin.Flag("collector.switch", "Enable the switch collector").Default("true").Bool()
)

var (
	IbnetdiscoverExec = ibnetdiscover
)

var (
	PerfqueryExec = perfquery
)

Functions

func ReadFixture

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

Types

type HCACollector

type HCACollector struct {
	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 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

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

type IbswinfoCollector struct {
	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

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

func (*IbswinfoCollector) Collect

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

func (*IbswinfoCollector) Describe

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

type InfinibandUplink struct {
	Type       string
	LID        string
	PortNumber string
	GUID       string
	Name       string
}

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 {
	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

type SwitchFan struct {
	ID  string
	RPM float64
}

type SwitchPowerSupply

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