More system actors and more consistent system actor naming

src/Proto.Cluster.Kubernetes/KubernetesProvider.cs

@@ -148,7 +148,7 @@ private void StartClusterMonitor()
             .FromProducer(() => new KubernetesClusterMonitor(_cluster, _config))
             .WithGuardianSupervisorStrategy(Supervision.AlwaysRestartStrategy);
 
-        _clusterMonitor = _cluster.System.Root.SpawnNamed(props, "kubernetes-cluster-monitor");
+        _clusterMonitor = _cluster.System.Root.SpawnNamedSystem(props, "$kubernetes-cluster-monitor");
         _podName = KubernetesExtensions.GetPodName();
 
         _cluster.System.Root.Send(

src/Proto.Cluster/Gossip/Gossiper.cs

@@ -45,7 +45,7 @@ public record GetGossipStateSnapshot;
 [PublicAPI]
 public class Gossiper
 {
-    public const string GossipActorName = "gossip";
+    public const string GossipActorName = "$gossip";
 
     private static readonly ILogger Logger = Log.CreateLogger<Gossiper>();
     private readonly Cluster _cluster;

src/Proto.Cluster/Identity/IdentityStorageLookup.cs

@@ -5,7 +5,8 @@ namespace Proto.Cluster.Identity;
 
 public class IdentityStorageLookup : IIdentityLookup
 {
-    private const string PlacementActorName = "placement-activator";
+    private const string WorkerActorName = "$identity-storage-worker";
+    private const string PlacementActorName = "$placement-activator";
     private bool _isClient;
     private string _memberId = string.Empty;
     private PID _placementActor = null!;
@@ -36,7 +37,7 @@ public async Task SetupAsync(Cluster cluster, string[] kinds, bool isClient)
         await Storage.Init();
 
         var workerProps = Props.FromProducer(() => new IdentityStorageWorker(this));
-        _worker = _system.Root.Spawn(workerProps);
+        _worker = _system.Root.SpawnNamedSystem(workerProps, WorkerActorName);
 
         //hook up events
         cluster.System.EventStream.Subscribe<ClusterTopology>(e => {

src/Proto.Cluster/Partition/PartitionManager.cs

@@ -11,8 +11,8 @@ namespace Proto.Cluster.Partition;
 //helper to interact with partition actors on this and other members
 class PartitionManager
 {
-    private const string PartitionIdentityActorName = "partition-identity";
-    private const string PartitionPlacementActorName = "partition-activator";
+    private const string PartitionIdentityActorName = "$partition-identity";
+    private const string PartitionPlacementActorName = "$partition-activator";
     private readonly Cluster _cluster;
     private readonly RootContext _context;
     private readonly bool _isClient;

src/Proto.Cluster/PartitionActivator/PartitionActivatorManager.cs

@@ -11,7 +11,7 @@ namespace Proto.Cluster.PartitionActivator;
 //helper to interact with partition actors on this and other members
 public class PartitionActivatorManager
 {
-    private const string PartitionActivatorActorName = "partition-activator";
+    private const string PartitionActivatorActorName = "$partition-activator";
     private readonly Cluster _cluster;
 
 

src/Proto.Cluster/Seed/SeedClientNodeActor.cs

@@ -13,7 +13,7 @@ namespace Proto.Cluster.Seed;
 
 public class SeedClientNodeActor : IActor
 {
-    public const string Name = "client_seed";
+    public const string Name = "$client_seed";
     public static Props Props(SeedNodeClusterProviderOptions options) => Proto.Props.FromProducer(() => new SeedClientNodeActor(options));
     private static readonly ILogger Logger = Log.CreateLogger<SeedClientNodeActor>();
     private ImmutableDictionary<string, Member> _members = ImmutableDictionary<string, Member>.Empty;

src/Proto.Cluster/Seed/SeedNodeActor.cs

@@ -15,7 +15,7 @@ namespace Proto.Cluster.Seed;
 
 public class SeedNodeActor : IActor
 {
-    public const string Name = "server_seed";
+    public const string Name = "$server_seed";
     private static readonly ILogger Logger = Log.CreateLogger<SeedNodeActor>();
     private ImmutableDictionary<string, Member> _members = ImmutableDictionary<string, Member>.Empty;
     private ImmutableList<PID> _clients = ImmutableList<PID>.Empty;

src/Proto.Remote/Endpoints/EndpointManager.cs

@@ -15,6 +15,8 @@ namespace Proto.Remote;
 
 public class EndpointManager
 {
+    public const string ActivatorActorName = "$activator";
+
     private static readonly ILogger Logger = Log.CreateLogger<EndpointManager>();
     private readonly CancellationTokenSource _cancellationTokenSource = new();
     private readonly IChannelProvider _channelProvider;
@@ -196,7 +198,7 @@ internal IEndpoint GetClientEndpoint(string systemId)
     private void SpawnActivator()
     {
         var props = Props.FromProducer(() => new Activator(_remoteConfig, _system));
-        ActivatorPid = _system.Root.SpawnNamedSystem(props, "activator");
+        ActivatorPid = _system.Root.SpawnNamedSystem(props, ActivatorActorName);
     }
     private void StopActivator() => _system.Root.Stop(ActivatorPid);
 }

src/Proto.Remote/IRemoteExtensions.cs

@@ -41,6 +41,6 @@ public static async Task<ActorPidResponse> SpawnNamedAsync(this IRemote remote,
 
         return res;
 
-        static PID ActivatorForAddress(string address) => PID.FromAddress(address, "activator");
+        static PID ActivatorForAddress(string address) => PID.FromAddress(address, EndpointManager.ActivatorActorName);
     }
 }