Data.MultiPool

Documentation

newtype InstanceName backend

Constructors

InstanceName

Fields

• rawInstanceName :: Hashed Text

Instances

Eq (InstanceName backend)

Methods

(==) :: InstanceName backend -> InstanceName backend -> Bool

(/=) :: InstanceName backend -> InstanceName backend -> Bool

Ord (InstanceName backend)

Methods

compare :: InstanceName backend -> InstanceName backend -> Ordering

(<) :: InstanceName backend -> InstanceName backend -> Bool

(<=) :: InstanceName backend -> InstanceName backend -> Bool

(>) :: InstanceName backend -> InstanceName backend -> Bool

(>=) :: InstanceName backend -> InstanceName backend -> Bool

max :: InstanceName backend -> InstanceName backend -> InstanceName backend

min :: InstanceName backend -> InstanceName backend -> InstanceName backend

Show (InstanceName backend)

Methods

showsPrec :: Int -> InstanceName backend -> ShowS

show :: InstanceName backend -> String

showList :: [InstanceName backend] -> ShowS

Hashable (InstanceName backend)

Methods

hashWithSalt :: Int -> InstanceName backend -> Int

hash :: InstanceName backend -> Int

mkInstanceName :: Text -> InstanceName backend

data InstanceDoesNotExist backend

Constructors

InstanceDoesNotExist

Fields

• instanceDoesNotExist :: InstanceName backend

Instances

Eq (InstanceDoesNotExist backend)

Methods

(==) :: InstanceDoesNotExist backend -> InstanceDoesNotExist backend -> Bool

(/=) :: InstanceDoesNotExist backend -> InstanceDoesNotExist backend -> Bool

Show (InstanceDoesNotExist backend)

Methods

showsPrec :: Int -> InstanceDoesNotExist backend -> ShowS

show :: InstanceDoesNotExist backend -> String

showList :: [InstanceDoesNotExist backend] -> ShowS

(Show (InstanceDoesNotExist backend), Typeable * backend) => Exception (InstanceDoesNotExist backend)

Methods

toException :: InstanceDoesNotExist backend -> SomeException

fromException :: SomeException -> Maybe (InstanceDoesNotExist backend)

displayException :: InstanceDoesNotExist backend -> String

class Monad m => MultiPoolBackend m backend where

Minimal complete definition

runWriteAny, runWrite, runReadMaster, runReadAnyMaster, runReadAny, runRead

Associated Types

type Masters backend :: *

type Replicas backend :: *

type MasterConnection backend :: *

type ReplicaConnection backend :: *

type MasterIdentifier backend :: *

type ReplicaIdentifier backend :: *

Methods

runWriteAny :: MultiPool backend -> ReaderT (MasterConnection backend) m a -> m a

runWrite :: MultiPool backend -> MasterIdentifier backend -> ReaderT (MasterConnection backend) m a -> m a

runReadMaster :: MultiPool backend -> MasterIdentifier backend -> ReaderT (ReplicaConnection backend) m a -> m a

runReadAnyMaster :: 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

data MultiPool backend

Constructors

MultiPool

Fields

• multiPoolMaster :: !(Masters backend)
• multiPoolReplica :: !(Replicas backend)
• multiPoolAnyMasterSelector :: MultiPool backend -> IO (MasterIdentifier backend)
• multiPoolAnyReplicaSelector :: MultiPool backend -> IO (Maybe (ReplicaIdentifier backend))

forReplicas :: (MultiPoolBackend m backend, Replicas backend ~ HashMap k v) => MultiPool backend -> (k -> v -> m a) -> m [a]

roundRobin :: MonadIO m => [choice] -> m (a -> IO (Maybe choice))