Database.Haskey.Alloc.Concurrent.Monad

This module implements the ConcurrentT monad.

The ConcurrentT monad is used to implement a page allocator with concurrent readers and serialized writers.

Documentation

data ConcurrentHandles

All necessary database handles.

Constructors

ConcurrentHandles

Fields

• concurrentHandlesData :: FilePath
• concurrentHandlesIndex :: FilePath
• concurrentHandlesMetadata1 :: FilePath
• concurrentHandlesMetadata2 :: FilePath
• concurrentHandlesOverflowDir :: FilePath

Instances

Show ConcurrentHandles

Methods

showsPrec :: Int -> ConcurrentHandles -> ShowS

show :: ConcurrentHandles -> String

showList :: [ConcurrentHandles] -> ShowS

ConcurrentMetaStoreM m => AllocReaderM (ConcurrentT WriterEnv ConcurrentHandles m)

Methods

readNode :: (Key key, Value val) => Height height -> NodeId height key val -> ConcurrentT WriterEnv ConcurrentHandles m (Node height key val)

readOverflow :: Value val => OverflowId -> ConcurrentT WriterEnv ConcurrentHandles m val

ConcurrentMetaStoreM m => AllocReaderM (ConcurrentT ReaderEnv ConcurrentHandles m)

Methods

readNode :: (Key key, Value val) => Height height -> NodeId height key val -> ConcurrentT ReaderEnv ConcurrentHandles m (Node height key val)

readOverflow :: Value val => OverflowId -> ConcurrentT ReaderEnv ConcurrentHandles m val

(ConcurrentMetaStoreM m, MonadIO m) => AllocM (ConcurrentT WriterEnv ConcurrentHandles m)

Methods

nodePageSize :: (Key key, Value val) => ConcurrentT WriterEnv ConcurrentHandles m (Height height -> Node height key val -> PageSize)

maxPageSize :: ConcurrentT WriterEnv ConcurrentHandles m PageSize

maxKeySize :: ConcurrentT WriterEnv ConcurrentHandles m Word64

maxValueSize :: ConcurrentT WriterEnv ConcurrentHandles m Word64

allocNode :: (Key key, Value val) => Height height -> Node height key val -> ConcurrentT WriterEnv ConcurrentHandles m (NodeId height key val)

freeNode :: Height height -> NodeId height key val -> ConcurrentT WriterEnv ConcurrentHandles m ()

allocOverflow :: Value val => val -> ConcurrentT WriterEnv ConcurrentHandles m OverflowId

freeOverflow :: OverflowId -> ConcurrentT WriterEnv ConcurrentHandles m ()

concurrentHandles :: FilePath -> ConcurrentHandles

Construct a set of ConcurrentHandles from a root directory.

newtype ConcurrentT env hnd m a

Monad in which page allocations can take place.

The monad has access to a ConcurrentMetaStoreM back-end which manages can store and retreive the corresponding metadata.

Constructors

ConcurrentT

Fields

• fromConcurrentT :: StateT (env hnd) m a

Instances

Monad m => MonadState (env hnd) (ConcurrentT env hnd m)

Methods

get :: ConcurrentT env hnd m (env hnd)

put :: env hnd -> ConcurrentT env hnd m ()

state :: (env hnd -> (a, env hnd)) -> ConcurrentT env hnd m a

MonadTrans (ConcurrentT env hnd)

Methods

lift :: Monad m => m a -> ConcurrentT env hnd m a

Monad m => Monad (ConcurrentT env hnd m)

Methods

(>>=) :: ConcurrentT env hnd m a -> (a -> ConcurrentT env hnd m b) -> ConcurrentT env hnd m b

(>>) :: ConcurrentT env hnd m a -> ConcurrentT env hnd m b -> ConcurrentT env hnd m b

return :: a -> ConcurrentT env hnd m a

fail :: String -> ConcurrentT env hnd m a

Functor m => Functor (ConcurrentT env hnd m)

Methods

fmap :: (a -> b) -> ConcurrentT env hnd m a -> ConcurrentT env hnd m b

(<$) :: a -> ConcurrentT env hnd m b -> ConcurrentT env hnd m a

Monad m => Applicative (ConcurrentT env hnd m)

Methods

pure :: a -> ConcurrentT env hnd m a

(<*>) :: ConcurrentT env hnd m (a -> b) -> ConcurrentT env hnd m a -> ConcurrentT env hnd m b

(*>) :: ConcurrentT env hnd m a -> ConcurrentT env hnd m b -> ConcurrentT env hnd m b

(<*) :: ConcurrentT env hnd m a -> ConcurrentT env hnd m b -> ConcurrentT env hnd m a

MonadIO m => MonadIO (ConcurrentT env hnd m)

Methods

liftIO :: IO a -> ConcurrentT env hnd m a

MonadThrow m => MonadThrow (ConcurrentT env hnd m)

Methods

throwM :: Exception e => e -> ConcurrentT env hnd m a

MonadCatch m => MonadCatch (ConcurrentT env hnd m)

Methods

catch :: Exception e => ConcurrentT env hnd m a -> (e -> ConcurrentT env hnd m a) -> ConcurrentT env hnd m a

MonadMask m => MonadMask (ConcurrentT env hnd m)

Methods

mask :: ((forall a. ConcurrentT env hnd m a -> ConcurrentT env hnd m a) -> ConcurrentT env hnd m b) -> ConcurrentT env hnd m b

uninterruptibleMask :: ((forall a. ConcurrentT env hnd m a -> ConcurrentT env hnd m a) -> ConcurrentT env hnd m b) -> ConcurrentT env hnd m b

ConcurrentMetaStoreM m => AllocReaderM (ConcurrentT WriterEnv ConcurrentHandles m)

Methods

readNode :: (Key key, Value val) => Height height -> NodeId height key val -> ConcurrentT WriterEnv ConcurrentHandles m (Node height key val)

readOverflow :: Value val => OverflowId -> ConcurrentT WriterEnv ConcurrentHandles m val

ConcurrentMetaStoreM m => AllocReaderM (ConcurrentT ReaderEnv ConcurrentHandles m)

Methods

readNode :: (Key key, Value val) => Height height -> NodeId height key val -> ConcurrentT ReaderEnv ConcurrentHandles m (Node height key val)

readOverflow :: Value val => OverflowId -> ConcurrentT ReaderEnv ConcurrentHandles m val

(ConcurrentMetaStoreM m, MonadIO m) => AllocM (ConcurrentT WriterEnv ConcurrentHandles m)

Methods

nodePageSize :: (Key key, Value val) => ConcurrentT WriterEnv ConcurrentHandles m (Height height -> Node height key val -> PageSize)

maxPageSize :: ConcurrentT WriterEnv ConcurrentHandles m PageSize

maxKeySize :: ConcurrentT WriterEnv ConcurrentHandles m Word64

maxValueSize :: ConcurrentT WriterEnv ConcurrentHandles m Word64

allocNode :: (Key key, Value val) => Height height -> Node height key val -> ConcurrentT WriterEnv ConcurrentHandles m (NodeId height key val)

freeNode :: Height height -> NodeId height key val -> ConcurrentT WriterEnv ConcurrentHandles m ()

allocOverflow :: Value val => val -> ConcurrentT WriterEnv ConcurrentHandles m OverflowId

freeOverflow :: OverflowId -> ConcurrentT WriterEnv ConcurrentHandles m ()

runConcurrentT :: ConcurrentMetaStoreM m => ConcurrentT env ConcurrentHandles m a -> env ConcurrentHandles -> m (a, env ConcurrentHandles)

Run the actions in an ConcurrentT monad, given a reader or writer environment.

evalConcurrentT :: ConcurrentMetaStoreM m => ConcurrentT env ConcurrentHandles m a -> env ConcurrentHandles -> m a

Evaluate the actions in an ConcurrentT monad, given a reader or writer environment.

readOverflow' :: (ConcurrentMetaStoreM m, Value v) => FilePath -> OverflowId -> ConcurrentT env hnd m v

getWriterHnd :: MonadState (WriterEnv ConcurrentHandles) m => Height height -> m FilePath

getReaderHnd :: MonadState (ReaderEnv ConcurrentHandles) m => Height height -> m FilePath