Safe Haskell	None
Language	GHC2021

Cassandra.Settings

Description

This module exports types and functions from Database.CQL.IO, while adding a few wire specific functions.

Synopsis

module Database.CQL.IO.Tinylog
retry :: MonadClient m => RetrySettings -> m a -> m a
random :: IO Policy
data Consistency
- = Any
- | One
- | LocalOne
- | Two
- | Three
- | Quorum
- | LocalQuorum
- | All
- | EachQuorum
- | Serial
- | LocalSerial
data ProtocolError where
- UnexpectedResponse :: forall k a b. Host -> Response k a b -> ProtocolError
- UnexpectedQueryId :: forall k a b. QueryId k a b -> ProtocolError
- UnsupportedCompression :: CompressionAlgorithm -> [CompressionAlgorithm] -> ProtocolError
- SerialiseError :: String -> ProtocolError
- ParseError :: String -> ProtocolError
write :: (MonadClient m, Tuple a, RunQ q) => q W a () -> QueryParams a -> m ()
shutdown :: MonadIO m => ClientState -> m ()
once :: MonadClient m => m a -> m a
data S
data R
init :: MonadIO m => Settings -> m ClientState
trans :: (MonadClient m, Tuple a, RunQ q) => q W a Row -> QueryParams a -> m [Row]
newtype Identity a = Identity {
- runIdentity :: a
}
data W
newtype QueryString k a b = QueryString {
- unQueryString :: Text
}
data Row
fromRow :: Cql a => Int -> Row -> Either String a
data SerialConsistency
- = SerialConsistency
- | LocalSerialConsistency
data QueryParams a = QueryParams !Consistency !Bool a (Maybe Int32) (Maybe PagingState) (Maybe SerialConsistency) (Maybe Bool)
newtype InetAddr = InetAddr {
- sockAddr :: SockAddr
}
data HostEvent
- = HostNew !Host
- | HostGone !InetAddr
- | HostUp !InetAddr
- | HostDown !InetAddr
data HostResponse k a b = HostResponse {
- hrHost :: !Host
- hrResponse :: !(Response k a b)
}
data Host
hostAddr :: Lens' Host InetAddr
dataCentre :: Lens' Host Text
rack :: Lens' Host Text
data Policy = Policy {
- setup :: [Host] -> [Host] -> IO ()
- onEvent :: HostEvent -> IO ()
- select :: IO (Maybe Host)
- current :: IO [Host]
- acceptable :: Host -> IO Bool
- hostCount :: IO Word
- display :: IO String
}
roundRobin :: IO Policy
data Authenticator = Authenticator {
- authMechanism :: !AuthMechanism
- authOnRequest :: AuthContext -> IO (AuthResponse, s)
- authOnChallenge :: Maybe (s -> AuthChallenge -> IO (AuthResponse, s))
- authOnSuccess :: s -> AuthSuccess -> IO ()
}
newtype AuthMechanism = AuthMechanism Text
data AuthContext
data ConnId
authConnId :: Lens' AuthContext ConnId
authHost :: Lens' AuthContext InetAddr
newtype AuthPass = AuthPass Text
newtype AuthUser = AuthUser Text
passwordAuthenticator :: AuthUser -> AuthPass -> Authenticator
data AuthenticationError
- = AuthenticationRequired !AuthMechanism
- | UnexpectedAuthenticationChallenge !AuthMechanism !AuthChallenge
data HashCollision = HashCollision !Text !Text
data ConnectionError
- = ConnectionClosed !InetAddr
- | ConnectTimeout !InetAddr
- | ResponseTimeout !InetAddr
data HostError
- = NoHostAvailable
- | HostsBusy
data ResponseError = ResponseError {
- reHost :: !Host
- reTrace :: !(Maybe UUID)
- reWarn :: ![Text]
- reCause :: !Error
}
data LogLevel
- = LogDebug
- | LogInfo
- | LogWarn
- | LogError
data Logger = Logger {
- logMessage :: LogLevel -> Builder -> IO ()
- logRequest :: ByteString -> IO ()
- logResponse :: ByteString -> IO ()
}
nullLogger :: Logger
stdoutLogger :: LogLevel -> Logger
data PrepQuery k a b
prepared :: QueryString k a b -> PrepQuery k a b
queryString :: PrepQuery k a b -> QueryString k a b
defQueryParams :: Consistency -> a -> QueryParams a
data RetrySettings
data PrepareStrategy
- = EagerPrepare
- | LazyPrepare
data Settings
defSettings :: Settings
setProtocolVersion :: Version -> Settings -> Settings
setContacts :: String -> [String] -> Settings -> Settings
addContact :: String -> Settings -> Settings
setPortNumber :: PortNumber -> Settings -> Settings
setPolicy :: IO Policy -> Settings -> Settings
setPrepareStrategy :: PrepareStrategy -> Settings -> Settings
setLogger :: Logger -> Settings -> Settings
setIdleTimeout :: NominalDiffTime -> Settings -> Settings
setMaxConnections :: Int -> Settings -> Settings
setPoolStripes :: Int -> Settings -> Settings
setMaxTimeouts :: Int -> Settings -> Settings
setCompression :: Compression -> Settings -> Settings
setMaxStreams :: Int -> Settings -> Settings
setConnectTimeout :: NominalDiffTime -> Settings -> Settings
setSendTimeout :: NominalDiffTime -> Settings -> Settings
setResponseTimeout :: NominalDiffTime -> Settings -> Settings
setKeyspace :: Keyspace -> Settings -> Settings
setRetrySettings :: RetrySettings -> Settings -> Settings
setMaxRecvBuffer :: Int -> Settings -> Settings
setSSLContext :: SSLContext -> Settings -> Settings
setAuthentication :: [Authenticator] -> Settings -> Settings
noRetry :: RetrySettings
defRetrySettings :: RetrySettings
eagerRetrySettings :: RetrySettings
defRetryPolicy :: RetryPolicy
eagerRetryPolicy :: RetryPolicy
defRetryHandlers :: forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool]
eagerRetryHandlers :: forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool]
setRetryPolicy :: RetryPolicy -> RetrySettings -> RetrySettings
setRetryHandlers :: (forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool]) -> RetrySettings -> RetrySettings
adjustConsistency :: Consistency -> RetrySettings -> RetrySettings
adjustSendTimeout :: NominalDiffTime -> RetrySettings -> RetrySettings
adjustResponseTimeout :: NominalDiffTime -> RetrySettings -> RetrySettings
data ClientState
data DebugInfo = DebugInfo {
- policyInfo :: String
- jobInfo :: [InetAddr]
- hostInfo :: [Host]
- controlInfo :: (Host, ControlState)
}
class (MonadIO m, MonadThrow m) => MonadClient (m :: Type -> Type) where
- liftClient :: Client a -> m a
- localState :: (ClientState -> ClientState) -> m a -> m a
data Client a
runClient :: MonadIO m => ClientState -> Client a -> m a
request :: (MonadClient m, Tuple a, Tuple b) => Request k a b -> m (HostResponse k a b)
debugInfo :: MonadClient m => m DebugInfo
getResult :: MonadThrow m => HostResponse k a b -> m (Result k a b)
data BatchM a
addQuery :: (Show a, Tuple a, Tuple b) => QueryString W a b -> a -> BatchM ()
addPrepQuery :: (Show a, Tuple a, Tuple b) => PrepQuery W a b -> a -> BatchM ()
setType :: BatchType -> BatchM ()
setConsistency :: Consistency -> BatchM ()
setSerialConsistency :: SerialConsistency -> BatchM ()
data Page a = Page {
- hasMore :: !Bool
- result :: [a]
- nextPage :: Client (Page a)
}
class RunQ (q :: Type -> Type -> Type -> Type) where
- runQ :: (MonadClient m, Tuple a, Tuple b) => q k a b -> QueryParams a -> m (HostResponse k a b)
query :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m [b]
query1 :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m (Maybe b)
schema :: (MonadClient m, Tuple a, RunQ q) => q S a () -> QueryParams a -> m (Maybe SchemaChange)
batch :: MonadClient m => BatchM () -> m ()
emptyPage :: Page a
paginate :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m (Page b)
initialContactsDisco :: MonadIO m => String -> String -> m (NonEmpty String)
initialContactsPlain :: MonadIO m => Text -> m (NonEmpty String)
dcAwareRandomPolicy :: Text -> IO Policy
dcFilterPolicyIfConfigured :: Logger -> Maybe Text -> IO Policy

Documentation

module Database.CQL.IO.Tinylog

retry :: MonadClient m => RetrySettings -> m a -> m a #

random :: IO Policy #

data Consistency Source #

Consistency level.

See: Consistency

Constructors

Any
One
LocalOne
Two
Three
Quorum
LocalQuorum
All
EachQuorum	Only for write queries.
Serial	Only for read queries.
LocalSerial	Only for read queries.

Instances

Instances details

Show Consistency
Instance details Defined in Database.CQL.Protocol.Types Methods showsPrec :: Int -> Consistency -> ShowS # show :: Consistency -> String # showList :: [Consistency] -> ShowS #
Eq Consistency
Instance details Defined in Database.CQL.Protocol.Types Methods (==) :: Consistency -> Consistency -> Bool # (/=) :: Consistency -> Consistency -> Bool #

data ProtocolError where #

Constructors

UnexpectedResponse :: forall k a b. Host -> Response k a b -> ProtocolError
UnexpectedQueryId :: forall k a b. QueryId k a b -> ProtocolError
UnsupportedCompression :: CompressionAlgorithm -> [CompressionAlgorithm] -> ProtocolError
SerialiseError :: String -> ProtocolError
ParseError :: String -> ProtocolError

Instances

Instances details

Exception ProtocolError
Instance details Defined in Database.CQL.IO.Exception Methods toException :: ProtocolError -> SomeException # fromException :: SomeException -> Maybe ProtocolError # displayException :: ProtocolError -> String #
Show ProtocolError
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> ProtocolError -> ShowS # show :: ProtocolError -> String # showList :: [ProtocolError] -> ShowS #

write :: (MonadClient m, Tuple a, RunQ q) => q W a () -> QueryParams a -> m () Source #

Run a CQL write-only query (e.g. insert/update/delete), returning no result.

/Note: If the write operation is conditional, i.e. is in fact a "lightweight transaction" returning a result, trans must be used instead./

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

once :: MonadClient m => m a -> m a #

data S Source #

Type tag for schema queries, i.e. 'QueryString S a b'.

data R Source #

Type tag for read queries, i.e. 'QueryString R a b'.

init :: MonadIO m => Settings -> m ClientState #

trans :: (MonadClient m, Tuple a, RunQ q) => q W a Row -> QueryParams a -> m [Row] Source #

Run a CQL conditional write query (e.g. insert/update/delete) as a "lightweight transaction", returning the result Rows describing the outcome.

newtype Identity a #

Identity functor and monad. (a non-strict monad)

Since: base-4.8.0.0

Constructors

Identity
Fields runIdentity :: a

Instances

Instances details

Representable Identity

Instance details

Defined in Data.Functor.Rep

Associated Types

type Rep Identity
Instance details Defined in Data.Functor.Rep type Rep Identity = ()

Methods

tabulate :: (Rep Identity -> a) -> Identity a Source #

index :: Identity a -> Rep Identity -> a Source #

FromJSON1 Identity

Instance details

Defined in Data.Aeson.Types.FromJSON

Methods

liftParseJSON :: Maybe a -> (Value -> Parser a) -> (Value -> Parser [a]) -> Value -> Parser (Identity a) Source #

liftParseJSONList :: Maybe a -> (Value -> Parser a) -> (Value -> Parser [a]) -> Value -> Parser [Identity a] Source #

liftOmittedField :: Maybe a -> Maybe (Identity a) Source #

ToJSON1 Identity

Instance details

Defined in Data.Aeson.Types.ToJSON

Methods

liftToJSON :: (a -> Bool) -> (a -> Value) -> ([a] -> Value) -> Identity a -> Value Source #

liftToJSONList :: (a -> Bool) -> (a -> Value) -> ([a] -> Value) -> [Identity a] -> Value Source #

liftToEncoding :: (a -> Bool) -> (a -> Encoding) -> ([a] -> Encoding) -> Identity a -> Encoding Source #

liftToEncodingList :: (a -> Bool) -> (a -> Encoding) -> ([a] -> Encoding) -> [Identity a] -> Encoding Source #

liftOmitField :: (a -> Bool) -> Identity a -> Bool Source #

MonadFix Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

mfix :: (a -> Identity a) -> Identity a #

MonadZip Identity

Since: base-4.8.0.0

Instance details

Defined in Control.Monad.Zip

Methods

mzip :: Identity a -> Identity b -> Identity (a, b) #

mzipWith :: (a -> b -> c) -> Identity a -> Identity b -> Identity c #

munzip :: Identity (a, b) -> (Identity a, Identity b) #

Foldable Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

fold :: Monoid m => Identity m -> m #

foldMap :: Monoid m => (a -> m) -> Identity a -> m #

foldMap' :: Monoid m => (a -> m) -> Identity a -> m #

foldr :: (a -> b -> b) -> b -> Identity a -> b #

foldr' :: (a -> b -> b) -> b -> Identity a -> b #

foldl :: (b -> a -> b) -> b -> Identity a -> b #

foldl' :: (b -> a -> b) -> b -> Identity a -> b #

foldr1 :: (a -> a -> a) -> Identity a -> a #

foldl1 :: (a -> a -> a) -> Identity a -> a #

toList :: Identity a -> [a] #

null :: Identity a -> Bool #

length :: Identity a -> Int #

elem :: Eq a => a -> Identity a -> Bool #

maximum :: Ord a => Identity a -> a #

minimum :: Ord a => Identity a -> a #

sum :: Num a => Identity a -> a #

product :: Num a => Identity a -> a #

Foldable1 Identity

Since: base-4.18.0.0

Instance details

Defined in Data.Foldable1

Methods

fold1 :: Semigroup m => Identity m -> m #

foldMap1 :: Semigroup m => (a -> m) -> Identity a -> m #

foldMap1' :: Semigroup m => (a -> m) -> Identity a -> m #

toNonEmpty :: Identity a -> NonEmpty a #

maximum :: Ord a => Identity a -> a #

minimum :: Ord a => Identity a -> a #

head :: Identity a -> a #

last :: Identity a -> a #

foldrMap1 :: (a -> b) -> (a -> b -> b) -> Identity a -> b #

foldlMap1' :: (a -> b) -> (b -> a -> b) -> Identity a -> b #

foldlMap1 :: (a -> b) -> (b -> a -> b) -> Identity a -> b #

foldrMap1' :: (a -> b) -> (a -> b -> b) -> Identity a -> b #

Eq1 Identity

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Classes

Methods

liftEq :: (a -> b -> Bool) -> Identity a -> Identity b -> Bool #

Ord1 Identity

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Classes

Methods

liftCompare :: (a -> b -> Ordering) -> Identity a -> Identity b -> Ordering #

Read1 Identity

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Classes

Methods

liftReadsPrec :: (Int -> ReadS a) -> ReadS [a] -> Int -> ReadS (Identity a) #

liftReadList :: (Int -> ReadS a) -> ReadS [a] -> ReadS [Identity a] #

liftReadPrec :: ReadPrec a -> ReadPrec [a] -> ReadPrec (Identity a) #

liftReadListPrec :: ReadPrec a -> ReadPrec [a] -> ReadPrec [Identity a] #

Show1 Identity

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Classes

Methods

liftShowsPrec :: (Int -> a -> ShowS) -> ([a] -> ShowS) -> Int -> Identity a -> ShowS #

liftShowList :: (Int -> a -> ShowS) -> ([a] -> ShowS) -> [Identity a] -> ShowS #

Traversable Identity

Since: base-4.9.0.0

Instance details

Defined in Data.Traversable

Methods

traverse :: Applicative f => (a -> f b) -> Identity a -> f (Identity b) #

sequenceA :: Applicative f => Identity (f a) -> f (Identity a) #

mapM :: Monad m => (a -> m b) -> Identity a -> m (Identity b) #

sequence :: Monad m => Identity (m a) -> m (Identity a) #

Applicative Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

pure :: a -> Identity a #

(<*>) :: Identity (a -> b) -> Identity a -> Identity b #

liftA2 :: (a -> b -> c) -> Identity a -> Identity b -> Identity c #

(*>) :: Identity a -> Identity b -> Identity b #

(<*) :: Identity a -> Identity b -> Identity a #

Functor Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

fmap :: (a -> b) -> Identity a -> Identity b #

(<$) :: a -> Identity b -> Identity a #

Monad Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(>>=) :: Identity a -> (a -> Identity b) -> Identity b #

(>>) :: Identity a -> Identity b -> Identity b #

return :: a -> Identity a #

NFData1 Identity

Since: deepseq-1.4.3.0

Instance details

Defined in Control.DeepSeq

Methods

liftRnf :: (a -> ()) -> Identity a -> () #

Hashable1 Identity

Instance details

Defined in Data.Hashable.Class

Methods

liftHashWithSalt :: (Int -> a -> Int) -> Int -> Identity a -> Int Source #

Settable Identity

So you can pass our Setter into combinators from other lens libraries.

Instance details

Defined in Control.Lens.Internal.Setter

Methods

untainted :: Identity a -> a Source #

untaintedDot :: Profunctor p => p a (Identity b) -> p a b Source #

taintedDot :: Profunctor p => p a b -> p a (Identity b) Source #

Generic1 Identity

Instance details

Defined in Data.Functor.Identity

Associated Types

type Rep1 Identity	Since: base-4.8.0.0
Instance details Defined in Data.Functor.Identity type Rep1 Identity = D1 ('MetaData "Identity" "Data.Functor.Identity" "base" 'True) (C1 ('MetaCons "Identity" 'PrefixI 'True) (S1 ('MetaSel ('Just "runIdentity") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) Par1))

Methods

from1 :: Identity a -> Rep1 Identity a #

to1 :: Rep1 Identity a -> Identity a #

Cosieve ReifiedGetter Identity

Instance details

Defined in Control.Lens.Reified

Methods

cosieve :: ReifiedGetter a b -> Identity a -> b Source #

Sieve ReifiedGetter Identity

Instance details

Defined in Control.Lens.Reified

Methods

sieve :: ReifiedGetter a b -> a -> Identity b Source #

Unbox a => Vector Vector (Identity a)

Instance details

Defined in Data.Vector.Unboxed.Base

Methods

basicUnsafeFreeze :: Mutable Vector s (Identity a) -> ST s (Vector (Identity a))

basicUnsafeThaw :: Vector (Identity a) -> ST s (Mutable Vector s (Identity a))

basicLength :: Vector (Identity a) -> Int

basicUnsafeSlice :: Int -> Int -> Vector (Identity a) -> Vector (Identity a)

basicUnsafeIndexM :: Vector (Identity a) -> Int -> Box (Identity a)

basicUnsafeCopy :: Mutable Vector s (Identity a) -> Vector (Identity a) -> ST s ()

elemseq :: Vector (Identity a) -> Identity a -> b -> b

Unbox a => MVector MVector (Identity a)

Instance details

Defined in Data.Vector.Unboxed.Base

Methods

basicLength :: MVector s (Identity a) -> Int

basicUnsafeSlice :: Int -> Int -> MVector s (Identity a) -> MVector s (Identity a)

basicOverlaps :: MVector s (Identity a) -> MVector s (Identity a) -> Bool

basicUnsafeNew :: Int -> ST s (MVector s (Identity a))

basicInitialize :: MVector s (Identity a) -> ST s ()

basicUnsafeReplicate :: Int -> Identity a -> ST s (MVector s (Identity a))

basicUnsafeRead :: MVector s (Identity a) -> Int -> ST s (Identity a)

basicUnsafeWrite :: MVector s (Identity a) -> Int -> Identity a -> ST s ()

basicClear :: MVector s (Identity a) -> ST s ()

basicSet :: MVector s (Identity a) -> Identity a -> ST s ()

basicUnsafeCopy :: MVector s (Identity a) -> MVector s (Identity a) -> ST s ()

basicUnsafeMove :: MVector s (Identity a) -> MVector s (Identity a) -> ST s ()

basicUnsafeGrow :: MVector s (Identity a) -> Int -> ST s (MVector s (Identity a))

FromJSON a => FromJSON (Identity a)

Instance details

Defined in Data.Aeson.Types.FromJSON

Methods

parseJSON :: Value -> Parser (Identity a) Source #

parseJSONList :: Value -> Parser [Identity a] Source #

omittedField :: Maybe (Identity a) Source #

FromJSONKey a => FromJSONKey (Identity a)

Instance details

Defined in Data.Aeson.Types.FromJSON

Methods

fromJSONKey :: FromJSONKeyFunction (Identity a) Source #

fromJSONKeyList :: FromJSONKeyFunction [Identity a] Source #

ToJSON a => ToJSON (Identity a)

Instance details

Defined in Data.Aeson.Types.ToJSON

Methods

toJSON :: Identity a -> Value Source #

toEncoding :: Identity a -> Encoding Source #

toJSONList :: [Identity a] -> Value Source #

toEncodingList :: [Identity a] -> Encoding Source #

omitField :: Identity a -> Bool Source #

ToJSONKey a => ToJSONKey (Identity a)

Instance details

Defined in Data.Aeson.Types.ToJSON

Methods

toJSONKey :: ToJSONKeyFunction (Identity a) Source #

toJSONKeyList :: ToJSONKeyFunction [Identity a] Source #

Data a => Data (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Data

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> Identity a -> c (Identity a) #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c (Identity a) #

toConstr :: Identity a -> Constr #

dataTypeOf :: Identity a -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c (Identity a)) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c (Identity a)) #

gmapT :: (forall b. Data b => b -> b) -> Identity a -> Identity a #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> Identity a -> r #

gmapQr :: forall r r'. (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> Identity a -> r #

gmapQ :: (forall d. Data d => d -> u) -> Identity a -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> Identity a -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> Identity a -> m (Identity a) #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> Identity a -> m (Identity a) #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> Identity a -> m (Identity a) #

IsString a => IsString (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.String

Methods

fromString :: String -> Identity a #

Storable a => Storable (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

sizeOf :: Identity a -> Int #

alignment :: Identity a -> Int #

peekElemOff :: Ptr (Identity a) -> Int -> IO (Identity a) #

pokeElemOff :: Ptr (Identity a) -> Int -> Identity a -> IO () #

peekByteOff :: Ptr b -> Int -> IO (Identity a) #

pokeByteOff :: Ptr b -> Int -> Identity a -> IO () #

peek :: Ptr (Identity a) -> IO (Identity a) #

poke :: Ptr (Identity a) -> Identity a -> IO () #

Monoid a => Monoid (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

mempty :: Identity a #

mappend :: Identity a -> Identity a -> Identity a #

mconcat :: [Identity a] -> Identity a #

Semigroup a => Semigroup (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(<>) :: Identity a -> Identity a -> Identity a #

sconcat :: NonEmpty (Identity a) -> Identity a #

stimes :: Integral b => b -> Identity a -> Identity a #

Bits a => Bits (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(.&.) :: Identity a -> Identity a -> Identity a #

(.|.) :: Identity a -> Identity a -> Identity a #

xor :: Identity a -> Identity a -> Identity a #

complement :: Identity a -> Identity a #

shift :: Identity a -> Int -> Identity a #

rotate :: Identity a -> Int -> Identity a #

zeroBits :: Identity a #

bit :: Int -> Identity a #

setBit :: Identity a -> Int -> Identity a #

clearBit :: Identity a -> Int -> Identity a #

complementBit :: Identity a -> Int -> Identity a #

testBit :: Identity a -> Int -> Bool #

bitSizeMaybe :: Identity a -> Maybe Int #

bitSize :: Identity a -> Int #

isSigned :: Identity a -> Bool #

shiftL :: Identity a -> Int -> Identity a #

unsafeShiftL :: Identity a -> Int -> Identity a #

shiftR :: Identity a -> Int -> Identity a #

unsafeShiftR :: Identity a -> Int -> Identity a #

rotateL :: Identity a -> Int -> Identity a #

rotateR :: Identity a -> Int -> Identity a #

popCount :: Identity a -> Int #

FiniteBits a => FiniteBits (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

finiteBitSize :: Identity a -> Int #

countLeadingZeros :: Identity a -> Int #

countTrailingZeros :: Identity a -> Int #

Bounded a => Bounded (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

minBound :: Identity a #

maxBound :: Identity a #

Enum a => Enum (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

succ :: Identity a -> Identity a #

pred :: Identity a -> Identity a #

toEnum :: Int -> Identity a #

fromEnum :: Identity a -> Int #

enumFrom :: Identity a -> [Identity a] #

enumFromThen :: Identity a -> Identity a -> [Identity a] #

enumFromTo :: Identity a -> Identity a -> [Identity a] #

enumFromThenTo :: Identity a -> Identity a -> Identity a -> [Identity a] #

Floating a => Floating (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

pi :: Identity a #

exp :: Identity a -> Identity a #

log :: Identity a -> Identity a #

sqrt :: Identity a -> Identity a #

(**) :: Identity a -> Identity a -> Identity a #

logBase :: Identity a -> Identity a -> Identity a #

sin :: Identity a -> Identity a #

cos :: Identity a -> Identity a #

tan :: Identity a -> Identity a #

asin :: Identity a -> Identity a #

acos :: Identity a -> Identity a #

atan :: Identity a -> Identity a #

sinh :: Identity a -> Identity a #

cosh :: Identity a -> Identity a #

tanh :: Identity a -> Identity a #

asinh :: Identity a -> Identity a #

acosh :: Identity a -> Identity a #

atanh :: Identity a -> Identity a #

log1p :: Identity a -> Identity a #

expm1 :: Identity a -> Identity a #

log1pexp :: Identity a -> Identity a #

log1mexp :: Identity a -> Identity a #

RealFloat a => RealFloat (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

floatRadix :: Identity a -> Integer #

floatDigits :: Identity a -> Int #

floatRange :: Identity a -> (Int, Int) #

decodeFloat :: Identity a -> (Integer, Int) #

encodeFloat :: Integer -> Int -> Identity a #

exponent :: Identity a -> Int #

significand :: Identity a -> Identity a #

scaleFloat :: Int -> Identity a -> Identity a #

isNaN :: Identity a -> Bool #

isInfinite :: Identity a -> Bool #

isDenormalized :: Identity a -> Bool #

isNegativeZero :: Identity a -> Bool #

isIEEE :: Identity a -> Bool #

atan2 :: Identity a -> Identity a -> Identity a #

Generic (Identity a)

Instance details

Defined in Data.Functor.Identity

Associated Types

type Rep (Identity a)	Since: base-4.8.0.0
Instance details Defined in Data.Functor.Identity type Rep (Identity a) = D1 ('MetaData "Identity" "Data.Functor.Identity" "base" 'True) (C1 ('MetaCons "Identity" 'PrefixI 'True) (S1 ('MetaSel ('Just "runIdentity") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a)))

Methods

from :: Identity a -> Rep (Identity a) x #

to :: Rep (Identity a) x -> Identity a #

Ix a => Ix (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

range :: (Identity a, Identity a) -> [Identity a] #

index :: (Identity a, Identity a) -> Identity a -> Int #

unsafeIndex :: (Identity a, Identity a) -> Identity a -> Int #

inRange :: (Identity a, Identity a) -> Identity a -> Bool #

rangeSize :: (Identity a, Identity a) -> Int #

unsafeRangeSize :: (Identity a, Identity a) -> Int #

Num a => Num (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(+) :: Identity a -> Identity a -> Identity a #

(-) :: Identity a -> Identity a -> Identity a #

(*) :: Identity a -> Identity a -> Identity a #

negate :: Identity a -> Identity a #

abs :: Identity a -> Identity a #

signum :: Identity a -> Identity a #

fromInteger :: Integer -> Identity a #

Read a => Read (Identity a)

This instance would be equivalent to the derived instances of the Identity newtype if the runIdentity field were removed

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

readsPrec :: Int -> ReadS (Identity a) #

readList :: ReadS [Identity a] #

readPrec :: ReadPrec (Identity a) #

readListPrec :: ReadPrec [Identity a] #

Fractional a => Fractional (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(/) :: Identity a -> Identity a -> Identity a #

recip :: Identity a -> Identity a #

fromRational :: Rational -> Identity a #

Integral a => Integral (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

quot :: Identity a -> Identity a -> Identity a #

rem :: Identity a -> Identity a -> Identity a #

div :: Identity a -> Identity a -> Identity a #

mod :: Identity a -> Identity a -> Identity a #

quotRem :: Identity a -> Identity a -> (Identity a, Identity a) #

divMod :: Identity a -> Identity a -> (Identity a, Identity a) #

toInteger :: Identity a -> Integer #

Real a => Real (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

toRational :: Identity a -> Rational #

RealFrac a => RealFrac (Identity a)

Since: base-4.9.0.0

Instance details

Defined in Data.Functor.Identity

Methods

properFraction :: Integral b => Identity a -> (b, Identity a) #

truncate :: Integral b => Identity a -> b #

round :: Integral b => Identity a -> b #

ceiling :: Integral b => Identity a -> b #

floor :: Integral b => Identity a -> b #

Show a => Show (Identity a)

This instance would be equivalent to the derived instances of the Identity newtype if the runIdentity field were removed

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

showsPrec :: Int -> Identity a -> ShowS #

show :: Identity a -> String #

showList :: [Identity a] -> ShowS #

Cql a => PrivateTuple (Identity a)

Instance details

Defined in Database.CQL.Protocol.Tuple

Methods

count :: Tagged (Identity a) Int Source #

check :: Tagged (Identity a) ([ColumnType] -> [ColumnType]) Source #

tuple :: Version -> [ColumnSpec] -> Get (Identity a) Source #

store :: Version -> Putter (Identity a) Source #

Cql a => Tuple (Identity a)

Instance details

Defined in Database.CQL.Protocol.Tuple

NFData a => NFData (Identity a)

Since: deepseq-1.4.0.0

Instance details

Defined in Control.DeepSeq

Methods

rnf :: Identity a -> () #

Eq a => Eq (Identity a)

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

(==) :: Identity a -> Identity a -> Bool #

(/=) :: Identity a -> Identity a -> Bool #

Ord a => Ord (Identity a)

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

Methods

compare :: Identity a -> Identity a -> Ordering #

(<) :: Identity a -> Identity a -> Bool #

(<=) :: Identity a -> Identity a -> Bool #

(>) :: Identity a -> Identity a -> Bool #

(>=) :: Identity a -> Identity a -> Bool #

max :: Identity a -> Identity a -> Identity a #

min :: Identity a -> Identity a -> Identity a #

Hashable a => Hashable (Identity a)

Instance details

Defined in Data.Hashable.Class

Methods

hashWithSalt :: Int -> Identity a -> Int Source #

hash :: Identity a -> Int Source #

Ixed (Identity a)

Instance details

Defined in Control.Lens.At

Methods

ix :: Index (Identity a) -> Traversal' (Identity a) (IxValue (Identity a)) Source #

Wrapped (Identity a)

Instance details

Defined in Control.Lens.Wrapped

Associated Types

type Unwrapped (Identity a)
Instance details Defined in Control.Lens.Wrapped type Unwrapped (Identity a) = a

Methods

_Wrapped' :: Iso' (Identity a) (Unwrapped (Identity a)) Source #

Pretty a => Pretty (Identity a)

>>> pretty (Identity 1)
1

Instance details

Defined in Prettyprinter.Internal

Methods

pretty :: Identity a -> Doc ann Source #

prettyList :: [Identity a] -> Doc ann Source #

Unbox a => Unbox (Identity a)

Instance details

Defined in Data.Vector.Unboxed.Base

t ~ Identity b => Rewrapped (Identity a) t

Instance details

Defined in Control.Lens.Wrapped

Each (Identity a) (Identity b) a b

each :: Traversal (Identity a) (Identity b) a b

Instance details

Defined in Control.Lens.Each

Methods

each :: Traversal (Identity a) (Identity b) a b Source #

Field1 (Identity a) (Identity b) a b

Instance details

Defined in Control.Lens.Tuple

Methods

_1 :: Lens (Identity a) (Identity b) a b Source #

type Rep Identity

Instance details

Defined in Data.Functor.Rep

type Rep Identity = ()

type Rep1 Identity

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

type Rep1 Identity = D1 ('MetaData "Identity" "Data.Functor.Identity" "base" 'True) (C1 ('MetaCons "Identity" 'PrefixI 'True) (S1 ('MetaSel ('Just "runIdentity") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) Par1))

newtype MVector s (Identity a)

Instance details

Defined in Data.Vector.Unboxed.Base

newtype MVector s (Identity a) = MV_Identity (MVector s a)

type Rep (Identity a)

Since: base-4.8.0.0

Instance details

Defined in Data.Functor.Identity

type Rep (Identity a) = D1 ('MetaData "Identity" "Data.Functor.Identity" "base" 'True) (C1 ('MetaCons "Identity" 'PrefixI 'True) (S1 ('MetaSel ('Just "runIdentity") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a)))

type Index (Identity a)

Instance details

Defined in Control.Lens.At

type Index (Identity a) = ()

type IxValue (Identity a)

Instance details

Defined in Control.Lens.At

type IxValue (Identity a) = a

type Unwrapped (Identity a)

Instance details

Defined in Control.Lens.Wrapped

type Unwrapped (Identity a) = a

newtype Vector (Identity a)

Instance details

Defined in Data.Vector.Unboxed.Base

newtype Vector (Identity a) = V_Identity (Vector a)

data W Source #

Type tag for write queries, i.e. 'QueryString W a b'.

newtype QueryString k a b Source #

Constructors

QueryString
Fields unQueryString :: Text

Instances

Instances details

RunQ QueryString
Instance details Defined in Database.CQL.IO Methods runQ :: (MonadClient m, Tuple a, Tuple b) => QueryString k a b -> QueryParams a -> m (HostResponse k a b) Source #
IsString (QueryString k a b)
Instance details Defined in Database.CQL.Protocol.Types Methods fromString :: String -> QueryString k a b #
Show (QueryString k a b)
Instance details Defined in Database.CQL.Protocol.Types Methods showsPrec :: Int -> QueryString k a b -> ShowS # show :: QueryString k a b -> String # showList :: [QueryString k a b] -> ShowS #
Eq (QueryString k a b)
Instance details Defined in Database.CQL.Protocol.Types Methods (==) :: QueryString k a b -> QueryString k a b -> Bool # (/=) :: QueryString k a b -> QueryString k a b -> Bool #

data Row Source #

A row is a vector of Values.

Instances

Instances details

Show Row
Instance details Defined in Database.CQL.Protocol.Tuple Methods showsPrec :: Int -> Row -> ShowS # show :: Row -> String # showList :: [Row] -> ShowS #
PrivateTuple Row
Instance details Defined in Database.CQL.Protocol.Tuple Methods count :: Tagged Row Int Source # check :: Tagged Row ([ColumnType] -> [ColumnType]) Source # tuple :: Version -> [ColumnSpec] -> Get Row Source # store :: Version -> Putter Row Source #
Tuple Row
Instance details Defined in Database.CQL.Protocol.Tuple
Eq Row
Instance details Defined in Database.CQL.Protocol.Tuple Methods (==) :: Row -> Row -> Bool # (/=) :: Row -> Row -> Bool #

fromRow :: Cql a => Int -> Row -> Either String a Source #

Convert a row element.

data SerialConsistency Source #

Consistency level for the serial phase of conditional updates (aka "lightweight transactions").

See: SerialConsistency

Constructors

SerialConsistency	Default. Quorum-based linearizable consistency.
LocalSerialConsistency	Like `SerialConsistency` except confined to a single (logical) data center.

Instances

Instances details

Show SerialConsistency
Instance details Defined in Database.CQL.Protocol.Request Methods showsPrec :: Int -> SerialConsistency -> ShowS # show :: SerialConsistency -> String # showList :: [SerialConsistency] -> ShowS #

data QueryParams a Source #

Query parameters.

Constructors

QueryParams !Consistency !Bool a (Maybe Int32) (Maybe PagingState) (Maybe SerialConsistency) (Maybe Bool)

Instances

Instances details

Show a => Show (QueryParams a)
Instance details Defined in Database.CQL.Protocol.Request Methods showsPrec :: Int -> QueryParams a -> ShowS # show :: QueryParams a -> String # showList :: [QueryParams a] -> ShowS #

newtype InetAddr #

Constructors

InetAddr
Fields sockAddr :: SockAddr

Instances

Instances details

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

data HostEvent #

Constructors

HostNew !Host
HostGone !InetAddr
HostUp !InetAddr
HostDown !InetAddr

data HostResponse k a b #

Constructors

HostResponse
Fields hrHost :: !Host hrResponse :: !(Response k a b)

Instances

Instances details

Show b => Show (HostResponse k a b)
Instance details Defined in Database.CQL.IO.Cluster.Host Methods showsPrec :: Int -> HostResponse k a b -> ShowS # show :: HostResponse k a b -> String # showList :: [HostResponse k a b] -> ShowS #

data Host #

Instances

Instances details

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

hostAddr :: Lens' Host InetAddr #

dataCentre :: Lens' Host Text #

rack :: Lens' Host Text #

data Policy #

Constructors

Policy
Fields setup :: [Host] -> [Host] -> IO () onEvent :: HostEvent -> IO () select :: IO (Maybe Host) current :: IO [Host] acceptable :: Host -> IO Bool hostCount :: IO Word display :: IO String

roundRobin :: IO Policy #

data Authenticator #

Constructors

Authenticator
Fields authMechanism :: !AuthMechanism authOnRequest :: AuthContext -> IO (AuthResponse, s) authOnChallenge :: Maybe (s -> AuthChallenge -> IO (AuthResponse, s)) authOnSuccess :: s -> AuthSuccess -> IO ()

newtype AuthMechanism #

Constructors

AuthMechanism Text

Instances

Instances details

IsString AuthMechanism
Instance details Defined in Database.CQL.IO.Connection.Settings Methods fromString :: String -> AuthMechanism #
Show AuthMechanism
Instance details Defined in Database.CQL.IO.Connection.Settings Methods showsPrec :: Int -> AuthMechanism -> ShowS # show :: AuthMechanism -> String # showList :: [AuthMechanism] -> ShowS #
Eq AuthMechanism
Instance details Defined in Database.CQL.IO.Connection.Settings Methods (==) :: AuthMechanism -> AuthMechanism -> Bool # (/=) :: AuthMechanism -> AuthMechanism -> Bool #
Ord AuthMechanism
Instance details Defined in Database.CQL.IO.Connection.Settings Methods compare :: AuthMechanism -> AuthMechanism -> Ordering # (<) :: AuthMechanism -> AuthMechanism -> Bool # (<=) :: AuthMechanism -> AuthMechanism -> Bool # (>) :: AuthMechanism -> AuthMechanism -> Bool # (>=) :: AuthMechanism -> AuthMechanism -> Bool # max :: AuthMechanism -> AuthMechanism -> AuthMechanism # min :: AuthMechanism -> AuthMechanism -> AuthMechanism #
Hashable AuthMechanism
Instance details Defined in Database.CQL.IO.Connection.Settings Methods hashWithSalt :: Int -> AuthMechanism -> Int Source # hash :: AuthMechanism -> Int Source #

data AuthContext #

data ConnId #

Instances

Instances details

Eq ConnId
Instance details Defined in Database.CQL.IO.Connection.Settings Methods (==) :: ConnId -> ConnId -> Bool # (/=) :: ConnId -> ConnId -> Bool #
Ord ConnId
Instance details Defined in Database.CQL.IO.Connection.Settings Methods compare :: ConnId -> ConnId -> Ordering # (<) :: ConnId -> ConnId -> Bool # (<=) :: ConnId -> ConnId -> Bool # (>) :: ConnId -> ConnId -> Bool # (>=) :: ConnId -> ConnId -> Bool # max :: ConnId -> ConnId -> ConnId # min :: ConnId -> ConnId -> ConnId #
Hashable ConnId
Instance details Defined in Database.CQL.IO.Connection.Settings Methods hashWithSalt :: Int -> ConnId -> Int Source # hash :: ConnId -> Int Source #

authConnId :: Lens' AuthContext ConnId #

authHost :: Lens' AuthContext InetAddr #

newtype AuthPass #

Constructors

AuthPass Text

newtype AuthUser #

Constructors

AuthUser Text

passwordAuthenticator :: AuthUser -> AuthPass -> Authenticator #

data AuthenticationError #

Constructors

AuthenticationRequired !AuthMechanism
UnexpectedAuthenticationChallenge !AuthMechanism !AuthChallenge

Instances

Instances details

Exception AuthenticationError
Instance details Defined in Database.CQL.IO.Exception Methods toException :: AuthenticationError -> SomeException # fromException :: SomeException -> Maybe AuthenticationError # displayException :: AuthenticationError -> String #
Show AuthenticationError
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> AuthenticationError -> ShowS # show :: AuthenticationError -> String # showList :: [AuthenticationError] -> ShowS #

data HashCollision #

Constructors

HashCollision !Text !Text

Instances

Instances details

Exception HashCollision
Instance details Defined in Database.CQL.IO.Exception Methods toException :: HashCollision -> SomeException # fromException :: SomeException -> Maybe HashCollision # displayException :: HashCollision -> String #
Show HashCollision
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> HashCollision -> ShowS # show :: HashCollision -> String # showList :: [HashCollision] -> ShowS #

data ConnectionError #

Constructors

ConnectionClosed !InetAddr
ConnectTimeout !InetAddr
ResponseTimeout !InetAddr

Instances

Instances details

Exception ConnectionError
Instance details Defined in Database.CQL.IO.Exception Methods toException :: ConnectionError -> SomeException # fromException :: SomeException -> Maybe ConnectionError # displayException :: ConnectionError -> String #
Show ConnectionError
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> ConnectionError -> ShowS # show :: ConnectionError -> String # showList :: [ConnectionError] -> ShowS #

data HostError #

Constructors

NoHostAvailable
HostsBusy

Instances

Instances details

Exception HostError
Instance details Defined in Database.CQL.IO.Exception Methods toException :: HostError -> SomeException # fromException :: SomeException -> Maybe HostError # displayException :: HostError -> String #
Show HostError
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> HostError -> ShowS # show :: HostError -> String # showList :: [HostError] -> ShowS #

data ResponseError #

Constructors

ResponseError
Fields reHost :: !Host reTrace :: !(Maybe UUID) reWarn :: ![Text] reCause :: !Error

Instances

Instances details

Exception ResponseError
Instance details Defined in Database.CQL.IO.Exception Methods toException :: ResponseError -> SomeException # fromException :: SomeException -> Maybe ResponseError # displayException :: ResponseError -> String #
Show ResponseError
Instance details Defined in Database.CQL.IO.Exception Methods showsPrec :: Int -> ResponseError -> ShowS # show :: ResponseError -> String # showList :: [ResponseError] -> ShowS #

data LogLevel #

Constructors

LogDebug
LogInfo
LogWarn
LogError

Instances

Instances details

Read LogLevel
Instance details Defined in Database.CQL.IO.Log Methods readsPrec :: Int -> ReadS LogLevel # readList :: ReadS [LogLevel] # readPrec :: ReadPrec LogLevel # readListPrec :: ReadPrec [LogLevel] #
Show LogLevel
Instance details Defined in Database.CQL.IO.Log Methods showsPrec :: Int -> LogLevel -> ShowS # show :: LogLevel -> String # showList :: [LogLevel] -> ShowS #
Eq LogLevel
Instance details Defined in Database.CQL.IO.Log Methods (==) :: LogLevel -> LogLevel -> Bool # (/=) :: LogLevel -> LogLevel -> Bool #
Ord LogLevel
Instance details Defined in Database.CQL.IO.Log Methods compare :: LogLevel -> LogLevel -> Ordering # (<) :: LogLevel -> LogLevel -> Bool # (<=) :: LogLevel -> LogLevel -> Bool # (>) :: LogLevel -> LogLevel -> Bool # (>=) :: LogLevel -> LogLevel -> Bool # max :: LogLevel -> LogLevel -> LogLevel # min :: LogLevel -> LogLevel -> LogLevel #

data Logger #

Constructors

Logger
Fields logMessage :: LogLevel -> Builder -> IO () logRequest :: ByteString -> IO () logResponse :: ByteString -> IO ()

nullLogger :: Logger #

stdoutLogger :: LogLevel -> Logger #

data PrepQuery k a b #

Instances

Instances details

RunQ PrepQuery
Instance details Defined in Database.CQL.IO Methods runQ :: (MonadClient m, Tuple a, Tuple b) => PrepQuery k a b -> QueryParams a -> m (HostResponse k a b) Source #
IsString (PrepQuery k a b)
Instance details Defined in Database.CQL.IO.PrepQuery Methods fromString :: String -> PrepQuery k a b #

prepared :: QueryString k a b -> PrepQuery k a b #

queryString :: PrepQuery k a b -> QueryString k a b #

defQueryParams :: Consistency -> a -> QueryParams a #

data RetrySettings #

data PrepareStrategy #

Constructors

EagerPrepare
LazyPrepare

Instances

Instances details

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

data Settings #

defSettings :: Settings #

setProtocolVersion :: Version -> Settings -> Settings #

setContacts :: String -> [String] -> Settings -> Settings #

addContact :: String -> Settings -> Settings #

setPortNumber :: PortNumber -> Settings -> Settings #

setPolicy :: IO Policy -> Settings -> Settings #

setPrepareStrategy :: PrepareStrategy -> Settings -> Settings #

setLogger :: Logger -> Settings -> Settings #

setIdleTimeout :: NominalDiffTime -> Settings -> Settings #

setMaxConnections :: Int -> Settings -> Settings #

setPoolStripes :: Int -> Settings -> Settings #

setMaxTimeouts :: Int -> Settings -> Settings #

setCompression :: Compression -> Settings -> Settings #

setMaxStreams :: Int -> Settings -> Settings #

setConnectTimeout :: NominalDiffTime -> Settings -> Settings #

setSendTimeout :: NominalDiffTime -> Settings -> Settings #

setResponseTimeout :: NominalDiffTime -> Settings -> Settings #

setKeyspace :: Keyspace -> Settings -> Settings #

setRetrySettings :: RetrySettings -> Settings -> Settings #

setMaxRecvBuffer :: Int -> Settings -> Settings #

setSSLContext :: SSLContext -> Settings -> Settings #

setAuthentication :: [Authenticator] -> Settings -> Settings #

noRetry :: RetrySettings #

defRetrySettings :: RetrySettings #

eagerRetrySettings :: RetrySettings #

defRetryPolicy :: RetryPolicy #

eagerRetryPolicy :: RetryPolicy #

defRetryHandlers :: forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool] #

eagerRetryHandlers :: forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool] #

setRetryPolicy :: RetryPolicy -> RetrySettings -> RetrySettings #

setRetryHandlers :: (forall (m :: Type -> Type). Monad m => [RetryStatus -> Handler m Bool]) -> RetrySettings -> RetrySettings #

adjustConsistency :: Consistency -> RetrySettings -> RetrySettings #

adjustSendTimeout :: NominalDiffTime -> RetrySettings -> RetrySettings #

adjustResponseTimeout :: NominalDiffTime -> RetrySettings -> RetrySettings #

data ClientState #

Instances

Instances details

MonadReader ClientState Client
Instance details Defined in Database.CQL.IO.Client Methods ask :: Client ClientState # local :: (ClientState -> ClientState) -> Client a -> Client a # reader :: (ClientState -> a) -> Client a #

data DebugInfo #

Constructors

DebugInfo
Fields policyInfo :: String jobInfo :: [InetAddr] hostInfo :: [Host] controlInfo :: (Host, ControlState)

Instances

Instances details

Show DebugInfo
Instance details Defined in Database.CQL.IO.Client Methods showsPrec :: Int -> DebugInfo -> ShowS # show :: DebugInfo -> String # showList :: [DebugInfo] -> ShowS #

class (MonadIO m, MonadThrow m) => MonadClient (m :: Type -> Type) where #

Methods

liftClient :: Client a -> m a #

localState :: (ClientState -> ClientState) -> m a -> m a #

Instances

Instances details

MonadClient Client
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> Client a # localState :: (ClientState -> ClientState) -> Client a -> Client a #
MonadClient m => MonadClient (ExceptT e m)
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> ExceptT e m a # localState :: (ClientState -> ClientState) -> ExceptT e m a -> ExceptT e m a #
MonadClient m => MonadClient (ReaderT r m)
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> ReaderT r m a # localState :: (ClientState -> ClientState) -> ReaderT r m a -> ReaderT r m a #
MonadClient m => MonadClient (StateT s m)
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> StateT s m a # localState :: (ClientState -> ClientState) -> StateT s m a -> StateT s m a #
MonadClient m => MonadClient (StateT s m)
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> StateT s m a # localState :: (ClientState -> ClientState) -> StateT s m a -> StateT s m a #

data Client a #

Instances

Instances details

MonadIO Client
Instance details Defined in Database.CQL.IO.Client Methods liftIO :: IO a -> Client a #
Applicative Client
Instance details Defined in Database.CQL.IO.Client Methods pure :: a -> Client a # (<>) :: Client (a -> b) -> Client a -> Client b # liftA2 :: (a -> b -> c) -> Client a -> Client b -> Client c # (>) :: Client a -> Client b -> Client b # (<*) :: Client a -> Client b -> Client a #
Functor Client
Instance details Defined in Database.CQL.IO.Client Methods fmap :: (a -> b) -> Client a -> Client b # (<$) :: a -> Client b -> Client a #
Monad Client
Instance details Defined in Database.CQL.IO.Client Methods (>>=) :: Client a -> (a -> Client b) -> Client b # (>>) :: Client a -> Client b -> Client b # return :: a -> Client a #
MonadClient Client
Instance details Defined in Database.CQL.IO.Client Methods liftClient :: Client a -> Client a # localState :: (ClientState -> ClientState) -> Client a -> Client a #
MonadCatch Client
Instance details Defined in Database.CQL.IO.Client Methods catch :: (HasCallStack, Exception e) => Client a -> (e -> Client a) -> Client a #
MonadMask Client
Instance details Defined in Database.CQL.IO.Client Methods mask :: HasCallStack => ((forall a. Client a -> Client a) -> Client b) -> Client b # uninterruptibleMask :: HasCallStack => ((forall a. Client a -> Client a) -> Client b) -> Client b # generalBracket :: HasCallStack => Client a -> (a -> ExitCase b -> Client c) -> (a -> Client b) -> Client (b, c) #
MonadThrow Client
Instance details Defined in Database.CQL.IO.Client Methods throwM :: (HasCallStack, Exception e) => e -> Client a #
MonadUnliftIO Client
Instance details Defined in Database.CQL.IO.Client Methods withRunInIO :: ((forall a. Client a -> IO a) -> IO b) -> Client b Source #
MonadReader ClientState Client
Instance details Defined in Database.CQL.IO.Client Methods ask :: Client ClientState # local :: (ClientState -> ClientState) -> Client a -> Client a # reader :: (ClientState -> a) -> Client a #

runClient :: MonadIO m => ClientState -> Client a -> m a #

request :: (MonadClient m, Tuple a, Tuple b) => Request k a b -> m (HostResponse k a b) #

debugInfo :: MonadClient m => m DebugInfo #

getResult :: MonadThrow m => HostResponse k a b -> m (Result k a b) #

data BatchM a #

Instances

Instances details

Applicative BatchM
Instance details Defined in Database.CQL.IO.Batch Methods pure :: a -> BatchM a # (<>) :: BatchM (a -> b) -> BatchM a -> BatchM b # liftA2 :: (a -> b -> c) -> BatchM a -> BatchM b -> BatchM c # (>) :: BatchM a -> BatchM b -> BatchM b # (<*) :: BatchM a -> BatchM b -> BatchM a #
Functor BatchM
Instance details Defined in Database.CQL.IO.Batch Methods fmap :: (a -> b) -> BatchM a -> BatchM b # (<$) :: a -> BatchM b -> BatchM a #
Monad BatchM
Instance details Defined in Database.CQL.IO.Batch Methods (>>=) :: BatchM a -> (a -> BatchM b) -> BatchM b # (>>) :: BatchM a -> BatchM b -> BatchM b # return :: a -> BatchM a #

addQuery :: (Show a, Tuple a, Tuple b) => QueryString W a b -> a -> BatchM () #

addPrepQuery :: (Show a, Tuple a, Tuple b) => PrepQuery W a b -> a -> BatchM () #

setType :: BatchType -> BatchM () #

setConsistency :: Consistency -> BatchM () #

setSerialConsistency :: SerialConsistency -> BatchM () #

data Page a Source #

Return value of paginate. Contains the actual result values as well as an indication of whether there is more data available and the actual action to fetch the next page.

Constructors

Page
Fields hasMore :: !Bool result :: [a] nextPage :: Client (Page a)

Instances

Instances details

Functor Page
Instance details Defined in Database.CQL.IO Methods fmap :: (a -> b) -> Page a -> Page b # (<$) :: a -> Page b -> Page a #

class RunQ (q :: Type -> Type -> Type -> Type) where Source #

A type which can be run as a query.

Methods

runQ :: (MonadClient m, Tuple a, Tuple b) => q k a b -> QueryParams a -> m (HostResponse k a b) Source #

Instances

Instances details

RunQ QueryString
Instance details Defined in Database.CQL.IO Methods runQ :: (MonadClient m, Tuple a, Tuple b) => QueryString k a b -> QueryParams a -> m (HostResponse k a b) Source #
RunQ PrepQuery
Instance details Defined in Database.CQL.IO Methods runQ :: (MonadClient m, Tuple a, Tuple b) => PrepQuery k a b -> QueryParams a -> m (HostResponse k a b) Source #

query :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m [b] Source #

Run a CQL read-only query returning a list of results.

query1 :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m (Maybe b) Source #

Run a CQL read-only query returning a single result.

schema :: (MonadClient m, Tuple a, RunQ q) => q S a () -> QueryParams a -> m (Maybe SchemaChange) Source #

Run a CQL schema query, returning SchemaChange information, if any.

batch :: MonadClient m => BatchM () -> m () Source #

Run a batch query against a Cassandra node.

emptyPage :: Page a Source #

A page with an empty result list.

paginate :: (MonadClient m, Tuple a, Tuple b, RunQ q) => q R a b -> QueryParams a -> m (Page b) Source #

Run a CQL read-only query against a Cassandra node.

This function is like query, but limits the result size to 10000 (default) unless there is an explicit size restriction given in QueryParams. The returned Page can be used to continue the query.

Please note that -- as of Cassandra 2.1.0 -- if your requested page size is equal to the result size, hasMore might be true and a subsequent nextPage will return an empty list in result.

initialContactsDisco :: MonadIO m => String -> String -> m (NonEmpty String) Source #

This function is likely only useful at Wire, as it is Wire-infra specific. Given a server name and a url returning a wire-custom "disco" json (AWS describe-instances-like json), e.g. { "roles" : { "server_name": [ {"privateIpAddress": "...", ...}, {...} ] } }, return a list of IP addresses.

initialContactsPlain :: MonadIO m => Text -> m (NonEmpty String) Source #

Puts the address into a list using the same signature as the other initialContacts

dcAwareRandomPolicy :: Text -> IO Policy Source #

Return hosts in random order for a given DC.

This is only useful during a cassandra datacentre migration.

dcFilterPolicyIfConfigured :: Logger -> Maybe Text -> IO Policy Source #

Use dcAwareRandomPolicy if config option filterNodesByDatacentre is set, otherwise use all available nodes with the default random policy.

This is only useful during a cassandra datacentre migration.