Safe Haskell	None
Language	Haskell2010

Database.Redis.IO

Contents

Redis client
Connection pool
Client and pool settings
Exceptions
Re-exports

Synopsis

Redis client

data Client a #

Redis client monad.

Instances

Monad Client #
Methods (>>=) :: Client a -> (a -> Client b) -> Client b # (>>) :: Client a -> Client b -> Client b # return :: a -> Client a # fail :: String -> Client a #
Functor Client #
Methods fmap :: (a -> b) -> Client a -> Client b # (<$) :: a -> Client b -> Client a #
Applicative Client #
Methods pure :: a -> Client a # (<>) :: Client (a -> b) -> Client a -> Client b # (>) :: Client a -> Client b -> Client b # (<*) :: Client a -> Client b -> Client a #
MonadIO Client #
Methods liftIO :: IO a -> Client a #
MonadThrow Client #
Methods throwM :: Exception e => e -> Client a #
MonadCatch Client #
Methods catch :: Exception e => Client a -> (e -> Client a) -> Client a #
MonadMask Client #
Methods mask :: ((forall a. Client a -> Client a) -> Client b) -> Client b # uninterruptibleMask :: ((forall a. Client a -> Client a) -> Client b) -> Client b #
MonadLogger Client #
Methods log :: Level -> (Msg -> Msg) -> Client () #
MonadClient Client #
Methods liftClient :: Client a -> Client a #
MonadBase IO Client #
Methods liftBase :: IO α -> Client α #
MonadBaseControl IO Client #
Associated Types type StM (Client :: * -> ) a :: # Methods liftBaseWith :: (RunInBase Client IO -> IO a) -> Client a # restoreM :: StM Client a -> Client a #
MonadReader Pool Client #
Methods ask :: Client Pool # local :: (Pool -> Pool) -> Client a -> Client a # reader :: (Pool -> a) -> Client a #
type StM Client a #
type StM Client a = StM (ReaderT * Pool IO) a

class (Functor m, Applicative m, Monad m, MonadIO m, MonadCatch m) => MonadClient m where #

Monads in which Client actions may be embedded.

Minimal complete definition

liftClient

Methods

liftClient :: Client a -> m a #

Lift a computation to the Client monad.

Instances

MonadClient Client #
Methods liftClient :: Client a -> Client a #
MonadClient m => MonadClient (StateT s m) #
Methods liftClient :: Client a -> StateT s m a #
MonadClient m => MonadClient (ExceptT e m) #
Methods liftClient :: Client a -> ExceptT e m a #
MonadClient m => MonadClient (StateT s m) #
Methods liftClient :: Client a -> StateT s m a #
MonadClient m => MonadClient (ReaderT * r m) #
Methods liftClient :: Client a -> ReaderT * r m a #

runRedis :: MonadIO m => Pool -> Client a -> m a #

commands :: MonadClient m => Redis IO a -> m a #

Execute the given redis commands pipelined, i.e. commands are send in batches to the server and the responses are fetched and parsed after a full batch has been sent. A failing command which produces a RedisError will not prevent subsequent commands from being executed by the redis server. However the first error will be thrown as an exception. To force sending see sync.

pubSub :: MonadClient m => (Maybe ByteString -> ByteString -> ByteString -> PubSub IO ()) -> PubSub IO () -> m () #

Execute the given publish/subscribe commands. The first parameter is the callback function which will be invoked with a possible pattern (if PSUBSCRIBE was used), channel, and message, once messages arrive.

sync :: Redis IO a -> Redis IO a #

Connection pool

data Pool #

Connection pool.

Instances

MonadReader Pool Client #
Methods ask :: Client Pool # local :: (Pool -> Pool) -> Client a -> Client a # reader :: (Pool -> a) -> Client a #

mkPool :: MonadIO m => Logger -> Settings -> m Pool #

shutdown :: MonadIO m => Pool -> m () #

Client and pool settings

data Settings #

defSettings :: Settings #

Default settings.

host = localhost
port = 6379
idle timeout = 60s
stripes = 2
connections per stripe = 25
connect timeout = 5s
send-receive timeout = 10s

setHost :: String -> Settings -> Settings #

setPort :: Word16 -> Settings -> Settings #

setIdleTimeout :: NominalDiffTime -> Settings -> Settings #

setMaxConnections :: Int -> Settings -> Settings #

Maximum connections per pool stripe.

setPoolStripes :: Int -> Settings -> Settings #

setConnectTimeout :: NominalDiffTime -> Settings -> Settings #

When a pool connection is opened, connect timeout is the maximum time we are willing to wait for the connection attempt to the redis server to succeed.

setSendRecvTimeout :: NominalDiffTime -> Settings -> Settings #

Exceptions

data ConnectionError #

Constructors

ConnectionsBusy	All connections are in use.
ConnectionClosed	The connection has been closed unexpectedly.
ConnectTimeout	Connecting to redis server took too long.

Instances

Show ConnectionError #
Methods showsPrec :: Int -> ConnectionError -> ShowS # show :: ConnectionError -> String # showList :: [ConnectionError] -> ShowS #
Exception ConnectionError #
Methods toException :: ConnectionError -> SomeException # fromException :: SomeException -> Maybe ConnectionError # displayException :: ConnectionError -> String #

newtype InternalError #

General error, e.g. parsing redis responses failed.

Constructors

InternalError String

Instances

Show InternalError #
Methods showsPrec :: Int -> InternalError -> ShowS # show :: InternalError -> String # showList :: [InternalError] -> ShowS #
Exception InternalError #
Methods toException :: InternalError -> SomeException # fromException :: SomeException -> Maybe InternalError # displayException :: InternalError -> String #

newtype Timeout #

A single send-receive cycle took too long.

Constructors

Timeout String

Instances

Show Timeout #
Methods showsPrec :: Int -> Timeout -> ShowS # show :: Timeout -> String # showList :: [Timeout] -> ShowS #
Exception Timeout #
Methods toException :: Timeout -> SomeException # fromException :: SomeException -> Maybe Timeout # displayException :: Timeout -> String #

data TransactionFailure #

An exception thrown on transaction failures.

Constructors

TransactionAborted	A `WATCH`ed key changed conccurrently.
TransactionDiscarded	The transaction was `DISCARD`ed.
TransactionFailure String	Other transaction failure.

Instances

Show TransactionFailure #
Methods showsPrec :: Int -> TransactionFailure -> ShowS # show :: TransactionFailure -> String # showList :: [TransactionFailure] -> ShowS #
Exception TransactionFailure #
Methods toException :: TransactionFailure -> SomeException # fromException :: SomeException -> Maybe TransactionFailure # displayException :: TransactionFailure -> String #

Re-exports

module Data.Redis.Command