hslogstash-0.2.3: A library to work with, or as, a logstash server

Safe HaskellNone

Data.Conduit.Redis

Description

Quick conduit for reading from Redis lists. Not tested much, and probably quite slow.

Synopsis

Documentation

redisSourceSource

Arguments

:: 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] 

redisSinkSource

Arguments

:: 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!