processengine

Documentation

Index

• type Engine
  • func NewEngine(lw leaderworker.Interface) *Engine
  • func (e *Engine) Start(ctx context.Context) error
  • func (e *Engine) StartPipeline(ctx context.Context, pipeline *types.Pipeline) error
  • func (e *Engine) Stop(ctx context.Context) error
  • func (e *Engine) UpdatePipeline(ctx context.Context, pipelineID string, operation *lwTypes.UpdateOperation) error
• type Interface

Types

type Engine

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

func NewEngine

func NewEngine(lw leaderworker.Interface) *Engine

func (*Engine) Start

func (e *Engine) Start(ctx context.Context) error

func (*Engine) StartPipeline

func (e *Engine) StartPipeline(ctx context.Context, pipeline *types.Pipeline) error

func (*Engine) Stop

func (e *Engine) Stop(ctx context.Context) error

func (*Engine) UpdatePipeline

func (e *Engine) UpdatePipeline(ctx context.Context, pipelineID string, operation *lwTypes.UpdateOperation) error

type Interface

type Interface interface {
	// Start implement the Server start method in kratos transport
	Start(ctx context.Context) error
	// Stop implement the Server stop method in kratos transport
	Stop(ctx context.Context) error

	// StartPipeline start schedule and execute pipeline
	StartPipeline(ctx context.Context, pipeline *types.Pipeline) error
	// UpdatePipeline update the pipeline with specified operation
	UpdatePipeline(ctx context.Context, pipelineID string, operation *lwTypes.UpdateOperation) error
}