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 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 hash_tag(&self) -> &str