pub struct IngressEnvelope {Show 18 fields
pub tenant: String,
pub env: Option<String>,
pub pack_id: Option<String>,
pub flow_id: String,
pub flow_type: Option<String>,
pub action: Option<String>,
pub session_hint: Option<String>,
pub provider: Option<String>,
pub messaging_endpoint_id: Option<String>,
pub channel: Option<String>,
pub conversation: Option<String>,
pub user: Option<String>,
pub entry_node: Option<String>,
pub activity_id: Option<String>,
pub timestamp: Option<String>,
pub payload: Value,
pub metadata: Option<Value>,
pub reply_scope: Option<ReplyScope>,
}Fields§
§tenant: String§env: Option<String>§pack_id: Option<String>§flow_id: String§flow_type: Option<String>§action: Option<String>§session_hint: Option<String>§provider: Option<String>§messaging_endpoint_id: Option<String>Multi-instance messaging endpoint discriminator (M1.4).
Distinguishes provider instances of the same provider_type —
e.g. teams-legal vs teams-accounting — so sessions and traces
don’t collide across endpoints that share provider/channel/user.
channel: Option<String>§conversation: Option<String>§user: Option<String>§entry_node: Option<String>Flow node this run must START at, lifted from a card-navigation target
that names a node rather than a card asset — see
crate::runner::card_nav. None starts at the flow’s entrypoint.
A parked snapshot still outranks it: resuming a waiting run is never the same thing as re-entering the flow at a node.
activity_id: Option<String>§timestamp: Option<String>§payload: Value§metadata: Option<Value>§reply_scope: Option<ReplyScope>Implementations§
Source§impl IngressEnvelope
impl IngressEnvelope
pub fn canonicalize(self) -> Self
pub fn canonical_session_hint(&self) -> String
pub fn tenant_ctx(&self) -> TenantCtx
Trait Implementations§
Source§impl Clone for IngressEnvelope
impl Clone for IngressEnvelope
Source§fn clone(&self) -> IngressEnvelope
fn clone(&self) -> IngressEnvelope
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for IngressEnvelope
impl Debug for IngressEnvelope
Source§impl<'de> Deserialize<'de> for IngressEnvelope
impl<'de> Deserialize<'de> for IngressEnvelope
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for IngressEnvelope
impl RefUnwindSafe for IngressEnvelope
impl Send for IngressEnvelope
impl Sync for IngressEnvelope
impl Unpin for IngressEnvelope
impl UnsafeUnpin for IngressEnvelope
impl UnwindSafe for IngressEnvelope
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request