Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2026 Changes in this version + type Checkpoint struct + EdgeStateData map[string]workflow.PortableValue + Parent *workflow.CheckpointInfo + RunnerData RunnerStateData + StateData *hashmap.Map[workflow.ScopeKey, workflow.PortableValue] + StepNumber int + WorkflowInfo WorkflowInfo + func (c *Checkpoint) IsInitial() bool + func (c *Checkpoint) MarshalJSON() ([]byte, error) + func (c *Checkpoint) UnmarshalJSON(data []byte) error + type CheckpointingHandle interface + Checkpoints func() []workflow.CheckpointInfo + IsCheckpointingEnabled func() bool + RestoreCheckpoint func(context.Context, workflow.CheckpointInfo) error + type Manager interface + Commit func(ctx context.Context, sessionID string, checkpoint *Checkpoint) (workflow.CheckpointInfo, error) + Lookup func(ctx context.Context, sessionID string, checkpointInfo workflow.CheckpointInfo) (*Checkpoint, error) + RetrieveIndex func(ctx context.Context, sessionID string, withParent *workflow.CheckpointInfo) ([]workflow.CheckpointInfo, error) + type PortableMessageEnvelope struct + Message workflow.PortableValue + MessageType workflow.TypeID + SourceID string + TargetID string + TraceContext map[string]string + type RunnerStateData struct + InstantiatedExecutors map[string]struct{} + OutstandingRequests []*workflow.ExternalRequest + QueuedMessages map[string][]*PortableMessageEnvelope + RequestOwners map[string]string + ResponsePortOwners map[string]string + type SessionCache struct + Cache map[workflow.CheckpointInfo]T + CheckpointIndex []workflow.CheckpointInfo + func (c *SessionCache[T]) Add(sessionID string, value T) workflow.CheckpointInfo + func (c *SessionCache[T]) AddCheckpointInfo(info workflow.CheckpointInfo, value T) bool + func (c *SessionCache[T]) Get(info workflow.CheckpointInfo) (T, bool) + func (c *SessionCache[T]) HasCheckpoints() bool + func (c *SessionCache[T]) IsInIndex(info workflow.CheckpointInfo) bool + func (c *SessionCache[T]) LastCheckpointInfo() (workflow.CheckpointInfo, bool) + type WorkflowInfo struct + Edges map[string][]workflow.EdgeInfo + Executors map[string]executorInfo + OutputExecutors map[string][]workflow.OutputTag + RequestPorts map[string]workflow.RequestPortInfo + StartExecutorID string + func NewWorkflowInfo(wf *workflow.Workflow) WorkflowInfo + func (w *WorkflowInfo) Match(wf *workflow.Workflow) bool
Go to main page