redis-job-queue-0.1.0: Simple priority job queue backed by Redis.

Safe HaskellNone
LanguageHaskell98

RedisJobQueue

Documentation

withJobQueue :: QueueName -> (JobQueue -> IO ()) -> IO () Source

withJobQueue' :: ConnectInfo -> QueueName -> (JobQueue -> IO ()) -> IO () Source

data JobQueue Source

push :: JobQueue -> Priority -> Job -> IO (Either Reply Integer) Source

pop :: JobQueue -> IO (Either Reply (Maybe Job)) Source

pushJson :: ToJSON a => JobQueue -> Priority -> a -> IO (Either Reply Integer) Source

popJson :: FromJSON a => JobQueue -> IO (Either String (Maybe a)) Source

type QueueName = ByteString Source

type Job = ByteString Source

type Priority = Double Source