pythonwasm

Documentation

Index

• type Executor
  • func NewExecutor(executors executor.ExecutorProvider) (*Executor, error)
  • func (e *Executor) GetBidStrategy(ctx context.Context) (bidstrategy.BidStrategy, 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, 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) GetBidStrategy

func (e *Executor) GetBidStrategy(ctx context.Context) (bidstrategy.BidStrategy, 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, job model.Job, resultsDir string) (
	*model.RunCommandResult, error)