Add refresh topology to cluster configuration builder and request struct.

Signed-off-by: currantw <[email protected]>

Author: currantw

sources/Valkey.Glide/ConnectionConfiguration.cs

@@ -25,9 +25,24 @@ internal record ConnectionConfig
         public Protocol? Protocol;
         public string? ClientName;
         public bool LazyConnect;
+        public bool RefreshTopologyFromInitialNodes;
 
         internal FFI.ConnectionConfig ToFfi() =>
-            new(Addresses, TlsMode, ClusterMode, (uint?)RequestTimeout?.TotalMilliseconds, (uint?)ConnectionTimeout?.TotalMilliseconds, ReadFrom, RetryStrategy, AuthenticationInfo, DatabaseId, Protocol, ClientName, LazyConnect);
+            new(
+                Addresses,
+                TlsMode,
+                ClusterMode,
+                (uint?)RequestTimeout?.TotalMilliseconds,
+                (uint?)ConnectionTimeout?.TotalMilliseconds,
+                ReadFrom,
+                RetryStrategy,
+                AuthenticationInfo,
+                DatabaseId,
+                Protocol,
+                ClientName,
+                LazyConnect,
+                RefreshTopologyFromInitialNodes
+            );
     }
 
     /// <summary>
@@ -584,6 +599,30 @@ public class ClusterClientConfigurationBuilder : ClientConfigurationBuilder<Clus
     {
         public ClusterClientConfigurationBuilder() : base(true) { }
 
+        #region Refresh Topology
+        /// <summary>
+        /// Enables refreshing the cluster topology using only the initial nodes.
+        /// <para />
+        /// When this option is enabled, all topology updates (both the periodic checks and on-demand
+        /// refreshes triggered by topology changes) will query only the initial nodes provided when
+        /// creating the client, rather than using the internal cluster view.
+        /// <para />
+        /// If not set, defaults to <c>false</c> (uses internal cluster view for topology refresh).
+        /// </summary>
+        public bool RefreshTopologyFromInitialNodes
+        {
+            get => Config.RefreshTopologyFromInitialNodes;
+            set => Config.RefreshTopologyFromInitialNodes = value;
+        }
+
+        /// <inheritdoc cref="RefreshTopologyFromInitialNodes" />
+        public ClusterClientConfigurationBuilder WithRefreshTopologyFromInitialNodes(bool refreshTopologyFromInitialNodes)
+        {
+            RefreshTopologyFromInitialNodes = refreshTopologyFromInitialNodes;
+            return this;
+        }
+        #endregion
+
         /// <summary>
         /// Complete the configuration with given settings.
         /// </summary>

sources/Valkey.Glide/Internals/FFI.structs.cs

@@ -213,7 +213,8 @@ public ConnectionConfig(
             uint databaseId,
             ConnectionConfiguration.Protocol? protocol,
             string? clientName,
-            bool lazyConnect = false)
+            bool lazyConnect = false,
+            bool refreshTopologyFromInitialNodes = false)
         {
             _addresses = addresses;
             _request = new()
@@ -237,6 +238,7 @@ public ConnectionConfig(
                 Protocol = protocol ?? default,
                 ClientName = clientName,
                 LazyConnect = lazyConnect,
+                RefreshTopologyFromInitialNodes = refreshTopologyFromInitialNodes,
             };
         }
 
@@ -774,6 +776,8 @@ private struct ConnectionRequest
         public string? ClientName;
         [MarshalAs(UnmanagedType.U1)]
         public bool LazyConnect;
+        [MarshalAs(UnmanagedType.U1)]
+        public bool RefreshTopologyFromInitialNodes;
         // TODO more config params, see ffi.rs
     }
 

tests/Valkey.Glide.UnitTests/ConnectionConfigurationTests.cs

@@ -0,0 +1,34 @@
+// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+
+using Valkey.Glide.Internals;
+
+using static Valkey.Glide.ConnectionConfiguration;
+
+namespace Valkey.Glide.UnitTests;
+
+public class ConnectionConfigurationTests
+{
+    [Fact]
+    public void RefreshTopologyFromInitialNodes()
+    {
+        ClusterClientConfigurationBuilder builder;
+        ClusterClientConfiguration config;
+
+        // Default (false).
+        builder = new ClusterClientConfigurationBuilder();
+        config = builder.Build();
+        Assert.False(config.Request.RefreshTopologyFromInitialNodes);
+
+        // Set to true.
+        builder = new ClusterClientConfigurationBuilder();
+        builder.WithRefreshTopologyFromInitialNodes(true);
+        config = builder.Build();
+        Assert.True(config.Request.RefreshTopologyFromInitialNodes);
+
+        // Set to false.
+        builder = new ClusterClientConfigurationBuilder();
+        builder.WithRefreshTopologyFromInitialNodes(false);
+        config = builder.Build();
+        Assert.False(config.Request.RefreshTopologyFromInitialNodes);
+    }
+}