k8s

Documentation

Index

• Constants
• func InitLabels(accelerator, block, spine, datacenter string)
• func Loader(ctx context.Context, config engines.Config) (engines.Engine, error)
• func MergeNodeLabels(node *corev1.Node, labels map[string]string)
• func NamedLoader() (string, engines.Loader)
• func NewTopologyLabeler() *topologyLabeler
• type K8sEngine
  • func New() (*K8sEngine, error)
  • func (eng *K8sEngine) AddNodeLabels(ctx context.Context, nodeName string, labels map[string]string) error
  • func (eng *K8sEngine) GenerateOutput(ctx context.Context, tree *topology.Vertex, params map[string]any) ([]byte, error)
  • func (eng *K8sEngine) GetComputeInstances(ctx context.Context, _ engines.Environment) ([]topology.ComputeInstances, error)
• type Labeler

Constants

const (
	DefaultLabelAccelerator = "network.topology.nvidia.com/accelerator"
	DefaultLabelBlock       = "network.topology.nvidia.com/block"
	DefaultLabelSpine       = "network.topology.nvidia.com/spine"
	DefaultLabelDatacenter  = "network.topology.nvidia.com/datacenter"
)

const NAME = "k8s"

Functions

func InitLabels

func InitLabels(accelerator, block, spine, datacenter string)

func Loader

func Loader(ctx context.Context, config engines.Config) (engines.Engine, error)

func MergeNodeLabels

func MergeNodeLabels(node *corev1.Node, labels map[string]string)

func NamedLoader

func NamedLoader() (string, engines.Loader)

func NewTopologyLabeler

func NewTopologyLabeler() *topologyLabeler

Types

type K8sEngine

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

func New

func New() (*K8sEngine, error)

func (*K8sEngine) AddNodeLabels

func (eng *K8sEngine) AddNodeLabels(ctx context.Context, nodeName string, labels map[string]string) error

func (*K8sEngine) GenerateOutput

func (eng *K8sEngine) GenerateOutput(ctx context.Context, tree *topology.Vertex, params map[string]any) ([]byte, error)

func (*K8sEngine) GetComputeInstances

func (eng *K8sEngine) GetComputeInstances(ctx context.Context, _ engines.Environment) ([]topology.ComputeInstances, error)

type Labeler

type Labeler interface {
	AddNodeLabels(context.Context, string, map[string]string) error
}