Updated Options into using latest version from ResilientFunctions

Cleipnir.Flows/FlowsContainer.cs

@@ -25,10 +25,12 @@ public FlowsContainer(IFunctionStore flowStore, IServiceProvider serviceProvider
             var logger = serviceProvider.GetRequiredService<ILogger>();
             options = new Options(
                     unhandledExceptionHandler: excp => logger.LogError(excp, "Unhandled exception in Cleipnir Flows"),
-                    options.CrashedCheckFrequency, 
-                    options.PostponedCheckFrequency, 
-                    options.TimeoutCheckFrequency,
-                    options.EventSourcePullFrequency,
+                    options.RetentionPeriod, 
+                    options.RetentionCleanUpFrequency,
+                    options.LeaseLength, 
+                    options.EnableWatchdogs,
+                    options.WatchdogCheckFrequency,
+                    options.MessagesPullFrequency,
                     options.DelayStartup, 
                     options.MaxParallelRetryInvocations, 
                     options.Serializer
@@ -40,7 +42,7 @@ public FlowsContainer(IFunctionStore flowStore, IServiceProvider serviceProvider
             .Select(m => m switch
             {
                 MiddlewareInstance middlewareInstance => middlewareInstance.Middleware,
-                MiddlewareType middlewareType => (IMiddleware)serviceProvider.GetRequiredService(middlewareType.Type),
+                MiddlewareType middlewareType => (IMiddleware) serviceProvider.GetRequiredService(middlewareType.Type),
                 _ => throw new ArgumentOutOfRangeException(nameof(m))
             })
             .ToList();

Cleipnir.Flows/Options.cs

@@ -12,34 +12,43 @@ public class Options
     public static Options Default { get; } = new();
 
     internal Action<RFunctionException>? UnhandledExceptionHandler { get; }
-    internal TimeSpan? CrashedCheckFrequency { get; }
-    internal TimeSpan? PostponedCheckFrequency { get; }
-    internal TimeSpan? TimeoutCheckFrequency { get; }
-    internal TimeSpan? EventSourcePullFrequency { get; }
+    internal TimeSpan? RetentionPeriod { get; }
+    internal TimeSpan? RetentionCleanUpFrequency { get; }
+    internal TimeSpan? LeaseLength { get; }
+    internal bool? EnableWatchdogs { get; }
+    internal TimeSpan? WatchdogCheckFrequency { get; }
     internal TimeSpan? DelayStartup { get; }
     internal int? MaxParallelRetryInvocations { get; }
+    internal TimeSpan? MessagesPullFrequency { get; }
     internal ISerializer? Serializer { get; }
+    internal IEnumerable<RoutingInformation>? Routes { get; }
     internal List<MiddlewareInstanceOrType> Middlewares  { get; } = new();
 
     public Options(
         Action<RFunctionException>? unhandledExceptionHandler = null, 
-        TimeSpan? crashedCheckFrequency = null, 
-        TimeSpan? postponedCheckFrequency = null, 
-        TimeSpan? timeoutCheckFrequency = null,
-        TimeSpan? eventSourcePullFrequency = null,
+        TimeSpan? retentionPeriod = null,
+        TimeSpan? retentionCleanUpFrequency = null,
+        TimeSpan? leaseLength = null, 
+        bool? enableWatchdogs = null,
+        TimeSpan? watchdogCheckFrequency = null,
+        TimeSpan? messagesPullFrequency = null,
         TimeSpan? delayStartup = null, 
         int? maxParallelRetryInvocations = null, 
-        ISerializer? serializer = null
+        ISerializer? serializer = null,
+        IEnumerable<RoutingInformation>? routes = null
     )
     {
         UnhandledExceptionHandler = unhandledExceptionHandler;
-        CrashedCheckFrequency = crashedCheckFrequency;
-        PostponedCheckFrequency = postponedCheckFrequency;
-        TimeoutCheckFrequency = timeoutCheckFrequency;
-        EventSourcePullFrequency = eventSourcePullFrequency;
+        WatchdogCheckFrequency = watchdogCheckFrequency;
+        LeaseLength = leaseLength;
+        RetentionPeriod = retentionPeriod;
+        RetentionCleanUpFrequency = retentionCleanUpFrequency;
+        EnableWatchdogs = enableWatchdogs;
+        MessagesPullFrequency = messagesPullFrequency;
         DelayStartup = delayStartup;
         MaxParallelRetryInvocations = maxParallelRetryInvocations;
         Serializer = serializer;
+        Routes = routes;
     }
 
     public Options UseMiddleware<TMiddleware>() where TMiddleware : IMiddleware
@@ -57,12 +66,15 @@ public Options UseMiddleware(IMiddleware middleware)
     internal Settings MapToRFunctionsSettings()
         => new(
             UnhandledExceptionHandler,
-            CrashedCheckFrequency,
-            PostponedCheckFrequency,
-            TimeoutCheckFrequency,
-            EventSourcePullFrequency,
+            RetentionPeriod,
+            RetentionCleanUpFrequency,
+            LeaseLength,
+            EnableWatchdogs,
+            WatchdogCheckFrequency,
+            MessagesPullFrequency,
             DelayStartup,
             MaxParallelRetryInvocations,
-            Serializer
+            Serializer,
+            Routes
         );
 }