noop

Documentation

Index

• type ExecutorConfig
• type ExecutorConfigExternalHooks
• type ExecutorHandlerGetBidStrategy
• type ExecutorHandlerGetVolumeSize
• type ExecutorHandlerHasStorageLocally
• type ExecutorHandlerIsInstalled
• type ExecutorHandlerJobHandler
  • func DelayedJobHandler(sleep time.Duration) ExecutorHandlerJobHandler
  • func ErrorJobHandler(err error) ExecutorHandlerJobHandler
• type NoopExecutor
  • func NewNoopExecutor() *NoopExecutor
  • func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor
  • func (e *NoopExecutor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (e *NoopExecutor) GetResourceBidStrategy(ctx context.Context) (bidstrategy.ResourceBidStrategy, error)
  • func (e *NoopExecutor) GetSemanticBidStrategy(ctx context.Context) (bidstrategy.SemanticBidStrategy, 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, executionID string, 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)

func DelayedJobHandler

func DelayedJobHandler(sleep time.Duration) ExecutorHandlerJobHandler

func ErrorJobHandler

func ErrorJobHandler(err error) ExecutorHandlerJobHandler

type NoopExecutor

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

func NewNoopExecutor

func NewNoopExecutor() *NoopExecutor

func NewNoopExecutorWithConfig

func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor

func (*NoopExecutor) GetOutputStream

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

func (*NoopExecutor) GetResourceBidStrategy

func (e *NoopExecutor) GetResourceBidStrategy(ctx context.Context) (bidstrategy.ResourceBidStrategy, error)

func (*NoopExecutor) GetSemanticBidStrategy

func (e *NoopExecutor) GetSemanticBidStrategy(ctx context.Context) (bidstrategy.SemanticBidStrategy, 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,
	executionID string,
	job model.Job,
	jobResultsDir string,
) (*model.RunCommandResult, error)