shell

Documentation

Index

• type Engine
  • func NewEngine() *Engine
  • func (e *Engine) CreateRunner(_ context.Context, _ engine.LogProvider, _ *api.Job) (engine.Runner, error)
  • func (e *Engine) Ping(_ context.Context) error
• type Runner
  • func NewRunner() *Runner
  • func (r *Runner) GetExecutor(_ context.Context) (executorpb.ExecutorClient, error)
  • func (r *Runner) Start(_ context.Context) error
  • func (r *Runner) Stop(ctx context.Context) error

Types

type Engine

type Engine struct{}

func NewEngine

func NewEngine() *Engine

func (*Engine) CreateRunner

func (e *Engine) CreateRunner(_ context.Context, _ engine.LogProvider, _ *api.Job) (engine.Runner, error)

func (*Engine) Ping

func (e *Engine) Ping(_ context.Context) error

type Runner

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

func NewRunner

func NewRunner() *Runner

func (*Runner) GetExecutor

func (r *Runner) GetExecutor(_ context.Context) (executorpb.ExecutorClient, error)

func (*Runner) Start

func (r *Runner) Start(_ context.Context) error

func (*Runner) Stop

func (r *Runner) Stop(ctx context.Context) error