Struct RemoteSystem 

pub struct RemoteSystem {
    pub system: ActorSystem,
    pub provider: Arc<RemoteActorRefProvider>,
    pub daemon: Arc<RemoteSystemDaemon>,
    pub watcher: Arc<RemoteWatcher>,
    pub address_uid: AddressUid,
    pub local_address: Address,
}

Returned by RemoteSystem::start.

Fields

system: ActorSystem

provider: Arc<RemoteActorRefProvider>

daemon: Arc<RemoteSystemDaemon>

watcher: Arc<RemoteWatcher>

address_uid: AddressUid

local_address: Address

Implementations

impl RemoteSystem

pub async fn start( system: ActorSystem, bind: SocketAddr, settings: RemoteSettings, ) -> Result<Self, TransportError>

Convenience: build a TcpTransport bound to bind, install it on system, and return the wired RemoteSystem.

pub async fn start_with_transport( system: ActorSystem, transport: Arc<dyn Transport>, settings: RemoteSettings, ) -> Result<Self, TransportError>

pub fn endpoint_manager(&self) -> &EndpointManager

pub fn registry(&self) -> &SerializerRegistry

pub fn register_bincode<T>(&self)

where T: Serialize + DeserializeOwned + Send + 'static,

Register the bincode codec for T. Required for any user message type that crosses the wire.

pub fn register_json<T>(&self)

where T: Serialize + DeserializeOwned + Send + 'static,

Register the JSON codec for T.

pub fn expose_actor<M>(&self, target: ActorRef<M>)

where M: Send + 'static,

Register a local actor as the destination for inbound remote messages addressed to its path. Caller must already have the codec for M registered.

pub fn actor_selection<M>(&self, path: &str) -> Option<ActorRef<M>>

where M: Serialize + Send + 'static,

Look up a remote actor by full path string, returning a typed ActorRef<M> with the bincode codec for M. Caller is responsible for matching M to whatever the receiving side declares.

pub fn actor_selection_untyped(&self, path: &str) -> Option<UntypedActorRef>

Untyped variant — useful for system-message-only refs (e.g. remote watchers).

pub async fn shutdown(&self)