engines

Documentation

Index

• Constants
• Variables
• type Config
• type Engine
• type Environment
• type Loader
• type NamedLoader
• type Registry
  • func NewRegistry(namedLoaders ...NamedLoader) Registry
  • func (r Registry) Get(name string) (Loader, error)

Constants

const (
	// TODO: Try to remove this
	EngineSLURM = "slurm"
)

Variables

var ErrUnsupportedEngine = errors.New("unsupported engine")

Types

type Config

type Config = struct{}

type Engine

type Engine interface {
	GetComputeInstances(ctx context.Context, environment Environment) ([]topology.ComputeInstances, error)
	GenerateOutput(ctx context.Context, vertex *topology.Vertex, params map[string]any) ([]byte, error)
}

type Environment

type Environment interface{}

type Loader

type Loader = component.Loader[Engine, Config]

type NamedLoader

type NamedLoader = component.NamedLoader[Engine, Config]

type Registry

type Registry component.Registry[Engine, Config]

func NewRegistry

func NewRegistry(namedLoaders ...NamedLoader) Registry

func (Registry) Get

func (r Registry) Get(name string) (Loader, error)