Struct FlowDescriptor 

pub struct FlowDescriptor {
    pub entrypoint: String,
    pub args_hash: String,
    pub explicit_key: Option<String>,
    pub code_hash: Option<String>,
}

How a flow is identified and fenced. Identity is (entrypoint, args_hash, explicit_key?) (spec §4.3); code_hash fences replay across deploys (spec §4.4).

Fields

entrypoint: String

The flow’s entrypoint, e.g. "py:pipeline.ingest:main".

args_hash: String

Hash of the flow’s arguments; part of its identity.

explicit_key: Option<String>

An optional explicit identity key, disambiguating two runs that share an entrypoint and args (spec §4.3).

code_hash: Option<String>

Hash of the flow’s code, used to fence replay across deploys.

Implementations

impl FlowDescriptor

pub fn flow_id(&self) -> FlowId

The deterministic storage key for this identity. Deterministic (no ULID clock/random draw) so a rerun with the same identity keys the same flow row — which is what makes resume-on-rerun work through the idempotent Journal::begin_flow.

Trait Implementations

impl Clone for FlowDescriptor

fn clone(&self) -> FlowDescriptor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FlowDescriptor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.