Struct ExecKeyContext 

pub struct ExecKeyContext { /* private fields */ }

Pre-computed key context for all keys on an execution’s partition. Created once per operation and reused for all key construction.

Implementations

impl ExecKeyContext

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

pub fn core(&self) -> String

ff:exec:{p:N}:<eid>:core — Authoritative execution record.

pub fn payload(&self) -> String

ff:exec:{p:N}:<eid>:payload — Opaque input payload.

pub fn result(&self) -> String

ff:exec:{p:N}:<eid>:result — Opaque result payload.

pub fn policy(&self) -> String

ff:exec:{p:N}:<eid>:policy — JSON-encoded ExecutionPolicySnapshot.

pub fn tags(&self) -> String

ff:exec:{p:N}:<eid>:tags — User-supplied key-value labels.

pub fn lease_current(&self) -> String

ff:exec:{p:N}:<eid>:lease:current — Full lease object.

pub fn lease_history(&self) -> String

ff:exec:{p:N}:<eid>:lease:history — Append-only lease events.

pub fn claim_grant(&self) -> String

ff:exec:{p:N}:<eid>:claim_grant — Ephemeral claim grant.

pub fn attempts(&self) -> String

ff:exec:{p:N}:<eid>:attempts — Attempt index ZSET.

pub fn attempt_hash(&self, index: AttemptIndex) -> String

ff:attempt:{p:N}:<eid>:<attempt_index> — Per-attempt detail.

pub fn attempt_usage(&self, index: AttemptIndex) -> String

ff:attempt:{p:N}:<eid>:<attempt_index>:usage — Per-attempt usage counters.

pub fn attempt_policy(&self, index: AttemptIndex) -> String

ff:attempt:{p:N}:<eid>:<attempt_index>:policy — Frozen attempt policy snapshot.

pub fn stream(&self, index: AttemptIndex) -> String

ff:stream:{p:N}:<eid>:<attempt_index> — Attempt-scoped output stream.

pub fn stream_meta(&self, index: AttemptIndex) -> String

ff:stream:{p:N}:<eid>:<attempt_index>:meta — Stream metadata.

pub fn suspension_current(&self) -> String

ff:exec:{p:N}:<eid>:suspension:current — Current suspension episode.

pub fn waitpoints(&self) -> String

ff:exec:{p:N}:<eid>:waitpoints — Set of all waitpoint IDs.

pub fn waitpoint(&self, wp_id: &WaitpointId) -> String

ff:wp:{p:N}:<wp_id> — Waitpoint record.

pub fn waitpoint_signals(&self, wp_id: &WaitpointId) -> String

ff:wp:{p:N}:<wp_id>:signals — Per-waitpoint signal history.

pub fn waitpoint_condition(&self, wp_id: &WaitpointId) -> String

ff:wp:{p:N}:<wp_id>:condition — Resume condition evaluation state.

pub fn signal(&self, sig_id: &SignalId) -> String

ff:signal:{p:N}:<signal_id> — Signal record.

pub fn signal_payload(&self, sig_id: &SignalId) -> String

ff:signal:{p:N}:<signal_id>:payload — Opaque signal payload.

pub fn exec_signals(&self) -> String

ff:exec:{p:N}:<eid>:signals — Per-execution signal index.

pub fn signal_dedup(&self, wp_id: &WaitpointId, idempotency_key: &str) -> String

ff:sigdedup:{p:N}:<wp_id>:<idem_key> — Signal idempotency guard.

pub fn deps_meta(&self) -> String

ff:exec:{p:N}:<eid>:deps:meta — Dependency summary.

pub fn dep_edge(&self, edge_id: &EdgeId) -> String

ff:exec:{p:N}:<eid>:dep:<edge_id> — Per-edge local state.

pub fn deps_unresolved(&self) -> String

ff:exec:{p:N}:<eid>:deps:unresolved — Set of unresolved edge IDs.

pub fn deps_all_edges(&self) -> String

ff:exec:{p:N}:<eid>:deps:all_edges — Set of ALL applied edge IDs on this execution (unresolved + satisfied + impossible). Populated by ff_apply_dependency_to_child, never pruned on resolve. Used by the retention trimmer to enumerate dep edge hashes without SCAN.

pub fn noop(&self) -> String

Dummy key on this partition, used as a placeholder for unused KEYS positions (e.g. empty idempotency key). Ensures all KEYS in an FCALL share the same hash tag, preventing CrossSlot errors in cluster mode.

pub fn hash_tag(&self) -> &str

pub fn execution_id_str(&self) -> &str