Skip to main content

Crate runifold_workflow

Crate runifold_workflow 

Source
Expand description

Durable, capability-safe workflow and Agent orchestration for Runifold.

Structs§

AgentStep
Adapts a Runifold Agent to the canonical workflow step boundary.
AgentStepOutput
Canonical Agent workflow value.
ClaimedWorkflow
A workflow task and its fenced worker lease.
InMemoryWorkflowStore
Deterministic in-memory implementation of the distributed store contract.
LeaseDuration
Positive lease duration represented in whole milliseconds.
ParallelBranch
One explicitly budgeted branch of a parallel workflow node.
PredicateCondition
Adapts a closure into a durable workflow branch condition.
StaticWorkflowTaskGovernanceAuthorizer
Immutable in-process authorizer for simple deployments and tests.
StepId
Stable workflow node identity used by checkpoints and event streams.
SystemWorkflowClock
System clock used by default for ephemeral workflow queues.
SystemWorkflowWorkerSleeper
System-timer implementation for production workers.
WorkerId
Stable identity of a distributed workflow worker.
Workflow
Validated, immutable workflow definition.
WorkflowBudgetAuditCursor
Stable cursor for incrementally consuming one tenant’s durable budget audit.
WorkflowBudgetAuditEvent
Immutable audit fact recorded with a tenant-budget state transition.
WorkflowBudgetAuditLimit
Validated page size for tenant budget audit reads.
WorkflowBudgetAuditProjectionId
Stable identity of one independent tenant-budget audit projection.
WorkflowBudgetAuditProjectionLease
Fenced ownership of one named tenant-budget audit projection.
WorkflowBuilder
Fluent, validation-preserving workflow assembly.
WorkflowCheckpoint
Stable handle binding one workflow checkpoint identity to a store.
WorkflowCheckpointHistoryLimit
Maximum number of immutable checkpoint revisions returned by one query.
WorkflowCheckpointRevision
Immutable, typed view of one historical workflow checkpoint revision.
WorkflowCheckpointState
Versioned workflow state stored in a domain-neutral checkpoint envelope.
WorkflowDefinition
Executable workflow definition and its root authority policy.
WorkflowForkCommand
Idempotent command that creates a new execution from immutable history.
WorkflowInterruptCommand
Idempotent control-plane command for one human-review request.
WorkflowInterruptId
Stable identity of one durable human-review request.
WorkflowInterruptRequest
Persisted request presented to a human reviewer.
WorkflowLease
Fenced ownership of one workflow task.
WorkflowLineage
Immutable parent relationship of one forked workflow execution.
WorkflowOutcome
Successful terminal workflow state.
WorkflowRegistry
Immutable workflow-definition registry used by workers.
WorkflowSignal
Idempotent external event targeted at one workflow checkpoint.
WorkflowSignalId
Globally stable idempotency identity of one external signal publication.
WorkflowSignalName
Validated external-signal name.
WorkflowSignalRetention
Retention period for consumed and dead-letter signal identities.
WorkflowSignalSnapshot
Safe signal metadata that deliberately excludes the payload.
WorkflowStoreError
Typed workflow-store failure.
WorkflowSupervisor
Continuous, bounded-concurrency host for a WorkflowWorker.
WorkflowSupervisorConfig
Validated policy for continuous worker polling and bounded concurrency.
WorkflowSupervisorMetricSnapshot
Point-in-time, low-cardinality supervisor metric values.
WorkflowSupervisorMetrics
Lock-free cumulative supervisor metrics suitable for polling by an exporter.
WorkflowSupervisorReport
Outcomes observed during one supervisor lifetime.
WorkflowTask
One durable workflow task awaiting execution.
WorkflowTaskCleanupLease
Fenced ownership of one tenant’s terminal Task cleanup partition.
WorkflowTaskCleanupLimit
Maximum terminal Tasks removed by one fenced cleanup operation.
WorkflowTaskCleanupShard
Stable assignment of tenants across cleanup processes.
WorkflowTaskCleanupSupervisor
Discovers, shards, and cleans terminal Tasks with bounded concurrency.
WorkflowTaskCleanupSupervisorConfig
Validated bounds and timing for automatic terminal Task cleanup.
WorkflowTaskCleanupSupervisorMetricSnapshot
Point-in-time Task cleanup supervisor health snapshot.
WorkflowTaskCleanupSupervisorMetrics
Lock-free, low-cardinality health state for readiness and telemetry export.
WorkflowTaskCleanupSupervisorReport
Cumulative work performed by cleanup scans.
WorkflowTaskGovernanceAuthorizationError
Safe authorizer failure. Control-plane operations fail closed.
WorkflowTaskGovernanceControlPlane
Authorized facade over the destructive tombstone governance store.
WorkflowTaskLegalHold
Active or released legal-hold state retained for audit.
WorkflowTaskLegalHoldReason
Bounded operator-facing justification for a legal hold.
WorkflowTaskRetention
Minimum time a terminal workflow remains queryable before physical cleanup.
WorkflowTaskSnapshot
Safe operator snapshot of one workflow task.
WorkflowTaskTombstone
Immutable audit fact retained after a terminal Task is physically removed.
WorkflowTaskTombstoneApprovalInboxItem
One tenant-scoped durable approval inbox entry.
WorkflowTaskTombstoneApprovalInboxLimit
Maximum approval inbox entries returned by one bounded query.
WorkflowTaskTombstoneApprovalLease
Fenced, expiring ownership of one approval request.
WorkflowTaskTombstoneApprovalWindow
Time available for an independent principal to approve a purge intent.
WorkflowTaskTombstoneArchiveBatch
Exact ordered tombstone batch delivered to an external archive.
WorkflowTaskTombstoneArchiveBatchId
Stable idempotency identity for one ordered archive batch.
WorkflowTaskTombstoneArchiveError
Safe archive adapter failure.
WorkflowTaskTombstoneArchiveReport
Result of one bounded archive-and-confirm cycle.
WorkflowTaskTombstoneCursor
Stable cursor for paginating immutable terminal Task tombstones.
WorkflowTaskTombstoneExport
Monotonic confirmation that an external archive accepted a tenant prefix.
WorkflowTaskTombstoneExportReceipt
Opaque receipt proving an external archive accepted a tombstone prefix.
WorkflowTaskTombstoneLimit
Maximum tombstones returned by one audit page.
WorkflowTaskTombstonePurgeEvidence
Immutable aggregate evidence retained after detailed tombstones are purged.
WorkflowTaskTombstonePurgeId
Stable identity of one prepared purge set.
WorkflowTaskTombstonePurgeIntent
Prepared, bounded, and independently approvable tombstone purge set.
WorkflowTaskTombstonePurgeLimit
Maximum tombstones captured in one immutable purge intent.
WorkflowTaskTombstoneRejectionReason
Bounded operator justification for rejecting a purge intent.
WorkflowTaskTombstoneRetention
Minimum age of an exported tombstone before it may enter a purge intent.
WorkflowTenantBudgetPolicy
Persistent aggregate budget policy for one workflow tenant.
WorkflowTenantBudgetSnapshot
Safe point-in-time view of one tenant budget ledger.
WorkflowTenantId
Validated isolation identity for workflow admission and control-plane access.
WorkflowTenantListLimit
Validated page size for discovering tenants with configured budgets.
WorkflowTenantPolicy
Per-tenant workflow admission limits.
WorkflowWorker
One distributed workflow worker.

Enums§

ParallelBranchCheckpoint
Persisted state of one branch inside an in-flight parallel node.
WorkflowBudgetAuditKind
One durable tenant-budget decision.
WorkflowBudgetForfeitReason
Why uncertain reserved capacity was conservatively committed.
WorkflowBudgetReservationOutcome
Outcome of attempting to reserve a tenant budget envelope.
WorkflowBuildError
Invalid workflow definition.
WorkflowCancelOutcome
Result of an idempotent external workflow cancellation.
WorkflowCheckpointPhase
Persisted workflow execution phase.
WorkflowDisposition
Durable task disposition accepted from the current lease owner.
WorkflowError
Failure of workflow execution or recovery.
WorkflowFailurePolicy
How a registered definition handles non-infrastructure execution failures.
WorkflowForkOutcome
Result of an idempotent workflow fork command.
WorkflowForkPolicy
Explicit safety policy for forking a historical checkpoint.
WorkflowInterruptDecision
Human decision applied to one durable interrupt.
WorkflowInterruptDecisionOutcome
Result of submitting a typed human-review decision.
WorkflowInterruptOutcome
Canonical downstream value produced by a human-review node.
WorkflowResumePolicy
Recovery behavior for a workflow interrupted inside one node.
WorkflowSignalOutcome
Result of an idempotent signal publication.
WorkflowSignalState
Durable lifecycle state of an accepted signal identity.
WorkflowStepError
Failure produced by one workflow step.
WorkflowStoreErrorKind
Stable workflow-store failure category.
WorkflowTaskGovernanceError
Fail-closed tombstone governance failure.
WorkflowTaskGovernanceOutcome
Low-cardinality governance outcome for telemetry.
WorkflowTaskGovernancePermission
One tenant-scoped tombstone governance authority.
WorkflowTaskStatus
Durable workflow queue state.
WorkflowTaskTombstoneApprovalState
Durable operator-visible state of a purge approval request.
WorkflowTaskTombstoneArchiveErrorKind
Stable failure class for archive retry and observability policy.
WorkflowWait
Durable reason for releasing a worker lease without completing a workflow.
WorkflowWaitError
Invalid durable-wait or external-signal input.
WorkflowWaitOutcome
Canonical output of a signal-or-timeout workflow node.
WorkflowWake
Durable value that caused a suspended workflow to become claimable.
WorkflowWorkerError
Worker construction or execution failure.
WorkflowWorkerOutcome
Result of one worker claim-and-execute cycle.

Traits§

WorkflowClock
Store-authoritative time source used by the in-memory reference adapter.
WorkflowCondition
Pure, synchronous branch decision over canonical workflow data.
WorkflowStep
One executable, provider-neutral workflow node.
WorkflowStore
Asynchronous distributed workflow task-control boundary.
WorkflowTaskCleanupObserver
Optional low-cardinality observer for cleanup control-plane outcomes.
WorkflowTaskGovernanceAuthorizer
Pluggable policy boundary for principal, tenant, and permission checks.
WorkflowTaskGovernanceObserver
Optional observer that must not retain tenant or principal identities.
WorkflowTaskRetentionStore
Optional fenced control plane for physically removing terminal Tasks.
WorkflowTaskTombstoneArchive
Idempotent external archive boundary.
WorkflowTaskTombstoneGovernanceStore
Optional governance plane for detailed Task tombstone lifecycle.
WorkflowWorkerSleeper
Replaceable worker timer used by heartbeat supervision.

Type Aliases§

WorkflowFuture
A boxed, sendable workflow execution future.
WorkflowStepFuture
Boxed asynchronous workflow-step result.
WorkflowStoreFuture
A boxed asynchronous workflow-store operation.
WorkflowTaskGovernanceAuthorizationFuture
Borrowing future returned by a governance authorizer.
WorkflowTaskTombstoneArchiveFuture
Borrowing future returned by an external tombstone archive.
WorkflowWorkerSleepFuture
A boxed worker sleep operation.