Trait Message 

pub trait Message:
    'static
    + Sync
    + Send
    + Sized {
    type Result: 'static + Sync + Send;

    // Provided methods
    fn into_envelope(
        self,
        envelope_type: EnvelopeType,
    ) -> Result<Envelope<Self>, MessageWrapErr> { ... }
    fn as_bytes(&self) -> Result<Vec<u8>, MessageWrapErr> { ... }
    fn from_envelope(envelope: Envelope<Self>) -> Result<Self, MessageUnwrapErr> { ... }
    fn from_bytes(_: Vec<u8>) -> Result<Self, MessageUnwrapErr> { ... }
    fn read_remote_result(_: Vec<u8>) -> Result<Self::Result, MessageUnwrapErr> { ... }
    fn write_remote_result(
        _res: Self::Result,
    ) -> Result<Vec<u8>, MessageWrapErr> { ... }
    fn name(&self) -> &'static str { ... }
    fn type_name() -> &'static str
       where Self: Sized { ... }
}

Required Associated Types

type Result: 'static + Sync + Send

Provided Methods

fn into_envelope( self, envelope_type: EnvelopeType, ) -> Result<Envelope<Self>, MessageWrapErr>

fn as_bytes(&self) -> Result<Vec<u8>, MessageWrapErr>

fn from_envelope(envelope: Envelope<Self>) -> Result<Self, MessageUnwrapErr>

fn from_bytes(_: Vec<u8>) -> Result<Self, MessageUnwrapErr>

fn read_remote_result(_: Vec<u8>) -> Result<Self::Result, MessageUnwrapErr>

fn write_remote_result(_res: Self::Result) -> Result<Vec<u8>, MessageWrapErr>

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

fn type_name() -> &'static str

where Self: Sized,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Message for ActorCount

type Result = usize

impl Message for ActorTerminated

type Result = ()

impl Message for AllocateShard

type Result = AllocateShardResult

impl Message for BeginHandshake

type Result = ()

impl Message for ClientConnected

type Result = ()

impl Message for ClientWrite

type Result = ()

impl Message for Connect

type Result = ()

impl Message for DeregisterActor

type Result = ()

impl Message for Describe

type Result = ()

impl Message for DescribeAll

type Result = ()

impl Message for Disconnected

type Result = ()

impl Message for Discover

type Result = ()

impl Message for EntityRequest

type Result = ()

impl Message for EntityStartResult

type Result = ()

impl Message for Forget

type Result = ()

impl Message for GetActorNode

type Result = ()

impl Message for GetAllStats

type Result = HashMap<String, Stats>

impl Message for GetClusterStats

type Result = Option<Receiver<Option<ShardingClusterStats>>>

impl Message for GetCoordinator

type Result = ActorRef<ShardCoordinator>

impl Message for GetHealth

type Result = ()

impl Message for GetHostStats

type Result = Option<Receiver<Option<HostStats>>>

impl Message for GetNodes

type Result = Vec<RemoteNodeState>

impl Message for GetShardTypes

type Result = ShardTypes

impl Message for GetShardingStats

type Result = ShardingStats

impl Message for GetShards

type Result = HostedShards

impl Message for coerce::remote::api::sharding::node::GetStats

type Result = Option<Stats>

impl Message for coerce::sharding::host::stats::GetStats

type Result = Receiver<HostStats>

impl Message for HandshakeAcknowledge

type Result = ()

impl Message for Identify

type Result = ()

impl Message for LeaderAllocated

type Result = ()

impl Message for NewClient

type Result = Option<LocalActorRef<RemoteClient>>

impl Message for NewSession

type Result = LocalActorRef<RemoteSession>

impl Message for NodeDiscovered

type Result = ()

impl Message for NodeForgotten

type Result = ()

impl Message for NodePing

type Result = ()

impl Message for NodeTerminated

type Result = ()

impl Message for OnLeaderChanged

type Result = ()

impl Message for PassivateEntity

type Result = ()

impl Message for PingTick

type Result = ()

impl Message for PopRequest

type Result = Option<RemoteRequest>

impl Message for PublishRaw

type Result = ()

impl Message for PushRequest

type Result = ()

impl Message for Rebalance

type Result = ()

impl Message for coerce::remote::actor::message::RegisterActor

type Result = ()

impl Message for RegisterHealthCheck

type Result = ()

impl Message for RegisterNode

type Result = ()

impl Message for RegisterNodes

type Result = ()

impl Message for RemoteEntityRequest

type Result = ()

impl Message for RemoveEntity

type Result = ()

impl Message for RemoveHealthCheck

type Result = ()

impl Message for SessionClosed

type Result = ()

impl Message for SessionWrite

type Result = ()

impl Message for SetRemote

type Result = ()

impl Message for SetSystem

type Result = ()

impl Message for ShardAllocated

type Result = ()

impl Message for ShardReady

type Result = ()

impl Message for ShardReallocating

type Result = ()

impl Message for ShardStopped

type Result = ()

impl Message for StartEntity

type Result = ()

impl Message for Status

type Result = ActorStatus

impl Message for Stop

type Result = ()

impl Message for StopShard

type Result = ()

impl Message for Terminated

type Result = ()

impl Message for Unwatch

type Result = ()

impl Message for UpdateNodes

type Result = ()

impl Message for Watch

type Result = ()

impl<A: Actor, T: Topic> Message for Subscribe<A, T>

type Result = Result<Subscription, SubscribeErr>

impl<A> Message for GetActor<A>

where A: 'static + Sync + Send + Actor,

type Result = Option<LocalActorRef<A>>

impl<A> Message for coerce::actor::scheduler::RegisterActor<A>

where A: 'static + Sync + Send + Actor,

type Result = ()

impl<F, A, R> Message for Exec<F, A, R>

where for<'r> F: FnMut(&mut A) -> R + 'static + Send + Sync, A: Actor, R: 'static + Send + Sync,

type Result = R

impl<M: Message> Message for WorkerMessage<M>

type Result = ()

impl<M: StreamData> Message for Write<M>

type Result = Result<(), RemoteClientErr>

impl<T: Topic> Message for Publish<T>

type Result = Result<(), PublishErr>

impl<T: Topic> Message for Receive<T>

type Result = ()