engine

package
v0.0.0-...-3cf0080 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2021 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Engine

type Engine struct {
	*inits.App
	Model models.Engine
}

Engine represents an engine instance.

func NewEngine

func NewEngine(app *inits.App) (Engine, error)

NewEngine creates a new workflow engine.

func (*Engine) ExecuteWorkflow

func (engine *Engine) ExecuteWorkflow(workflowID uuid.UUID) error

ExecuteWorkflow takes a workflow object and executes it.

type Poller

type Poller struct {
	Interval int
}

Poller polls for information on a particular endpoint periodically.

type RESTHook

type RESTHook struct {
	CallbackURL  string
	ClientDomain string
}

RESTHook is a webhook with subscription management ability.

type Subscription

type Subscription interface {
}

Subscription represent a subscription type that can send payload to its subscribers.

type Trigger

type Trigger struct {
	Sub Subscription
}

Trigger represents the first step of a workflow that watches for events before running subsequent steps.

type Workflow

type Workflow struct {
	Model          *models.Workflow
	WorkflowConfig *configs.WorkflowConfig
}

Workflow represents a runnable workflow.

func (*Workflow) Execute

func (workflow *Workflow) Execute() error

Execute starts the execution of workflow run.

type WorkflowInstance

type WorkflowInstance struct {
	Model    *models.WorkflowInstance
	Workflow *Workflow
}

WorkflowInstance represents a running, paused or stopped workflow instance.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL