Safe Haskell	None
Language	GHC2021

Database.Redis

Contents

RESP Protocol
Transport
Redis Commands
FromResp conversion
Cluster
Multiplexing
Standalone Multiplexed Client
Connection Helpers
ByteString (re-exported for convenience)

Description

Convenience re-export module for the hask-redis-mux library.

Import this single module for both standalone and cluster Redis usage.

Standalone usage with bracket pattern (recommended):

{-# LANGUAGE OverloadedStrings #-}
import Database.Redis

main :: IO ()
main = do
  result <- runRedis defaultStandaloneConfig $ do
    set "mykey" "myvalue"
    (val :: ByteString) <- get "mykey"
    return val
  print result

Typed returns via FromResp:

runRedis defaultStandaloneConfig $ do
  set "counter" "42"
  (n :: Integer) <- get "counter"  -- automatically parsed
  (bs :: ByteString) <- get "counter"  -- raw bytes
  (mt :: Maybe Text) <- get "missing"  -- Nothing for missing keys

Cluster usage with bracket pattern:

withClusterClient clusterConfig connector $ \client ->
  runClusterCommandClient client $ do
    set "mykey" "myvalue"
    get "mykey"

Since: 0.1.0.0

Synopsis

class Encodable a where
- encode :: a -> Builder
data RespData where
- RespSimpleString :: !ByteString -> RespData
- RespError :: !ByteString -> RespData
- RespInteger :: !Integer -> RespData
- RespBulkString :: !ByteString -> RespData
- RespNullBulkString :: RespData
- RespArray :: ![RespData] -> RespData
- RespMap :: !(Map RespData RespData) -> RespData
- RespSet :: !(Set RespData) -> RespData
parseRespData :: Parser RespData
parseStrict :: ByteString -> Either String RespData
class Client (client :: ConnectionStatus -> Type) where
- connect :: MonadIO m => client 'NotConnected -> m (client 'Connected)
- close :: MonadIO m => client 'Connected -> m ()
- send :: MonadIO m => client 'Connected -> ByteString -> m ()
- sendChunks :: MonadIO m => client 'Connected -> [ByteString] -> m ()
- receive :: (MonadIO m, MonadFail m) => client 'Connected -> m ByteString
data ConnectionStatus
- = Connected
- | NotConnected
- | Server
data PlainTextClient (a :: ConnectionStatus) where
- NotConnectedPlainTextClient :: String -> Maybe Int -> PlainTextClient 'NotConnected
data TLSClient (a :: ConnectionStatus) where
- NotConnectedTLSClient :: String -> Maybe Int -> TLSClient 'NotConnected
- NotConnectedTLSClientWithHostname :: String -> String -> Maybe Int -> TLSClient 'NotConnected
- TLSTunnel :: TLSClient 'Connected -> TLSClient 'Server
class MonadIO m => RedisCommands (m :: Type -> Type) where
- auth :: FromResp a => ByteString -> ByteString -> m a
- ping :: FromResp a => m a
- set :: FromResp a => ByteString -> ByteString -> m a
- get :: FromResp a => ByteString -> m a
- mget :: FromResp a => [ByteString] -> m a
- setnx :: FromResp a => ByteString -> ByteString -> m a
- decr :: FromResp a => ByteString -> m a
- psetex :: FromResp a => ByteString -> Int -> ByteString -> m a
- bulkSet :: FromResp a => [(ByteString, ByteString)] -> m a
- flushAll :: FromResp a => m a
- dbsize :: FromResp a => m a
- del :: FromResp a => [ByteString] -> m a
- exists :: FromResp a => [ByteString] -> m a
- incr :: FromResp a => ByteString -> m a
- hset :: FromResp a => ByteString -> ByteString -> ByteString -> m a
- hget :: FromResp a => ByteString -> ByteString -> m a
- hmget :: FromResp a => ByteString -> [ByteString] -> m a
- hexists :: FromResp a => ByteString -> ByteString -> m a
- lpush :: FromResp a => ByteString -> [ByteString] -> m a
- lrange :: FromResp a => ByteString -> Int -> Int -> m a
- expire :: FromResp a => ByteString -> Int -> m a
- ttl :: FromResp a => ByteString -> m a
- rpush :: FromResp a => ByteString -> [ByteString] -> m a
- lpop :: FromResp a => ByteString -> m a
- rpop :: FromResp a => ByteString -> m a
- sadd :: FromResp a => ByteString -> [ByteString] -> m a
- smembers :: FromResp a => ByteString -> m a
- scard :: FromResp a => ByteString -> m a
- sismember :: FromResp a => ByteString -> ByteString -> m a
- hdel :: FromResp a => ByteString -> [ByteString] -> m a
- hkeys :: FromResp a => ByteString -> m a
- hvals :: FromResp a => ByteString -> m a
- llen :: FromResp a => ByteString -> m a
- lindex :: FromResp a => ByteString -> Int -> m a
- clientSetInfo :: FromResp a => [ByteString] -> m a
- clientReply :: ClientReplyValues -> m (Maybe RespData)
- zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> m a
- zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> m a
- geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> m a
- geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> m a
- geohash :: FromResp a => ByteString -> [ByteString] -> m a
- geopos :: FromResp a => ByteString -> [ByteString] -> m a
- georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a
- georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a
- georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a
- georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a
- geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> m a
- geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> m a
- clusterSlots :: FromResp a => m a
data ClientState (client :: ConnectionStatus -> Type) = ClientState {
- getClient :: client 'Connected
- getParseBuffer :: ByteString
}
data ClientReplyValues
- = OFF
- | ON
- | SKIP
data RedisCommandClient (client :: ConnectionStatus -> Type) a where
- RedisCommandClient :: forall (client :: ConnectionStatus -> Type) a. Client client => {..} -> RedisCommandClient client a
data RedisError
- = ParseError String
- | ConnectionClosed
- | UnexpectedResp RespData
convertResp :: (FromResp a, MonadIO m) => RespData -> m a
encodeBulkArg :: ByteString -> Builder
encodeCommand :: [ByteString] -> ByteString
encodeCommandBuilder :: [ByteString] -> Builder
encodeGetBuilder :: ByteString -> Builder
encodeSetBuilder :: ByteString -> ByteString -> Builder
parseManyWith :: forall (client :: ConnectionStatus -> Type) m. (Client client, MonadIO m, MonadState (ClientState client) m) => Int -> m ByteString -> m [RespData]
parseWith :: forall (client :: ConnectionStatus -> Type) m. (Client client, MonadIO m, MonadState (ClientState client) m) => m ByteString -> m RespData
showBS :: Show a => a -> ByteString
class FromResp a where
- fromResp :: RespData -> Either RedisError a
data ClusterNode = ClusterNode {
- nodeId :: ByteString
- nodeAddress :: NodeAddress
- nodeRole :: NodeRole
- nodeSlotsServed :: [SlotRange]
- nodeReplicas :: [ByteString]
}
data ClusterTopology = ClusterTopology {
- topologySlots :: Vector ByteString
- topologyAddresses :: Vector NodeAddress
- topologyNodes :: Map ByteString ClusterNode
- topologyUpdateTime :: UTCTime
}
data NodeAddress = NodeAddress {
- nodeHost :: String
- nodePort :: Int
}
data NodeRole
- = Master
- | Replica
data SlotRange = SlotRange {
- slotStart :: Word16
- slotEnd :: Word16
- slotMaster :: ByteString
- slotReplicas :: [ByteString]
}
data ClusterClient (client :: ConnectionStatus -> Type) = ClusterClient {
- clusterTopology :: TVar ClusterTopology
- clusterConnectionPool :: ConnectionPool client
- clusterConfig :: ClusterConfig
- clusterConnector :: Connector client
- clusterRefreshLock :: MVar ()
- clusterMultiplexPool :: MultiplexPool client
}
data ClusterCommandClient (client :: ConnectionStatus -> Type) a
data ClusterConfig = ClusterConfig {
- clusterSeedNode :: NodeAddress
- clusterPoolConfig :: PoolConfig
- clusterMaxRetries :: Int
- clusterRetryDelay :: Int
- clusterTopologyRefreshInterval :: Int
}
data ClusterError
- = MovedError Word16 NodeAddress
- | AskError Word16 NodeAddress
- | ClusterDownError String
- | TryAgainError String
- | CrossSlotError String
- | MaxRetriesExceeded String
- | TopologyError String
- | ConnectionError String
closeClusterClient :: forall (client :: ConnectionStatus -> Type). Client client => ClusterClient client -> IO ()
createClusterClient :: Client client => ClusterConfig -> Connector client -> IO (ClusterClient client)
refreshTopology :: forall (client :: ConnectionStatus -> Type). Client client => ClusterClient client -> IO ()
runClusterCommandClient :: forall (client :: ConnectionStatus -> Type) a. Client client => ClusterClient client -> ClusterCommandClient client a -> IO a
data ConnectionPool (client :: ConnectionStatus -> Type) = ConnectionPool {
- poolConnections :: MVar (Map NodeAddress (NodePool client))
- poolConfig :: PoolConfig
}
data PoolConfig = PoolConfig {
- maxConnectionsPerNode :: Int
- connectionTimeout :: Int
- maxRetries :: Int
- useTLS :: Bool
}
closePool :: forall (client :: ConnectionStatus -> Type). Client client => ConnectionPool client -> IO ()
createPool :: forall (client :: ConnectionStatus -> Type). PoolConfig -> IO (ConnectionPool client)
withConnection :: Client client => ConnectionPool client -> NodeAddress -> Connector client -> (client 'Connected -> IO a) -> IO a
data Multiplexer
data MultiplexerException
- = MultiplexerDead String
- | MultiplexerParseError String
- | MultiplexerConnectionClosed
createMultiplexer :: Client client => client 'Connected -> IO ByteString -> IO Multiplexer
destroyMultiplexer :: Multiplexer -> IO ()
isMultiplexerAlive :: Multiplexer -> IO Bool
submitCommand :: Multiplexer -> Builder -> IO RespData
data MultiplexPool (client :: ConnectionStatus -> Type)
closeMultiplexPool :: forall (client :: ConnectionStatus -> Type). MultiplexPool client -> IO ()
createMultiplexPool :: Client client => Connector client -> Int -> IO (MultiplexPool client)
submitToNode :: forall (client :: ConnectionStatus -> Type). Client client => MultiplexPool client -> NodeAddress -> Builder -> IO RespData
data StandaloneClient
data StandaloneCommandClient a
data StandaloneConfig (client :: ConnectionStatus -> Type) = StandaloneConfig {
- standaloneNodeAddress :: !NodeAddress
- standaloneConnector :: !(Connector client)
- standaloneMultiplexerCount :: !Int
}
closeStandaloneClient :: StandaloneClient -> IO ()
createStandaloneClient :: Client client => Connector client -> NodeAddress -> IO StandaloneClient
createStandaloneClientFromConfig :: forall (client :: ConnectionStatus -> Type). Client client => StandaloneConfig client -> IO StandaloneClient
runStandaloneClient :: StandaloneClient -> StandaloneCommandClient a -> IO a
type Connector (client :: ConnectionStatus -> Type) = NodeAddress -> IO (client 'Connected)
clusterPlaintextConnector :: Connector PlainTextClient
clusterTLSConnector :: String -> Connector TLSClient
connectPlaintext :: String -> Int -> IO (PlainTextClient 'Connected)
connectTLS :: String -> Int -> IO (TLSClient 'Connected)
data ByteString

RESP Protocol

class Encodable a where #

Methods

encode :: a -> Builder #

Instances

Instances details

Encodable RespData
Instance details Defined in Database.Redis.Resp Methods encode :: RespData -> Builder #

data RespData where #

Constructors

RespSimpleString :: !ByteString -> RespData
RespError :: !ByteString -> RespData
RespInteger :: !Integer -> RespData
RespBulkString :: !ByteString -> RespData
RespNullBulkString :: RespData
RespArray :: ![RespData] -> RespData
RespMap :: !(Map RespData RespData) -> RespData
RespSet :: !(Set RespData) -> RespData

Instances

Instances details

Show RespData
Instance details Defined in Database.Redis.Resp Methods showsPrec :: Int -> RespData -> ShowS # show :: RespData -> String # showList :: [RespData] -> ShowS #
Eq RespData
Instance details Defined in Database.Redis.Resp Methods (==) :: RespData -> RespData -> Bool # (/=) :: RespData -> RespData -> Bool #
Ord RespData
Instance details Defined in Database.Redis.Resp Methods compare :: RespData -> RespData -> Ordering # (<) :: RespData -> RespData -> Bool # (<=) :: RespData -> RespData -> Bool # (>) :: RespData -> RespData -> Bool # (>=) :: RespData -> RespData -> Bool # max :: RespData -> RespData -> RespData # min :: RespData -> RespData -> RespData #
FromResp RespData
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError RespData #
Encodable RespData
Instance details Defined in Database.Redis.Resp Methods encode :: RespData -> Builder #
FromResp [RespData]
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError [RespData] #

parseRespData :: Parser RespData #

parseStrict :: ByteString -> Either String RespData #

Transport

class Client (client :: ConnectionStatus -> Type) where #

Minimal complete definition

connect, close, send, receive

Methods

connect :: MonadIO m => client 'NotConnected -> m (client 'Connected) #

close :: MonadIO m => client 'Connected -> m () #

send :: MonadIO m => client 'Connected -> ByteString -> m () #

sendChunks :: MonadIO m => client 'Connected -> [ByteString] -> m () #

receive :: (MonadIO m, MonadFail m) => client 'Connected -> m ByteString #

Instances

Instances details

Client PlainTextClient
Instance details Defined in Database.Redis.Client Methods connect :: MonadIO m => PlainTextClient 'NotConnected -> m (PlainTextClient 'Connected) # close :: MonadIO m => PlainTextClient 'Connected -> m () # send :: MonadIO m => PlainTextClient 'Connected -> ByteString -> m () # sendChunks :: MonadIO m => PlainTextClient 'Connected -> [ByteString] -> m () # receive :: (MonadIO m, MonadFail m) => PlainTextClient 'Connected -> m ByteString #
Client TLSClient
Instance details Defined in Database.Redis.Client Methods connect :: MonadIO m => TLSClient 'NotConnected -> m (TLSClient 'Connected) # close :: MonadIO m => TLSClient 'Connected -> m () # send :: MonadIO m => TLSClient 'Connected -> ByteString -> m () # sendChunks :: MonadIO m => TLSClient 'Connected -> [ByteString] -> m () # receive :: (MonadIO m, MonadFail m) => TLSClient 'Connected -> m ByteString #

data ConnectionStatus #

Constructors

Connected
NotConnected
Server

data PlainTextClient (a :: ConnectionStatus) where #

Constructors

NotConnectedPlainTextClient :: String -> Maybe Int -> PlainTextClient 'NotConnected

Instances

Instances details

Client PlainTextClient

Instance details

Defined in Database.Redis.Client

Methods

connect :: MonadIO m => PlainTextClient 'NotConnected -> m (PlainTextClient 'Connected) #

close :: MonadIO m => PlainTextClient 'Connected -> m () #

send :: MonadIO m => PlainTextClient 'Connected -> ByteString -> m () #

sendChunks :: MonadIO m => PlainTextClient 'Connected -> [ByteString] -> m () #

receive :: (MonadIO m, MonadFail m) => PlainTextClient 'Connected -> m ByteString #

data TLSClient (a :: ConnectionStatus) where #

Constructors

NotConnectedTLSClient :: String -> Maybe Int -> TLSClient 'NotConnected
NotConnectedTLSClientWithHostname :: String -> String -> Maybe Int -> TLSClient 'NotConnected
TLSTunnel :: TLSClient 'Connected -> TLSClient 'Server

Instances

Instances details

Client TLSClient

Instance details

Defined in Database.Redis.Client

Methods

connect :: MonadIO m => TLSClient 'NotConnected -> m (TLSClient 'Connected) #

close :: MonadIO m => TLSClient 'Connected -> m () #

send :: MonadIO m => TLSClient 'Connected -> ByteString -> m () #

sendChunks :: MonadIO m => TLSClient 'Connected -> [ByteString] -> m () #

receive :: (MonadIO m, MonadFail m) => TLSClient 'Connected -> m ByteString #

Redis Commands

class MonadIO m => RedisCommands (m :: Type -> Type) where #

Methods

auth :: FromResp a => ByteString -> ByteString -> m a #

ping :: FromResp a => m a #

set :: FromResp a => ByteString -> ByteString -> m a #

get :: FromResp a => ByteString -> m a #

mget :: FromResp a => [ByteString] -> m a #

setnx :: FromResp a => ByteString -> ByteString -> m a #

decr :: FromResp a => ByteString -> m a #

psetex :: FromResp a => ByteString -> Int -> ByteString -> m a #

bulkSet :: FromResp a => [(ByteString, ByteString)] -> m a #

flushAll :: FromResp a => m a #

dbsize :: FromResp a => m a #

del :: FromResp a => [ByteString] -> m a #

exists :: FromResp a => [ByteString] -> m a #

incr :: FromResp a => ByteString -> m a #

hset :: FromResp a => ByteString -> ByteString -> ByteString -> m a #

hget :: FromResp a => ByteString -> ByteString -> m a #

hmget :: FromResp a => ByteString -> [ByteString] -> m a #

hexists :: FromResp a => ByteString -> ByteString -> m a #

lpush :: FromResp a => ByteString -> [ByteString] -> m a #

lrange :: FromResp a => ByteString -> Int -> Int -> m a #

expire :: FromResp a => ByteString -> Int -> m a #

ttl :: FromResp a => ByteString -> m a #

rpush :: FromResp a => ByteString -> [ByteString] -> m a #

lpop :: FromResp a => ByteString -> m a #

rpop :: FromResp a => ByteString -> m a #

sadd :: FromResp a => ByteString -> [ByteString] -> m a #

smembers :: FromResp a => ByteString -> m a #

scard :: FromResp a => ByteString -> m a #

sismember :: FromResp a => ByteString -> ByteString -> m a #

hdel :: FromResp a => ByteString -> [ByteString] -> m a #

hkeys :: FromResp a => ByteString -> m a #

hvals :: FromResp a => ByteString -> m a #

llen :: FromResp a => ByteString -> m a #

lindex :: FromResp a => ByteString -> Int -> m a #

clientSetInfo :: FromResp a => [ByteString] -> m a #

clientReply :: ClientReplyValues -> m (Maybe RespData) #

zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> m a #

zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> m a #

geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> m a #

geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> m a #

geohash :: FromResp a => ByteString -> [ByteString] -> m a #

geopos :: FromResp a => ByteString -> [ByteString] -> m a #

georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a #

georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a #

georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a #

georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> m a #

geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> m a #

geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> m a #

clusterSlots :: FromResp a => m a #

Instances

Instances details

RedisCommands StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods auth :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # ping :: FromResp a => StandaloneCommandClient a # set :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # get :: FromResp a => ByteString -> StandaloneCommandClient a # mget :: FromResp a => [ByteString] -> StandaloneCommandClient a # setnx :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # decr :: FromResp a => ByteString -> StandaloneCommandClient a # psetex :: FromResp a => ByteString -> Int -> ByteString -> StandaloneCommandClient a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> StandaloneCommandClient a # flushAll :: FromResp a => StandaloneCommandClient a # dbsize :: FromResp a => StandaloneCommandClient a # del :: FromResp a => [ByteString] -> StandaloneCommandClient a # exists :: FromResp a => [ByteString] -> StandaloneCommandClient a # incr :: FromResp a => ByteString -> StandaloneCommandClient a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> StandaloneCommandClient a # hget :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # hmget :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # hexists :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # lpush :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # lrange :: FromResp a => ByteString -> Int -> Int -> StandaloneCommandClient a # expire :: FromResp a => ByteString -> Int -> StandaloneCommandClient a # ttl :: FromResp a => ByteString -> StandaloneCommandClient a # rpush :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # lpop :: FromResp a => ByteString -> StandaloneCommandClient a # rpop :: FromResp a => ByteString -> StandaloneCommandClient a # sadd :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # smembers :: FromResp a => ByteString -> StandaloneCommandClient a # scard :: FromResp a => ByteString -> StandaloneCommandClient a # sismember :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # hdel :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # hkeys :: FromResp a => ByteString -> StandaloneCommandClient a # hvals :: FromResp a => ByteString -> StandaloneCommandClient a # llen :: FromResp a => ByteString -> StandaloneCommandClient a # lindex :: FromResp a => ByteString -> Int -> StandaloneCommandClient a # clientSetInfo :: FromResp a => [ByteString] -> StandaloneCommandClient a # clientReply :: ClientReplyValues -> StandaloneCommandClient (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> StandaloneCommandClient a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> StandaloneCommandClient a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> StandaloneCommandClient a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> StandaloneCommandClient a # geohash :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # geopos :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> StandaloneCommandClient a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> StandaloneCommandClient a # clusterSlots :: FromResp a => StandaloneCommandClient a #
Client client => RedisCommands (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods auth :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # ping :: FromResp a => ClusterCommandClient client a # set :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # get :: FromResp a => ByteString -> ClusterCommandClient client a # mget :: FromResp a => [ByteString] -> ClusterCommandClient client a # setnx :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # decr :: FromResp a => ByteString -> ClusterCommandClient client a # psetex :: FromResp a => ByteString -> Int -> ByteString -> ClusterCommandClient client a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> ClusterCommandClient client a # flushAll :: FromResp a => ClusterCommandClient client a # dbsize :: FromResp a => ClusterCommandClient client a # del :: FromResp a => [ByteString] -> ClusterCommandClient client a # exists :: FromResp a => [ByteString] -> ClusterCommandClient client a # incr :: FromResp a => ByteString -> ClusterCommandClient client a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> ClusterCommandClient client a # hget :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # hmget :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # hexists :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # lpush :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # lrange :: FromResp a => ByteString -> Int -> Int -> ClusterCommandClient client a # expire :: FromResp a => ByteString -> Int -> ClusterCommandClient client a # ttl :: FromResp a => ByteString -> ClusterCommandClient client a # rpush :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # lpop :: FromResp a => ByteString -> ClusterCommandClient client a # rpop :: FromResp a => ByteString -> ClusterCommandClient client a # sadd :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # smembers :: FromResp a => ByteString -> ClusterCommandClient client a # scard :: FromResp a => ByteString -> ClusterCommandClient client a # sismember :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # hdel :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # hkeys :: FromResp a => ByteString -> ClusterCommandClient client a # hvals :: FromResp a => ByteString -> ClusterCommandClient client a # llen :: FromResp a => ByteString -> ClusterCommandClient client a # lindex :: FromResp a => ByteString -> Int -> ClusterCommandClient client a # clientSetInfo :: FromResp a => [ByteString] -> ClusterCommandClient client a # clientReply :: ClientReplyValues -> ClusterCommandClient client (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> ClusterCommandClient client a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> ClusterCommandClient client a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> ClusterCommandClient client a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> ClusterCommandClient client a # geohash :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # geopos :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> ClusterCommandClient client a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> ClusterCommandClient client a # clusterSlots :: FromResp a => ClusterCommandClient client a #
Client client => RedisCommands (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods auth :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # ping :: FromResp a => RedisCommandClient client a # set :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # get :: FromResp a => ByteString -> RedisCommandClient client a # mget :: FromResp a => [ByteString] -> RedisCommandClient client a # setnx :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # decr :: FromResp a => ByteString -> RedisCommandClient client a # psetex :: FromResp a => ByteString -> Int -> ByteString -> RedisCommandClient client a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> RedisCommandClient client a # flushAll :: FromResp a => RedisCommandClient client a # dbsize :: FromResp a => RedisCommandClient client a # del :: FromResp a => [ByteString] -> RedisCommandClient client a # exists :: FromResp a => [ByteString] -> RedisCommandClient client a # incr :: FromResp a => ByteString -> RedisCommandClient client a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> RedisCommandClient client a # hget :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # hmget :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # hexists :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # lpush :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # lrange :: FromResp a => ByteString -> Int -> Int -> RedisCommandClient client a # expire :: FromResp a => ByteString -> Int -> RedisCommandClient client a # ttl :: FromResp a => ByteString -> RedisCommandClient client a # rpush :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # lpop :: FromResp a => ByteString -> RedisCommandClient client a # rpop :: FromResp a => ByteString -> RedisCommandClient client a # sadd :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # smembers :: FromResp a => ByteString -> RedisCommandClient client a # scard :: FromResp a => ByteString -> RedisCommandClient client a # sismember :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # hdel :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # hkeys :: FromResp a => ByteString -> RedisCommandClient client a # hvals :: FromResp a => ByteString -> RedisCommandClient client a # llen :: FromResp a => ByteString -> RedisCommandClient client a # lindex :: FromResp a => ByteString -> Int -> RedisCommandClient client a # clientSetInfo :: FromResp a => [ByteString] -> RedisCommandClient client a # clientReply :: ClientReplyValues -> RedisCommandClient client (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> RedisCommandClient client a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> RedisCommandClient client a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> RedisCommandClient client a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> RedisCommandClient client a # geohash :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # geopos :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> RedisCommandClient client a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> RedisCommandClient client a # clusterSlots :: FromResp a => RedisCommandClient client a #

data ClientState (client :: ConnectionStatus -> Type) #

Constructors

ClientState
Fields getClient :: client 'Connected getParseBuffer :: ByteString

Instances

Instances details

Client client => MonadState (ClientState client) (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods get :: RedisCommandClient client (ClientState client) # put :: ClientState client -> RedisCommandClient client () # state :: (ClientState client -> (a, ClientState client)) -> RedisCommandClient client a #

data ClientReplyValues #

Constructors

OFF
ON
SKIP

Instances

Instances details

Show ClientReplyValues
Instance details Defined in Database.Redis.Command Methods showsPrec :: Int -> ClientReplyValues -> ShowS # show :: ClientReplyValues -> String # showList :: [ClientReplyValues] -> ShowS #
Eq ClientReplyValues
Instance details Defined in Database.Redis.Command Methods (==) :: ClientReplyValues -> ClientReplyValues -> Bool # (/=) :: ClientReplyValues -> ClientReplyValues -> Bool #

data RedisCommandClient (client :: ConnectionStatus -> Type) a where #

Constructors

RedisCommandClient
Fields :: forall (client :: ConnectionStatus -> Type) a. Client client => { runRedisCommandClient :: StateT (ClientState client) IO a } -> RedisCommandClient client a

Instances

Instances details

Client client => MonadIO (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods liftIO :: IO a -> RedisCommandClient client a #
Client client => Applicative (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods pure :: a -> RedisCommandClient client a # (<>) :: RedisCommandClient client (a -> b) -> RedisCommandClient client a -> RedisCommandClient client b # liftA2 :: (a -> b -> c) -> RedisCommandClient client a -> RedisCommandClient client b -> RedisCommandClient client c # (>) :: RedisCommandClient client a -> RedisCommandClient client b -> RedisCommandClient client b # (<*) :: RedisCommandClient client a -> RedisCommandClient client b -> RedisCommandClient client a #
Client client => Functor (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods fmap :: (a -> b) -> RedisCommandClient client a -> RedisCommandClient client b # (<$) :: a -> RedisCommandClient client b -> RedisCommandClient client a #
Client client => Monad (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods (>>=) :: RedisCommandClient client a -> (a -> RedisCommandClient client b) -> RedisCommandClient client b # (>>) :: RedisCommandClient client a -> RedisCommandClient client b -> RedisCommandClient client b # return :: a -> RedisCommandClient client a #
Client client => MonadFail (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods fail :: String -> RedisCommandClient client a #
Client client => RedisCommands (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods auth :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # ping :: FromResp a => RedisCommandClient client a # set :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # get :: FromResp a => ByteString -> RedisCommandClient client a # mget :: FromResp a => [ByteString] -> RedisCommandClient client a # setnx :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # decr :: FromResp a => ByteString -> RedisCommandClient client a # psetex :: FromResp a => ByteString -> Int -> ByteString -> RedisCommandClient client a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> RedisCommandClient client a # flushAll :: FromResp a => RedisCommandClient client a # dbsize :: FromResp a => RedisCommandClient client a # del :: FromResp a => [ByteString] -> RedisCommandClient client a # exists :: FromResp a => [ByteString] -> RedisCommandClient client a # incr :: FromResp a => ByteString -> RedisCommandClient client a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> RedisCommandClient client a # hget :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # hmget :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # hexists :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # lpush :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # lrange :: FromResp a => ByteString -> Int -> Int -> RedisCommandClient client a # expire :: FromResp a => ByteString -> Int -> RedisCommandClient client a # ttl :: FromResp a => ByteString -> RedisCommandClient client a # rpush :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # lpop :: FromResp a => ByteString -> RedisCommandClient client a # rpop :: FromResp a => ByteString -> RedisCommandClient client a # sadd :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # smembers :: FromResp a => ByteString -> RedisCommandClient client a # scard :: FromResp a => ByteString -> RedisCommandClient client a # sismember :: FromResp a => ByteString -> ByteString -> RedisCommandClient client a # hdel :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # hkeys :: FromResp a => ByteString -> RedisCommandClient client a # hvals :: FromResp a => ByteString -> RedisCommandClient client a # llen :: FromResp a => ByteString -> RedisCommandClient client a # lindex :: FromResp a => ByteString -> Int -> RedisCommandClient client a # clientSetInfo :: FromResp a => [ByteString] -> RedisCommandClient client a # clientReply :: ClientReplyValues -> RedisCommandClient client (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> RedisCommandClient client a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> RedisCommandClient client a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> RedisCommandClient client a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> RedisCommandClient client a # geohash :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # geopos :: FromResp a => ByteString -> [ByteString] -> RedisCommandClient client a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> RedisCommandClient client a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> RedisCommandClient client a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> RedisCommandClient client a # clusterSlots :: FromResp a => RedisCommandClient client a #
Client client => MonadState (ClientState client) (RedisCommandClient client)
Instance details Defined in Database.Redis.Command Methods get :: RedisCommandClient client (ClientState client) # put :: ClientState client -> RedisCommandClient client () # state :: (ClientState client -> (a, ClientState client)) -> RedisCommandClient client a #

data RedisError #

Constructors

ParseError String
ConnectionClosed
UnexpectedResp RespData

Instances

Instances details

Exception RedisError
Instance details Defined in Database.Redis.RedisError Methods toException :: RedisError -> SomeException # fromException :: SomeException -> Maybe RedisError # displayException :: RedisError -> String # backtraceDesired :: RedisError -> Bool #
Show RedisError
Instance details Defined in Database.Redis.RedisError Methods showsPrec :: Int -> RedisError -> ShowS # show :: RedisError -> String # showList :: [RedisError] -> ShowS #
Eq RedisError
Instance details Defined in Database.Redis.RedisError Methods (==) :: RedisError -> RedisError -> Bool # (/=) :: RedisError -> RedisError -> Bool #

convertResp :: (FromResp a, MonadIO m) => RespData -> m a #

encodeBulkArg :: ByteString -> Builder #

encodeCommand :: [ByteString] -> ByteString #

encodeCommandBuilder :: [ByteString] -> Builder #

encodeGetBuilder :: ByteString -> Builder #

encodeSetBuilder :: ByteString -> ByteString -> Builder #

parseManyWith :: forall (client :: ConnectionStatus -> Type) m. (Client client, MonadIO m, MonadState (ClientState client) m) => Int -> m ByteString -> m [RespData] #

parseWith :: forall (client :: ConnectionStatus -> Type) m. (Client client, MonadIO m, MonadState (ClientState client) m) => m ByteString -> m RespData #

showBS :: Show a => a -> ByteString #

FromResp conversion

class FromResp a where #

Methods

fromResp :: RespData -> Either RedisError a #

Instances

Instances details

FromResp ByteString
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError ByteString #
FromResp RespData
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError RespData #
FromResp Text
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError Text #
FromResp Integer
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError Integer #
FromResp ()
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError () #
FromResp Bool
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError Bool #
FromResp (Maybe ByteString)
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError (Maybe ByteString) #
FromResp (Maybe Text)
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError (Maybe Text) #
FromResp [ByteString]
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError [ByteString] #
FromResp [RespData]
Instance details Defined in Database.Redis.FromResp Methods fromResp :: RespData -> Either RedisError [RespData] #

Cluster

data ClusterNode #

Constructors

ClusterNode
Fields nodeId :: ByteString nodeAddress :: NodeAddress nodeRole :: NodeRole nodeSlotsServed :: [SlotRange] nodeReplicas :: [ByteString]

Instances

Instances details

Show ClusterNode
Instance details Defined in Database.Redis.Cluster Methods showsPrec :: Int -> ClusterNode -> ShowS # show :: ClusterNode -> String # showList :: [ClusterNode] -> ShowS #
Eq ClusterNode
Instance details Defined in Database.Redis.Cluster Methods (==) :: ClusterNode -> ClusterNode -> Bool # (/=) :: ClusterNode -> ClusterNode -> Bool #

data ClusterTopology #

Constructors

ClusterTopology
Fields topologySlots :: Vector ByteString topologyAddresses :: Vector NodeAddress topologyNodes :: Map ByteString ClusterNode topologyUpdateTime :: UTCTime

Instances

Instances details

Show ClusterTopology
Instance details Defined in Database.Redis.Cluster Methods showsPrec :: Int -> ClusterTopology -> ShowS # show :: ClusterTopology -> String # showList :: [ClusterTopology] -> ShowS #

data NodeAddress #

Constructors

NodeAddress
Fields nodeHost :: String nodePort :: Int

Instances

Instances details

Show NodeAddress
Instance details Defined in Database.Redis.Cluster Methods showsPrec :: Int -> NodeAddress -> ShowS # show :: NodeAddress -> String # showList :: [NodeAddress] -> ShowS #
Eq NodeAddress
Instance details Defined in Database.Redis.Cluster Methods (==) :: NodeAddress -> NodeAddress -> Bool # (/=) :: NodeAddress -> NodeAddress -> Bool #
Ord NodeAddress
Instance details Defined in Database.Redis.Cluster Methods compare :: NodeAddress -> NodeAddress -> Ordering # (<) :: NodeAddress -> NodeAddress -> Bool # (<=) :: NodeAddress -> NodeAddress -> Bool # (>) :: NodeAddress -> NodeAddress -> Bool # (>=) :: NodeAddress -> NodeAddress -> Bool # max :: NodeAddress -> NodeAddress -> NodeAddress # min :: NodeAddress -> NodeAddress -> NodeAddress #

data NodeRole #

Constructors

Master
Replica

Instances

Instances details

Show NodeRole
Instance details Defined in Database.Redis.Cluster Methods showsPrec :: Int -> NodeRole -> ShowS # show :: NodeRole -> String # showList :: [NodeRole] -> ShowS #
Eq NodeRole
Instance details Defined in Database.Redis.Cluster Methods (==) :: NodeRole -> NodeRole -> Bool # (/=) :: NodeRole -> NodeRole -> Bool #

data SlotRange #

Constructors

SlotRange
Fields slotStart :: Word16 slotEnd :: Word16 slotMaster :: ByteString slotReplicas :: [ByteString]

Instances

Instances details

Show SlotRange
Instance details Defined in Database.Redis.Cluster Methods showsPrec :: Int -> SlotRange -> ShowS # show :: SlotRange -> String # showList :: [SlotRange] -> ShowS #
Eq SlotRange
Instance details Defined in Database.Redis.Cluster Methods (==) :: SlotRange -> SlotRange -> Bool # (/=) :: SlotRange -> SlotRange -> Bool #

data ClusterClient (client :: ConnectionStatus -> Type) #

Constructors

ClusterClient
Fields clusterTopology :: TVar ClusterTopology clusterConnectionPool :: ConnectionPool client clusterConfig :: ClusterConfig clusterConnector :: Connector client clusterRefreshLock :: MVar () clusterMultiplexPool :: MultiplexPool client

Instances

Instances details

Client client => MonadState (ClusterClient client) (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods get :: ClusterCommandClient client (ClusterClient client) # put :: ClusterClient client -> ClusterCommandClient client () # state :: (ClusterClient client -> (a, ClusterClient client)) -> ClusterCommandClient client a #

data ClusterCommandClient (client :: ConnectionStatus -> Type) a #

Instances

Instances details

Client client => MonadIO (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods liftIO :: IO a -> ClusterCommandClient client a #
Client client => Applicative (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods pure :: a -> ClusterCommandClient client a # (<>) :: ClusterCommandClient client (a -> b) -> ClusterCommandClient client a -> ClusterCommandClient client b # liftA2 :: (a -> b -> c) -> ClusterCommandClient client a -> ClusterCommandClient client b -> ClusterCommandClient client c # (>) :: ClusterCommandClient client a -> ClusterCommandClient client b -> ClusterCommandClient client b # (<*) :: ClusterCommandClient client a -> ClusterCommandClient client b -> ClusterCommandClient client a #
Client client => Functor (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods fmap :: (a -> b) -> ClusterCommandClient client a -> ClusterCommandClient client b # (<$) :: a -> ClusterCommandClient client b -> ClusterCommandClient client a #
Client client => Monad (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods (>>=) :: ClusterCommandClient client a -> (a -> ClusterCommandClient client b) -> ClusterCommandClient client b # (>>) :: ClusterCommandClient client a -> ClusterCommandClient client b -> ClusterCommandClient client b # return :: a -> ClusterCommandClient client a #
Client client => MonadFail (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods fail :: String -> ClusterCommandClient client a #
Client client => RedisCommands (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods auth :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # ping :: FromResp a => ClusterCommandClient client a # set :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # get :: FromResp a => ByteString -> ClusterCommandClient client a # mget :: FromResp a => [ByteString] -> ClusterCommandClient client a # setnx :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # decr :: FromResp a => ByteString -> ClusterCommandClient client a # psetex :: FromResp a => ByteString -> Int -> ByteString -> ClusterCommandClient client a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> ClusterCommandClient client a # flushAll :: FromResp a => ClusterCommandClient client a # dbsize :: FromResp a => ClusterCommandClient client a # del :: FromResp a => [ByteString] -> ClusterCommandClient client a # exists :: FromResp a => [ByteString] -> ClusterCommandClient client a # incr :: FromResp a => ByteString -> ClusterCommandClient client a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> ClusterCommandClient client a # hget :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # hmget :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # hexists :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # lpush :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # lrange :: FromResp a => ByteString -> Int -> Int -> ClusterCommandClient client a # expire :: FromResp a => ByteString -> Int -> ClusterCommandClient client a # ttl :: FromResp a => ByteString -> ClusterCommandClient client a # rpush :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # lpop :: FromResp a => ByteString -> ClusterCommandClient client a # rpop :: FromResp a => ByteString -> ClusterCommandClient client a # sadd :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # smembers :: FromResp a => ByteString -> ClusterCommandClient client a # scard :: FromResp a => ByteString -> ClusterCommandClient client a # sismember :: FromResp a => ByteString -> ByteString -> ClusterCommandClient client a # hdel :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # hkeys :: FromResp a => ByteString -> ClusterCommandClient client a # hvals :: FromResp a => ByteString -> ClusterCommandClient client a # llen :: FromResp a => ByteString -> ClusterCommandClient client a # lindex :: FromResp a => ByteString -> Int -> ClusterCommandClient client a # clientSetInfo :: FromResp a => [ByteString] -> ClusterCommandClient client a # clientReply :: ClientReplyValues -> ClusterCommandClient client (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> ClusterCommandClient client a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> ClusterCommandClient client a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> ClusterCommandClient client a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> ClusterCommandClient client a # geohash :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # geopos :: FromResp a => ByteString -> [ByteString] -> ClusterCommandClient client a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> ClusterCommandClient client a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> ClusterCommandClient client a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> ClusterCommandClient client a # clusterSlots :: FromResp a => ClusterCommandClient client a #
Client client => MonadState (ClusterClient client) (ClusterCommandClient client)
Instance details Defined in Database.Redis.Cluster.Client Methods get :: ClusterCommandClient client (ClusterClient client) # put :: ClusterClient client -> ClusterCommandClient client () # state :: (ClusterClient client -> (a, ClusterClient client)) -> ClusterCommandClient client a #

data ClusterConfig #

Constructors

ClusterConfig
Fields clusterSeedNode :: NodeAddress clusterPoolConfig :: PoolConfig clusterMaxRetries :: Int clusterRetryDelay :: Int clusterTopologyRefreshInterval :: Int

Instances

Instances details

Show ClusterConfig
Instance details Defined in Database.Redis.Cluster.Client Methods showsPrec :: Int -> ClusterConfig -> ShowS # show :: ClusterConfig -> String # showList :: [ClusterConfig] -> ShowS #

data ClusterError #

Constructors

MovedError Word16 NodeAddress
AskError Word16 NodeAddress
ClusterDownError String
TryAgainError String
CrossSlotError String
MaxRetriesExceeded String
TopologyError String
ConnectionError String

Instances

Instances details

Show ClusterError
Instance details Defined in Database.Redis.Cluster.Client Methods showsPrec :: Int -> ClusterError -> ShowS # show :: ClusterError -> String # showList :: [ClusterError] -> ShowS #
Eq ClusterError
Instance details Defined in Database.Redis.Cluster.Client Methods (==) :: ClusterError -> ClusterError -> Bool # (/=) :: ClusterError -> ClusterError -> Bool #

closeClusterClient :: forall (client :: ConnectionStatus -> Type). Client client => ClusterClient client -> IO () #

createClusterClient :: Client client => ClusterConfig -> Connector client -> IO (ClusterClient client) #

refreshTopology :: forall (client :: ConnectionStatus -> Type). Client client => ClusterClient client -> IO () #

runClusterCommandClient :: forall (client :: ConnectionStatus -> Type) a. Client client => ClusterClient client -> ClusterCommandClient client a -> IO a #

data ConnectionPool (client :: ConnectionStatus -> Type) #

Constructors

ConnectionPool
Fields poolConnections :: MVar (Map NodeAddress (NodePool client)) poolConfig :: PoolConfig

data PoolConfig #

Constructors

PoolConfig
Fields maxConnectionsPerNode :: Int connectionTimeout :: Int maxRetries :: Int useTLS :: Bool

Instances

Instances details

Show PoolConfig
Instance details Defined in Database.Redis.Cluster.ConnectionPool Methods showsPrec :: Int -> PoolConfig -> ShowS # show :: PoolConfig -> String # showList :: [PoolConfig] -> ShowS #

closePool :: forall (client :: ConnectionStatus -> Type). Client client => ConnectionPool client -> IO () #

createPool :: forall (client :: ConnectionStatus -> Type). PoolConfig -> IO (ConnectionPool client) #

withConnection :: Client client => ConnectionPool client -> NodeAddress -> Connector client -> (client 'Connected -> IO a) -> IO a #

Multiplexing

data Multiplexer #

data MultiplexerException #

Constructors

MultiplexerDead String
MultiplexerParseError String
MultiplexerConnectionClosed

Instances

Instances details

Exception MultiplexerException
Instance details Defined in Database.Redis.Internal.Multiplexer Methods toException :: MultiplexerException -> SomeException # fromException :: SomeException -> Maybe MultiplexerException # displayException :: MultiplexerException -> String # backtraceDesired :: MultiplexerException -> Bool #
Show MultiplexerException
Instance details Defined in Database.Redis.Internal.Multiplexer Methods showsPrec :: Int -> MultiplexerException -> ShowS # show :: MultiplexerException -> String # showList :: [MultiplexerException] -> ShowS #

createMultiplexer :: Client client => client 'Connected -> IO ByteString -> IO Multiplexer #

destroyMultiplexer :: Multiplexer -> IO () #

isMultiplexerAlive :: Multiplexer -> IO Bool #

submitCommand :: Multiplexer -> Builder -> IO RespData #

data MultiplexPool (client :: ConnectionStatus -> Type) #

closeMultiplexPool :: forall (client :: ConnectionStatus -> Type). MultiplexPool client -> IO () #

createMultiplexPool :: Client client => Connector client -> Int -> IO (MultiplexPool client) #

submitToNode :: forall (client :: ConnectionStatus -> Type). Client client => MultiplexPool client -> NodeAddress -> Builder -> IO RespData #

Standalone Multiplexed Client

data StandaloneClient #

data StandaloneCommandClient a #

Instances

Instances details

MonadIO StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods liftIO :: IO a -> StandaloneCommandClient a #
Applicative StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods pure :: a -> StandaloneCommandClient a # (<>) :: StandaloneCommandClient (a -> b) -> StandaloneCommandClient a -> StandaloneCommandClient b # liftA2 :: (a -> b -> c) -> StandaloneCommandClient a -> StandaloneCommandClient b -> StandaloneCommandClient c # (>) :: StandaloneCommandClient a -> StandaloneCommandClient b -> StandaloneCommandClient b # (<*) :: StandaloneCommandClient a -> StandaloneCommandClient b -> StandaloneCommandClient a #
Functor StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods fmap :: (a -> b) -> StandaloneCommandClient a -> StandaloneCommandClient b # (<$) :: a -> StandaloneCommandClient b -> StandaloneCommandClient a #
Monad StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods (>>=) :: StandaloneCommandClient a -> (a -> StandaloneCommandClient b) -> StandaloneCommandClient b # (>>) :: StandaloneCommandClient a -> StandaloneCommandClient b -> StandaloneCommandClient b # return :: a -> StandaloneCommandClient a #
MonadFail StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods fail :: String -> StandaloneCommandClient a #
RedisCommands StandaloneCommandClient
Instance details Defined in Database.Redis.Standalone Methods auth :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # ping :: FromResp a => StandaloneCommandClient a # set :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # get :: FromResp a => ByteString -> StandaloneCommandClient a # mget :: FromResp a => [ByteString] -> StandaloneCommandClient a # setnx :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # decr :: FromResp a => ByteString -> StandaloneCommandClient a # psetex :: FromResp a => ByteString -> Int -> ByteString -> StandaloneCommandClient a # bulkSet :: FromResp a => [(ByteString, ByteString)] -> StandaloneCommandClient a # flushAll :: FromResp a => StandaloneCommandClient a # dbsize :: FromResp a => StandaloneCommandClient a # del :: FromResp a => [ByteString] -> StandaloneCommandClient a # exists :: FromResp a => [ByteString] -> StandaloneCommandClient a # incr :: FromResp a => ByteString -> StandaloneCommandClient a # hset :: FromResp a => ByteString -> ByteString -> ByteString -> StandaloneCommandClient a # hget :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # hmget :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # hexists :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # lpush :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # lrange :: FromResp a => ByteString -> Int -> Int -> StandaloneCommandClient a # expire :: FromResp a => ByteString -> Int -> StandaloneCommandClient a # ttl :: FromResp a => ByteString -> StandaloneCommandClient a # rpush :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # lpop :: FromResp a => ByteString -> StandaloneCommandClient a # rpop :: FromResp a => ByteString -> StandaloneCommandClient a # sadd :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # smembers :: FromResp a => ByteString -> StandaloneCommandClient a # scard :: FromResp a => ByteString -> StandaloneCommandClient a # sismember :: FromResp a => ByteString -> ByteString -> StandaloneCommandClient a # hdel :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # hkeys :: FromResp a => ByteString -> StandaloneCommandClient a # hvals :: FromResp a => ByteString -> StandaloneCommandClient a # llen :: FromResp a => ByteString -> StandaloneCommandClient a # lindex :: FromResp a => ByteString -> Int -> StandaloneCommandClient a # clientSetInfo :: FromResp a => [ByteString] -> StandaloneCommandClient a # clientReply :: ClientReplyValues -> StandaloneCommandClient (Maybe RespData) # zadd :: FromResp a => ByteString -> [(Int, ByteString)] -> StandaloneCommandClient a # zrange :: FromResp a => ByteString -> Int -> Int -> Bool -> StandaloneCommandClient a # geoadd :: FromResp a => ByteString -> [(Double, Double, ByteString)] -> StandaloneCommandClient a # geodist :: FromResp a => ByteString -> ByteString -> ByteString -> Maybe GeoUnit -> StandaloneCommandClient a # geohash :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # geopos :: FromResp a => ByteString -> [ByteString] -> StandaloneCommandClient a # georadius :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusRo :: FromResp a => ByteString -> Double -> Double -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusByMember :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # georadiusByMemberRo :: FromResp a => ByteString -> ByteString -> Double -> GeoUnit -> [GeoRadiusFlag] -> StandaloneCommandClient a # geosearch :: FromResp a => ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> StandaloneCommandClient a # geosearchstore :: FromResp a => ByteString -> ByteString -> GeoSearchFrom -> GeoSearchBy -> [GeoSearchOption] -> Bool -> StandaloneCommandClient a # clusterSlots :: FromResp a => StandaloneCommandClient a #