Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var E = NewExecutor()
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor struct {
HostExecutor IExecutor
PipelineExecRuntimes map[uint32]*PipelineExecRuntime
}
func NewExecutor ¶
func NewExecutor() *Executor
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.