Struct DestinationPort

Source

pub struct DestinationPort { /* private fields */ }

Expand description

Destination port id of a message. It is a PortId with the rank masked out, and the messege is always sent to the root actor because only root actor can be accessed externally. The rank is resolved by the destination Selection of the message. We can use DestinationPort::port_id(rank) to get the actual PortId of the message.

Struct DestinationPortCopy item path

Implementations§

impl DestinationPort

pub fn new<A, M>(actor_name: String) -> Selfwhere A: RemoteActor + RemoteHandles<IndexedErasedUnbound<M>>, M: Castable + RemoteMessage,

pub fn port(&self) -> u64

pub fn actor_name(&self) -> &str

Trait Implementations§

impl Clone for DestinationPort

fn clone(&self) -> DestinationPort

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

impl Debug for DestinationPort

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

impl<'de> Deserialize<'de> for DestinationPort

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Named for DestinationPort

fn typename() -> &'static str

fn typehash() -> u64

fn typeid() -> TypeId

fn port() -> u64

fn arm(&self) -> Option<&'static str>

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

impl PartialEq for DestinationPort

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

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

impl Serialize for DestinationPort

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

impl StructuralPartialEq for DestinationPort

Auto Trait Implementations§

impl Freeze for DestinationPort

impl RefUnwindSafe for DestinationPort

impl Send for DestinationPort

impl Sync for DestinationPort

impl Unpin for DestinationPort

impl UnwindSafe for DestinationPort

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Any for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn type_name(&self) -> &'static str

impl<T> AnySync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Checkpointable for Twhere T: RemoteMessage + Clone,

type State = T

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>where T: 'async_trait,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<A, M> Handler<IndexedErasedUnbound<M>> for Awhere A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Serialize for Twhere T: Serialize + ?Sized,

fn erased_serialize(&self, serializer: &mut dyn Serializer) -> Result<Ok, Error>

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

Struct DestinationPort

pub fn new<A, M>(actor_name: String) -> Self
where A: RemoteActor + RemoteHandles<IndexedErasedUnbound<M>>, M: Castable + RemoteMessage,

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Any for T
where T: Any,

impl<T> AnySync for T
where T: Any + Send + Sync,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> Checkpointable for T
where T: RemoteMessage + Clone,

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>
where T: 'async_trait,

impl<T> CloneToUninit for T
where T: Clone,

impl<A, M> Handler<IndexedErasedUnbound<M>> for A
where A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> Serialize for T
where T: Serialize + ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<M> Message for M
where M: Debug + Send + Sync + 'static,

impl<M> RemoteMessage for M
where M: Message + Named + Serialize + DeserializeOwned,