Safe Haskell	None
Language	Haskell2010

Raft.Persistent

Synopsis

class Monad m => RaftPersist m where
- type RaftPersistError m
- readPersistentState :: Exception (RaftPersistError m) => m (Either (RaftPersistError m) PersistentState)
- writePersistentState :: Exception (RaftPersistError m) => PersistentState -> m (Either (RaftPersistError m) ())
data PersistentState = PersistentState {
- currentTerm :: Term
- votedFor :: Maybe NodeId
}
initPersistentState :: PersistentState

Documentation

class Monad m => RaftPersist m where Source #

Provides an interface to read and write the persistent state to disk.

Associated Types

type RaftPersistError m Source #

Methods

readPersistentState :: Exception (RaftPersistError m) => m (Either (RaftPersistError m) PersistentState) Source #

writePersistentState :: Exception (RaftPersistError m) => PersistentState -> m (Either (RaftPersistError m) ()) Source #

Instances

(MonadIO m, MonadConc m) => RaftPersist (RaftFileStoreT m) Source #
Instance details Defined in Examples.Raft.FileStore Associated Types type RaftPersistError (RaftFileStoreT m) :: Type Source # Methods readPersistentState :: RaftFileStoreT m (Either (RaftPersistError (RaftFileStoreT m)) PersistentState) Source # writePersistentState :: PersistentState -> RaftFileStoreT m (Either (RaftPersistError (RaftFileStoreT m)) ()) Source #

data PersistentState Source #

Persistent state that all Raft nodes maintain, regardless of node state.

Constructors

PersistentState
Fields currentTerm :: Term Last term server has seen votedFor :: Maybe NodeId Candidate id that received vote in current term

Instances

Show PersistentState Source #
Instance details Defined in Raft.Persistent Methods showsPrec :: Int -> PersistentState -> ShowS # show :: PersistentState -> String # showList :: [PersistentState] -> ShowS #
Generic PersistentState Source #
Instance details Defined in Raft.Persistent Associated Types type Rep PersistentState :: Type -> Type # Methods from :: PersistentState -> Rep PersistentState x # to :: Rep PersistentState x -> PersistentState #
Serialize PersistentState Source #
Instance details Defined in Raft.Persistent Methods put :: Putter PersistentState # get :: Get PersistentState #
MonadState PersistentState (TransitionM sm v) Source #
Instance details Defined in Raft.Monad Methods get :: TransitionM sm v PersistentState # put :: PersistentState -> TransitionM sm v () # state :: (PersistentState -> (a, PersistentState)) -> TransitionM sm v a #
RaftLogger (RWS (TransitionEnv sm) [Action sm v] PersistentState) Source #
Instance details Defined in Raft.Monad Methods loggerNodeId :: RWS (TransitionEnv sm) [Action sm v] PersistentState NodeId Source # loggerNodeState :: RWS (TransitionEnv sm) [Action sm v] PersistentState RaftNodeState Source #
type Rep PersistentState Source #
Instance details Defined in Raft.Persistent type Rep PersistentState = D1 (MetaData "PersistentState" "Raft.Persistent" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "PersistentState" PrefixI True) (S1 (MetaSel (Just "currentTerm") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Term) :*: S1 (MetaSel (Just "votedFor") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe NodeId))))

initPersistentState :: PersistentState Source #

A node initiates its persistent state with term 0 and with its vote blank