executor

Documentation

Index

• type Executor
  • func New() (*Executor, error)
  • func (e *Executor) Exists(ctx context.Context, w entity.Workload) (bool, error)
  • func (e *Executor) GetState(ctx context.Context, w entity.Workload) (entity.JobState, error)
  • func (e *Executor) Remove(ctx context.Context, w entity.Workload) error
  • func (e *Executor) Run(ctx context.Context, w entity.Workload) error
  • func (e *Executor) Stop(ctx context.Context, w entity.Workload) error

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

func New

func New() (*Executor, error)

func (*Executor) Exists

func (e *Executor) Exists(ctx context.Context, w entity.Workload) (bool, error)

func (*Executor) GetState

func (e *Executor) GetState(ctx context.Context, w entity.Workload) (entity.JobState, error)

func (*Executor) Remove

func (e *Executor) Remove(ctx context.Context, w entity.Workload) error

func (*Executor) Run

func (e *Executor) Run(ctx context.Context, w entity.Workload) error

func (*Executor) Stop

func (e *Executor) Stop(ctx context.Context, w entity.Workload) error