peermem

Documentation

Overview

Package peermem monitors the peermem module status. Optional, enabled if the host has NVIDIA GPUs.

Index

• Constants
• func HasPeermemInvalidContext(line string) bool
• func Match(line string) (eventName string, message string)
• func New(ctx context.Context, cfg nvidia_common.Config) (components.Component, error)
• type Output
  • func ParseOutputJSON(data []byte) (*Output, error)
  • func ParseStateLsmodPeermem(m map[string]string) (*Output, error)
  • func ParseStatesToOutput(states ...components.State) (*Output, error)
  • func ToOutput(i *nvidia_query.Output) *Output
  • func (o *Output) JSON() ([]byte, error)
  • func (o *Output) States() ([]components.State, error)

Constants

const (
	StateNameLsmodPeermem = "lsmod_peermem"

	StateKeyLsmodPeermemData           = "data"
	StateKeyLsmodPeermemEncoding       = "encoding"
	StateValueLsmodPeermemEncodingJSON = "json"
)

Functions

func HasPeermemInvalidContext

func HasPeermemInvalidContext(line string) bool

func Match

func Match(line string) (eventName string, message string)

func New

func New(ctx context.Context, cfg nvidia_common.Config) (components.Component, error)

Types

type Output

type Output struct {
	// Represents the number of GPUs in the system.
	// This is used to determine if ibcore may be expected to use peermem module.
	GPUCount int `json:"gpu_count"`

	ProductName  string                           `json:"product_name"`
	LsmodPeermem peermem.LsmodPeermemModuleOutput `json:"lsmod_peermem"`
}

func ParseOutputJSON

func ParseOutputJSON(data []byte) (*Output, error)

func ParseStateLsmodPeermem

func ParseStateLsmodPeermem(m map[string]string) (*Output, error)

func ParseStatesToOutput

func ParseStatesToOutput(states ...components.State) (*Output, error)

func ToOutput

func ToOutput(i *nvidia_query.Output) *Output

ToOutput converts nvidia_query.Output to Output. It returns an empty non-nil object, if the input or the required field is nil (e.g., i.SMI).

func (*Output) JSON

func (o *Output) JSON() ([]byte, error)

func (*Output) States

func (o *Output) States() ([]components.State, error)