rakka-remote 0.2.0

rakka remoting — Transport, Endpoint, FailureDetectors, wire protocol.
Documentation

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]