Mealstrom.MemoryStore

Documentation

data MemoryStore k s e a

Instances

WALStore (MemoryStore k s e a) k

Defined in Mealstrom.MemoryStore

Methods

walUpsertIncrement :: MemoryStore k s e a -> k -> IO ()

walDecrement :: MemoryStore k s e a -> k -> IO ()

walScan :: MemoryStore k s e a -> Int -> IO [WALEntry k]

MealyInstance k s e a => FSMStore (MemoryStore k s e a) k s e a

Defined in Mealstrom.MemoryStore

Methods

fsmRead :: MemoryStore k s e a -> k -> Proxy k s e a -> IO (Maybe s)

fsmCreate :: MemoryStore k s e a -> Instance k s e a -> IO (Maybe String)

fsmUpdate :: MemoryStore k s e a -> k -> MachineTransformer s e a -> IO MealyStatus

mkStore :: MealyInstance k s e a => Text -> IO (MemoryStore k s e a)

_fsmRead :: MemoryStore k s e a -> k -> STM (Maybe (Instance k s e a))

_fsmCreate :: MemoryStore k s e a -> Instance k s e a -> STM (Maybe String)

For compatibility with the other stores we check existence here

_fsmUpdate :: MemoryStore k s e a -> k -> MachineTransformer s e a -> IO MealyStatus

We need to use a lock here, because we are in the unfortunate position of having to use IO while performing STM operations, which is not possible. Using the lock we can rest assured no concurrent update operation can progress.

printWal :: MemoryStore k s e a -> k -> IO ()