A high-performance, thread-safe, multi-layer caching library for .NET with advanced features including cache stampede protection and distributed caching support.
Features
🚀 High Performance: Optimized for speed and efficiency
🔒 Thread-safe Operations: Safe for concurrent access
📦 Multi-layer Caching: Combine memory and distributed caching
🌐 Distributed Cache Support: Scale across multiple nodes
Installation
dotnet add package CacheFlow
Quick Start
// Configure services
services.AddCacheFlow(options =>
{
options.EnableLogging = true;
options.EnableMetrics = true;
options.DefaultDuration = TimeSpan.FromMinutes(10);
});
// Use in your code
public class ProductService
{
private readonly CacheFlowManager _cache;
public ProductService(CacheFlowManager cache)
{
_cache = cache;
}
public async Task<Product> GetProductAsync(string productId)
{
return await _cache.GetOrCreateAsync(
$"product:{productId}",
productId,
async (id, ct) => await FetchProductFromDatabase(id),
new CacheFlowEntryOptions
{
Duration = TimeSpan.FromHours(1),
Tags = new[] { "products" }
}
);
}
}
Configuration Options
Option
Description
Default
DefaultDuration
Default cache duration
30 minutes
EnableLogging
Enable detailed logging
true
EnableMetrics
Enable performance metrics
true
MaxMemorySize
Maximum memory cache size
null (no limit)
SerializerType
Type of serializer to use
JSON
Cache Operations
Basic Operations
// Set a value
await _cache.SetAsync("key", value);
// Get a value
var result = await _cache.GetOrCreateAsync("key", factory);
// Remove a value
await _cache.RemoveAsync("key");
Tag-based Operations
// Set with tags
await _cache.SetAsync(
"product:1",
product,
new CacheFlowEntryOptions
{
Tags = new[] { "products", "active" }
}
);
// Remove by tag
await _cache.RemoveByTagAsync("products");