Documentation
¶
Index ¶
- Constants
- func GetClusterID(ctx context.Context, client *kubernetes.Clientset, config *rest.Config, ...) (string, error)
- func GetNodeAnnotations(ctx context.Context, client *kubernetes.Clientset, config *rest.Config, ...) (map[string]string, error)
- func LoaderBM(_ context.Context, _ providers.Config) (providers.Provider, *httperr.Error)
- func LoaderK8S(ctx context.Context, config providers.Config) (providers.Provider, *httperr.Error)
- func NamedLoaderBM() (string, providers.Loader)
- func NamedLoaderK8S() (string, providers.Loader)
- type Cluster
- type IBNetDiscover
- type IBNetDiscoverBM
- type IBNetDiscoverK8S
- type Params
- type ProviderBM
- func (p *ProviderBM) GenerateTopologyConfig(ctx context.Context, _ *int, cis []topology.ComputeInstances) (*topology.Vertex, *httperr.Error)
- func (p *ProviderBM) GetInstancesRegions(ctx context.Context, nodes []string) (map[string]string, error)
- func (p *ProviderBM) Instances2NodeMap(ctx context.Context, nodes []string) (map[string]string, error)
- type ProviderK8S
Constants ¶
View Source
const NAME_BM = "infiniband-bm"
View Source
const NAME_K8S = "infiniband-k8s"
Variables ¶
This section is empty.
Functions ¶
func GetClusterID ¶
func GetNodeAnnotations ¶
func NamedLoaderBM ¶
func NamedLoaderK8S ¶
Types ¶
type IBNetDiscover ¶
type IBNetDiscoverBM ¶
type IBNetDiscoverBM struct{}
type IBNetDiscoverK8S ¶
type IBNetDiscoverK8S struct {
// contains filtered or unexported fields
}
func NewIBNetDiscoverK8S ¶
func NewIBNetDiscoverK8S(config *rest.Config, client *kubernetes.Clientset) *IBNetDiscoverK8S
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)
Click to show internal directories.
Click to hide internal directories.