Safe Haskell | None |
---|
Quick conduit for reading from Redis lists. Not tested much, and probably quite slow.
- redisSource :: MonadResource m => HostName -> Int -> ByteString -> Int -> Integer -> Source m [ByteString]
- redisSink :: MonadResource m => HostName -> Int -> ByteString -> Sink ByteString m ()
Documentation
:: MonadResource m | |
=> HostName | Hostname of the Redis server |
-> Int | Port of the Redis server (usually 6379) |
-> ByteString | Name of the list |
-> Int | Number of elements to pop at once |
-> Integer | Timeout of the brpop function in seconds, useful for getting Flush events into your conduit. Set to 0 for no timeout. |
-> Source m [ByteString] |
:: MonadResource m | |
=> HostName | Hostname of the Redis server |
-> Int | Port of the Redis server (usually 6379) |
-> ByteString | Name of the list |
-> Sink ByteString m () |
Warning, this outputs strings when things go wrong!