Struct BoundedClusterHandle 

pub struct BoundedClusterHandle<R: Reactor = TokioReactor, N: Network = TokioNetwork, F: FileSystem = TokioFileSystem> { /* private fields */ }

Implementations

impl<R: Reactor + Clone, N: Network + Clone, F: FileSystem + Clone> BoundedClusterHandle<R, N, F>

pub fn transport(&self) -> &BoundedTransportHandle<R, N>

pub fn peers(&self) -> &[PeerSpec]

pub fn declared_actors(&self) -> &[DeclaredRemoteActor]

pub fn roles(&self) -> &[BoundedClusterRole]

pub fn placement_policies(&self) -> &[BoundedPlacementPolicy]

pub fn add_peer(&mut self, peer: PeerSpec) -> Result<(), ClusterError>

pub fn declare_remote_actor( &mut self, owner: EngineId, path: ActorPath, ) -> Result<(), ClusterError>

pub fn undeclare_remote_actor( &mut self, path: &ActorPath, ) -> Result<(), ClusterError>

pub fn can_route(&self, path: &ActorPath) -> bool

pub async fn remote_supervision_status( &self, path: &ActorPath, ) -> Result<RemoteSupervisionStatus, RemoteSupervisionError>

pub async fn spawn_remote_on_role<M>( &self, role: &str, spec: RemoteSpawnSpec, ) -> Result<Addr<M>, RemoteSpawnError>

where M: RemoteMessage, M::Response: Serialize + for<'de> Deserialize<'de> + Send + 'static, R: Send + Sync,

pub async fn spawn_remote_for_class<M>( &self, actor_class: &str, spec: RemoteSpawnSpec, ) -> Result<Addr<M>, RemoteSpawnError>

where M: RemoteMessage, M::Response: Serialize + for<'de> Deserialize<'de> + Send + 'static, R: Send + Sync,

pub async fn spawn_remote<M>( &self, target: EngineId, spec: RemoteSpawnSpec, ) -> Result<Addr<M>, RemoteSpawnError>

where M: RemoteMessage, M::Response: Serialize + for<'de> Deserialize<'de> + Send + 'static, R: Send + Sync,

Trait Implementations

impl<R: Clone + Reactor, N: Clone + Network, F: Clone + FileSystem> Clone for BoundedClusterHandle<R, N, F>

fn clone(&self) -> BoundedClusterHandle<R, N, F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.