withtheflow

README

withtheflow

Lightweight Golang local workflow engine

Documentation

Index

• type FlowHandler
• type FlowId
• type Runtime
• type WorkflowRunner

Types

type FlowHandler

type FlowHandler func(args interface{}, runtime Runtime, subFlowResults []interface{}) interface{}

type FlowId

type FlowId interface{}

type Runtime

type Runtime interface {
	// Schedules a new flow which combines the results of the given flow ids.
	AddFlow(funcname string, args interface{}, dependentFlows ...FlowId) FlowId
	// Sets the result of this flow to be the result of the given flow id (once it has finished executing)
	// The return of DeferredResult should be returned by the flow handler
	DeferredResult(FlowId) interface{}
}

type WorkflowRunner

type WorkflowRunner interface {
	SetFlowHandlers(map[string]FlowHandler) WorkflowRunner
	Run(funcname string, args interface{}) interface{}
}