Struct Chains 

pub struct Chains { /* private fields */ }

The itineraries a running factory is accounting against.

One per causal chain, created when the chain begins and reused by every flight within it.

Implementations

impl Chains

pub fn new() -> Self

An empty set of chains.

pub fn with<T>( &self, id: &ItineraryId, defaults: &Defaults, act: impl FnOnce(&mut Itinerary) -> T, ) -> Option<T>

Runs act against the itinerary for id, creating it on first sight.

Creating on first sight rather than requiring registration means a queued flight from a previous process still lands in a chain with the configured rails, instead of being refused for belonging to an itinerary this process has never heard of.

pub fn count(&self) -> usize

How many chains are being accounted, for reporting.

pub fn opened_by(&self, id: &ItineraryId, pipeline: Option<&PipelineName>)

Remembers which pipeline opened a chain.

Only the first flight of a chain carries one, so this is recorded once and read by every run after it.

pub fn pipeline_of(&self, id: &ItineraryId) -> Option<PipelineName>

Which pipeline a chain was triggered through, if it is known.

Trait Implementations

impl Debug for Chains

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

Formats the value using the given formatter.

impl Default for Chains

fn default() -> Self

Returns the “default value” for a type.