utils

Documentation

Index

• Constants
• Variables
• func Filter[T any](slice []T, filter func(T) bool) []T
• func FindAccelerator(cfgPath string) (bool, string, error)
• func IsSingleNodeCluster(c client.Client) (bool, error)
• func NewLogWrapper() *logrusWrapper
• func NewLogger() *logrus.Logger
• func SetOsEnvIfNotSet(key, value string, logger logr.Logger) error
• type AcceleratorDiscoveryConfig
  • func LoadDiscoveryConfig(cfgPath string) (AcceleratorDiscoveryConfig, error)

Constants

const (
	CONFIG_FILE_SIZE_LIMIT_IN_BYTES = 10485760 //10 MB
	SRIOV_PREFIX                    = "SRIOV_FEC_"
	PCI_PF_STUB_DASH                = "pci-pf-stub"
	PCI_PF_STUB_UNDERSCORE          = "pci_pf_stub"
	VFIO_PCI                        = "vfio-pci"
	VFIO_PCI_UNDERSCORE             = "vfio_pci"
	IGB_UIO                         = "igb_uio"
)

Variables

var GetPCIDevices = func() ([]*ghw.PCIDevice, error) {
	pci, err := ghw.PCI()
	if err != nil {
		return nil, fmt.Errorf("Failed to get PCI info: %v", err)
	}

	devices := pci.ListDevices()
	if len(devices) == 0 {
		return nil, fmt.Errorf("Got 0 devices")
	}
	return devices, nil
}

Functions

func Filter

func Filter[T any](slice []T, filter func(T) bool) []T

func FindAccelerator

func FindAccelerator(cfgPath string) (bool, string, error)

func IsSingleNodeCluster

func IsSingleNodeCluster(c client.Client) (bool, error)

func NewLogWrapper

func NewLogWrapper() *logrusWrapper

func NewLogger

func NewLogger() *logrus.Logger

func SetOsEnvIfNotSet

func SetOsEnvIfNotSet(key, value string, logger logr.Logger) error

Types

type AcceleratorDiscoveryConfig

type AcceleratorDiscoveryConfig struct {
	VendorID  map[string]string
	Class     string
	SubClass  string
	Devices   map[string]string
	NodeLabel string
}

func LoadDiscoveryConfig

func LoadDiscoveryConfig(cfgPath string) (AcceleratorDiscoveryConfig, error)