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).

Structs§

AddExecutionToFlowArgs
AppendFrameArgs
ApplyDependencyToChildArgs
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
EvaluateFlowEligibilityArgs
ExecutionInfo
Full execution info returned by Server::get_execution.
ExecutionSummary
Summary of an execution for list views.
ExpireExecutionArgs
ExpireSuspensionArgs
FailExecutionArgs
IssueClaimGrantArgs
IssueReclaimGrantArgs
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).
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
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.
StageDependencyEdgeResult
SuspendExecutionResult
UnblockExecutionResult
UpdateProgressResult

Constants§

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