flowcore

Documentation

Index

• type Executor
  • func NewExecutor(flow *types.Flow, state *FlowState) *Executor
  • func (ex *Executor) NextState(nodeType types.NodeType, data map[string]string) (_nextState *FlowState, _nextNodes []*types.Node, _err error)
• type FlowState
  • func NewFlowState(pageID, psID, flowID dot.IntID) *FlowState
  • func (s *FlowState) String() string

Types

type Executor

type Executor struct {
	Flow  *types.Flow
	State *FlowState
}

func NewExecutor

func NewExecutor(flow *types.Flow, state *FlowState) *Executor

func (*Executor) NextState

func (ex *Executor) NextState(nodeType types.NodeType, data map[string]string) (_nextState *FlowState, _nextNodes []*types.Node, _err error)

type FlowState

type FlowState struct {
	PageID dot.IntID `json:"page_id"`

	PSID dot.IntID `json:"psid"`

	FlowID dot.IntID `json:"flow_id"`

	LastNodeID dot.IntID `json:"last_node_id"`

	NodeID dot.IntID `json:"node_id"`

	Extra map[string]string `json:"extra"`
}

func NewFlowState

func NewFlowState(pageID, psID, flowID dot.IntID) *FlowState

func (*FlowState) String

func (s *FlowState) String() string