Struct ActorSystem 

pub struct ActorSystem { /* private fields */ }

Public handle to the actor system.

Implementations

impl ActorSystem

pub async fn create( name: impl Into<String>, config: Config, ) -> Result<Self, ActorSystemError>

Create an actor system with the given name and configuration.

pub fn name(&self) -> &str

pub fn address(&self) -> &Address

pub fn config(&self) -> &Config

pub fn scheduler(&self) -> Arc<dyn Scheduler>

pub fn extensions(&self) -> &Extensions

pub fn set_spawn_observer(&self, obs: Arc<dyn SpawnObserver>)

Install a SpawnObserver. Only one observer may be installed; subsequent calls replace the previous one. This is the hook used by atomr-telemetry to populate its actor registry.

pub fn set_dead_letter_observer(&self, obs: Arc<dyn DeadLetterObserver>)

Install a DeadLetterObserver that is notified when a tell fails because the target has stopped.

pub fn set_remote_provider(&self, provider: Arc<dyn RemoteProvider>)

Install the remote provider. Done by atomr-remote::RemoteSystemExt::enable_remote. Replaces any previous provider.

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

True if a remote provider is installed and the address has global scope.

pub fn actor_selection(&self, path_str: &str) -> Option<UntypedActorRef>

Look up an actor by full path string. Local paths return the local child if it exists; remote paths consult the installed remote provider.

pub fn actor_selection_with<M>( &self, path_str: &str, serialize: Arc<dyn Fn(M, Option<ActorPath>) -> SerializedMessage + Send + Sync>, ) -> Option<ActorRef<M>>

where M: Send + 'static,

Resolve a remote path and produce a typed ActorRef<M>. The caller supplies a serializer closure for M; atomr-remote::RemoteSystem provides a default that uses bincode + type_name::<M>().

pub fn actor_of<A: Actor>( &self, props: Props<A>, name: &str, ) -> Result<ActorRef<A::Msg>, ActorSystemError>

Spawn a top-level actor under /user.

pub fn stop(&self, name: &str)

Stop a top-level actor by name.

pub async fn terminate(&self)

Initiate orderly shutdown. Awaits actor termination best-effort.

pub async fn when_terminated(&self)

Trait Implementations

impl Clone for ActorSystem

fn clone(&self) -> ActorSystem

Returns a duplicate of the value.

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

Performs copy-assignment from source.