List of all items

Structs

• backend::AppendFrameOutcome
• backend::BackendConfig
• backend::BackendRetry
• backend::BackendTimeouts
• backend::BestEffortLiveConfig
• backend::CapabilitySet
• backend::ClaimPolicy
• backend::CompletionPayload
• backend::FailureReason
• backend::Frame
• backend::Handle
• backend::HandleOpaque
• backend::LeaseRenewal
• backend::PendingWaitpoint
• backend::PostgresConnection
• backend::ReclaimToken
• backend::ResumeSignal
• backend::ScannerFilter
• backend::SummaryDocument
• backend::UsageDimensions
• backend::ValkeyConnection
• backend::WaitpointHmac
• backend::WaitpointSpec
• capability::BackendIdentity
• capability::Capabilities
• capability::Supports
• capability::Version
• caps::CapabilityRequirement
• contracts::AddExecutionToFlowArgs
• contracts::AdditionalWaitpointBinding
• contracts::AppendFrameArgs
• contracts::ApplyDependencyToChildArgs
• contracts::AttemptSummary
• contracts::BlockExecutionArgs
• contracts::BudgetStatus
• contracts::BufferSignalArgs
• contracts::CancelExecutionArgs
• contracts::CancelFlowArgs
• contracts::ChangePriorityArgs
• contracts::CheckAdmissionArgs
• contracts::ClaimExecutionArgs
• contracts::ClaimForWorkerArgs
• contracts::ClaimGrant
• contracts::ClaimResumedExecutionArgs
• contracts::ClaimedExecution
• contracts::ClaimedResumedExecution
• contracts::CloseWaitpointArgs
• contracts::CompleteExecutionArgs
• contracts::CompositeValidationError
• contracts::CreateBudgetArgs
• contracts::CreateExecutionArgs
• contracts::CreateFlowArgs
• contracts::CreatePendingWaitpointArgs
• contracts::CreateQuotaPolicyArgs
• contracts::DelayExecutionArgs
• contracts::DeliverSignalArgs
• contracts::EdgeGroupSnapshot
• contracts::EdgeSnapshot
• contracts::EvaluateFlowEligibilityArgs
• contracts::ExecutionInfo
• contracts::ExecutionSnapshot
• contracts::ExecutionSummary
• contracts::ExpireExecutionArgs
• contracts::ExpireSuspensionArgs
• contracts::FailExecutionArgs
• contracts::FlowSnapshot
• contracts::FlowSummary
• contracts::IdempotencyKey
• contracts::IssueClaimGrantArgs
• contracts::IssueReclaimGrantArgs
• contracts::LeaseSummary
• contracts::ListExecutionsPage
• contracts::ListExecutionsResult
• contracts::ListFlowsPage
• contracts::ListLanesPage
• contracts::ListPendingWaitpointsArgs
• contracts::ListPendingWaitpointsResult
• contracts::ListSuspendedPage
• contracts::ListWaitpointHmacKidsArgs
• contracts::MarkLeaseExpiredArgs
• contracts::MoveToWaitingChildrenArgs
• contracts::PendingWaitpointInfo
• contracts::PromoteBlockedToEligibleArgs
• contracts::ReadFramesArgs
• contracts::ReclaimExecutionArgs
• contracts::ReclaimGrant
• contracts::ReleaseAdmissionArgs
• contracts::RenewLeaseArgs
• contracts::ReplayExecutionArgs
• contracts::ReportUsageAdminArgs
• contracts::ReportUsageArgs
• contracts::ResetBudgetArgs
• contracts::ResolveDependencyArgs
• contracts::ResumeExecutionArgs
• contracts::ResumePolicy
• contracts::RevokeLeaseArgs
• contracts::RotateWaitpointHmacSecretAllArgs
• contracts::RotateWaitpointHmacSecretAllEntry
• contracts::RotateWaitpointHmacSecretAllResult
• contracts::RotateWaitpointHmacSecretArgs
• contracts::SeedWaitpointHmacSecretArgs
• contracts::SetEdgeGroupPolicyArgs
• contracts::SetExecutionTagsArgs
• contracts::SetFlowTagsArgs
• contracts::StageDependencyEdgeArgs
• contracts::StateSummary
• contracts::StreamFrame
• contracts::StreamFrames
• contracts::SuspendArgs
• contracts::SuspendExecutionArgs
• contracts::SuspendOutcomeDetails
• contracts::SuspendedExecutionEntry
• contracts::UnblockExecutionArgs
• contracts::UpdateProgressArgs
• contracts::VerifyingKid
• contracts::WaitpointHmacKids
• handle_codec::DecodedHandle
• handle_codec::HandlePayload
• keys::BudgetKeyContext
• keys::ExecKeyContext
• keys::FlowIndexKeys
• keys::FlowKeyContext
• keys::IndexKeys
• keys::QuotaKeyContext
• partition::Crc16SoloPartitioner
• partition::Partition
• partition::PartitionConfig
• partition::PartitionKey
• policy::ExecutionPolicy
• policy::FallbackPolicy
• policy::FallbackTier
• policy::RetryPolicy
• policy::RoutingRequirements
• policy::StreamPolicy
• policy::SuspensionPolicy
• policy::TimeoutPolicy
• state::StateVector
• stream_events::CompletionEvent
• stream_events::SignalDeliveryEvent
• stream_subscribe::StreamCursor
• types::AttemptId
• types::AttemptIndex
• types::BudgetId
• types::EdgeId
• types::ExecutionId
• types::FlowId
• types::LaneId
• types::LeaseEpoch
• types::LeaseFence
• types::LeaseId
• types::Namespace
• types::QuotaPolicyId
• types::SignalId
• types::SuspensionId
• types::TimestampMs
• types::WaitpointId
• types::WaitpointKey
• types::WaitpointToken
• types::WorkerId
• types::WorkerInstanceId

Enums

• backend::BackendConnection
• backend::BackendTag
• backend::CancelFlowPolicy
• backend::CancelFlowWait
• backend::FailOutcome
• backend::FailureClass
• backend::FrameKind
• backend::HandleKind
• backend::PatchKind
• backend::PrepareOutcome
• backend::StreamMode
• backend::TailVisibility
• backend::WaitpointKind
• contracts::AddExecutionToFlowResult
• contracts::AppendFrameResult
• contracts::ApplyDependencyToChildResult
• contracts::BlockExecutionResult
• contracts::BufferSignalResult
• contracts::CancelExecutionResult
• contracts::CancelFlowHeader
• contracts::CancelFlowResult
• contracts::ChangePriorityResult
• contracts::CheckAdmissionResult
• contracts::ClaimExecutionResult
• contracts::ClaimForWorkerOutcome
• contracts::ClaimResumedExecutionResult
• contracts::CloseWaitpointResult
• contracts::CompleteExecutionResult
• contracts::CompositeBody
• contracts::CountKind
• contracts::CreateBudgetResult
• contracts::CreateExecutionResult
• contracts::CreateFlowResult
• contracts::CreatePendingWaitpointResult
• contracts::CreateQuotaPolicyResult
• contracts::DelayExecutionResult
• contracts::DeliverSignalResult
• contracts::EdgeDependencyPolicy
• contracts::EdgeDirection
• contracts::EdgeGroupState
• contracts::EvaluateFlowEligibilityResult
• contracts::ExpireExecutionResult
• contracts::ExpireSuspensionResult
• contracts::FailExecutionResult
• contracts::FlowStatus
• contracts::IssueClaimGrantResult
• contracts::IssueReclaimGrantResult
• contracts::MarkLeaseExpiredResult
• contracts::MoveToWaitingChildrenResult
• contracts::OnSatisfied
• contracts::PromoteBlockedToEligibleResult
• contracts::ReadFramesResult
• contracts::ReclaimExecutionResult
• contracts::ReleaseAdmissionResult
• contracts::RenewLeaseResult
• contracts::ReplayExecutionResult
• contracts::ReportUsageResult
• contracts::ResetBudgetResult
• contracts::ResolveDependencyResult
• contracts::ResumeCondition
• contracts::ResumeExecutionResult
• contracts::ResumeTarget
• contracts::RevokeLeaseResult
• contracts::RotateWaitpointHmacSecretOutcome
• contracts::SeedOutcome
• contracts::SetEdgeGroupPolicyResult
• contracts::SetExecutionTagsResult
• contracts::SetFlowTagsResult
• contracts::SignalMatcher
• contracts::StageDependencyEdgeResult
• contracts::StreamCursor
• contracts::StreamCursorParseError
• contracts::SuspendExecutionResult
• contracts::SuspendOutcome
• contracts::SuspensionReasonCode
• contracts::SuspensionRequester
• contracts::TimeoutBehavior
• contracts::UnblockExecutionResult
• contracts::UpdateProgressResult
• contracts::WaitpointBinding
• engine_error::BackendError
• engine_error::BackendErrorKind
• engine_error::BugKind
• engine_error::ConflictKind
• engine_error::ContentionKind
• engine_error::EngineError
• engine_error::StateKind
• engine_error::ValidationKind
• error::ErrorClass
• handle_codec::HandleDecodeError
• partition::PartitionFamily
• partition::PartitionKeyParseError
• policy::BackoffStrategy
• state::AttemptLifecycle
• state::AttemptState
• state::AttemptType
• state::BlockingReason
• state::EligibilityState
• state::LaneState
• state::LifecyclePhase
• state::OwnershipState
• state::PublicState
• state::TerminalOutcome
• stream_events::CompletionOutcome
• stream_events::InstanceTagEvent
• stream_events::LeaseHistoryEvent
• stream_events::SignalDeliveryEffect
• types::CancelSource
• types::ExecutionIdParseError
• types::LaneIdError

Traits

• completion_backend::CompletionBackend
• engine_backend::EngineBackend
• partition::SoloPartitioner

Functions

• caps::matches
• caps::matches_csv
• contracts::decode::build_edge_snapshot
• contracts::decode::build_execution_snapshot
• contracts::decode::build_flow_snapshot
• engine_backend::cancel_flow_wait_deadline
• engine_backend::wait_for_flow_cancellation
• engine_error::backend_context
• handle_codec::decode
• handle_codec::encode
• hash::fnv1a_u16_mod
• hash::fnv1a_u64
• hash::fnv1a_xor8hex
• keys::budget_attach_key
• keys::budget_policies_index
• keys::budget_resets_key
• keys::global_config_partitions
• keys::idempotency_key
• keys::lane_config_key
• keys::lane_counts_key
• keys::lanes_index_key
• keys::namespace_executions_key
• keys::noop_key
• keys::quota_attach_key
• keys::quota_policies_index
• keys::tag_index_key
• keys::usage_dedup_key
• keys::waitpoint_key_resolution
• keys::worker_caps_key
• keys::worker_key
• keys::workers_capability_key
• keys::workers_index_key
• partition::budget_partition
• partition::execution_partition
• partition::flow_partition
• partition::quota_partition
• partition::solo_partition
• partition::solo_partition_with
• stream_subscribe::decode_postgres_event_cursor
• stream_subscribe::decode_valkey_cursor
• stream_subscribe::encode_postgres_event_cursor
• stream_subscribe::encode_valkey_cursor

Type Aliases

• completion_backend::CompletionStream
• stream_events::CompletionSubscription
• stream_events::InstanceTagSubscription
• stream_events::LeaseHistorySubscription
• stream_events::SignalDeliverySubscription

Constants

• backend::SUMMARY_NULL_SENTINEL
• contracts::MAX_COMPOSITE_DEPTH
• contracts::STREAM_READ_HARD_CAP
• contracts::decode::EDGE_KNOWN_FIELDS
• contracts::decode::FLOW_CORE_KNOWN_FIELDS
• keys::USAGE_DEDUP_KEY_PREFIX
• policy::CAPS_MAX_BYTES
• policy::CAPS_MAX_TOKENS
• stream_subscribe::POSTGRES_CURSOR_PREFIX
• stream_subscribe::VALKEY_CURSOR_PREFIX
• types::LANE_ID_MAX_BYTES