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.