Struct PropagatedHistory 

pub struct PropagatedHistory {
    pub scope: HistoryPropagationScope,
    pub events: Vec<HistoryEvent>,
    pub chunks: Vec<PropagatedHistoryChunk>,
}

Propagated execution history delivered to a child workflow or activity.

Use PropagatedHistory::events for the flat event stream, or any of the events_by_* / workflow_by_name filters to slice it by chunk metadata.

Fields

scope: HistoryPropagationScope

The propagation scope the parent used when scheduling this work item.

events: Vec<HistoryEvent>

All propagated events flattened in execution order.

chunks: Vec<PropagatedHistoryChunk>

Per-app/per-instance chunk metadata.

Implementations

impl PropagatedHistory

pub fn from_proto(p: PropagatedHistory) -> Option<Self>

Build a PropagatedHistory from the wire-format proto.

Returns None if the proto’s scope is SCOPE_NONE (no propagation happened) or unknown. Each chunk’s raw bytes are decoded once into typed HistoryEvents; malformed events are silently dropped (the chunk’s event_count reflects the original wire count so the caller can detect drift).

pub fn app_ids(&self) -> Vec<String>

Deduplicated list of app IDs in the propagated chain, in chunk order (earliest ancestor first).

pub fn workflow_by_name( &self, name: &str, ) -> Result<&PropagatedHistoryChunk, PropagationNotFoundError>

Return the chunk produced by a workflow with the given function name.

If multiple chunks share the same name (re-entrant ancestor calls) the first match in chain order is returned.

pub fn events_by_app_id( &self, app_id: &str, ) -> Result<Vec<HistoryEvent>, PropagationNotFoundError>

All events from chunks tagged with the given Dapr app ID.

pub fn events_by_instance_id( &self, instance_id: &str, ) -> Result<Vec<HistoryEvent>, PropagationNotFoundError>

All events from the chunk with the given instance ID.

pub fn events_by_workflow_name( &self, name: &str, ) -> Result<Vec<HistoryEvent>, PropagationNotFoundError>

All events from chunks produced by a workflow with the given function name.

Trait Implementations

impl Clone for PropagatedHistory

fn clone(&self) -> PropagatedHistory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PropagatedHistory

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

Formats the value using the given formatter.