rakka-remote. akka.net: src/core/Akka.Remote/.
Cross-process actor remoting for rakka. Two ActorSystems on
different machines (or different ports on the same machine) become
reachable from each other once each side has called
[RemoteSystem::start] with overlapping codecs.
# async fn run() -> Result<(), Box<dyn std::error::Error>> {
use rakka_core::prelude::*;
use rakka_remote::{RemoteSettings, RemoteSystem};
let sys_a = ActorSystem::create("A", rakka_config::Config::reference()).await?;
let remote_a = RemoteSystem::start(sys_a.clone(), "127.0.0.1:0".parse()?, RemoteSettings::default()).await?;
remote_a.register_bincode::<String>();
# Ok(()) }
Module map
| Akka.NET | rakka |
|---|---|
Akka.Remote.RemoteSettings |
[settings::RemoteSettings] |
Akka.Remote.AddressUidExtension |
[address_uid::AddressUid] |
Akka.Remote.Transport.Transport |
[transport::Transport] |
Akka.Remote.Transport.DotNetty.TcpTransport |
[transport::TcpTransport] |
Akka.Remote.Transport.AkkaProtocolTransport |
[transport::AkkaProtocolTransport] |
Akka.Remote.Transport.ThrottleTransportAdapter |
[transport::ThrottleTransport] |
Akka.Remote.Transport.FailureInjectorTransportAdapter |
[transport::FailureInjectorTransport] |
Akka.Remote.Transport.TestTransport |
[transport::TestTransport] |
Akka.Remote.EndpointManager |
[endpoint_manager::EndpointManager] |
Akka.Remote.Endpoint (Reader+Writer) |
[endpoint::EndpointHandle] |
Akka.Remote.Transport.AckedDelivery |
[acked_delivery] |
Akka.Remote.RemoteActorRef |
[remote_ref::RemoteActorRefImpl] |
Akka.Remote.RemoteActorRefProvider |
[provider::RemoteActorRefProvider] |
Akka.Remote.RemoteSystemDaemon |
[system_daemon::RemoteSystemDaemon] |
Akka.Remote.RemoteDeployer |
[system_daemon::RemoteDeployer] |
Akka.Remote.RemoteWatcher |
[remote_watcher::RemoteWatcher] |
Akka.Remote.RemoteMetricsExtension |
[metrics::RemoteMetrics] |
Akka.Remote.DefaultFailureDetectorRegistry |
[failure_detector_registry::FailureDetectorRegistry] |
Akka.Remote.Routing.RemoteRouterConfig |
[router::RemoteRouterConfig] |