Struct FlowIndexKeys 

pub struct FlowIndexKeys { /* private fields */ }

Flow-partition index keys.

Implementations

impl FlowIndexKeys

pub fn new(partition: &Partition) -> Self

pub fn flow_index(&self) -> String

ff:idx:{fp:N}:flow_index — SET of flow IDs on this partition. Used by the flow projector for cluster-safe discovery (replaces SCAN).

pub fn cancel_backlog(&self) -> String

ff:idx:{fp:N}:cancel_backlog — ZSET of flow IDs whose async cancel dispatch is still owed members. Score = grace-window expiry (unix ms). The cancel reconciler scanner ZRANGEBYSCOREs entries whose score <= now, drains their pending_cancels set, and ZREMs when empty. Live dispatch runs without waiting on this score, so the grace window just keeps the reconciler from fighting the happy path.

pub fn pending_cancel_groups(&self) -> String

ff:idx:{fp:N}:pending_cancel_groups — RFC-016 Stage C per-flow-partition SET of <flow_id>|<downstream_eid> tuples whose edgegroup has a non-empty sibling-cancel queue awaiting dispatch. Populated atomically by ff_resolve_dependency when the AnyOf/Quorum resolver flips to satisfied|impossible under OnSatisfied::CancelRemaining; drained by the dispatcher via ff_drain_sibling_cancel_group once per-sibling cancels have been acked. The sibling-cancel dispatcher scanner iterates this SET (cluster-safe) instead of scanning edgegroup hashes.