Safe Haskell	None
Language	Haskell2010

Data.MultiPool.PostgreSQLSimple

Contents

Orphan instances

Documentation

class Monad m => MultiPoolBackend (m :: Type -> Type) backend where #

Associated Types

type Primaries backend :: Type #

type Replicas backend :: Type #

type LocalPrimary backend :: Type #

type LocalReplica backend :: Type #

type PrimaryConnection backend :: Type #

type ReplicaConnection backend :: Type #

type PrimaryIdentifier backend :: Type #

type ReplicaIdentifier backend :: Type #

Methods

runWriteAny :: MultiPool backend -> ReaderT (PrimaryConnection backend) m a -> m a #

runWrite :: MultiPool backend -> PrimaryIdentifier backend -> ReaderT (PrimaryConnection backend) m a -> m a #

runReadPrimary :: MultiPool backend -> PrimaryIdentifier backend -> ReaderT (ReplicaConnection backend) m a -> m a #

runReadAnyPrimary :: MultiPool backend -> ReaderT (ReplicaConnection backend) m a -> m a #

runReadAny :: MultiPool backend -> ReaderT (ReplicaConnection backend) m a -> m a #

runRead :: MultiPool backend -> ReplicaIdentifier backend -> ReaderT (ReplicaConnection backend) m a -> m a #

takePrimary :: MultiPool backend -> PrimaryIdentifier backend -> m (PrimaryConnection backend, LocalPrimary backend) #

putPrimary :: MultiPool backend -> LocalPrimary backend -> PrimaryConnection backend -> m () #

takeReplica :: MultiPool backend -> ReplicaIdentifier backend -> m (ReplicaConnection backend, LocalReplica backend) #

putReplica :: MultiPool backend -> LocalReplica backend -> ReplicaConnection backend -> m () #

Instances

MonadUnliftIO m => MultiPoolBackend m Connection Source #

Instance details

Defined in Data.MultiPool.PostgreSQLSimple

Associated Types

type Primaries Connection :: Type #

type Replicas Connection :: Type #

type LocalPrimary Connection :: Type #

type LocalReplica Connection :: Type #

type PrimaryConnection Connection :: Type #

type ReplicaConnection Connection :: Type #

type PrimaryIdentifier Connection :: Type #

type ReplicaIdentifier Connection :: Type #

Methods

runWriteAny :: MultiPool Connection -> ReaderT (PrimaryConnection Connection) m a -> m a #

runWrite :: MultiPool Connection -> PrimaryIdentifier Connection -> ReaderT (PrimaryConnection Connection) m a -> m a #

runReadPrimary :: MultiPool Connection -> PrimaryIdentifier Connection -> ReaderT (ReplicaConnection Connection) m a -> m a #

runReadAnyPrimary :: MultiPool Connection -> ReaderT (ReplicaConnection Connection) m a -> m a #

runReadAny :: MultiPool Connection -> ReaderT (ReplicaConnection Connection) m a -> m a #

runRead :: MultiPool Connection -> ReplicaIdentifier Connection -> ReaderT (ReplicaConnection Connection) m a -> m a #

takePrimary :: MultiPool Connection -> PrimaryIdentifier Connection -> m (PrimaryConnection Connection, LocalPrimary Connection) #

putPrimary :: MultiPool Connection -> LocalPrimary Connection -> PrimaryConnection Connection -> m () #

takeReplica :: MultiPool Connection -> ReplicaIdentifier Connection -> m (ReplicaConnection Connection, LocalReplica Connection) #

putReplica :: MultiPool Connection -> LocalReplica Connection -> ReplicaConnection Connection -> m () #

initMultiPool :: MonadUnliftIO m => ByteString -> Int -> [(InstanceName Connection, ByteString, Int)] -> m (MultiPool Connection) Source #

initMultiPool' Source #

Arguments

:: MonadUnliftIO m
=> (MultiPool Connection -> IO (Maybe (InstanceName Connection)))
-> ByteString	Primary connection string
-> Int	Max number of connections to master instance
-> [(InstanceName Connection, ByteString, Int)]	Replica connection details
-> m (MultiPool Connection)