pythonwasm

Documentation

Index

• type Executor
  • func NewExecutor(executors executor.ExecutorProvider) (*Executor, error)
  • func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (e *Executor) GetResourceBidStrategy(ctx context.Context) (bidstrategy.ResourceBidStrategy, error)
  • func (e *Executor) GetSemanticBidStrategy(ctx context.Context) (bidstrategy.SemanticBidStrategy, error)
  • func (e *Executor) GetVolumeSize(context.Context, model.StorageSpec) (uint64, error)
  • func (e *Executor) HasStorageLocally(context.Context, model.StorageSpec) (bool, error)
  • func (e *Executor) IsInstalled(ctx context.Context) (bool, error)
  • func (e *Executor) Run(ctx context.Context, executionID string, job model.Job, resultsDir string) (*model.RunCommandResult, error)

Types

type Executor

type Executor struct {
	Jobs map[string]*model.Job
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(
	executors executor.ExecutorProvider,
) (*Executor, error)

func (*Executor) GetOutputStream

func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)

func (*Executor) GetResourceBidStrategy

func (e *Executor) GetResourceBidStrategy(ctx context.Context) (bidstrategy.ResourceBidStrategy, error)

func (*Executor) GetSemanticBidStrategy

func (e *Executor) GetSemanticBidStrategy(ctx context.Context) (bidstrategy.SemanticBidStrategy, error)

func (*Executor) GetVolumeSize

func (e *Executor) GetVolumeSize(context.Context, model.StorageSpec) (uint64, error)

func (*Executor) HasStorageLocally

func (e *Executor) HasStorageLocally(context.Context, model.StorageSpec) (bool, error)

func (*Executor) IsInstalled

func (e *Executor) IsInstalled(ctx context.Context) (bool, error)

func (*Executor) Run

func (e *Executor) Run(ctx context.Context, executionID string, job model.Job, resultsDir string) (
	*model.RunCommandResult, error)