Data.MultiPool.Persist.Sql

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 SqlBackend

Defined in Data.MultiPool.Persist.Sql

Associated Types

type Primaries SqlBackend :: Type

type Replicas SqlBackend :: Type

type LocalPrimary SqlBackend :: Type

type LocalReplica SqlBackend :: Type

type PrimaryConnection SqlBackend :: Type

type ReplicaConnection SqlBackend :: Type

type PrimaryIdentifier SqlBackend :: Type

type ReplicaIdentifier SqlBackend :: Type

Methods

runWriteAny :: MultiPool SqlBackend -> ReaderT (PrimaryConnection SqlBackend) m a -> m a

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

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

runReadAnyPrimary :: MultiPool SqlBackend -> ReaderT (ReplicaConnection SqlBackend) m a -> m a

runReadAny :: MultiPool SqlBackend -> ReaderT (ReplicaConnection SqlBackend) m a -> m a

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

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

putPrimary :: MultiPool SqlBackend -> LocalPrimary SqlBackend -> PrimaryConnection SqlBackend -> m ()

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

putReplica :: MultiPool SqlBackend -> LocalReplica SqlBackend -> ReplicaConnection SqlBackend -> m ()

unsafeRead :: ReaderT SqlBackend m a -> ReaderT SqlReadBackend m a

Orphan instances

MonadUnliftIO m => MultiPoolBackend m SqlBackend

Associated Types

type Primaries SqlBackend :: Type

type Replicas SqlBackend :: Type

type LocalPrimary SqlBackend :: Type

type LocalReplica SqlBackend :: Type

type PrimaryConnection SqlBackend :: Type

type ReplicaConnection SqlBackend :: Type

type PrimaryIdentifier SqlBackend :: Type

type ReplicaIdentifier SqlBackend :: Type

Methods

runWriteAny :: MultiPool SqlBackend -> ReaderT (PrimaryConnection SqlBackend) m a -> m a

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

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

runReadAnyPrimary :: MultiPool SqlBackend -> ReaderT (ReplicaConnection SqlBackend) m a -> m a

runReadAny :: MultiPool SqlBackend -> ReaderT (ReplicaConnection SqlBackend) m a -> m a

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

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

putPrimary :: MultiPool SqlBackend -> LocalPrimary SqlBackend -> PrimaryConnection SqlBackend -> m ()

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

putReplica :: MultiPool SqlBackend -> LocalReplica SqlBackend -> ReplicaConnection SqlBackend -> m ()