workflow

Documentation

Index

• type Engine
  • func NewEngine(store storage.WorkflowStore, tracer tracing.Tracer) *Engine
  • func (e *Engine) GetWorkflowStatus(ctx context.Context, workflowID string) (*workflow.WorkflowStatus, error)
  • func (e *Engine) StartWorkflow(ctx context.Context, workflowID string, input interface{}) error
  • func (e *Engine) StopWorkflow(ctx context.Context, workflowID string) error

Types

type Engine

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

func NewEngine

func NewEngine(store storage.WorkflowStore, tracer tracing.Tracer) *Engine

func (*Engine) GetWorkflowStatus

func (e *Engine) GetWorkflowStatus(ctx context.Context, workflowID string) (*workflow.WorkflowStatus, error)

func (*Engine) StartWorkflow

func (e *Engine) StartWorkflow(ctx context.Context, workflowID string, input interface{}) error

func (*Engine) StopWorkflow

func (e *Engine) StopWorkflow(ctx context.Context, workflowID string) error