Versions in this module Expand all Collapse all v0 v0.1.1 Jul 16, 2025 v0.1.0 Jul 15, 2025 Changes in this version + const BatchCompleteAction + const DefaultAction + type Flow struct + func NewFlow() *Flow + func (f *Flow) Run(shared *SharedState) string + func (f *Flow) Start(node *Node) *Flow + func (f *Flow) StartNode() *Node + type Node struct + func NewNode() *Node + func (n *Node) GetParam(key string) interface{} + func (n *Node) GetSuccessors() map[string]*Node + func (n *Node) Next(node *Node, action string) *Node + func (n *Node) Run(shared *SharedState) string + func (n *Node) SetExecFunc(fn func(interface{}) (interface{}, error)) + func (n *Node) SetParams(params map[string]interface{}) + func (n *Node) SetPostFunc(fn func(*SharedState, interface{}, interface{}) string) + func (n *Node) SetPrepFunc(fn func(*SharedState) interface{}) + type SharedState struct + func NewSharedState() *SharedState + func (s *SharedState) Append(key string, value interface{}) + func (s *SharedState) Get(key string) interface{} + func (s *SharedState) GetInt(key string) int + func (s *SharedState) GetSlice(key string) []interface{} + func (s *SharedState) Set(key string, value interface{})
Go to main page