Foundatio.Redis by bniemyjski,ejsmith

<PackageReference Include="Foundatio.Redis" Version="4.2.1176" />

---

API Diff between 4.2.1176 and 1.0.355

27 Additions 37 Removals

Foundatio.Caching

• public sealed class RedisCacheClient : ICacheClient, IDisposable, IHaveSerializer
  • public RedisCacheClient(ConnectionMultiplexer connectionMultiplexer, ISerializer serializer = null)
  • public bool Add<T>(string key, T value)
  • public bool Add<T>(string key, T value, DateTime expiresAt)
  • public bool Add<T>(string key, T value, TimeSpan expiresIn)
  • protected T ChangeType<T>(RedisValue value)
  • public long Decrement(string key, uint amount)
  • public long Decrement(string key, uint amount, DateTime expiresAt)
  • public long Decrement(string key, uint amount, TimeSpan expiresIn)
  • public RedisCacheClient(ConnectionMultiplexer connectionMultiplexer, ISerializer serializer = null, ILoggerFactory loggerFactory = null)
  • public Task<bool> AddAsync<T>(string key, T value, TimeSpan? expiresIn = default)
  • public void FlushAll()
  • public T Get<T>(string key)
  • public IDictionary<string, T> GetAll<T>(IEnumerable<string> keys)
  • public DateTime? GetExpiration(string key)
  • public long Increment(string key, uint amount)
  • public long Increment(string key, uint amount, DateTime expiresAt)
  • public long Increment(string key, uint amount, TimeSpan expiresIn)
  • protected bool InternalSet<T>(string key, T value, TimeSpan? expiresIn = default, When when = 0, CommandFlags flags = 0)
  • protected bool InternalTryGet<T>(string key, out T value, CommandFlags flags = 0)
  • public bool Remove(string key)
  • public void RemoveAll(IEnumerable<string> keys)
  • public void RemoveByPrefix(string prefix)
  • public bool Replace<T>(string key, T value)
  • public bool Replace<T>(string key, T value, DateTime expiresAt)
  • public bool Replace<T>(string key, T value, TimeSpan expiresIn)
  • public bool Set<T>(string key, T value)
  • public bool Set<T>(string key, T value, DateTime expiresAt)
  • public bool Set<T>(string key, T value, TimeSpan expiresIn)
  • public void SetAll<T>(IDictionary<string, T> values)
  • public void SetExpiration(string key, DateTime expiresAt)
  • public void SetExpiration(string key, TimeSpan expiresIn)
  • public bool TryGet<T>(string key, out T value)
  • public Task<bool> ExistsAsync(string key)
  • public Task<IDictionary<string, CacheValue<T>>> GetAllAsync<T>(IEnumerable<string> keys)
  • public Task<CacheValue<T>> GetAsync<T>(string key)
  • public Task<TimeSpan?> GetExpirationAsync(string key)
  • public Task<CacheValue<ICollection<T>>> GetSetAsync<T>(string key)
  • public Task<double> IncrementAsync(string key, double amount = 1, TimeSpan? expiresIn = default)
  • public Task<int> RemoveAllAsync(IEnumerable<string> keys = null)
  • public Task<int> RemoveByPrefixAsync(string prefix)
  • public Task<bool> ReplaceAsync<T>(string key, T value, TimeSpan? expiresIn = default)
  • public Task<long> SetAddAsync<T>(string key, IEnumerable<T> values, TimeSpan? expiresIn = default)
  • public Task<int> SetAllAsync<T>(IDictionary<string, T> values, TimeSpan? expiresIn = default)
  • public Task<bool> SetAsync<T>(string key, T value, TimeSpan? expiresIn = default)
  • public Task SetExpirationAsync(string key, TimeSpan expiresIn)
  • public Task<double> SetIfHigherAsync(string key, double value, TimeSpan? expiresIn = default)
  • public Task<double> SetIfLowerAsync(string key, double value, TimeSpan? expiresIn = default)
  • public Task<long> SetRemoveAsync<T>(string key, IEnumerable<T> values, TimeSpan? expiresIn = default)
• public class RedisHybridCacheClient : HybridCacheClient
  • public RedisHybridCacheClient(ConnectionMultiplexer connectionMultiplexer, ISerializer serializer = null)
  • public RedisHybridCacheClient(ConnectionMultiplexer connectionMultiplexer, ISerializer serializer = null, ILoggerFactory loggerFactory = null)

Foundatio.Messaging

• public class RedisMessageBus : MessageBusBase, IMessageBus, IMessagePublisher, IMessageSubscriber, IDisposable
  • public RedisMessageBus(ISubscriber subscriber, string topic = null, ISerializer serializer = null)
  • public void Subscribe<T>(Action<T> handler)
  • public RedisMessageBus(ISubscriber subscriber, string topic = null, ISerializer serializer = null, ILoggerFactory loggerFactory = null)

Foundatio.Metrics

• public class RedisMetricsClient : CacheBucketMetricsClientBase
  • public RedisMetricsClient(ConnectionMultiplexer connection, bool buffered = true, string prefix = null, ILoggerFactory loggerFactory = null)

Foundatio.Queues

• public class RedisQueue<T> : QueueBase<T>
  • protected readonly IDatabase _db
  • protected readonly ConnectionMultiplexer _connectionMultiplexer
  • protected readonly AsyncLock _lock
  • protected readonly IMetricsClient _metrics
  • protected Task _maintenanceTask
  • protected readonly bool _runMaintenanceTasks
  • public RedisQueue(ConnectionMultiplexer connection, ISerializer serializer = null, string queueName = null, int retries = 2, TimeSpan? retryDelay = default, int[] retryMultipliers = null, TimeSpan? workItemTimeout = default, TimeSpan? deadLetterTimeToLive = default, int deadLetterMaxItems = 100, bool runMaintenanceTasks = true, IEnumerable<IQueueBehavior<T>> behaviours = null)
  • public void StopWorking()
  • public RedisQueue(ConnectionMultiplexer connection, ISerializer serializer = null, string queueName = null, int retries = 2, TimeSpan? retryDelay = default, int[] retryMultipliers = null, TimeSpan? workItemTimeout = default, TimeSpan? deadLetterTimeToLive = default, int deadLetterMaxItems = 100, bool runMaintenanceTasks = true, IEnumerable<IQueueBehavior<T>> behaviors = null, ILoggerFactory loggerFactory = null)