pub struct BackplaneEnvelope {
pub origin: String,
pub target: Target,
pub event: Value,
}Expand description
The wire format a distributed Backplane broadcasts on its bus: who
published it (so a pod can skip its own echo), the Target to re-resolve
locally, and the event payload.
Shared so the Redis and NATS adapters — and any host’s own transport adapter —
speak the same envelope; a pod on the other end deserializes this and calls
publish on its local InMemoryBackplane to fan out to its sockets.
Fields§
§origin: StringOpaque id of the publishing node. A receiver compares it to its own id and skips the message if equal — the origin already delivered locally.
target: TargetThe delivery target, re-resolved against the receiving pod’s registry.
event: ValueThe event payload, delivered verbatim to matching local sinks.
Trait Implementations§
Source§impl Clone for BackplaneEnvelope
impl Clone for BackplaneEnvelope
Source§fn clone(&self) -> BackplaneEnvelope
fn clone(&self) -> BackplaneEnvelope
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 BackplaneEnvelope
impl Debug for BackplaneEnvelope
Source§impl<'de> Deserialize<'de> for BackplaneEnvelope
impl<'de> Deserialize<'de> for BackplaneEnvelope
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 BackplaneEnvelope
impl RefUnwindSafe for BackplaneEnvelope
impl Send for BackplaneEnvelope
impl Sync for BackplaneEnvelope
impl Unpin for BackplaneEnvelope
impl UnsafeUnpin for BackplaneEnvelope
impl UnwindSafe for BackplaneEnvelope
Blanket Implementations§
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> FromResponse for Twhere
T: DeserializeOwned,
impl<T> FromResponse for Twhere
T: DeserializeOwned,
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> 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