Data.BTree.Cache.STM

Documentation

data State k v

Constructors

Read !(Maybe v)

Write !(Maybe k) !(Maybe v)

Instances

(Eq k, Eq v) => Eq (State k v)

Show (State k v)

mtoS :: Maybe a -> [Char]

type AccessTime = UTCTime

data Exist

Constructors

Exist

NoExist

Instances

Eq Exist

data Ref k v

Constructors

Ref

Fields

refST :: TVar (Either (State k v) (State k v, Int, State k v))

refExt :: TVar Exist

data Param m k v

Constructors

Param

Fields

cacheSize :: Int

table :: HashTableSTM k (Ref k (Either ByteString v))

toIO :: forall a. m a -> IO a

flushQ :: TVar [(k, Ref k v)]

timestamp :: UTCTime

genId :: TVar Int

genActive :: TVar Int

Instances

Monad (CacheSTM m k v) => MonadReader (Param m k v) (CacheSTM m k v)

(Monad (CacheSTM m k v), Show k, Serialize k, Serialize v, Ord k, Eq k, Eq v, Hashable k, KVBackend m k ByteString) => Cache (CacheSTM m k v) (Param m k v) k v

trace :: a -> a

newtype CacheSTM m k v a

Constructors

CacheSTM

Fields

runCacheSTM :: ReaderT (Param m k v) (ErrorT (IO ()) STM) a

Instances

Monad (CacheSTM m k v) => MonadError (IO ()) (CacheSTM m k v)

Monad (CacheSTM m k v)

Functor (CacheSTM m k v)

Monad (CacheSTM m k v) => MonadReader (Param m k v) (CacheSTM m k v)

(Monad (CacheSTM m k v), Show k, Serialize k, Serialize v, Ord k, Eq k, Eq v, Hashable k, KVBackend m k ByteString) => Cache (CacheSTM m k v) (Param m k v) k v

stm :: (Monad (t1 m), Monad m, MonadTrans t, MonadTrans t1) => m a -> t (t1 m) a

evalCacheSTM :: Param m k v -> CacheSTM m k v a -> IO a

sizedParam :: Int -> (forall a. m a -> IO a) -> IO (Param m k v)

getRef :: (Monad (t1 STM), Ord k, Hashable k, MonadTrans t, MonadTrans t1, MonadError (IO ()) (t (t1 STM)), MonadReader (Param m k b) (t (t1 STM)), KVBackend m k ByteString) => k -> t (t1 STM) (Ref k (Either ByteString b))

newRef :: (Monad (t1 STM), Ord k, Hashable k, MonadTrans t, MonadTrans t1, MonadError (IO ()) (t (t1 STM)), MonadReader (Param m k v) (t (t1 STM)), KVBackend m k ByteString) => Maybe k -> k -> Maybe (Either ByteString v) -> t (t1 STM) ()

maybeQueue :: (Monad (t1 STM), MonadTrans t, MonadTrans t1, MonadReader (Param m k v) (t (t1 STM))) => Bool -> TVar (Either (State t2 t3) (State t6 t7, t4, t5)) -> (k, Ref k v) -> t (t1 STM) ()

store :: (Ord k, Hashable k, KVBackend m k ByteString) => Maybe k -> k -> v -> CacheSTM m k v ()

fetch :: (Ord k, Serialize v, Hashable k, KVBackend m k ByteString) => k -> CacheSTM m k v (Maybe v)

fetchGen :: (Ord k, Serialize v, Hashable k, KVBackend m k ByteString) => Int -> k -> CacheSTM m k v (Maybe v)

remove :: (Ord k, Hashable k, KVBackend m k ByteString) => Maybe k -> k -> CacheSTM m k v ()

updateTag :: (Ord k, Hashable k) => Maybe k -> k -> CacheSTM m k v ()

keys :: CacheSTM m k v [k]

debug :: (Show a, MonadIO m) => a -> m ()

getGen :: Eq a => a -> Either t (t, a, t) -> t

flipWrite :: Eq v => Maybe v -> Either (State k v) (State k1 v, t, State t1 v) -> Either (State k v) (State k1 v, t, State t1 v)

equals :: (Eq b, Serialize b) => State t (Either ByteString b) -> State t1 (Either ByteString b) -> Bool

value :: Serialize b => State t (Either ByteString b) -> Maybe b

withGeneration :: MonadIO m => Param m1 k v -> (Int -> m b) -> m b

flush :: (Ord t, Serialize a, Hashable t) => Param m t a -> IO ()

flushKey :: (Ord k1, Serialize a, Hashable k1) => HashTableSTM k1 v1 -> (k1, Ref t (Either ByteString a)) -> CacheSTM m k v (Maybe (Either (State t (Either ByteString a)) (State t (Either ByteString a), Int, State t (Either ByteString a))))

sync :: (Eq b, Ord t, Serialize b, KVBackend m t ByteString) => Param m t b -> IO ()

liftSTM :: STM a -> CacheSTM m k v a

fail :: IO () -> CacheSTM m k v a