slinky

Documentation

Index

• Constants
• func Loader(ctx context.Context, params engines.Config) (engines.Engine, error)
• func NamedLoader() (string, engines.Loader)
• type Params
• type SlinkyEngine
  • func New(params engines.Config) (*SlinkyEngine, error)
  • func (eng *SlinkyEngine) GenerateOutput(ctx context.Context, root *topology.Vertex, _ map[string]any) ([]byte, error)
  • func (eng *SlinkyEngine) GetComputeInstances(ctx context.Context, _ engines.Environment) ([]topology.ComputeInstances, error)
  • func (eng *SlinkyEngine) UpdateTopologyConfigmap(ctx context.Context, name, namespace string, data map[string]string) error

Constants

const NAME = "slinky"

Functions

func Loader

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

func NamedLoader

func NamedLoader() (string, engines.Loader)

Types

type Params

type Params struct {
	slurm.BaseParams `mapstructure:",squash"`
	Namespace        string               `mapstructure:"namespace"`
	LabelSelector    metav1.LabelSelector `mapstructure:"podSelector"`
	ConfigPath       string               `mapstructure:"topologyConfigPath"`
	ConfigMapName    string               `mapstructure:"topologyConfigmapName"`
	// contains filtered or unexported fields
}

type SlinkyEngine

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

func New

func New(params engines.Config) (*SlinkyEngine, error)

func (*SlinkyEngine) GenerateOutput

func (eng *SlinkyEngine) GenerateOutput(ctx context.Context, root *topology.Vertex, _ map[string]any) ([]byte, error)

func (*SlinkyEngine) GetComputeInstances

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

func (*SlinkyEngine) UpdateTopologyConfigmap

func (eng *SlinkyEngine) UpdateTopologyConfigmap(ctx context.Context, name, namespace string, data map[string]string) error