workflow

Documentation

Index

• Constants
• type Temporal
  • func (t *Temporal) Execute(workflowJson models.Workflow, input map[string]interface{}) (string, error)
  • func (t *Temporal) ExecuteNode(node models.Node, context map[string]interface{}) (map[string]interface{}, error)
  • func (t *Temporal) ExtractOutputValues(nodeResponseMap map[string]interface{}, outputConfig []models.NodeOutput) map[string]interface{}
  • func (t *Temporal) GetWorkflowHistory(workflow models.Workflow) error
  • func (t *Temporal) ReplaceInputValues(input []models.NodeInput, workflowOutput map[string]map[string]interface{})
  • func (t *Temporal) RunWorkflow(ctx workflow.Context, workflowJson models.Workflow, ...) (string, error)
  • func (t *Temporal) TestPlugin(ctx context.Context, data map[string]interface{}) (string, error)

Constants

const (
	StartNode   = "startNode"
	DefaultNode = "defaultNode"
)

Types

type Temporal

type Temporal struct {
}

func (*Temporal) Execute

func (t *Temporal) Execute(workflowJson models.Workflow, input map[string]interface{}) (string, error)

func (*Temporal) ExecuteNode

func (t *Temporal) ExecuteNode(node models.Node, context map[string]interface{}) (map[string]interface{}, error)

func (*Temporal) ExtractOutputValues

func (t *Temporal) ExtractOutputValues(nodeResponseMap map[string]interface{}, outputConfig []models.NodeOutput) map[string]interface{}

func (*Temporal) GetWorkflowHistory

func (t *Temporal) GetWorkflowHistory(workflow models.Workflow) error

func (*Temporal) ReplaceInputValues

func (t *Temporal) ReplaceInputValues(input []models.NodeInput, workflowOutput map[string]map[string]interface{})

func (*Temporal) RunWorkflow

func (t *Temporal) RunWorkflow(ctx workflow.Context, workflowJson models.Workflow, input map[string]interface{}) (string, error)

func (*Temporal) TestPlugin

func (t *Temporal) TestPlugin(ctx context.Context, data map[string]interface{}) (string, error)