Documentation
¶
Index ¶
- Constants
- func Loader(_ context.Context, params engines.Config) (engines.Engine, *httperr.Error)
- func NamedLoader() (string, engines.Loader)
- type Params
- type SlinkyEngine
- func (eng *SlinkyEngine) GenerateOutput(ctx context.Context, root *topology.Vertex, _ map[string]any) ([]byte, *httperr.Error)
- func (eng *SlinkyEngine) GetComputeInstances(ctx context.Context, _ engines.Environment) ([]topology.ComputeInstances, *httperr.Error)
- func (eng *SlinkyEngine) UpdateTopologyConfigmap(ctx context.Context, name, namespace string, data map[string]string) error
Constants ¶
View Source
const NAME = "slinky"
Variables ¶
This section is empty.
Functions ¶
func NamedLoader ¶
Types ¶
type Params ¶
type Params struct {
slurm.BaseParams `mapstructure:",squash"`
// Namespace specifies the namespace where Slinky cluster is deployed
Namespace string `mapstructure:"namespace"`
// PodSelector specifies slurmd pods
PodSelector metav1.LabelSelector `mapstructure:"podSelector"`
// NodeSelector (optional) specifies nodes running slurmd pods
NodeSelector map[string]string `mapstructure:"nodeSelector"`
// ConfigMapName specifies the name of the configmap containing topology config
ConfigMapName string `mapstructure:"topologyConfigmapName"`
// ConfigPath specifies the topology config filename inside the configmap
ConfigPath string `mapstructure:"topologyConfigPath"`
// contains filtered or unexported fields
}
type SlinkyEngine ¶
type SlinkyEngine struct {
// contains filtered or unexported fields
}
func (*SlinkyEngine) GenerateOutput ¶
func (*SlinkyEngine) GetComputeInstances ¶
func (eng *SlinkyEngine) GetComputeInstances(ctx context.Context, _ engines.Environment) ([]topology.ComputeInstances, *httperr.Error)
func (*SlinkyEngine) UpdateTopologyConfigmap ¶
Click to show internal directories.
Click to hide internal directories.