inmemory

func (*Store) ActivateCompensationEntry ¶

func (s *Store) ActivateCompensationEntry(ctx context.Context, request workflowruntime.ActivateCompensationEntryRequest) (workflowruntime.ActivateCompensationEntryResult, error)

func (*Store) ActivateNodeRetry ¶

func (s *Store) ActivateNodeRetry(ctx context.Context, request workflowruntime.ActivateNodeRetryRequest) (workflowruntime.ActivateNodeRetryResult, error)

func (*Store) AdmitNode ¶

func (s *Store) AdmitNode(ctx context.Context, request workflowruntime.AdmitNodeRequest) (workflowruntime.AdmitNodeResult, error)

func (*Store) AppendEvent ¶

func (s *Store) AppendEvent(ctx context.Context, request workflowruntime.AppendEventRequest) (workflowruntime.Event, error)

AppendEvent atomically allocates a monotonic sequence within request.RunID.

func (*Store) ApplyExternalOperation ¶

func (s *Store) ApplyExternalOperation(ctx context.Context, request workflowruntime.ApplyExternalOperationRequest) (workflowruntime.ApplyExternalOperationResult, error)

ApplyExternalOperation atomically records pending progress or a terminal observation. Terminal application also closes the unfinished attempt and moves the waiting aggregate node to its selected outcome.

func (*Store) ApplyRunFailurePolicy ¶

func (s *Store) ApplyRunFailurePolicy(ctx context.Context, request workflowruntime.ApplyRunFailurePolicyRequest) (workflowruntime.ApplyRunFailurePolicyResult, error)

func (*Store) ApplyServiceHeartbeat ¶

func (s *Store) ApplyServiceHeartbeat(ctx context.Context, request workflowruntime.ApplyServiceHeartbeatRequest) (workflowruntime.ServiceSnapshot, error)

func (*Store) ApplyServiceReady ¶

func (s *Store) ApplyServiceReady(ctx context.Context, request workflowruntime.ApplyServiceReadyRequest) (workflowruntime.ApplyServiceReadyResult, error)

func (*Store) ApplyServiceStop ¶

func (s *Store) ApplyServiceStop(ctx context.Context, request workflowruntime.ApplyServiceStopRequest) (workflowruntime.ApplyServiceStopResult, error)

func (*Store) BeginManualCompensation ¶

func (s *Store) BeginManualCompensation(ctx context.Context, request workflowruntime.BeginManualCompensationRequest) (workflowruntime.FreezeCompensationResult, error)

func (*Store) BeginReplay ¶

func (s *Store) BeginReplay(ctx context.Context, request workflowruntime.BeginReplayRequest) (workflowruntime.BeginReplayResult, error)

func (*Store) BeginTerminalIntent ¶

func (s *Store) BeginTerminalIntent(ctx context.Context, request workflowruntime.BeginTerminalIntentRequest) (workflowruntime.BeginTerminalIntentResult, error)

func (*Store) BindNodeInputs ¶

func (s *Store) BindNodeInputs(ctx context.Context, request workflowruntime.BindNodeInputsRequest) (workflowruntime.BindNodeInputsResult, error)

func (*Store) BindPin ¶

func (s *Store) BindPin(ctx context.Context, request workflowruntime.BindPinRequest) (workflowruntime.BindPinResult, error)

func (*Store) CancelCompensation ¶

func (s *Store) CancelCompensation(ctx context.Context, request workflowruntime.CancelCompensationRequest) (workflowruntime.CompensationLedgerSnapshot, error)

func (*Store) ClaimNode ¶

func (s *Store) ClaimNode(ctx context.Context, request workflowruntime.ClaimNodeRequest) (workflowruntime.ClaimResult, error)

ClaimNode atomically attempts to acquire a ready node under claim-generation CAS. Non-ready nodes and live leases produce replayable negative results without exposing another owner's lease.

func (*Store) CompleteFanOut ¶

func (s *Store) CompleteFanOut(ctx context.Context, request workflowruntime.CompleteFanOutRequest) (workflowruntime.CompleteFanOutResult, error)

func (*Store) CompleteTerminalIntent ¶

func (s *Store) CompleteTerminalIntent(ctx context.Context, request workflowruntime.CompleteTerminalIntentRequest) (workflowruntime.CompleteTerminalIntentResult, error)

func (*Store) CreateNodeInvocation ¶

func (s *Store) CreateNodeInvocation(ctx context.Context, request workflowruntime.CreateNodeInvocationRequest) (workflowruntime.NodeInvocationSnapshot, error)

CreateNodeInvocation implements runtime.StateStore.

func (*Store) CreateRun ¶

func (s *Store) CreateRun(ctx context.Context, request workflowruntime.CreateRunRequest) (workflowruntime.RunSnapshot, workflowruntime.IdempotencyOutcome, error)

CreateRun implements runtime.StateStore.

func (*Store) ExpandFanOut ¶

func (s *Store) ExpandFanOut(ctx context.Context, request workflowruntime.ExpandFanOutRequest) (workflowruntime.ExpandFanOutResult, error)

func (*Store) FailCompensationEntry ¶

func (s *Store) FailCompensationEntry(ctx context.Context, request workflowruntime.FailCompensationEntryRequest) (workflowruntime.SealCompensationEntryResult, error)

func (*Store) FinishCompensableAttempt ¶

func (s *Store) FinishCompensableAttempt(ctx context.Context, request workflowruntime.FinishCompensableAttemptRequest) (workflowruntime.FinishCompensableAttemptResult, error)

func (*Store) FinishNodeAttempt ¶

func (s *Store) FinishNodeAttempt(ctx context.Context, request workflowruntime.FinishNodeAttemptRequest) (workflowruntime.FinishNodeAttemptResult, error)

FinishNodeAttempt atomically closes the latest unfinished running attempt, updates the aggregate node, clears its lease, and appends the derived event.

func (*Store) FreezeCompensation ¶

func (s *Store) FreezeCompensation(ctx context.Context, request workflowruntime.FreezeCompensationRequest) (workflowruntime.FreezeCompensationResult, error)

func (*Store) GetCacheEntry ¶

func (s *Store) GetCacheEntry(ctx context.Context, key string, now time.Time) (workflowruntime.CacheEntry, bool, error)

GetCacheEntry implements runtime.StateStore.

func (*Store) GetPinnedValue ¶

func (s *Store) GetPinnedValue(ctx context.Context, key string, now time.Time) (workflowruntime.PinnedValue, bool, error)

GetPinnedValue implements runtime.StateStore.

func (*Store) InspectSchedulerResources ¶

func (s *Store) InspectSchedulerResources(ctx context.Context, query workflowruntime.SchedulerResourceQuery) (workflowruntime.SchedulerResourceState, error)

func (*Store) ListAttempts ¶

func (s *Store) ListAttempts(ctx context.Context, id workflowruntime.NodeInvocationID) ([]workflowruntime.AttemptSnapshot, error)

ListAttempts implements runtime.StateStore in attempt-number order.

func (*Store) ListChildRuns ¶

func (s *Store) ListChildRuns(ctx context.Context, parent workflowruntime.RunID) ([]workflowruntime.ChildRunLink, error)

func (*Store) ListCompensationEntries ¶

func (s *Store) ListCompensationEntries(ctx context.Context, runID workflowruntime.RunID) ([]workflowruntime.CompensationEntrySnapshot, error)

func (*Store) ListEvents ¶

func (s *Store) ListEvents(ctx context.Context, query workflowruntime.EventQuery) ([]workflowruntime.Event, error)

ListEvents implements runtime.StateStore in ascending per-run sequence.

func (*Store) ListPinnedValues ¶

func (s *Store) ListPinnedValues(ctx context.Context, now time.Time) ([]workflowruntime.PinnedValue, error)

ListPinnedValues implements runtime.StateStore in key order.

func (*Store) ListRunInvocations ¶

func (s *Store) ListRunInvocations(ctx context.Context, runID workflowruntime.RunID) ([]workflowruntime.NodeInvocationSnapshot, error)

func (*Store) LoadAttempt ¶

func (s *Store) LoadAttempt(ctx context.Context, id workflowruntime.AttemptID) (workflowruntime.AttemptSnapshot, error)

LoadAttempt implements runtime.StateStore.

func (*Store) LoadCompensationEntryByHandler ¶

func (s *Store) LoadCompensationEntryByHandler(ctx context.Context, id workflowruntime.NodeInvocationID) (workflowruntime.CompensationEntrySnapshot, error)

func (*Store) LoadCompensationLedger ¶

func (s *Store) LoadCompensationLedger(ctx context.Context, runID workflowruntime.RunID) (workflowruntime.CompensationLedgerSnapshot, error)

func (*Store) LoadControlDecision ¶

func (s *Store) LoadControlDecision(ctx context.Context, id workflowruntime.ControlDecisionID) (workflowruntime.ControlDecisionSnapshot, error)

func (*Store) LoadExternalOperation ¶

func (s *Store) LoadExternalOperation(ctx context.Context, id workflowruntime.AttemptID) (workflowruntime.ExternalOperationSnapshot, error)

LoadExternalOperation returns the durable operation bound to one attempt.

func (*Store) LoadFanOut ¶

func (s *Store) LoadFanOut(ctx context.Context, parent workflowruntime.NodeInvocationID) (workflowruntime.FanOutSnapshot, error)

func (*Store) LoadFanOutItemResults ¶

func (s *Store) LoadFanOutItemResults(ctx context.Context, parent workflowruntime.NodeInvocationID) ([]workflowruntime.FanOutItemResult, error)

func (*Store) LoadMemoEntry ¶

func (s *Store) LoadMemoEntry(ctx context.Context, key string) (workflowruntime.MemoEntry, error)

func (*Store) LoadNodeInvocation ¶

func (s *Store) LoadNodeInvocation(ctx context.Context, id workflowruntime.NodeInvocationID) (workflowruntime.NodeInvocationSnapshot, error)

LoadNodeInvocation implements runtime.StateStore.

func (*Store) LoadPin ¶

func (s *Store) LoadPin(ctx context.Context, id workflowruntime.NodeInvocationID) (workflowruntime.PinBinding, error)

func (*Store) LoadPlan ¶

func (s *Store) LoadPlan(ctx context.Context, digest string) (workflowruntime.PlanRef, error)

LoadPlan implements runtime.StateStore.

func (*Store) LoadReplayProvenance ¶

func (s *Store) LoadReplayProvenance(ctx context.Context, runID workflowruntime.RunID) (workflowruntime.ReplayProvenance, error)

func (*Store) LoadRetryActivation ¶

func (s *Store) LoadRetryActivation(ctx context.Context, id string) (workflowruntime.RetryActivationSnapshot, error)

func (*Store) LoadRun ¶

func (s *Store) LoadRun(ctx context.Context, id workflowruntime.RunID) (workflowruntime.RunSnapshot, error)

LoadRun implements runtime.StateStore.

func (*Store) LoadRunPolicyDecision ¶

func (s *Store) LoadRunPolicyDecision(ctx context.Context, runID workflowruntime.RunID) (workflowruntime.RunPolicyDecisionSnapshot, error)

func (*Store) LoadService ¶

func (s *Store) LoadService(ctx context.Context, start workflowruntime.NodeInvocationID) (workflowruntime.ServiceSnapshot, error)

func (*Store) LoadTerminalIntent ¶

func (s *Store) LoadTerminalIntent(ctx context.Context, runID workflowruntime.RunID) (workflowruntime.TerminalIntentSnapshot, error)

func (*Store) LoadValueRecord ¶

func (s *Store) LoadValueRecord(ctx context.Context, ref values.ValueSetRef) (workflowruntime.ValueRecord, error)

func (*Store) LoadValues ¶

func (s *Store) LoadValues(ctx context.Context, ref values.ValueSetRef) (values.ValueSet, error)

LoadValues implements runtime.StateStore.

func (*Store) LoadWait ¶

func (s *Store) LoadWait(ctx context.Context, id workflowruntime.WaitID) (workflowruntime.WaitSnapshot, error)

LoadWait implements runtime.StateStore.

func (*Store) LoadWaitContinuation ¶

func (s *Store) LoadWaitContinuation(ctx context.Context, id workflowruntime.AttemptID) (workflowruntime.WaitSnapshot, error)

LoadWaitContinuation returns the most recently resolved resumed wait bound to exactly id. Open and other terminal states are never continuations.

func (*Store) PrepareServiceStart ¶

func (s *Store) PrepareServiceStart(ctx context.Context, request workflowruntime.PrepareServiceStartRequest) (workflowruntime.ServiceSnapshot, error)

func (*Store) PutCacheEntry ¶

func (s *Store) PutCacheEntry(ctx context.Context, entry workflowruntime.CacheEntry) error

PutCacheEntry implements runtime.StateStore.

func (*Store) PutPinnedValue ¶

func (s *Store) PutPinnedValue(ctx context.Context, pin workflowruntime.PinnedValue) error

PutPinnedValue implements runtime.StateStore.

func (*Store) ReconcileCrashedAttempt ¶

func (s *Store) ReconcileCrashedAttempt(ctx context.Context, request workflowruntime.ReconcileCrashedAttemptRequest) (workflowruntime.ReconcileCrashedAttemptResult, error)

func (*Store) RecordChildRun ¶

func (s *Store) RecordChildRun(ctx context.Context, link workflowruntime.ChildRunLink) error

func (*Store) RecordControlDecision ¶

func (s *Store) RecordControlDecision(ctx context.Context, request workflowruntime.RecordControlDecisionRequest) (workflowruntime.RecordControlDecisionResult, error)

func (*Store) RecordExternalActivation ¶

func (s *Store) RecordExternalActivation(ctx context.Context, request workflowruntime.ExternalActivationRequest) (workflowruntime.ExternalActivationSnapshot, workflowruntime.IdempotencyOutcome, error)

RecordExternalActivation implements runtime.StateStore.

func (*Store) RecordMemoEntry ¶

func (s *Store) RecordMemoEntry(ctx context.Context, entry workflowruntime.MemoEntry) (workflowruntime.MemoEntry, workflowruntime.IdempotencyOutcome, error)

func (*Store) RecordPlan ¶

func (s *Store) RecordPlan(ctx context.Context, plan workflowruntime.PlanRef) error

RecordPlan implements runtime.StateStore.

func (*Store) RecoverCancellationIntents ¶

func (s *Store) RecoverCancellationIntents(ctx context.Context, query workflowruntime.CancellationIntentQuery) ([]workflowruntime.CancellationIntentSnapshot, error)

func (*Store) RecoverCompensation ¶

func (s *Store) RecoverCompensation(ctx context.Context, limit int) ([]workflowruntime.CompensationLedgerSnapshot, error)

func (*Store) RecoverExternalOperations ¶

func (s *Store) RecoverExternalOperations(ctx context.Context, query workflowruntime.ExternalOperationQuery) ([]workflowruntime.ExternalOperationSnapshot, error)

RecoverExternalOperations returns pending work in deterministic storage order without assigning observation fairness or ownership policy.

func (*Store) RecoverOpenWaits ¶

func (s *Store) RecoverOpenWaits(ctx context.Context, query workflowruntime.OpenWaitQuery) ([]workflowruntime.WaitSnapshot, error)

RecoverOpenWaits returns storage state only; callers own scheduling policy.

func (*Store) RecoverRetryActivations ¶

func (s *Store) RecoverRetryActivations(ctx context.Context, query workflowruntime.RetryActivationQuery) ([]workflowruntime.RetryActivationSnapshot, error)

func (*Store) RecoverServiceStart ¶

func (s *Store) RecoverServiceStart(ctx context.Context, request workflowruntime.RecoverServiceStartRequest) (workflowruntime.SuspendServiceStartResult, error)

func (*Store) RecoverServices ¶

func (s *Store) RecoverServices(ctx context.Context, query workflowruntime.ServiceQuery) ([]workflowruntime.ServiceSnapshot, error)

func (*Store) Recovery ¶

func (s *Store) Recovery(ctx context.Context, query workflowruntime.RecoveryQuery) (workflowruntime.RecoverySnapshot, error)

Recovery implements runtime.StateStore with deterministic category ordering.

func (*Store) ReleaseNodeClaim ¶

func (s *Store) ReleaseNodeClaim(ctx context.Context, request workflowruntime.ReleaseClaimRequest) error

ReleaseNodeClaim implements runtime.StateStore.

func (*Store) RenewNodeLease ¶

func (s *Store) RenewNodeLease(ctx context.Context, request workflowruntime.RenewLeaseRequest) (workflowruntime.ClaimLease, error)

RenewNodeLease implements runtime.StateStore.

func (*Store) RequestExternalOperationCancel ¶

func (s *Store) RequestExternalOperationCancel(ctx context.Context, request workflowruntime.RequestExternalOperationCancelRequest) (workflowruntime.RequestExternalOperationCancelResult, error)

RequestExternalOperationCancel persists cancel intent before an adapter call.

func (*Store) RequestRunCancellation ¶

func (s *Store) RequestRunCancellation(ctx context.Context, request workflowruntime.RequestRunCancellationRequest) (workflowruntime.RequestRunCancellationResult, error)

func (*Store) RequestRunCancellationWithFinalizers ¶

func (s *Store) RequestRunCancellationWithFinalizers(ctx context.Context, request workflowruntime.RequestRunCancellationWithFinalizersRequest) (workflowruntime.RequestRunCancellationWithFinalizersResult, error)

func (*Store) ResolveCancellationIntent ¶

func (s *Store) ResolveCancellationIntent(ctx context.Context, request workflowruntime.ResolveCancellationIntentRequest) (workflowruntime.ResolveCancellationIntentResult, error)

func (*Store) ResumeNodeWait ¶

func (s *Store) ResumeNodeWait(ctx context.Context, request workflowruntime.ResumeNodeWaitRequest) (workflowruntime.ResumeWaitResult, error)

ResumeNodeWait is the common atomic data-plane mutation used by every wake source after the host authorizer has accepted the responder.

func (*Store) RetryCompensation ¶

func (s *Store) RetryCompensation(ctx context.Context, request workflowruntime.RetryCompensationRequest) (workflowruntime.CompensationLedgerSnapshot, error)

func (*Store) ReuseNodeOutputs ¶

func (s *Store) ReuseNodeOutputs(ctx context.Context, request workflowruntime.ReuseNodeOutputsRequest) (workflowruntime.ReuseNodeOutputsResult, error)

func (*Store) SaveNodeInvocation ¶

func (s *Store) SaveNodeInvocation(ctx context.Context, request workflowruntime.SaveNodeInvocationRequest) (workflowruntime.NodeInvocationSnapshot, error)

SaveNodeInvocation implements runtime.StateStore.

func (*Store) SaveRun ¶

func (s *Store) SaveRun(ctx context.Context, request workflowruntime.SaveRunRequest) (workflowruntime.RunSnapshot, error)

SaveRun implements runtime.StateStore.

func (*Store) SaveValues ¶

func (s *Store) SaveValues(ctx context.Context, request workflowruntime.SaveValuesRequest) (values.ValueSetRef, error)

SaveValues implements runtime.StateStore.

func (*Store) ScheduleNodeRetry ¶

func (s *Store) ScheduleNodeRetry(ctx context.Context, request workflowruntime.ScheduleNodeRetryRequest) (workflowruntime.ScheduleNodeRetryResult, error)

func (*Store) SealCompensationEntry ¶

func (s *Store) SealCompensationEntry(ctx context.Context, request workflowruntime.SealCompensationEntryRequest) (workflowruntime.SealCompensationEntryResult, error)

func (*Store) StartNodeAttempt ¶

func (s *Store) StartNodeAttempt(ctx context.Context, request workflowruntime.StartNodeAttemptRequest) (workflowruntime.StartNodeAttemptResult, error)

StartNodeAttempt atomically starts exactly LatestAttempt+1.

func (*Store) SuspendExternalOperation ¶

func (s *Store) SuspendExternalOperation(ctx context.Context, request workflowruntime.SuspendExternalOperationRequest) (workflowruntime.SuspendExternalOperationResult, error)

SuspendExternalOperation atomically persists adapter-owned work, moves the aggregate node to waiting, and releases the worker lease.

func (*Store) SuspendNodeWait ¶

func (s *Store) SuspendNodeWait(ctx context.Context, request workflowruntime.SuspendNodeWaitRequest) (workflowruntime.SuspendWaitResult, error)

SuspendNodeWait atomically materializes an open wait, changes the running node to waiting, releases its lease, and appends both durable facts.

func (*Store) SuspendServiceStart ¶

func (s *Store) SuspendServiceStart(ctx context.Context, request workflowruntime.SuspendServiceStartRequest) (workflowruntime.SuspendServiceStartResult, error)

func (*Store) SuspendServiceTeardown ¶

func (s *Store) SuspendServiceTeardown(ctx context.Context, request workflowruntime.SuspendServiceTeardownRequest) (workflowruntime.SuspendServiceTeardownResult, error)

func (*Store) TimeoutWait ¶

func (s *Store) TimeoutWait(ctx context.Context, request workflowruntime.TimeoutWaitRequest) (workflowruntime.WaitTimeoutResult, error)

TimeoutWait atomically marks an open wait, its waiting attempt, and its node timed out while appending all derived events under one store lock.

func (*Store) TransitionNode ¶

func (s *Store) TransitionNode(ctx context.Context, request workflowruntime.NodeTransitionRequest) (workflowruntime.NodeTransitionResult, error)

TransitionNode atomically validates and persists a non-attempt lifecycle edge and its derived event.

func (*Store) TransitionRun ¶

func (s *Store) TransitionRun(ctx context.Context, request workflowruntime.RunTransitionRequest) (workflowruntime.RunTransitionResult, error)

TransitionRun atomically validates and persists a run status change and its derived lifecycle event.