executor

Documentation

Index

• Variables
• type Executor
  • func NewExecutor() *Executor
  • func (o *Executor) Exec(letterString string)
• type IExecutor
• type PipelineExecRuntime
  • func NewPipelineExecRuntime(pipelineId uint32, cancelFunc context.CancelFunc) *PipelineExecRuntime

Variables

var E = NewExecutor()

Types

type Executor

type Executor struct {
	HostExecutor         IExecutor
	PipelineExecRuntimes map[uint32]*PipelineExecRuntime
}

func NewExecutor

func NewExecutor() *Executor

func (*Executor) Exec

func (o *Executor) Exec(letterString string)

type IExecutor

type IExecutor interface {
	Start(ctx context.Context, payload *letter.StartPipelinePayload, w io.WriteCloser) error
}

type PipelineExecRuntime

type PipelineExecRuntime struct {
	PipelineId uint32
	// contains filtered or unexported fields
}

func NewPipelineExecRuntime

func NewPipelineExecRuntime(pipelineId uint32, cancelFunc context.CancelFunc) *PipelineExecRuntime