language

Documentation

Index

• type Executor
  • func NewExecutor(ctx context.Context, cm *system.CleanupManager, ...) (*Executor, 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) RunShard(ctx context.Context, shard model.JobShard, 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) 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) RunShard

func (e *Executor) RunShard(
	ctx context.Context,
	shard model.JobShard,
	jobResultsDir string,
) (*model.RunCommandResult, error)

type LanguageSpec

type LanguageSpec struct {
	Language, Version string
}