Skip to main content

Module contracts

Module contracts 

Source
Expand description

Phase 1 function contracts — Args + Result types for each FCALL.

Each Args struct defines the typed inputs to a Valkey Function. Each Result enum defines the possible outcomes (success variants + error codes).

Modules§

decode
Canonical decoders for engine-owned hash shapes.

Structs§

AddExecutionToFlowArgs
AppendFrameArgs
ApplyDependencyToChildArgs
AttemptSummary
Currently-active attempt summary inside an ExecutionSnapshot.
BlockExecutionArgs
BudgetStatus
Operator-facing budget status snapshot (not an FCALL — direct HGETALL reads).
BufferSignalArgs
CancelExecutionArgs
CancelFlowArgs
ChangePriorityArgs
CheckAdmissionArgs
ClaimExecutionArgs
ClaimGrant
A claim grant issued by the scheduler for a specific execution.
ClaimResumedExecutionArgs
ClaimedExecution
ClaimedResumedExecution
CloseWaitpointArgs
CompleteExecutionArgs
CreateBudgetArgs
CreateExecutionArgs
CreateFlowArgs
CreatePendingWaitpointArgs
CreateQuotaPolicyArgs
DelayExecutionArgs
DeliverSignalArgs
EdgeSnapshot
Engine-decoupled read-model for one dependency edge.
EvaluateFlowEligibilityArgs
ExecutionInfo
Full execution info returned by Server::get_execution.
ExecutionSnapshot
Engine-decoupled read-model for one execution.
ExecutionSummary
Summary of an execution for list views.
ExpireExecutionArgs
ExpireSuspensionArgs
FailExecutionArgs
FlowSnapshot
Engine-decoupled read-model for one flow.
IssueClaimGrantArgs
IssueReclaimGrantArgs
LeaseSummary
Currently-held lease summary inside an ExecutionSnapshot.
ListExecutionsResult
Result of a list_executions query.
ListWaitpointHmacKidsArgs
MarkLeaseExpiredArgs
MoveToWaitingChildrenArgs
PendingWaitpointInfo
One entry in the read-only view of an execution’s active waitpoints.
PromoteBlockedToEligibleArgs
ReadFramesArgs
Inputs to ff_read_attempt_stream (XRANGE wrapper).
ReclaimExecutionArgs
ReclaimGrant
A reclaim grant issued for a resumed (attempt_interrupted) execution.
ReleaseAdmissionArgs
RenewLeaseArgs
ReplayExecutionArgs
ReportUsageArgs
ResetBudgetArgs
ResolveDependencyArgs
ResumeExecutionArgs
RevokeLeaseArgs
RotateWaitpointHmacSecretArgs
Args for ff_rotate_waitpoint_hmac_secret. Rotates the HMAC signing kid on ONE partition. Callers fan out across every partition themselves (ff-server does the parallel fan-out in rotate_waitpoint_secret; direct-Valkey consumers mirror the pattern).
SetExecutionTagsArgs
Args for ff_set_execution_tags. Tag keys MUST match ^[a-z][a-z0-9_]*\. — the caller-namespace rule — or the FCALL returns invalid_tag_key. Values are arbitrary strings. The map is ordered (BTreeMap) so two callers submitting the same logical set of tags produce identical ARGV.
SetFlowTagsArgs
Args for ff_set_flow_tags. Same namespace rule as SetExecutionTagsArgs. The Lua function also lazy-migrates any pre-58.4 reserved-namespace fields stashed inline on flow_core into the new tags key.
StageDependencyEdgeArgs
StateSummary
Summary of state after a mutation, returned by many functions.
StreamFrame
A single frame read from an attempt-scoped stream.
StreamFrames
Result of reading frames from an attempt stream — frames plus terminal signal so consumers can stop polling without a timeout fallback.
SuspendExecutionArgs
UnblockExecutionArgs
UpdateProgressArgs
VerifyingKid
WaitpointHmacKids
Snapshot of the waitpoint HMAC keystore on ONE partition.

Enums§

AddExecutionToFlowResult
AppendFrameResult
ApplyDependencyToChildResult
BlockExecutionResult
BufferSignalResult
CancelExecutionResult
CancelFlowResult
ChangePriorityResult
CheckAdmissionResult
ClaimExecutionResult
ClaimResumedExecutionResult
CloseWaitpointResult
CompleteExecutionResult
CreateBudgetResult
CreateExecutionResult
CreateFlowResult
CreatePendingWaitpointResult
CreateQuotaPolicyResult
DelayExecutionResult
DeliverSignalResult
EdgeDirection
Direction marker for crate::engine_backend::EngineBackend::list_edges.
EvaluateFlowEligibilityResult
ExpireExecutionResult
ExpireSuspensionResult
FailExecutionResult
Outcome of a fail_execution call.
IssueClaimGrantResult
IssueReclaimGrantResult
MarkLeaseExpiredResult
MoveToWaitingChildrenResult
PromoteBlockedToEligibleResult
ReadFramesResult
ReclaimExecutionResult
ReleaseAdmissionResult
RenewLeaseResult
ReplayExecutionResult
ReportUsageResult
ResetBudgetResult
ResolveDependencyResult
ResumeExecutionResult
RevokeLeaseResult
RotateWaitpointHmacSecretOutcome
Outcome of a single-partition rotation.
SetExecutionTagsResult
Result of ff_set_execution_tags.
SetFlowTagsResult
Result of ff_set_flow_tags.
StageDependencyEdgeResult
StreamCursor
Opaque cursor for attempt-stream reads/tails.
StreamCursorParseError
Error produced when parsing a StreamCursor from a string.
SuspendExecutionResult
UnblockExecutionResult
UpdateProgressResult

Constants§

STREAM_READ_HARD_CAP
Hard cap on the number of frames returned by a single read/tail call.