debasishg / scala-redis

A scala library for connecting to a redis server, or a cluster of redis nodes using consistent hashing on the client side.
1.02k stars 219 forks source link

Add support for Redis Streams #214

Open gkorland opened 6 years ago

gkorland commented 6 years ago

Add support for XADD / XREAD / XRANGE / XREVRANGE / XLEN ... operations

debasishg commented 6 years ago

Thanks for reporting. I assigned this to myself and will work on it .. may be it will take some time to push into my already full calendar ..

masahitojp commented 5 years ago

Hi , @debasishg Do you work it now? I'd like to implement this and started to do it.

https://github.com/masahitojp/scala-redis/tree/support-redis-stream Could you please assign this issue to me if you do not mind?

Thanks!

nguyenvietyen commented 5 years ago

FYI. I tried to continue this for our own projects that are now based on Redis Streams. I found it not trivial to make a simple yet generic implementation. The responses from various Stream command have potentially a high variability. The response parsing functions are therefore not so straightforward.

We've resorted to custom parsers ATM to workaround this.

codeninja55 commented 4 years ago

Just wondering what the status of this additional feature will be? Does anyone have a basic implementation of this as a workaround for now?

debasishg commented 4 years ago

@masahitojp Thanks for your effort .. I am too pre-occupied with other stuff to start working on this. It would be wonderful to have a PR though .. and apologies for the late response ..