Struct FlowKeyContext 

pub struct FlowKeyContext { /* private fields */ }

Key context for flow-structural partition keys.

Implementations

impl FlowKeyContext

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

pub fn core(&self) -> String

ff:flow:{fp:N}:<flow_id>:core

pub fn members(&self) -> String

ff:flow:{fp:N}:<flow_id>:members

pub fn tags(&self) -> String

ff:flow:{fp:N}:<flow_id>:tags — User-supplied key-value labels. Symmetric with ExecKeyContext::tags. Populated by ff_set_flow_tags, which also lazy-migrates any pre-58.4 reserved-namespace fields stashed inline on flow_core.

pub fn member(&self, eid: &ExecutionId) -> String

ff:flow:{fp:N}:<flow_id>:member:<eid>

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

ff:flow:{fp:N}:<flow_id>:edge:<edge_id>

pub fn outgoing(&self, upstream_eid: &ExecutionId) -> String

ff:flow:{fp:N}:<flow_id>:out:<upstream_eid>

pub fn incoming(&self, downstream_eid: &ExecutionId) -> String

ff:flow:{fp:N}:<flow_id>:in:<downstream_eid>

pub fn events(&self) -> String

ff:flow:{fp:N}:<flow_id>:events

pub fn summary(&self) -> String

ff:flow:{fp:N}:<flow_id>:summary

pub fn grant(&self, mutation_id: &str) -> String

ff:flow:{fp:N}:<flow_id>:grant:<mutation_id>

pub fn pending_cancels(&self) -> String

ff:flow:{fp:N}:<flow_id>:pending_cancels — SET of execution IDs whose cancel is still owed after a cancel_all cancel_flow. The live async dispatch SREMs entries as it succeeds; the cancel reconciler scanner drains the remainder on its interval so a process crash mid-dispatch or a member whose cancel hit a permanent error can’t leave a flow member un-cancelled.

pub fn hash_tag(&self) -> &str