[Persistence] Add supervisor strategy to journal and snapshot options

src/Akka.Hosting.API.Tests/verify/CoreApiSpec.ApprovePersistence.verified.txt

@@ -38,6 +38,7 @@ namespace Akka.Persistence.Hosting
         public bool IsDefaultPlugin { get; set; }
         public string PluginId { get; }
         public string? Serializer { get; set; }
+        public Akka.Actor.SupervisorStrategyConfigurator? SupervisorStrategy { get; set; }
         public abstract string Identifier { get; set; }
         protected virtual System.Text.StringBuilder Build(System.Text.StringBuilder sb) { }
         public Akka.Configuration.Config ToConfig() { }
@@ -58,6 +59,7 @@ namespace Akka.Persistence.Hosting
         public bool IsDefaultPlugin { get; set; }
         public string PluginId { get; }
         public string? Serializer { get; set; }
+        public Akka.Actor.SupervisorStrategyConfigurator? SupervisorStrategy { get; set; }
         public abstract string Identifier { get; set; }
         protected virtual System.Text.StringBuilder Build(System.Text.StringBuilder sb) { }
         public Akka.Configuration.Config ToConfig() { }

src/Akka.Persistence.Hosting/JournalOptions.cs

@@ -8,6 +8,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
+using Akka.Actor;
 using Akka.Annotations;
 using Akka.Configuration;
 using Akka.Hosting;
@@ -53,6 +54,17 @@ protected JournalOptions(bool isDefault)
         /// </summary>
         public string? Serializer { get; set; }
 
+        /// <summary>
+        /// <para>
+        /// Supervisor strategy for the journal actor.
+        /// It needs to be a subclass of Akka.Actor.SupervisorStrategyConfigurator and have a parameterless constructor.
+        /// </para>
+        /// <para>
+        /// By default, it restarts the journal when it crashed.
+        /// </para>
+        /// </summary>
+        public SupervisorStrategyConfigurator? SupervisorStrategy { get; set; }
+
         /// <summary>
         ///     <para>
         ///         The default configuration for this journal. This must be the actual configuration block for this journal.
@@ -102,6 +114,10 @@ protected virtual StringBuilder Build(StringBuilder sb)
             sb.Insert(0, $"{PluginId} {{{Environment.NewLine}");
             sb.AppendLine($"auto-initialize = {AutoInitialize.ToHocon()}");
             sb.AppendLine($"serializer = {Serializer.ToHocon()}");
+
+            if (SupervisorStrategy is not null)
+                sb.AppendLine($"supervisor-strategy = {SupervisorStrategy.GetType().AssemblyQualifiedName.ToHocon()}");
+
             Adapters.AppendAdapters(sb);
             sb.AppendLine("}");
 

src/Akka.Persistence.Hosting/SnapshotOptions.cs

@@ -6,6 +6,7 @@
 
 using System;
 using System.Text;
+using Akka.Actor;
 using Akka.Configuration;
 using Akka.Hosting;
 
@@ -48,6 +49,17 @@ protected SnapshotOptions(bool isDefault)
         /// </summary>
         public string? Serializer { get; set; }
 
+        /// <summary>
+        /// <para>
+        /// Supervisor strategy for the snapshot-store actor.
+        /// It needs to be a subclass of Akka.Actor.SupervisorStrategyConfigurator and have a parameterless constructor.
+        /// </para>
+        /// <para>
+        /// By default, it restarts the snapshot-store when it crashed.
+        /// </para>
+        /// </summary>
+        public SupervisorStrategyConfigurator? SupervisorStrategy { get; set; }
+
         /// <summary>
         ///     <para>
         ///         The default configuration for this snapshot store. This must be the actual configuration block for this journal.
@@ -91,6 +103,10 @@ protected virtual StringBuilder Build(StringBuilder sb)
             sb.Insert(0, $"{PluginId} {{{Environment.NewLine}");
             sb.AppendLine($"serializer = {Serializer.ToHocon()}");
             sb.AppendLine($"auto-initialize = {AutoInitialize.ToHocon()}");
+
+            if (SupervisorStrategy is not null)
+                sb.AppendLine($"supervisor-strategy = {SupervisorStrategy.GetType().AssemblyQualifiedName.ToHocon()}");
+
             sb.AppendLine("}");
 
             if (IsDefaultPlugin)