Struct IndexKeys 

pub struct IndexKeys { /* private fields */ }

Index keys scoped to a single execution partition.

Implementations

impl IndexKeys

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

pub fn lane_eligible(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:eligible

pub fn lane_delayed(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:delayed

pub fn lane_active(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:active

pub fn lane_terminal(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:terminal

pub fn lane_blocked_dependencies(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:blocked:dependencies

pub fn lane_blocked_budget(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:blocked:budget

pub fn lane_blocked_quota(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:blocked:quota

pub fn lane_blocked_route(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:blocked:route

pub fn lane_blocked_operator(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:blocked:operator

pub fn lane_suspended(&self, lane_id: &LaneId) -> String

ff:idx:{p:N}:lane:<lane_id>:suspended

pub fn waitpoint_hmac_secrets(&self) -> String

ff:sec:{p:N}:waitpoint_hmac — HMAC signing secrets replicated across every execution partition (RFC-004 §Waitpoint Security). Hash fields: current_kid, previous_kid, secret:<kid> (hex), previous_expires_at. Replication is required for cluster mode: every FCALL that mints or validates a token must hash-tag-collocate this key with the rest of its execution-partition KEYS. The secret value is identical across partitions; rotation fans out HSETs across them.

pub fn lease_expiry(&self) -> String

ff:idx:{p:N}:lease_expiry — Cross-lane lease expiry scanner target.

pub fn worker_leases(&self, wid: &WorkerInstanceId) -> String

ff:idx:{p:N}:worker:<worker_instance_id>:leases

pub fn suspension_timeout(&self) -> String

ff:idx:{p:N}:suspension_timeout

pub fn pending_waitpoint_expiry(&self) -> String

ff:idx:{p:N}:pending_waitpoint_expiry

pub fn attempt_timeout(&self) -> String

ff:idx:{p:N}:attempt_timeout

pub fn execution_deadline(&self) -> String

ff:idx:{p:N}:execution_deadline

pub fn all_executions(&self) -> String

ff:idx:{p:N}:all_executions

pub fn partition_signal_delivery(&self) -> String

ff:part:{fp:N}:signal_delivery — partition-level aggregate stream that ff_deliver_signal XADDs into on every successful delivery. subscribe_signal_delivery XREAD BLOCKs this key. RFC-019 Stage B / #310.