Skip to content

Commit

Permalink
Merge branch 'feature/fix-change-non-concurrent-collections' into fea…
Browse files Browse the repository at this point in the history
…ture/adjust-max-size
  • Loading branch information
jason-aelf committed Aug 29, 2024
2 parents 719102f + d94404e commit c0ca299
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
using System.Collections.Concurrent;
using System.Linq.Expressions;
using System.Reflection;
using AElf.EntityMapping.Elasticsearch.Exceptions;
Expand All @@ -18,7 +19,7 @@ public class ShardingKeyProvider<TEntity> : IShardingKeyProvider<TEntity> where
private readonly ILogger<ShardingKeyProvider<TEntity>> _logger;

private List<ShardingKeyInfo<TEntity>> _shardKeyInfoList;
private readonly Dictionary<string, bool> _existIndexShardDictionary = new Dictionary<string, bool>();
private readonly ConcurrentDictionary<string, bool> _existIndexShardDictionary = new ConcurrentDictionary<string, bool>();
private readonly Type _type = typeof(TEntity);
private readonly string _defaultCollectionName;
private readonly IShardingCollectionTailProvider<TEntity> _shardingCollectionTailProvider;
Expand Down

0 comments on commit c0ca299

Please sign in to comment.