Hostedservice logging

src/Proto.Cluster/Cluster.cs

@@ -287,14 +287,17 @@ public async Task ShutdownAsync(bool graceful = true, string reason = "")
 
         // Inform all members of the cluster that this node intends to leave. Also, let the MemberList know that this
         // node was the one that initiated the shutdown to prevent another shutdown from being called.
+        Logger.LogInformation("Setting GracefullyLeft gossip state for {Id}", System.Id);
         MemberList.Stopping = true;
         await Gossip.SetStateAsync(GossipKeys.GracefullyLeft, new Empty()).ConfigureAwait(false);
 
-        // Deregister from configured cluster provider.
-        await Provider.ShutdownAsync(graceful).ConfigureAwait(false);
-
+        Logger.LogInformation("Waiting for two gossip intervals to pass for {Id}", System.Id);
         // In case provider shutdown is quick, let's wait at least 2 gossip intervals.
         await Task.Delay((int)Config.GossipInterval.TotalMilliseconds * 2).ConfigureAwait(false);
+
+        Logger.LogInformation("Stopping cluster provider for {Id}", System.Id);
+        // Deregister from configured cluster provider.
+        await Provider.ShutdownAsync(graceful).ConfigureAwait(false);
 
         if (_clusterKindObserver != null)
         {

src/Proto.Cluster/ProtoActorLifecycleHost.cs

@@ -1,23 +1,27 @@
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
 
 namespace Proto.Cluster;
 
 public class ProtoActorLifecycleHost : IHostedService
 {
     private readonly ActorSystem _actorSystem;
+    private readonly ILogger<ProtoActorLifecycleHost> _logger;
     private readonly bool _runAsClient;
     private readonly IHostApplicationLifetime _lifetime;
     private bool _shutdownViaActorSystem;
 
     public ProtoActorLifecycleHost(
         ActorSystem actorSystem,
+        ILogger<ProtoActorLifecycleHost> logger,
         IHostApplicationLifetime lifetime,
         bool runAsClient
         )
     {
         _actorSystem = actorSystem;
+        _logger = logger;
         _runAsClient = runAsClient;
         _lifetime = lifetime;
     }
@@ -35,16 +39,19 @@ public async Task StartAsync(CancellationToken _)
 
             if (_actorSystem.Cluster().Config.ExitOnShutdown)
             {
+                _logger.LogWarning("[ProtoActorLifecycleHost]{SystemId} Exit on shutdown is enabled, shutting down host process", _actorSystem.Id);
                 _lifetime.StopApplication();
             }
         });
 
         if (_runAsClient)
         {
+            _logger.LogInformation("[ProtoActorLifecycleHost]{SystemId} Starting Proto.Actor cluster client", _actorSystem.Id);
             await _actorSystem.Cluster().StartClientAsync().ConfigureAwait(false);
         }
         else
         {
+            _logger.LogInformation("[ProtoActorLifecycleHost]{SystemId} Starting Proto.Actor cluster client", _actorSystem.Id);
             await _actorSystem.Cluster().StartMemberAsync().ConfigureAwait(false);
         }
     }
@@ -53,10 +60,12 @@ public async Task StopAsync(CancellationToken cancellationToken)
     {
         if (_shutdownViaActorSystem)
         {
+            _logger.LogInformation("[ProtoActorLifecycleHost]{SystemId} Stopping Proto.Actor cluster via actor system", _actorSystem.Id);
             await _actorSystem.Cluster().ShutdownCompleted.ConfigureAwait(false);
         }
         else
         {
+            _logger.LogInformation("[ProtoActorLifecycleHost]{SystemId} Stopping Proto.Actor cluster via host application lifetime (SIGTERM)", _actorSystem.Id);
             await _actorSystem.Cluster().ShutdownAsync(true, "Host process is stopping").ConfigureAwait(false);
         }
     }

src/Proto.Cluster/ServiceCollectionExtensions.cs

@@ -63,6 +63,7 @@ public static IServiceCollection AddProtoCluster(this IServiceCollection self, A
         self.AddHostedService(p =>
             new ProtoActorLifecycleHost(
                 p.GetRequiredService<ActorSystem>(),
+                p.GetRequiredService<ILogger<ProtoActorLifecycleHost>>(),
                 p.GetRequiredService<IHostApplicationLifetime>(),
                 boot.RunAsClient));
 
@@ -108,6 +109,7 @@ public static IServiceCollection AddProtoCluster(this IServiceCollection self, s
         self.AddHostedService(p =>
             new ProtoActorLifecycleHost(
                 p.GetRequiredService<ActorSystem>(),
+                p.GetRequiredService<ILogger<ProtoActorLifecycleHost>>(),
                 p.GetRequiredService<IHostApplicationLifetime>(),
                 runAsClient));