Mealstrom.WALStore

A WALStore is anything being able to store WALEntries. WALEntries indicate how often a recovery process has been started for an instance.

Documentation

class WALStore st k where

Methods

walUpsertIncrement :: st -> k -> IO ()

walDecrement :: st -> k -> IO ()

walScan :: st -> Int -> IO [WALEntry k]

Instances

FSMKey k => WALStore PostgresJSONStore k

Defined in Mealstrom.PostgresJSONStore

Methods

walUpsertIncrement :: PostgresJSONStore -> k -> IO ()

walDecrement :: PostgresJSONStore -> k -> IO ()

walScan :: PostgresJSONStore -> Int -> IO [WALEntry k]

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]

data WALEntry k

Constructors

WALEntry

Fields

• walId :: k
• walTime :: UTCTime
• walCount :: Int

Instances

Eq k => Eq (WALEntry k)

Defined in Mealstrom.WALStore

Methods

(==) :: WALEntry k -> WALEntry k -> Bool

(/=) :: WALEntry k -> WALEntry k -> Bool

Show k => Show (WALEntry k)

Defined in Mealstrom.WALStore

Methods

showsPrec :: Int -> WALEntry k -> ShowS

show :: WALEntry k -> String

showList :: [WALEntry k] -> ShowS

FSMKey k => Generic (WALEntry k)

Defined in Mealstrom.PostgresJSONStore

Associated Types

type Rep (WALEntry k) :: Type -> Type

Methods

from :: WALEntry k -> Rep (WALEntry k) x

to :: Rep (WALEntry k) x -> WALEntry k

FSMKey k => FromRow (WALEntry k)

Defined in Mealstrom.PostgresJSONStore

Methods

fromRow :: RowParser (WALEntry k)

type Rep (WALEntry k)

Defined in Mealstrom.PostgresJSONStore

type Rep (WALEntry k) = D1 (MetaData "WALEntry" "Mealstrom.WALStore" "mealstrom-0.0.1.0-1iE9qiPdHB2KeFDL81oqg9" False) (C1 (MetaCons "WALEntry" PrefixI True) (S1 (MetaSel (Just "walId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 k) :*: (S1 (MetaSel (Just "walTime") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UTCTime) :*: S1 (MetaSel (Just "walCount") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))))

openTxn :: WALStore st k => st -> k -> IO ()

closeTxn :: WALStore st k => st -> k -> IO ()