Struct ockam::LocalMessage
source · [−]pub struct LocalMessage { /* private fields */ }
Expand description
LocalMessage is a message type that is routed locally within one node.
LocalMessage consists of TransportMessage + local info in binary format, that can be added by Workers within the same node. TransportMessages are used to transfer messages between different nodes using Transport Workers. Upon arrival to receiving Transport Worker, TransportMessage is wrapped inside LocalMessage and forwarded to other Workers inside that node.
LocalMessage provides mechanism of transporting metadata that is trusted to come from the same node, which is convenient for delegating Authentication/Authorization mechanisms to dedicated local Workers.
Implementations
sourceimpl LocalMessage
impl LocalMessage
sourcepub fn into_transport_message(self) -> TransportMessage
pub fn into_transport_message(self) -> TransportMessage
Underlying transport message
sourcepub fn transport(&self) -> &TransportMessage
pub fn transport(&self) -> &TransportMessage
Underlying transport message
sourcepub fn transport_mut(&mut self) -> &mut TransportMessage
pub fn transport_mut(&mut self) -> &mut TransportMessage
Underlying transport message
sourcepub fn local_info(&self) -> &[LocalInfo]
pub fn local_info(&self) -> &[LocalInfo]
LocalInfo added by Workers within the same node
sourceimpl LocalMessage
impl LocalMessage
sourcepub fn new(
transport_message: TransportMessage,
local_info: Vec<LocalInfo, Global>
) -> LocalMessage
pub fn new(
transport_message: TransportMessage,
local_info: Vec<LocalInfo, Global>
) -> LocalMessage
Constructor
Trait Implementations
sourceimpl Clone for LocalMessage
impl Clone for LocalMessage
sourcefn clone(&self) -> LocalMessage
fn clone(&self) -> LocalMessage
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for LocalMessage
impl Debug for LocalMessage
sourceimpl<'de> Deserialize<'de> for LocalMessage
impl<'de> Deserialize<'de> for LocalMessage
sourcefn deserialize<__D>(
__deserializer: __D
) -> Result<LocalMessage, <__D as Deserializer<'de>>::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D
) -> Result<LocalMessage, <__D as Deserializer<'de>>::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
sourceimpl Hash for LocalMessage
impl Hash for LocalMessage
sourceimpl Ord for LocalMessage
impl Ord for LocalMessage
sourceimpl PartialEq<LocalMessage> for LocalMessage
impl PartialEq<LocalMessage> for LocalMessage
sourcefn eq(&self, other: &LocalMessage) -> bool
fn eq(&self, other: &LocalMessage) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &LocalMessage) -> bool
fn ne(&self, other: &LocalMessage) -> bool
This method tests for !=
.
sourceimpl PartialOrd<LocalMessage> for LocalMessage
impl PartialOrd<LocalMessage> for LocalMessage
sourcefn partial_cmp(&self, other: &LocalMessage) -> Option<Ordering>
fn partial_cmp(&self, other: &LocalMessage) -> Option<Ordering>
This method returns an ordering between self
and other
values if one exists. Read more
1.0.0 · sourcefn lt(&self, other: &Rhs) -> bool
fn lt(&self, other: &Rhs) -> bool
This method tests less than (for self
and other
) and is used by the <
operator. Read more
1.0.0 · sourcefn le(&self, other: &Rhs) -> bool
fn le(&self, other: &Rhs) -> bool
This method tests less than or equal to (for self
and other
) and is used by the <=
operator. Read more
sourceimpl Serialize for LocalMessage
impl Serialize for LocalMessage
sourcefn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
Serialize this value into the given Serde serializer. Read more
impl Eq for LocalMessage
impl Message for LocalMessage
impl StructuralEq for LocalMessage
impl StructuralPartialEq for LocalMessage
Auto Trait Implementations
impl RefUnwindSafe for LocalMessage
impl Send for LocalMessage
impl Sync for LocalMessage
impl Unpin for LocalMessage
impl UnwindSafe for LocalMessage
Blanket Implementations
sourceimpl<D> AsyncTryClone for D where
D: Clone + Sync,
impl<D> AsyncTryClone for D where
D: Clone + Sync,
sourcefn async_try_clone<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<D, Error>> + Send + 'async_trait, Global>>ⓘNotable traits for Pin<P>impl<P> Future for Pin<P> where
P: DerefMut,
<P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output;
where
'life0: 'async_trait,
D: 'async_trait,
fn async_try_clone<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<D, Error>> + Send + 'async_trait, Global>>ⓘNotable traits for Pin<P>impl<P> Future for Pin<P> where
P: DerefMut,
<P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output;
where
'life0: 'async_trait,
D: 'async_trait,
P: DerefMut,
<P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output;
Try cloning a object and return an Err
in case of failure.
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Decodable for T where
T: DeserializeOwned,
impl<T> Decodable for T where
T: DeserializeOwned,
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
sourcefn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
where
S: Into<Dispatch>,
T: Future, type Output = <T as Future>::Output;
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where
T: Future, type Output = <T as Future>::Output;
T: Future, type Output = <T as Future>::Output;
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more