Skip to content

Commit

Permalink
fix delete redis keys
Browse files Browse the repository at this point in the history
  • Loading branch information
nhathoang989 committed Nov 4, 2024
1 parent 1d33691 commit 8143f05
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/mix.heart/Services/MixCacheService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public Task RemoveCacheAsync(object key, string cacheFolder, CancellationToken c
try
{
cancellationToken.ThrowIfCancellationRequested();
return _cache.ClearCache($"{cacheFolder}_{key}".ToLower(), cancellationToken);
return _cache.ClearCache($"{cacheFolder}:{key}".ToLower(), cancellationToken);
}
catch
{
Expand Down
2 changes: 1 addition & 1 deletion src/mix.heart/Services/MixStaticFileCacheClient.cs
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ public Task SetCache<T>(string key, T value, TimeSpan? cacheExpiration = default

public Task ClearCache(string key, CancellationToken cancellationToken = default)
{
MixFileHelper.DeleteFolder($"{_cacheFolder}/{key}");
MixFileHelper.DeleteFolder($"{_cacheFolder}:{key}");
return Task.CompletedTask;
}

Expand Down
3 changes: 1 addition & 2 deletions src/mix.heart/Services/RedisCacheClient.cs
Original file line number Diff line number Diff line change
Expand Up @@ -47,8 +47,7 @@ public async Task ClearCache(string key, CancellationToken cancellationToken = d
foreach (var endpoint in endpoints)
{
var server = _connectionMultiplexer.GetServer(endpoint);
//var keys = server.Keys(pattern: .ToList();
await _database.KeyDeleteAsync(key.Split(':')[0]);
await _database.KeyDeleteAsync(server.Keys(pattern: $"{key}:*").ToArray());
}
}

Expand Down

0 comments on commit 8143f05

Please sign in to comment.