Refactor OrleansExtension configuration for Kubernetes support

Removed Kubernetes-specific configurations and added default settings for non-Kubernetes environments.
argon-chat · Jan 2, 2025 · de051dd · de051dd
1 parent bf84397
commit de051dd
Showing 1 changed file with 15 additions and 13 deletions.
diff --git a/src/Argon.Api/Features/Orleanse/OrleansExtension.cs b/src/Argon.Api/Features/Orleanse/OrleansExtension.cs
@@ -44,23 +44,25 @@ public static WebApplicationBuilder AddOrleans(this WebApplicationBuilder builde
 
             if (builder.Environment.IsKube())
             {
-                siloBuilder
-                   .UseKubeMembership()
-                   .AddActivationRepartitioner<BalanceRule>()
-                   .AddRedisStorage(IFusionSessionGrain.StorageId, 2)
-                   .AddPersistentStreams("default", NatsAdapterFactory.Create, options => { })
-                   .AddPersistentStreams(IArgonEvent.ProviderId, NatsAdapterFactory.Create, options => { })
-                   .AddBroadcastChannel(IArgonEvent.Broadcast);
+                //siloBuilder
+                //   .UseKubeMembership()
+                //   .AddActivationRepartitioner<BalanceRule>()
+                //   .AddRedisStorage(IFusionSessionGrain.StorageId, 2)
+                //   .AddPersistentStreams("default", NatsAdapterFactory.Create, options => { })
+                //   .AddPersistentStreams(IArgonEvent.ProviderId, NatsAdapterFactory.Create, options => { })
+                //   .AddBroadcastChannel(IArgonEvent.Broadcast);
             }
             else
             {
-                siloBuilder
-                   .UseLocalhostClustering()
-                   .AddMemoryStreams("default")
-                   .AddMemoryStreams(IArgonEvent.ProviderId)
-                   .AddMemoryGrainStorage(IFusionSessionGrain.StorageId)
-                   .AddBroadcastChannel(IArgonEvent.Broadcast);
+
             }
+
+            siloBuilder
+               .UseLocalhostClustering()
+               .AddMemoryStreams("default")
+               .AddMemoryStreams(IArgonEvent.ProviderId)
+               .AddMemoryGrainStorage(IFusionSessionGrain.StorageId)
+               .AddBroadcastChannel(IArgonEvent.Broadcast);
         });
 
         return builder;