language

Documentation

Index

• type Executor
  • func NewExecutor(ctx context.Context, cm *system.CleanupManager, ...) (*Executor, error)
  • func (*Executor) GetBidStrategy(context.Context) (bidstrategy.BidStrategy, error)
  • func (e *Executor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (e *Executor) GetVolumeSize(ctx context.Context, volumes model.StorageSpec) (uint64, error)
  • func (e *Executor) HasStorageLocally(ctx context.Context, volume 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, jobResultsDir string) (*model.RunCommandResult, error)
• type LanguageSpec

Types

type Executor

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

func NewExecutor

func NewExecutor(
	ctx context.Context,
	cm *system.CleanupManager,
	executors executor.ExecutorProvider,
) (*Executor, error)

func (*Executor) GetBidStrategy

func (*Executor) GetBidStrategy(context.Context) (bidstrategy.BidStrategy, error)

func (*Executor) GetOutputStream

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

func (*Executor) GetVolumeSize

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

func (*Executor) HasStorageLocally

func (e *Executor) HasStorageLocally(ctx context.Context, volume 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,
	jobResultsDir string,
) (*model.RunCommandResult, error)

type LanguageSpec

type LanguageSpec struct {
	Language, Version string
}