workflow

Documentation

Index

• type Adapter
• type Engine
  • func NewEngine(objSaver adapter.ObjectSaver) Engine
  • func (e Engine) Execute(workflow entity.Workflow) []entity.NewRun
• type Result
• type Run
  • func (r Run) ToNewEntity() entity.NewRun
• type Type
• type Workflow
  • func FromWorkflowEntity(e entity.Workflow) Workflow

Types

type Adapter

type Adapter interface {
	Execute(code string, sharedData map[string]any) adapter.ExecutionResult
}

type Engine

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

func NewEngine

func NewEngine(objSaver adapter.ObjectSaver) Engine

func (Engine) Execute

func (e Engine) Execute(workflow entity.Workflow) []entity.NewRun

type Result

type Result struct {
	Error      error
	Runs       []Run
	SharedData map[string]any
}

type Run

type Run struct {
	WorkflowID string
	Error      error
	SharedData map[string]any
	StartTime  time.Time
	FinishTime time.Time
	Logs       []entity.NewRunLog
}

func (Run) ToNewEntity

func (r Run) ToNewEntity() entity.NewRun

type Type

type Type string

const (
	Javascript Type = "javascript"
	External   Type = "external"
	Folder     Type = "folder"
)

type Workflow

type Workflow struct {
	ID          string
	Name        string
	Code        string
	ObjectType  Type
	Children    []Workflow
	FailOnError bool
}

func FromWorkflowEntity

func FromWorkflowEntity(e entity.Workflow) Workflow