Versions in this module Expand all Collapse all v1 v1.0.0 Jan 15, 2024 Changes in this version + func RecordSnapshot(stateRecordingMode RecordingMode) bool + func RecordSteps(stateRecordingMode RecordingMode) bool + func UpdateFlow(s *SnapshotBase, change *change.Flow) + func UpdateLinks(snapshot *SnapshotBase, linkId int, change *change.Link) + func UpdateQueue(fs *Snapshot, id int, queueChg *change.Queue, first *int) bool + func UpdateTasks(snapshot *SnapshotBase, taskId string, change *change.Task) + type FlowInfo struct + EndTime string + ExecutionTime string + FlowInputs map[string]interface{} + FlowName string + FlowStatus string + FlowURI string + HostId string + Id string + OriginalInstanceId string + RerunCount int + StartTime string + Status int + type FlowState struct + AppName string + AppVersion string + EndTime time.Time + FlowInputs map[string]interface{} + FlowInstanceId string + FlowName string + FlowOutputs map[string]interface{} + FlowStats string + HostId string + OriginalInstanceId string + RerunCount int + StartTime time.Time + UserId string + type Link struct + Id int + Status int + type Recorder interface + RecordDone func(state *FlowState) error + RecordSnapshot func(snapshot *Snapshot) error + RecordStart func(state *FlowState) error + RecordStep func(step *Step) error + type RecordingMode string + const RecordingModeDebugger + const RecordingModeFull + const RecordingModeOff + const RecordingModeSnapshot + const RecordingModeStep + func ToRecordingMode(mode interface{}) (RecordingMode, error) + type Snapshot struct + Id string + Subflows []*Subflow + WorkQueue []*WorkItem + func StepsToSnapshot(flowId string, steps []*Step) *Snapshot + type SnapshotBase struct + Attrs map[string]interface{} + FlowURI string + Links []*Link + Status int + Tasks []*Task + type Step struct + EndTime time.Time + FlowChanges map[int]*change.Flow + FlowId string + Id int + QueueChanges map[int]*change.Queue + Rerun bool + StartTime time.Time + type Subflow struct + Id int + TaskId string + type Task struct + Id string + Status int + type WorkItem struct + ID int + SubflowId int + TaskId string