diff --git a/ZeroLevel/Services/PartitionStorage/Interfaces/IStore.cs b/ZeroLevel/Services/PartitionStorage/Interfaces/IStore.cs index 90da852..c25fbee 100644 --- a/ZeroLevel/Services/PartitionStorage/Interfaces/IStore.cs +++ b/ZeroLevel/Services/PartitionStorage/Interfaces/IStore.cs @@ -29,7 +29,7 @@ namespace ZeroLevel.Services.PartitionStorage /// /// Performs a search for data in the repository /// - IAsyncEnumerable> Search(StoreSearchRequest searchRequest); + IAsyncEnumerable> Search(StoreSearchRequest searchRequest); /// /// bypass all key value by meta /// diff --git a/ZeroLevel/Services/PartitionStorage/KV.cs b/ZeroLevel/Services/PartitionStorage/KV.cs index df51584..8a0d619 100644 --- a/ZeroLevel/Services/PartitionStorage/KV.cs +++ b/ZeroLevel/Services/PartitionStorage/KV.cs @@ -1,4 +1,6 @@ namespace ZeroLevel.Services.PartitionStorage { public record KV(TKey Key, TValue Value); + + public record KVM(TKey Key, TValue Value, TMeta Meta); } diff --git a/ZeroLevel/Services/PartitionStorage/Store.cs b/ZeroLevel/Services/PartitionStorage/Store.cs index 37877d7..3a8ba19 100644 --- a/ZeroLevel/Services/PartitionStorage/Store.cs +++ b/ZeroLevel/Services/PartitionStorage/Store.cs @@ -1,5 +1,4 @@ using System; -using System.Collections.Concurrent; using System.Collections.Generic; using System.IO; using System.Linq; @@ -70,7 +69,7 @@ namespace ZeroLevel.Services.PartitionStorage _fileAccessorCachee.DropAllIndexReaders(); } - public async IAsyncEnumerable> Search(StoreSearchRequest searchRequest) + public async IAsyncEnumerable> Search(StoreSearchRequest searchRequest) { if (searchRequest.PartitionSearchRequests?.Any() ?? false) { @@ -84,10 +83,9 @@ namespace ZeroLevel.Services.PartitionStorage { using (accessor) { - var set = new ConcurrentBag>(); await foreach (var kv in accessor.Find(pair.Value)) { - yield return kv; + yield return new KVM(kv.Key, kv.Value, pair.Key); } } } diff --git a/ZeroLevel/ZeroLevel.csproj b/ZeroLevel/ZeroLevel.csproj index dfdc311..20631e2 100644 --- a/ZeroLevel/ZeroLevel.csproj +++ b/ZeroLevel/ZeroLevel.csproj @@ -6,16 +6,16 @@ ogoun ogoun - 3.4.0.2 - KVDB ia async now + 3.4.0.4 + KVDB, extend search method https://github.com/ogoun/Zero/wiki Copyright Ogoun 2023 https://github.com/ogoun/Zero git - 3.4.0.2 - 3.4.0.2 + 3.4.0.4 + 3.4.0.4 AnyCPU;x64;x86 zero.png full