Struct AwaitSpec 

pub struct AwaitSpec {
    pub kind: String,
    pub correlation: Vec<CorrelationKey>,
    pub deadline: String,
    pub from: Option<String>,
}

What a run is waiting for.

Fields

kind: String

correlation: Vec<CorrelationKey>

deadline: String

The obligation that bounds this wait.

Mandatory by design. An unbounded wait is a run that can hang forever with nothing to notice it — the failure mode that presents as “the process just stalled” and is invisible until someone asks.

from: Option<String>

The one producer whose event satisfies this wait, matched against InboundEvent::source. Absent, any producer may.

Implementations

impl AwaitSpec

pub fn new(kind: impl Into<String>, deadline: impl Into<String>) -> Self

pub fn correlate(self, key: CorrelationKey) -> Self

pub fn from(self, source: impl Into<String>) -> Self

Accept the event only from source, compared verbatim with InboundEvent::source.

Correlation keys are business values another producer may know; a wait that names its sender cannot be consumed by an authenticated producer that merely guessed the kind and the key.

An event that arrives over the served API or A2A carries peer:<actor>, the authenticated caller’s actor as the deployment’s authenticator names it — a CloudEvent’s own source attribute is not used. An event passed to Runtime::deliver in process carries whatever source its caller built it with.

Trait Implementations

impl Clone for AwaitSpec

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AwaitSpec

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AwaitSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AwaitSpec

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for AwaitSpec

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AwaitSpec