Versions in this module Expand all Collapse all v1 v1.0.4 Mar 26, 2020 Changes in this version + type Flow struct + FlowModel *model.Flow + func (a *Flow) CheckFlowInstanceTodo(flowInstanceID string) (bool, error) + func (a *Flow) CheckNodeCandidate(nodeInstanceID, userID string) (bool, error) + func (a *Flow) CreateFlow(flow *schema.Flow, nodes *schema.NodeOperating, forms *schema.FormOperating) error + func (a *Flow) CreateNodeInstance(flowInstanceID, nodeID string, inputData []byte, candidates []string) (string, error) + func (a *Flow) CreateNodeTiming(item *schema.NodeTiming) error + func (a *Flow) DeleteFlow(flowID string) error + func (a *Flow) DeleteNodeTiming(nodeInstanceID string) error + func (a *Flow) DoneFlowInstance(flowInstanceID string) error + func (a *Flow) DoneNodeInstance(nodeInstanceID, processor string, outData []byte) error + func (a *Flow) GetDoneByID(nodeInstanceID string) (*schema.FlowDoneResult, error) + func (a *Flow) GetDoneCount(userID string) (int64, error) + func (a *Flow) GetFlow(recordID string) (*schema.Flow, error) + func (a *Flow) GetFlowByCode(code string) (*schema.Flow, error) + func (a *Flow) GetFlowFormByNodeID(nodeID string) (*schema.Form, error) + func (a *Flow) GetFlowInstance(recordID string) (*schema.FlowInstance, error) + func (a *Flow) GetFlowInstanceByNode(nodeInstanceID string) (*schema.FlowInstance, error) + func (a *Flow) GetForm(formID string) (*schema.Form, error) + func (a *Flow) GetNode(recordID string) (*schema.Node, error) + func (a *Flow) GetNodeByFlowAndTypeCode(flowID, typeCode string) (*schema.Node, error) + func (a *Flow) GetNodeInstance(recordID string) (*schema.NodeInstance, error) + func (a *Flow) GetNodeProperty(nodeID string) (map[string]string, error) + func (a *Flow) GetTodoByID(nodeInstanceID string) (*schema.FlowTodoResult, error) + func (a *Flow) LaunchFlowInstance(flowCode, nodeCode, launcher string, inputData []byte) (*schema.NodeInstance, error) + func (a *Flow) LaunchFlowInstance2(flowID, userID string, status int, inputData []byte) (*schema.FlowInstance, *schema.NodeInstance, error) + func (a *Flow) QueryAllFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error) + func (a *Flow) QueryDone(typeCode, flowCode, userID string, lastTime int64, count int) ([]*schema.FlowDoneResult, error) + func (a *Flow) QueryDoneIDs(flowCode, userID string) ([]string, error) + func (a *Flow) QueryExpiredNodeTiming() ([]*schema.NodeTiming, error) + func (a *Flow) QueryFlowByCode(flowCode string) ([]*schema.Flow, error) + func (a *Flow) QueryFlowByIDs(flowIDs []string) ([]*schema.FlowQueryResult, error) + func (a *Flow) QueryFlowIDsByType(typeCodes ...string) ([]string, error) + func (a *Flow) QueryFlowVersion(recordID string) ([]*schema.FlowQueryResult, error) + func (a *Flow) QueryGroupFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error) + func (a *Flow) QueryHandleFlowInstanceResult(processor, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error) + func (a *Flow) QueryHistory(flowInstanceID string) ([]*schema.FlowHistoryResult, error) + func (a *Flow) QueryLastNodeInstance(flowInstanceID string) (*schema.NodeInstance, error) + func (a *Flow) QueryLastNodeInstances(flowInstanceIDs []string) (map[string]*schema.NodeInstance, error) + func (a *Flow) QueryLaunchFlowInstanceResult(launcher, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error) + func (a *Flow) QueryNodeAssignments(nodeID string) ([]*schema.NodeAssignment, error) + func (a *Flow) QueryNodeByTypeCodeAndFlowIDs(typeCode string, flowIDs ...string) ([]*schema.Node, error) + func (a *Flow) QueryNodeCandidates(nodeInstanceID string) ([]*schema.NodeCandidate, error) + func (a *Flow) QueryNodeRouters(sourceNodeID string) ([]*schema.NodeRouter, error) + func (a *Flow) QueryTodo(typeCode, flowCode, userID string, count int) ([]*schema.FlowTodoResult, error) + func (a *Flow) QueryTodoFlowInstanceResult(userID, typeCode, flowCode string, lastID int64, count int) ([]*schema.FlowInstanceResult, error) + func (a *Flow) QueryTodoPaginate(typeCode string, flowCode string, userID string, page int, pageSize int) (int, []*schema.FlowTodoResult, error) + func (a *Flow) StopFlowInstance(flowInstanceID string) error + func (a *Flow) UpdateFlowInfo(recordID string, info map[string]interface{}) error + func (a *Flow) UpdateFlowStatus(recordID string, status int) error
Go to main page