nodes

Documentation

Index

• type Node
• type Workflow
  • func NewWorkflow(nodes ...Node) Workflow
  • func (w Workflow) Run(ctx WorkflowContext, input any) (any, error)
• type WorkflowContext
  • func NewWorkflowContext(w http.ResponseWriter, req *http.Request, params httprouter.Params) WorkflowContext

Types

type Node

type Node interface {
	Run(ctx WorkflowContext, input any) (any, error)
}

type Workflow

type Workflow []Node

func NewWorkflow

func NewWorkflow(nodes ...Node) Workflow

func (Workflow) Run

func (w Workflow) Run(ctx WorkflowContext, input any) (any, error)

type WorkflowContext

type WorkflowContext struct {
	ResponseWriter http.ResponseWriter
	Request        *http.Request
	Params         httprouter.Params
}

func NewWorkflowContext

func NewWorkflowContext(w http.ResponseWriter, req *http.Request, params httprouter.Params) WorkflowContext