.Net: Delete CreateCollection, rename CreateIfNotExists and make EnsureExists thread safe. (#11937)

### Motivation and Context

#11829

### Description

- DeleteCreateCollection
- Rename CreateCollectionIfNotExists to EnsureCollectionExists
- Make EnsureCollectionExists thread safe
- Update tests and samples.

### Contribution Checklist

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

- [ ] The code builds clean without any errors or warnings
- [ ] 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
- [ ] All unit tests pass, and I have added new tests where possible
- [ ] I didn't break anyone 😄

Author: westey-m

dotnet/samples/Concepts/Caching/SemanticCachingWithFilters.cs

@@ -196,7 +196,7 @@ public async Task OnPromptRenderAsync(PromptRenderContext context, Func<PromptRe
             var promptEmbedding = await textEmbeddingGenerationService.GenerateEmbeddingAsync(prompt);
 
             var collection = vectorStore.GetCollection<string, CacheRecord>(CollectionName);
-            await collection.CreateCollectionIfNotExistsAsync();
+            await collection.EnsureCollectionExistsAsync();
 
             // Search for similar prompts in cache.
             var searchResult = (await collection.SearchEmbeddingAsync(promptEmbedding, top: 1, cancellationToken: context.CancellationToken)
@@ -241,7 +241,7 @@ public async Task OnFunctionInvocationAsync(FunctionInvocationContext context, F
 
                 // Cache rendered prompt and LLM result.
                 var collection = vectorStore.GetCollection<string, CacheRecord>(CollectionName);
-                await collection.CreateCollectionIfNotExistsAsync();
+                await collection.EnsureCollectionExistsAsync();
 
                 var cacheRecord = new CacheRecord
                 {

dotnet/samples/Concepts/Memory/VectorStoreExtensions.cs

@@ -49,7 +49,7 @@ internal static async Task<VectorStoreCollection<TKey, TRecord>> CreateCollectio
     {
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<TKey, TRecord>(collectionName);
-        await collection.CreateCollectionIfNotExistsAsync().ConfigureAwait(false);
+        await collection.EnsureCollectionExistsAsync().ConfigureAwait(false);
 
         // Create records and generate embeddings for them.
         var tasks = entries.Select(entry => Task.Run(async () =>
@@ -85,7 +85,7 @@ internal static async Task<VectorStoreCollection<TKey, TRecord>> CreateCollectio
     {
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<TKey, TRecord>(collectionName);
-        await collection.CreateCollectionIfNotExistsAsync().ConfigureAwait(false);
+        await collection.EnsureCollectionExistsAsync().ConfigureAwait(false);
 
         // Create records and generate embeddings for them.
         var tasks = searchResults.Select(searchResult => Task.Run(async () =>

dotnet/samples/Concepts/Memory/VectorStore_ConsumeFromMemoryStore_AzureAISearch.cs

@@ -42,7 +42,7 @@ public async Task ConsumeExampleAsync()
 
         // Use the VectorStore abstraction to connect to an existing collection which was previously created via the IMemoryStore abstraction
         var collection = vectorStore.GetCollection<string, VectorStoreRecord>("memorystorecollection");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Show that the data can be read using the VectorStore abstraction.
         // Note that AzureAISearchMemoryStore converts all keys to base64

dotnet/samples/Concepts/Memory/VectorStore_ConsumeFromMemoryStore_Qdrant.cs

@@ -37,7 +37,7 @@ public async Task ConsumeExampleAsync()
 
         // Use the VectorStore abstraction to connect to an existing collection which was previously created via the IMemoryStore abstraction
         var collection = vectorStore.GetCollection<Guid, VectorStoreRecord>("memorystorecollection");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Show that the data can be read using the VectorStore abstraction.
         var record1 = await collection.GetAsync(new Guid("11111111-1111-1111-1111-111111111111"));

dotnet/samples/Concepts/Memory/VectorStore_ConsumeFromMemoryStore_Redis.cs

@@ -39,7 +39,7 @@ public async Task ConsumeExampleAsync()
 
         // Connect to the same collection using the VectorStore abstraction.
         var collection = vectorStore.GetCollection<string, VectorStoreRecord>(MemoryStoreCollectionName);
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Show that the data can be read using the VectorStore abstraction.
         var record1 = await collection.GetAsync("11111111-1111-1111-1111-111111111111");

dotnet/samples/Concepts/Memory/VectorStore_DataIngestion_MultiStore.cs

@@ -173,7 +173,7 @@ public async Task<IEnumerable<TKey>> ImportDataAsync<TKey>(Func<TKey> uniqueKeyG
         {
             // Get and create collection if it doesn't exist.
             var collection = vectorStore.GetCollection<TKey, Glossary<TKey>>("skglossary");
-            await collection.CreateCollectionIfNotExistsAsync();
+            await collection.EnsureCollectionExistsAsync();
 
             // Create glossary entries and generate embeddings for them.
             var glossaryEntries = CreateGlossaryEntries(uniqueKeyGenerator).ToList();

dotnet/samples/Concepts/Memory/VectorStore_DataIngestion_Simple.cs

@@ -40,7 +40,7 @@ public async Task ExampleAsync()
 
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<ulong, Glossary>("skglossary");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Create glossary entries and generate embeddings for them.
         var glossaryEntries = CreateGlossaryEntries().ToList();

dotnet/samples/Concepts/Memory/VectorStore_DynamicDataModel_Interop.cs

@@ -50,7 +50,7 @@ public async Task UpsertWithDynamicRetrieveWithCustomAsync()
 
         // Get and create collection if it doesn't exist using the dynamic data model and record definition that defines the schema.
         var dynamicDataModelCollection = vectorStore.GetCollection<object, Dictionary<string, object?>>("skglossary", s_vectorStoreRecordDefinition);
-        await dynamicDataModelCollection.CreateCollectionIfNotExistsAsync();
+        await dynamicDataModelCollection.EnsureCollectionExistsAsync();
 
         // Create glossary entries and generate embeddings for them.
         var glossaryEntries = CreateDynamicGlossaryEntries().ToList();
@@ -88,7 +88,7 @@ public async Task UpsertWithCustomRetrieveWithDynamicAsync()
 
         // Get and create collection if it doesn't exist using the custom data model.
         var customDataModelCollection = vectorStore.GetCollection<ulong, Glossary>("skglossary");
-        await customDataModelCollection.CreateCollectionIfNotExistsAsync();
+        await customDataModelCollection.EnsureCollectionExistsAsync();
 
         // Create glossary entries and generate embeddings for them.
         var glossaryEntries = CreateCustomGlossaryEntries().ToList();

dotnet/samples/Concepts/Memory/VectorStore_HybridSearch_Simple_AzureAISearch.cs

@@ -38,7 +38,7 @@ public async Task IngestDataAndUseHybridSearch()
 
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<string, Glossary>("skglossary");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
         var hybridSearchCollection = (IKeywordHybridSearchable<Glossary>)collection;
 
         // Create glossary entries and generate embeddings for them.

dotnet/samples/Concepts/Memory/VectorStore_MigrateFromMemoryStore_Redis.cs

@@ -34,7 +34,7 @@ public async Task IngestDataAndSearchAsync<TKey>(string collectionName, Func<TKe
     {
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<TKey, Glossary<TKey>>(collectionName);
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Create glossary entries and generate embeddings for them.
         var glossaryEntries = CreateGlossaryEntries(uniqueKeyGenerator).ToList();

dotnet/samples/Concepts/Memory/VectorStore_VectorSearch_MultiStore_Common.cs

@@ -33,7 +33,7 @@ public async Task VectorSearchWithMultiVectorRecordAsync()
 
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<int, Product>("skproducts");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Create product records and generate embeddings for them.
         var productRecords = CreateProductRecords().ToList();

dotnet/samples/Concepts/Memory/VectorStore_VectorSearch_MultiVector.cs

@@ -23,7 +23,7 @@ public async Task VectorSearchWithPagingAsync()
 
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<int, TextSnippet>("skglossary");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Create some test data entries.
         // We are not generating real embeddings here, just some random numbers

dotnet/samples/Concepts/Memory/VectorStore_VectorSearch_Paging.cs

@@ -33,7 +33,7 @@ public async Task ExampleAsync()
 
         // Get and create collection if it doesn't exist.
         var collection = vectorStore.GetCollection<ulong, Glossary>("skglossary");
-        await collection.CreateCollectionIfNotExistsAsync();
+        await collection.EnsureCollectionExistsAsync();
 
         // Create glossary entries and generate embeddings for them.
         var glossaryEntries = CreateGlossaryEntries().ToList();

dotnet/samples/Concepts/Memory/VectorStore_VectorSearch_Simple.cs

@@ -208,7 +208,7 @@ public async Task OnPromptRenderAsync(PromptRenderContext context, Func<PromptRe
                 // Create collection and upsert all vector store records for search.
                 // It's possible to do it only once and re-use the same examples for future requests.
                 var collection = vectorStore.GetCollection<string, ExampleRecord>(CollectionName);
-                await collection.CreateCollectionIfNotExistsAsync(context.CancellationToken);
+                await collection.EnsureCollectionExistsAsync(context.CancellationToken);
 
                 await collection.UpsertAsync(exampleRecords, cancellationToken: context.CancellationToken);