Raft.Transition

Documentation

tellAction :: Action sm v -> TransitionM sm v ()

tellActions :: [Action sm v] -> TransitionM sm v ()

data TransitionEnv sm v

Constructors

TransitionEnv

Fields

• nodeConfig :: RaftNodeConfig
• stateMachine :: sm
• nodeState :: RaftNodeState v
• nodeMetrics :: RaftNodeMetrics

Instances

RaftLogger v (RWS (TransitionEnv sm v) [Action sm v] PersistentState)

Defined in Raft.Transition

Methods

loggerCtx :: RWS (TransitionEnv sm v) [Action sm v] PersistentState (NodeId, RaftNodeState v)

MonadReader (TransitionEnv sm v) (TransitionM sm v)

Defined in Raft.Transition

Methods

ask :: TransitionM sm v (TransitionEnv sm v)

local :: (TransitionEnv sm v -> TransitionEnv sm v) -> TransitionM sm v a -> TransitionM sm v a

reader :: (TransitionEnv sm v -> a) -> TransitionM sm v a

newtype TransitionM sm v a

Constructors

TransitionM

Fields

• unTransitionM :: RaftLoggerT v (RWS (TransitionEnv sm v) [Action sm v] PersistentState) a

Instances

MonadState PersistentState (TransitionM sm v)

Defined in Raft.Transition

Methods

get :: TransitionM sm v PersistentState

put :: PersistentState -> TransitionM sm v ()

state :: (PersistentState -> (a, PersistentState)) -> TransitionM sm v a

MonadWriter [Action sm v] (TransitionM sm v)

Defined in Raft.Transition

Methods

writer :: (a, [Action sm v]) -> TransitionM sm v a

tell :: [Action sm v] -> TransitionM sm v ()

listen :: TransitionM sm v a -> TransitionM sm v (a, [Action sm v])

pass :: TransitionM sm v (a, [Action sm v] -> [Action sm v]) -> TransitionM sm v a

Monad (TransitionM sm v)

Defined in Raft.Transition

Methods

(>>=) :: TransitionM sm v a -> (a -> TransitionM sm v b) -> TransitionM sm v b

(>>) :: TransitionM sm v a -> TransitionM sm v b -> TransitionM sm v b

return :: a -> TransitionM sm v a

fail :: String -> TransitionM sm v a

Functor (TransitionM sm v)

Defined in Raft.Transition

Methods

fmap :: (a -> b) -> TransitionM sm v a -> TransitionM sm v b

(<$) :: a -> TransitionM sm v b -> TransitionM sm v a

Applicative (TransitionM sm v)

Defined in Raft.Transition

Methods

pure :: a -> TransitionM sm v a

(<*>) :: TransitionM sm v (a -> b) -> TransitionM sm v a -> TransitionM sm v b

liftA2 :: (a -> b -> c) -> TransitionM sm v a -> TransitionM sm v b -> TransitionM sm v c

(*>) :: TransitionM sm v a -> TransitionM sm v b -> TransitionM sm v b

(<*) :: TransitionM sm v a -> TransitionM sm v b -> TransitionM sm v a

MonadReader (TransitionEnv sm v) (TransitionM sm v)

Defined in Raft.Transition

Methods

ask :: TransitionM sm v (TransitionEnv sm v)

local :: (TransitionEnv sm v -> TransitionEnv sm v) -> TransitionM sm v a -> TransitionM sm v a

reader :: (TransitionEnv sm v -> a) -> TransitionM sm v a

runTransitionM :: TransitionEnv sm v -> PersistentState -> TransitionM sm v a -> ((a, [LogMsg]), PersistentState, [Action sm v])

askNodeId :: TransitionM sm v NodeId

askPeerNodeIds :: TransitionM sm v NodeIds

Returns the set of all node ids excluding the node's own id

type RPCHandler ns sm r v = (RPCType r v, Show v) => NodeState ns v -> NodeId -> r -> TransitionM sm v (ResultState ns v)

type TimeoutHandler ns sm v = Show v => NodeState ns v -> Timeout -> TransitionM sm v (ResultState ns v)

type ClientReqHandler ns cr sm v = (ClientReqType cr v, Show v) => NodeState ns v -> ClientId -> cr -> TransitionM sm v (ResultState ns v)

broadcast :: SendRPCAction v -> TransitionM sm v ()

send :: NodeId -> SendRPCAction v -> TransitionM sm v ()

resetElectionTimeout :: TransitionM sm v ()

Resets the election timeout.

resetHeartbeatTimeout :: TransitionM sm v ()

redirectClientToLeader :: ClientId -> CurrentLeader -> TransitionM sm v ()

respondClientRead :: ClientId -> ClientReadReq -> TransitionM sm v ()

respondClientWrite :: ClientId -> Index -> SerialNum -> TransitionM sm v ()

respondClientMetrics :: ClientId -> TransitionM sm v ()

respondClientRedir :: ClientId -> CurrentLeader -> TransitionM sm v ()

appendLogEntries :: Show v => Seq (Entry v) -> TransitionM sm v ()

updateClientReqCacheFromIdx :: Index -> TransitionM sm v ()

startElection :: Index -> Index -> LastLogEntry v -> ClientWriteReqCache -> TransitionM sm v (CandidateState v)

logInfo :: Text -> TransitionM sm v ()

logDebug :: Text -> TransitionM sm v ()