chore: single storage client support multiple blob-containers

libs/server/Servers/GarnetServerOptions.cs

@@ -246,10 +246,21 @@ public class GarnetServerOptions : ServerOptions
         /// </summary>
         public int ThreadPoolMaxThreads = 0;
 
+        private Func<INamedDeviceFactory> _deviceFactoryCreator;
+        private Lazy<INamedDeviceFactory> _deviceFactoryLazyCreator;
+
         /// <summary>
         /// Creator of device factories
         /// </summary>
-        public Func<INamedDeviceFactory> DeviceFactoryCreator = null;
+        public Func<INamedDeviceFactory> DeviceFactoryCreator
+        {
+            get => _deviceFactoryCreator;
+            set
+            {
+                _deviceFactoryCreator = value;
+                _deviceFactoryLazyCreator = new Lazy<INamedDeviceFactory>(_deviceFactoryCreator);
+            }
+        }
 
         /// <summary>
         /// Whether and by how much should we throttle the disk IO for checkpoints (default = 0)
@@ -640,7 +651,7 @@ public void GetAofSettings(out TsavoriteLogSettings tsavoriteLogSettings)
                 throw new Exception("AOF Page size cannot be more than the AOF memory size.");
             }
             tsavoriteLogSettings.LogCommitManager = new DeviceLogCommitCheckpointManager(
-                MainMemoryReplication ? new NullNamedDeviceFactory() : DeviceFactoryCreator(),
+                MainMemoryReplication ? new NullNamedDeviceFactory() : GetDeviceFactory(),
                     new DefaultCheckpointNamingScheme(CheckpointDir + "/AOF"),
                     removeOutdated: true,
                     fastCommitThrottleFreq: EnableFastCommit ? FastCommitThrottleFreq : 0);
@@ -739,6 +750,6 @@ IDevice GetAofDevice()
         /// Get device factory
         /// </summary>
         /// <returns></returns>
-        public INamedDeviceFactory GetDeviceFactory() => DeviceFactoryCreator();
+        public INamedDeviceFactory GetDeviceFactory() => _deviceFactoryLazyCreator.Value;
     }
 }

test/Garnet.test/GarnetServerOptionsTests.cs

@@ -0,0 +1,30 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+using Garnet.server;
+using NUnit.Framework;
+using Tsavorite.core;
+
+namespace Garnet.test
+{
+    [TestFixture]
+    public class GarnetServerOptionsTests
+    {
+        [Test]
+        public void TestDeviceFactoryCreator_ReturnSameInstance()
+        {
+            // Arrange
+            var options = new GarnetServerOptions
+            {
+                DeviceFactoryCreator = () => new LocalStorageNamedDeviceFactory()
+            };
+
+            // Act
+            var device1 = options.GetDeviceFactory();
+            var device2 = options.GetDeviceFactory();
+
+            // Assert
+            Assert.That(device1, Is.SameAs(device2));
+        }
+    }
+}