noop

Documentation

Index

• type ExecutorConfig
• type ExecutorConfigExternalHooks
• type ExecutorHandlerGetVolumeSize
• type ExecutorHandlerHasStorageLocally
• type ExecutorHandlerIsInstalled
• type ExecutorHandlerJobHandler
• type NoopExecutor
  • func NewNoopExecutor() *NoopExecutor
  • func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor
  • func (e *NoopExecutor) GetVolumeSize(ctx context.Context, volume model.StorageSpec) (uint64, error)
  • func (e *NoopExecutor) HasStorageLocally(ctx context.Context, volume model.StorageSpec) (bool, error)
  • func (e *NoopExecutor) IsInstalled(ctx context.Context) (bool, error)
  • func (e *NoopExecutor) RunShard(ctx context.Context, shard model.JobShard, jobResultsDir string) (*model.RunCommandResult, error)

Types

type ExecutorConfig

type ExecutorConfig struct {
	ExternalHooks ExecutorConfigExternalHooks
}

type ExecutorConfigExternalHooks

type ExecutorConfigExternalHooks struct {
	IsInstalled       ExecutorHandlerIsInstalled
	HasStorageLocally ExecutorHandlerHasStorageLocally
	GetVolumeSize     ExecutorHandlerGetVolumeSize
	JobHandler        ExecutorHandlerJobHandler
}

type ExecutorHandlerGetVolumeSize

type ExecutorHandlerGetVolumeSize func(ctx context.Context, volume model.StorageSpec) (uint64, error)

type ExecutorHandlerHasStorageLocally

type ExecutorHandlerHasStorageLocally func(ctx context.Context, volume model.StorageSpec) (bool, error)

type ExecutorHandlerIsInstalled

type ExecutorHandlerIsInstalled func(ctx context.Context) (bool, error)

type ExecutorHandlerJobHandler

type ExecutorHandlerJobHandler func(ctx context.Context, shard model.JobShard, resultsDir string) (*model.RunCommandResult, error)

type NoopExecutor

type NoopExecutor struct {
	Jobs   []model.Job
	Config ExecutorConfig
}

func NewNoopExecutor

func NewNoopExecutor() *NoopExecutor

func NewNoopExecutorWithConfig

func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor

func (*NoopExecutor) GetVolumeSize

func (e *NoopExecutor) GetVolumeSize(ctx context.Context, volume model.StorageSpec) (uint64, error)

func (*NoopExecutor) HasStorageLocally

func (e *NoopExecutor) HasStorageLocally(ctx context.Context, volume model.StorageSpec) (bool, error)

func (*NoopExecutor) IsInstalled

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

func (*NoopExecutor) RunShard

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