infiniband

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const NAME_BM = "infiniband-bm"
View Source
const NAME_K8S = "infiniband-k8s"

Variables

This section is empty.

Functions

func GetClusterID

func GetClusterID(ctx context.Context, client *kubernetes.Clientset, config *rest.Config, hostname string, overrides map[string]string) (string, error)

func GetNodeAnnotations

func GetNodeAnnotations(ctx context.Context, client *kubernetes.Clientset, config *rest.Config, hostname string, overrides map[string]string) (map[string]string, error)

func LoaderK8S

func LoaderK8S(ctx context.Context, config providers.Config) (providers.Provider, *httperr.Error)

func NamedLoaderBM

func NamedLoaderBM() (string, providers.Loader)

func NamedLoaderK8S

func NamedLoaderK8S() (string, providers.Loader)

Types

type Cluster

type Cluster struct {
	UUID string
	// contains filtered or unexported fields
}

func (*Cluster) ID

func (c *Cluster) ID() (string, error)

type IBNetDiscover

type IBNetDiscover interface {
	Run(context.Context, string) (*bytes.Buffer, error)
}

type IBNetDiscoverBM

type IBNetDiscoverBM struct{}

func (*IBNetDiscoverBM) Run

func (h *IBNetDiscoverBM) Run(ctx context.Context, node string) (*bytes.Buffer, error)

type IBNetDiscoverK8S

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

func NewIBNetDiscoverK8S

func NewIBNetDiscoverK8S(config *rest.Config, client *kubernetes.Clientset) *IBNetDiscoverK8S

func (*IBNetDiscoverK8S) Run

func (h *IBNetDiscoverK8S) Run(ctx context.Context, node string) (*bytes.Buffer, error)

type Params added in v0.3.0

type Params struct {
	// NodeSelector (optional) specifies nodes participating in the topology
	NodeSelector map[string]string `mapstructure:"nodeSelector"`
	// contains filtered or unexported fields
}

type ProviderBM

type ProviderBM struct{}

func (*ProviderBM) GenerateTopologyConfig

func (p *ProviderBM) GenerateTopologyConfig(ctx context.Context, _ *int, cis []topology.ComputeInstances) (*topology.Vertex, *httperr.Error)

func (*ProviderBM) GetInstancesRegions

func (p *ProviderBM) GetInstancesRegions(ctx context.Context, nodes []string) (map[string]string, error)

GetInstancesRegions implements slurm.instanceMapper

func (*ProviderBM) Instances2NodeMap

func (p *ProviderBM) Instances2NodeMap(ctx context.Context, nodes []string) (map[string]string, error)

Instances2NodeMap implements slurm.instanceMapper

type ProviderK8S

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

func (*ProviderK8S) GenerateTopologyConfig

func (p *ProviderK8S) GenerateTopologyConfig(ctx context.Context, _ *int, cis []topology.ComputeInstances) (*topology.Vertex, *httperr.Error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL