Periodic.Server.Persist

Documentation

class Exception (PersistException db) => Persist db where

Associated Types

data PersistConfig db

data PersistException db

Methods

newPersist :: PersistConfig db -> IO db

member :: db -> State -> FuncName -> JobName -> IO Bool

lookup :: db -> State -> FuncName -> JobName -> IO (Maybe Job)

insert :: db -> State -> FuncName -> JobName -> Job -> IO ()

delete :: db -> FuncName -> JobName -> IO ()

size :: db -> State -> FuncName -> IO Int64

foldr :: forall a. db -> State -> (Job -> a -> a) -> a -> IO a

foldrPending :: forall a. db -> Int64 -> [FuncName] -> (Job -> a -> a) -> a -> IO a

foldrLocking :: forall a. db -> Int -> FuncName -> (Job -> a -> a) -> a -> IO a

dumpJob :: db -> IO [Job]

configGet :: db -> String -> IO (Maybe Int)

configSet :: db -> String -> Int -> IO ()

insertFuncName :: db -> FuncName -> IO ()

removeFuncName :: db -> FuncName -> IO ()

funcList :: db -> IO [FuncName]

minSchedAt :: db -> FuncName -> IO Int64

Instances

Persist PSQL

Defined in Periodic.Server.Persist.PSQL

Associated Types

data PersistConfig PSQL :: Type

data PersistException PSQL :: Type

Methods

newPersist :: PersistConfig PSQL -> IO PSQL

member :: PSQL -> State -> FuncName -> JobName -> IO Bool

lookup :: PSQL -> State -> FuncName -> JobName -> IO (Maybe Job)

insert :: PSQL -> State -> FuncName -> JobName -> Job -> IO ()

delete :: PSQL -> FuncName -> JobName -> IO ()

size :: PSQL -> State -> FuncName -> IO Int64

foldr :: PSQL -> State -> (Job -> a -> a) -> a -> IO a

foldrPending :: PSQL -> Int64 -> [FuncName] -> (Job -> a -> a) -> a -> IO a

foldrLocking :: PSQL -> Int -> FuncName -> (Job -> a -> a) -> a -> IO a

dumpJob :: PSQL -> IO [Job]

configGet :: PSQL -> String -> IO (Maybe Int)

configSet :: PSQL -> String -> Int -> IO ()

insertFuncName :: PSQL -> FuncName -> IO ()

removeFuncName :: PSQL -> FuncName -> IO ()

funcList :: PSQL -> IO [FuncName]

minSchedAt :: PSQL -> FuncName -> IO Int64

Persist SQLite

Defined in Periodic.Server.Persist.SQLite

Associated Types

data PersistConfig SQLite :: Type

data PersistException SQLite :: Type

Methods

newPersist :: PersistConfig SQLite -> IO SQLite

member :: SQLite -> State -> FuncName -> JobName -> IO Bool

lookup :: SQLite -> State -> FuncName -> JobName -> IO (Maybe Job)

insert :: SQLite -> State -> FuncName -> JobName -> Job -> IO ()

delete :: SQLite -> FuncName -> JobName -> IO ()

size :: SQLite -> State -> FuncName -> IO Int64

foldr :: SQLite -> State -> (Job -> a -> a) -> a -> IO a

foldrPending :: SQLite -> Int64 -> [FuncName] -> (Job -> a -> a) -> a -> IO a

foldrLocking :: SQLite -> Int -> FuncName -> (Job -> a -> a) -> a -> IO a

dumpJob :: SQLite -> IO [Job]

configGet :: SQLite -> String -> IO (Maybe Int)

configSet :: SQLite -> String -> Int -> IO ()

insertFuncName :: SQLite -> FuncName -> IO ()

removeFuncName :: SQLite -> FuncName -> IO ()

funcList :: SQLite -> IO [FuncName]

minSchedAt :: SQLite -> FuncName -> IO Int64

data State

Constructors

Pending

Running

Locking