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) Cancel(ctx context.Context, id string) error
  • func (e *NoopExecutor) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (e *NoopExecutor) IsInstalled(ctx context.Context) (bool, error)
  • func (e *NoopExecutor) Run(ctx context.Context, args *executor.RunCommandRequest) (*models.RunCommandResult, error)
  • func (e *NoopExecutor) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
  • func (e *NoopExecutor) ShouldBidBasedOnUsage(ctx context.Context, request bidstrategy.BidStrategyRequest, ...) (bidstrategy.BidStrategyResponse, error)
  • func (e *NoopExecutor) Start(ctx context.Context, request *executor.RunCommandRequest) error
  • func (e *NoopExecutor) Wait(ctx context.Context, executionID string) (<-chan *models.RunCommandResult, <-chan 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 models.InputSource) (uint64, error)

type ExecutorHandlerHasStorageLocally

type ExecutorHandlerHasStorageLocally func(ctx context.Context, volume models.InputSource) (bool, error)

type ExecutorHandlerIsInstalled

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

type ExecutorHandlerJobHandler

type ExecutorHandlerJobHandler func(ctx context.Context, jobID string, resultsDir string) (*models.RunCommandResult, error)

func DelayedJobHandler

func DelayedJobHandler(sleep time.Duration) ExecutorHandlerJobHandler

func ErrorJobHandler

func ErrorJobHandler(err error) ExecutorHandlerJobHandler

type NoopExecutor

type NoopExecutor struct {
	Jobs   []string
	Config ExecutorConfig
	// contains filtered or unexported fields
}

func NewNoopExecutor

func NewNoopExecutor() *NoopExecutor

func NewNoopExecutorWithConfig

func NewNoopExecutorWithConfig(config ExecutorConfig) *NoopExecutor

func (*NoopExecutor) Cancel

func (e *NoopExecutor) Cancel(ctx context.Context, id string) error

func (*NoopExecutor) GetOutputStream

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

func (*NoopExecutor) IsInstalled

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

func (*NoopExecutor) Run

func (e *NoopExecutor) Run(
	ctx context.Context,
	args *executor.RunCommandRequest,
) (*models.RunCommandResult, error)

func (*NoopExecutor) ShouldBid

func (e *NoopExecutor) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

func (*NoopExecutor) ShouldBidBasedOnUsage

func (e *NoopExecutor) ShouldBidBasedOnUsage(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
	usage models.Resources,
) (bidstrategy.BidStrategyResponse, error)

func (*NoopExecutor) Start

func (e *NoopExecutor) Start(ctx context.Context, request *executor.RunCommandRequest) error

func (*NoopExecutor) Wait

func (e *NoopExecutor) Wait(ctx context.Context, executionID string) (<-chan *models.RunCommandResult, <-chan error)