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 stream_summary(&self, index: AttemptIndex) -> String

ff:attempt:{p:N}:<eid>:<attempt_index>:summary — Rolling summary Hash for the DurableSummary stream mode (RFC-015 §3.1). Shares the {p:N} hash-tag slot with Self::stream / Self::stream_meta so the summary Hash, the stream key, and the stream-meta Hash are all co-located for atomic multi-key FCALL application from the single-shard Lua Function.

pub fn suspension_current(&self) -> String

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

pub fn suspension_satisfied_set(&self) -> String

ff:exec:{p:N}:<eid>:suspension:current:satisfied_set — RFC-014 §3.1. Durable SET of satisfier tokens accumulated during the active suspension. Created at suspend_execution (for composite conditions only) and deleted on the three terminating paths (resume, cancel, expire).

pub fn suspension_member_map(&self) -> String

ff:exec:{p:N}:<eid>:suspension:current:member_map — RFC-014 §3.1. Write-once HASH mapping waitpoint_id → node_path (e.g. "members[0]"). Read by deliver_signal to locate which composite node a signal affects.

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 suspend_dedup(&self, idempotency_key: &str) -> String

ff:dedup:suspend:{p:N}:<eid>:<idem_key> — Suspend idempotency guard (RFC-013 §2.2). Partition-scoped hash that stores a serialized crate::contracts::SuspendOutcome when a caller supplies SuspendArgs::idempotency_key; a retry within the TTL window replays the first outcome verbatim without state mutation.

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