.Net: Adding generic redis IVectorRecordStore implementation (#6741)

### Motivation and Context

As part of the evolution of memory connectors, we need to support custom
data models and remove opinionated behaviors, so adding a new record
store implementation for redis.

### Description

Adding an implementation for IVectorRecordStore for redis with support
for:

Custom mappers
Generic data models
Annotating data models via attributes or via definition objects.
Also improving some styling in the AzureAISearch implementation.

See #6525

### Contribution Checklist

<!-- Before submitting this PR, please make sure: -->

- [X] The code builds clean without any errors or warnings
- [X] The PR follows the [SK Contribution
Guidelines](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md)
and the [pre-submission formatting
script](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md#development-scripts)
raises no violations
- [X] All unit tests pass, and I have added new tests where possible
- [X] I didn't break anyone 😄

Author: westey-m

dotnet/src/Connectors/Connectors.Memory.AzureAISearch/AzureAISearchVectorRecordStore.cs

@@ -18,7 +18,7 @@
 namespace Microsoft.SemanticKernel.Connectors.AzureAISearch;
 
 /// <summary>
-/// Service for storing and retrieving records, that uses Azure AI Search as the underlying storage.
+/// Service for storing and retrieving vector records, that uses Azure AI Search as the underlying storage.
 /// </summary>
 /// <typeparam name="TRecord">The data model to use for adding, updating and retrieving data from storage.</typeparam>
 public sealed class AzureAISearchVectorRecordStore<TRecord> : IVectorRecordStore<string, TRecord>
@@ -140,9 +140,9 @@ public Task DeleteAsync(string key, DeleteRecordOptions? options = default, Canc
         // Remove record.
         var searchClient = this.GetSearchClient(collectionName);
         return RunOperationAsync(
-            () => searchClient.DeleteDocumentsAsync(this._keyPropertyName, [key], new IndexDocumentsOptions(), cancellationToken),
             collectionName,
-            "DeleteDocuments");
+            "DeleteDocuments",
+            () => searchClient.DeleteDocumentsAsync(this._keyPropertyName, [key], new IndexDocumentsOptions(), cancellationToken));
     }
 
     /// <inheritdoc />
@@ -156,9 +156,9 @@ public Task DeleteBatchAsync(IEnumerable<string> keys, DeleteRecordOptions? opti
         // Remove records.
         var searchClient = this.GetSearchClient(collectionName);
         return RunOperationAsync(
-            () => searchClient.DeleteDocumentsAsync(this._keyPropertyName, keys, new IndexDocumentsOptions(), cancellationToken),
             collectionName,
-            "DeleteDocuments");
+            "DeleteDocuments",
+            () => searchClient.DeleteDocumentsAsync(this._keyPropertyName, keys, new IndexDocumentsOptions(), cancellationToken));
     }
 
     /// <inheritdoc />
@@ -214,21 +214,21 @@ private async Task<TRecord> GetDocumentAndMapToDataModelAsync(
         if (this._options.MapperType == AzureAISearchRecordMapperType.JsonObjectCustomMapper)
         {
             var jsonObject = await RunOperationAsync(
-                () => searchClient.GetDocumentAsync<JsonObject>(key, innerOptions, cancellationToken),
                 collectionName,
-                "GetDocument").ConfigureAwait(false);
+                "GetDocument",
+                () => searchClient.GetDocumentAsync<JsonObject>(key, innerOptions, cancellationToken)).ConfigureAwait(false);
 
             return RunModelConversion(
-                () => this._options.JsonObjectCustomMapper!.MapFromStorageToDataModel(jsonObject),
                 collectionName,
-                "GetDocument");
+                "GetDocument",
+                () => this._options.JsonObjectCustomMapper!.MapFromStorageToDataModel(jsonObject));
         }
 
         // Use the built in Azure AI Search mapper.
         return await RunOperationAsync(
-            () => searchClient.GetDocumentAsync<TRecord>(key, innerOptions, cancellationToken),
             collectionName,
-            "GetDocument").ConfigureAwait(false);
+            "GetDocument",
+            () => searchClient.GetDocumentAsync<TRecord>(key, innerOptions, cancellationToken)).ConfigureAwait(false);
     }
 
     /// <summary>
@@ -251,21 +251,21 @@ private Task<Response<IndexDocumentsResult>> MapToStorageModelAndUploadDocumentA
         if (this._options.MapperType == AzureAISearchRecordMapperType.JsonObjectCustomMapper)
         {
             var jsonObjects = RunModelConversion(
-                () => records.Select(this._options.JsonObjectCustomMapper!.MapFromDataToStorageModel),
                 collectionName,
-                "UploadDocuments");
+                "UploadDocuments",
+                () => records.Select(this._options.JsonObjectCustomMapper!.MapFromDataToStorageModel));
 
             return RunOperationAsync(
-                () => searchClient.UploadDocumentsAsync<JsonObject>(jsonObjects, innerOptions, cancellationToken),
                 collectionName,
-                "UploadDocuments");
+                "UploadDocuments",
+                () => searchClient.UploadDocumentsAsync<JsonObject>(jsonObjects, innerOptions, cancellationToken));
         }
 
         // Use the built in Azure AI Search mapper.
         return RunOperationAsync(
-            () => searchClient.UploadDocumentsAsync<TRecord>(records, innerOptions, cancellationToken),
             collectionName,
-            "UploadDocuments");
+            "UploadDocuments",
+            () => searchClient.UploadDocumentsAsync<TRecord>(records, innerOptions, cancellationToken));
     }
 
     /// <summary>
@@ -322,14 +322,14 @@ private GetDocumentOptions ConvertGetDocumentOptions(GetRecordOptions? options)
     }
 
     /// <summary>
-    /// Run the given operation and wrap any <see cref="RequestFailedException"/> with <see cref="HttpOperationException"/>."/>
+    /// Run the given operation and wrap any <see cref="RequestFailedException"/> with <see cref="VectorStoreOperationException"/>."/>
     /// </summary>
     /// <typeparam name="T">The response type of the operation.</typeparam>
-    /// <param name="operation">The operation to run.</param>
     /// <param name="collectionName">The name of the collection the operation is being run on.</param>
     /// <param name="operationName">The type of database operation being run.</param>
+    /// <param name="operation">The operation to run.</param>
     /// <returns>The result of the operation.</returns>
-    private static async Task<T> RunOperationAsync<T>(Func<Task<T>> operation, string collectionName, string operationName)
+    private static async Task<T> RunOperationAsync<T>(string collectionName, string operationName, Func<Task<T>> operation)
     {
         try
         {
@@ -365,11 +365,11 @@ private static async Task<T> RunOperationAsync<T>(Func<Task<T>> operation, strin
     /// Run the given model conversion and wrap any exceptions with <see cref="VectorStoreRecordMappingException"/>.
     /// </summary>
     /// <typeparam name="T">The response type of the operation.</typeparam>
-    /// <param name="operation">The operation to run.</param>
     /// <param name="collectionName">The name of the collection the operation is being run on.</param>
     /// <param name="operationName">The type of database operation being run.</param>
+    /// <param name="operation">The operation to run.</param>
     /// <returns>The result of the operation.</returns>
-    private static T RunModelConversion<T>(Func<T> operation, string collectionName, string operationName)
+    private static T RunModelConversion<T>(string collectionName, string operationName, Func<T> operation)
     {
         try
         {

dotnet/src/Connectors/Connectors.Memory.Redis/RedisRecordMapperType.cs

@@ -0,0 +1,21 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Text.Json.Nodes;
+
+namespace Microsoft.SemanticKernel.Connectors.Redis;
+
+/// <summary>
+/// The types of mapper supported by <see cref="RedisVectorRecordStore{TRecord}"/>.
+/// </summary>
+public enum RedisRecordMapperType
+{
+    /// <summary>
+    /// Use the default semantic kernel mapper that uses property attributes to determine how to map fields.
+    /// </summary>
+    Default,
+
+    /// <summary>
+    /// Use a custom mapper between <see cref="JsonNode"/> and the data model.
+    /// </summary>
+    JsonNodeCustomMapper
+}