rediscala
rediscala copied to clipboard
etaty
Non-blocking, Reactive Redis driver for Scala (with Sentinel support)
Looks like no breaking changes were hit so there aren't really any signficant changes. The only thing is that I had to drop 2.11 since Akka 2.6 no longer supports...
Fixes #231 SMEMBERS is a read only command therefore it should be run on slaves.
Although it is a read only command, `Smembers` is set as `isMasterOnly = true`. Therefore `SMEMBERS` calls are run against master in `RedisClientMasterSlaves` mode. One workaround could be using `SINTER`...
I threw together some enrichments that provide support for [rebloom](https://github.com/RedisLabsModules/rebloom), [redis-cell](https://github.com/brandur/redis-cell), and [redis-timeseries](https://github.com/danni-m/redis-timeseries). If there is any general interest in these, I'd be happy to clean up my implementations and...
The current stable(1.9.0) release still doesn't have https://github.com/etaty/rediscala/commit/aac07d28aadf876c68d33b4042ea205a5f32c8db this fix.
Hi there! As noted in my previous pull request, I've made some changes to support redis 5.0 and the new Streams commands. This branch is based on my features/redis-4.0 branch,...
We have a cache which contains serialized (ObjectInputStream) objects but if for some reason our cache entry becomes unreadable there does not seem to be a way to catch that...
Not sure how we got this though rediscala 1.8.0 / scala 2.12.x ``` java.lang.Exception: Redis Protocol error: Got 43 as initial reply byte for Operation: Operation(Get(waylay:default:publickey.6ccc8843-d78d-49e8-84c4-3734a4af9929),Future(Failure(redis.actors.InvalidRedisReply$: Could not decode the...
hi @etaty when a connection fails when using redisscala it seems to go into an endless retry loop. is there some config somewhere to change this? thanks
One can set connect timeout for a simple RedisClient. It's not the case with RedisClientPool. The latter extends RedisClientPoolLike which creates RedisClientActors with following way: `def makeRedisClientActor(server: RedisServer, active: Ref[Boolean]):...
