Raft.Log.PostgreSQL

Documentation

newtype RaftPostgresT m a

A single threaded PostgreSQL storage monad transformer

Constructors

RaftPostgresT

Fields

• unRaftPostgresT :: ReaderT RaftPostgresEnv m a

Instances

MonadTrans RaftPostgresT

Defined in Raft.Log.PostgreSQL

Methods

lift :: Monad m => m a -> RaftPostgresT m a

MonadRaftChan v m => MonadRaftChan v (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftEventChan v (RaftPostgresT m) :: Type

Methods

readRaftChan :: RaftEventChan v (RaftPostgresT m) -> RaftPostgresT m (Event v)

writeRaftChan :: RaftEventChan v (RaftPostgresT m) -> Event v -> RaftPostgresT m ()

newRaftChan :: RaftPostgresT m (RaftEventChan v (RaftPostgresT m))

Monad m => Monad (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

(>>=) :: RaftPostgresT m a -> (a -> RaftPostgresT m b) -> RaftPostgresT m b

(>>) :: RaftPostgresT m a -> RaftPostgresT m b -> RaftPostgresT m b

return :: a -> RaftPostgresT m a

fail :: String -> RaftPostgresT m a

Functor m => Functor (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

fmap :: (a -> b) -> RaftPostgresT m a -> RaftPostgresT m b

(<$) :: a -> RaftPostgresT m b -> RaftPostgresT m a

MonadFail m => MonadFail (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

fail :: String -> RaftPostgresT m a

Applicative m => Applicative (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

pure :: a -> RaftPostgresT m a

(<*>) :: RaftPostgresT m (a -> b) -> RaftPostgresT m a -> RaftPostgresT m b

liftA2 :: (a -> b -> c) -> RaftPostgresT m a -> RaftPostgresT m b -> RaftPostgresT m c

(*>) :: RaftPostgresT m a -> RaftPostgresT m b -> RaftPostgresT m b

(<*) :: RaftPostgresT m a -> RaftPostgresT m b -> RaftPostgresT m a

Alternative m => Alternative (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

empty :: RaftPostgresT m a

(<|>) :: RaftPostgresT m a -> RaftPostgresT m a -> RaftPostgresT m a

some :: RaftPostgresT m a -> RaftPostgresT m [a]

many :: RaftPostgresT m a -> RaftPostgresT m [a]

MonadPlus m => MonadPlus (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

mzero :: RaftPostgresT m a

mplus :: RaftPostgresT m a -> RaftPostgresT m a -> RaftPostgresT m a

MonadIO m => MonadIO (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

liftIO :: IO a -> RaftPostgresT m a

MonadThrow m => MonadThrow (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

throwM :: Exception e => e -> RaftPostgresT m a

MonadCatch m => MonadCatch (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

catch :: Exception e => RaftPostgresT m a -> (e -> RaftPostgresT m a) -> RaftPostgresT m a

MonadMask m => MonadMask (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Methods

mask :: ((forall a. RaftPostgresT m a -> RaftPostgresT m a) -> RaftPostgresT m b) -> RaftPostgresT m b

uninterruptibleMask :: ((forall a. RaftPostgresT m a -> RaftPostgresT m a) -> RaftPostgresT m b) -> RaftPostgresT m b

generalBracket :: RaftPostgresT m a -> (a -> ExitCase b -> RaftPostgresT m c) -> (a -> RaftPostgresT m b) -> RaftPostgresT m (b, c)

RaftPersist m => RaftPersist (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftPersistError (RaftPostgresT m) :: Type

Methods

initializePersistentState :: RaftPostgresT m (Either (RaftPersistError (RaftPostgresT m)) ())

readPersistentState :: RaftPostgresT m (Either (RaftPersistError (RaftPostgresT m)) PersistentState)

writePersistentState :: PersistentState -> RaftPostgresT m (Either (RaftPersistError (RaftPostgresT m)) ())

(MonadIO m, MonadRaftFork m) => MonadRaftFork (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftThreadId (RaftPostgresT m) :: Type

Methods

raftFork :: RaftThreadRole -> RaftPostgresT m () -> RaftPostgresT m (RaftThreadId (RaftPostgresT m))

(Typeable v, Serialize v, MonadIO m) => RaftReadLog (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftReadLogError (RaftPostgresT m) :: Type

Methods

readLogEntry :: Index -> RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Maybe (Entry v)))

readLogEntriesFrom :: Index -> RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Entries v))

readLastLogEntry :: RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Maybe (Entry v)))

(Serialize v, MonadIO m) => RaftDeleteLog (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftDeleteLogError (RaftPostgresT m) :: Type

Methods

deleteLogEntriesFrom :: Index -> RaftPostgresT m (Either (RaftDeleteLogError (RaftPostgresT m)) (DeleteSuccess v))

(Serialize v, MonadIO m) => RaftWriteLog (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftWriteLogError (RaftPostgresT m) :: Type

Methods

writeLogEntries :: Entries v -> RaftPostgresT m (Either (RaftWriteLogError (RaftPostgresT m)) ())

MonadIO m => RaftInitLog (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftInitLogError (RaftPostgresT m) :: Type

Methods

initializeLog :: Proxy v -> RaftPostgresT m (Either (RaftInitLogError (RaftPostgresT m)) ())

(Monad m, RaftRecvRPC m v) => RaftRecvRPC (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftRecvRPCError (RaftPostgresT m) v :: Type

Methods

receiveRPC :: RaftPostgresT m (Either (RaftRecvRPCError (RaftPostgresT m) v) (RPCMessage v))

(Monad m, RaftSendRPC m v) => RaftSendRPC (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Methods

sendRPC :: NodeId -> RPCMessage v -> RaftPostgresT m ()

(Monad m, RaftRecvClient m v) => RaftRecvClient (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

Associated Types

type RaftRecvClientError (RaftPostgresT m) v :: Type

Methods

receiveClient :: RaftPostgresT m (Either (RaftRecvClientError (RaftPostgresT m) v) (ClientRequest v))

RaftStateMachine m sm v => RaftStateMachine (RaftPostgresT m) sm v

Defined in Raft.Log.PostgreSQL

Methods

validateCmd :: v -> RaftPostgresT m (Either (RaftStateMachinePureError sm v) ())

preprocessCmd :: v -> RaftPostgresT m v

askRaftStateMachinePureCtx :: RaftPostgresT m (RaftStateMachinePureCtx sm v)

(Monad m, RaftSendClient m sm v) => RaftSendClient (RaftPostgresT m) sm v

Defined in Raft.Log.PostgreSQL

Methods

sendClient :: ClientId -> ClientResponse sm v -> RaftPostgresT m ()

type RaftEventChan v (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftEventChan v (RaftPostgresT m) = RaftEventChan v m

type RaftPersistError (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftPersistError (RaftPostgresT m) = RaftPersistError m

type RaftReadLogError (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftReadLogError (RaftPostgresT m)

type RaftDeleteLogError (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftDeleteLogError (RaftPostgresT m)

type RaftWriteLogError (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftWriteLogError (RaftPostgresT m)

type RaftInitLogError (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftInitLogError (RaftPostgresT m)

type RaftThreadId (RaftPostgresT m)

Defined in Raft.Log.PostgreSQL

type RaftThreadId (RaftPostgresT m) = RaftThreadId m

type RaftRecvRPCError (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

type RaftRecvRPCError (RaftPostgresT m) v = RaftRecvRPCError m v

type RaftRecvClientError (RaftPostgresT m) v

Defined in Raft.Log.PostgreSQL

type RaftRecvClientError (RaftPostgresT m) v = RaftRecvClientError m v

runRaftPostgresT :: MonadIO m => ConnectInfo -> RaftPostgresT m a -> m a

Run a RaftPostgresT computation by supplying the database connection info

runRaftPostgresM :: ConnectInfo -> RaftPostgresM a -> IO a

raftDatabaseName :: [Char] -> [Char]

raftDatabaseConnInfo :: [Char] -> [Char] -> [Char] -> ConnectInfo

initConnInfo :: ConnectInfo

setupDB :: ConnectInfo -> IO (Either PGError Connection)

Create the libraft database to store all log entries

deleteDB :: [Char] -> Connection -> IO Int64