noop

Documentation

Index

• type ExecutorConfig
• type ExecutorConfigExternalHooks
• type ExecutorHandlerGetBidStrategy
• type ExecutorHandlerGetVolumeSize
• type ExecutorHandlerHasStorageLocally
• type ExecutorHandlerIsInstalled
• type ExecutorHandlerJobHandler
• type NoopExecutor
  • func NewNoopExecutor() *NoopExecutor
  • func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor
  • func (e *NoopExecutor) GetBidStrategy(ctx context.Context) (bidstrategy.BidStrategy, error)
  • 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) Run(ctx context.Context, job model.Job, jobResultsDir string) (*model.RunCommandResult, error)

Types

type ExecutorConfig

type ExecutorConfig struct {
	ExternalHooks ExecutorConfigExternalHooks
}

type ExecutorConfigExternalHooks

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

type ExecutorHandlerGetBidStrategy

type ExecutorHandlerGetBidStrategy func(ctx context.Context) (bidstrategy.BidStrategy, error)

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, job model.Job, 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) GetBidStrategy

func (e *NoopExecutor) GetBidStrategy(ctx context.Context) (bidstrategy.BidStrategy, error)

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) Run

func (e *NoopExecutor) Run(
	ctx context.Context,
	job model.Job,
	jobResultsDir string,
) (*model.RunCommandResult, error)