Fixed low speed of LINQ query (#67)

* Code update based on #65 (comment) * Removed IKafkaSerdesFactory and other code clean-up
masesgroup · Oct 4, 2023 · 6fe86c1 · 6fe86c1
1 parent 1608959
commit 6fe86c1
Show file tree

Hide file tree

Showing 16 changed files with 201 additions and 443 deletions.
diff --git a/src/net/KEFCore/Extensions/KafkaServiceCollectionExtensions.cs b/src/net/KEFCore/Extensions/KafkaServiceCollectionExtensions.cs
@@ -23,7 +23,6 @@
 using MASES.EntityFrameworkCore.KNet.Infrastructure.Internal;
 using MASES.EntityFrameworkCore.KNet.Metadata.Conventions;
 using MASES.EntityFrameworkCore.KNet.Query.Internal;
-using MASES.EntityFrameworkCore.KNet.Serdes.Internal;
 using MASES.EntityFrameworkCore.KNet.Storage.Internal;
 using MASES.EntityFrameworkCore.KNet.ValueGeneration.Internal;
 using System.ComponentModel;
@@ -72,8 +71,7 @@ public static IServiceCollection AddEntityFrameworkKafkaDatabase(this IServiceCo
                     .TryAddSingleton<IKafkaSingletonOptions, KafkaSingletonOptions>()
                     .TryAddSingleton<IKafkaClusterCache, KafkaClusterCache>()
                     .TryAddSingleton<IKafkaTableFactory, KafkaTableFactory>()
-                    .TryAddScoped<IKafkaDatabase, KafkaDatabase>()
-                    .TryAddScoped<IKafkaSerdesFactory, KafkaSerdesFactory>());
+                    .TryAddScoped<IKafkaDatabase, KafkaDatabase>());
 
         builder.TryAddCoreServices();
 

diff --git a/src/net/KEFCore/Query/Internal/KafkaQueryContext.cs b/src/net/KEFCore/Query/Internal/KafkaQueryContext.cs
@@ -32,17 +32,15 @@ public virtual IEnumerable<ValueBuffer> GetValueBuffers(IEntityType entityType)
     {
         if (!_valueBuffersCache.TryGetValue(entityType, out var valueBuffers))
         {
-            valueBuffers = Cluster.GetData(entityType);
+            valueBuffers = Cluster.GetValueBuffers(entityType);
 
             _valueBuffersCache[entityType] = valueBuffers;
         }
 
         return valueBuffers;
     }
 
-    public KafkaQueryContext(
-        QueryContextDependencies dependencies,
-        IKafkaCluster cluster)
+    public KafkaQueryContext(QueryContextDependencies dependencies, IKafkaCluster cluster)
         : base(dependencies)
     {
         Cluster = cluster;

diff --git a/src/net/KEFCore/Serdes/Internal/IKafkaSerdesEntityType.cs b/src/net/KEFCore/Serdes/Internal/IKafkaSerdesEntityType.cs
diff --git a/src/net/KEFCore/Serdes/Internal/IKafkaSerdesFactory.cs b/src/net/KEFCore/Serdes/Internal/IKafkaSerdesFactory.cs
diff --git a/src/net/KEFCore/Serdes/Internal/KafkaSerdesEntityType.cs b/src/net/KEFCore/Serdes/Internal/KafkaSerdesEntityType.cs
diff --git a/src/net/KEFCore/Serdes/Internal/KafkaSerdesFactory.cs b/src/net/KEFCore/Serdes/Internal/KafkaSerdesFactory.cs