C#: Client configuration (#3321)

---------

Signed-off-by: Yury-Fridlyand <[email protected]>
Co-authored-by: Edward Liang <[email protected]>

Author: Yury-Fridlyand

benchmarks/csharp/Program.cs

@@ -12,6 +12,8 @@
 
 using StackExchange.Redis;
 
+using static Glide.ConnectionConfiguration;
+
 public static class MainClass
 {
     private enum ChosenAction { GET_NON_EXISTING, GET_EXISTING, SET };
@@ -49,11 +51,6 @@ public class CommandLineOptions
 
     private static string GetAddressForStackExchangeRedis(string host, bool useTLS) => $"{GetAddress(host)},ssl={useTLS}";
 
-    private static string GetAddressWithRedisPrefix(string host, bool useTLS)
-    {
-        string protocol = useTLS ? "rediss" : "redis";
-        return $"{protocol}://{GetAddress(host)}";
-    }
     private const double PROB_GET = 0.8;
 
     private const double PROB_GET_EXISTING_KEY = 0.8;
@@ -95,7 +92,7 @@ private static double Percentile(double[] sequence, double excelPercentile)
         }
     }
 
-    private static double CalculateLatency(IEnumerable<double> latency_list, double percentile_point) => Math.Round(Percentile(latency_list.ToArray(), percentile_point), 2);
+    private static double CalculateLatency(IEnumerable<double> latency_list, double percentile_point) => Math.Round(Percentile([.. latency_list], percentile_point), 2);
 
     private static void PrintResults(string resultsFile)
     {
@@ -263,7 +260,9 @@ private static async Task RunWithParameters(int total_commands,
         {
             ClientWrapper[] clients = await CreateClients(clientCount, () =>
             {
-                BaseClient glide_client = new GlideClient(host, PORT, useTLS);
+                StandaloneClientConfiguration config = new StandaloneClientConfigurationBuilder()
+                    .WithAddress(host, PORT).WithTls(useTLS).Build();
+                BaseClient glide_client = new GlideClient(config);
                 return Task.FromResult<(Func<string, Task<string?>>, Func<string, string, Task>, Action)>(
                     (async (key) => await glide_client.Get(key),
                      async (key, value) => await glide_client.Set(key, value),

csharp/lib/BaseClient.cs

@@ -6,18 +6,23 @@
 using Glide.Commands;
 using Glide.Internals;
 
+using static Glide.ConnectionConfiguration;
+
 namespace Glide;
 
 public abstract class BaseClient : IDisposable, IStringBaseCommands
 {
     #region public methods
-    protected BaseClient(string host, uint port, bool useTLS)
+    protected BaseClient(BaseClientConfiguration config)
     {
         _successCallbackDelegate = SuccessCallback;
         nint successCallbackPointer = Marshal.GetFunctionPointerForDelegate(_successCallbackDelegate);
         _failureCallbackDelegate = FailureCallback;
         nint failureCallbackPointer = Marshal.GetFunctionPointerForDelegate(_failureCallbackDelegate);
-        _clientPointer = CreateClientFfi(host, port, useTLS, successCallbackPointer, failureCallbackPointer);
+        nint configPtr = Marshal.AllocHGlobal(Marshal.SizeOf(typeof(ConnectionRequest)));
+        Marshal.StructureToPtr(config.ToRequest(), configPtr, false);
+        _clientPointer = CreateClientFfi(configPtr, successCallbackPointer, failureCallbackPointer);
+        Marshal.FreeHGlobal(configPtr);
         if (_clientPointer == IntPtr.Zero)
         {
             throw new Exception("Failed creating a client");
@@ -123,7 +128,7 @@ private void FailureCallback(ulong index) =>
 
     private delegate void IntAction(IntPtr arg);
     [DllImport("libglide_rs", CallingConvention = CallingConvention.Cdecl, EntryPoint = "create_client")]
-    private static extern IntPtr CreateClientFfi(string host, uint port, bool useTLS, IntPtr successCallback, IntPtr failureCallback);
+    private static extern IntPtr CreateClientFfi(IntPtr config, IntPtr successCallback, IntPtr failureCallback);
 
     [DllImport("libglide_rs", CallingConvention = CallingConvention.Cdecl, EntryPoint = "close_client")]
     private static extern void CloseClientFfi(IntPtr client);