fabricmanager

Documentation

Overview

Package fabricmanager tracks the NVIDIA fabric manager version and its activeness. And streams the fabric manager logs for any errors and events.

Index

• Constants
• func DefaultLogConfig() query_log_config.Config
• func New(ctx context.Context, cfg Config) (components.Component, error)
• type Config
  • func ParseConfig(b any, db *sql.DB) (*Config, error)
  • func (cfg Config) Validate() error
• type Output
  • func ParseOutputJSON(data []byte) (*Output, error)
  • func ParseStateFabricManager(m map[string]string) (*Output, error)
  • func ParseStatesToOutput(states ...components.State) (*Output, error)
  • func ToOutput(i *nvidia_query.Output) *Output
  • func (o *Output) Evaluate() (string, bool, error)
  • func (o *Output) JSON() ([]byte, error)
  • func (o *Output) States() ([]components.State, error)

Constants

const (
	EventKeyFabricManagerNVSwitchLogUnixSeconds = "fabricmanager_nvswitch_log_unix_seconds"
	EventKeyFabricManagerNVSwitchLogLine        = "fabricmanager_nvswitch_log_line"
	EventKeyFabricManagerNVSwitchLogFilter      = "fabricmanager_nvswitch_log_filter"
	EventKeyFabricManagerNVSwitchLogError       = "fabricmanager_nvswitch_log_error"
)

const (
	StateNameFabricManager = "fabric_manager"

	StateKeyFabricManagerData           = "data"
	StateKeyFabricManagerEncoding       = "encoding"
	StateValueFabricManagerEncodingJSON = "json"
)

const Name = "accelerator-nvidia-fabric-manager"

Functions

func DefaultLogConfig

func DefaultLogConfig() query_log_config.Config

func New

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

Types

type Config

type Config struct {
	Query query_config.Config     `json:"query"`
	Log   query_log_config.Config `json:"log"`
}

func ParseConfig

func ParseConfig(b any, db *sql.DB) (*Config, error)

func (Config) Validate

func (cfg Config) Validate() error

type Output

type Output struct {
	FabricManager nvidia_query.FabricManagerOutput `json:"fabric_manager"`
}

func ParseOutputJSON

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

func ParseStateFabricManager

func ParseStateFabricManager(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) Evaluate

func (o *Output) Evaluate() (string, bool, error)

Returns the output evaluation reason and its healthy-ness.

func (*Output) JSON

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

func (*Output) States

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