Raft.Action

Documentation

data Action sm v

Constructors

SendRPC NodeId (SendRPCAction v)

Send a message to a specific node id

SendRPCs (Map NodeId (SendRPCAction v))

Send a unique message to specific nodes in parallel

BroadcastRPC NodeIds (SendRPCAction v)

Broadcast the same message to all nodes

AppendLogEntries (Entries v)

Append entries to the replicated log

RespondToClient ClientId (ClientResponse sm)

Respond to client after a client request

ResetTimeoutTimer Timeout

Reset a timeout timer

Instances

MonadWriter [Action sm v] (TransitionM sm v)

Defined in Raft.Monad

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

(Show v, Show sm) => Show (Action sm v)

Defined in Raft.Action

Methods

showsPrec :: Int -> Action sm v -> ShowS

show :: Action sm v -> String

showList :: [Action sm v] -> ShowS

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

Defined in Raft.Monad

Methods

loggerNodeId :: RWS (TransitionEnv sm) [Action sm v] PersistentState NodeId

loggerNodeState :: RWS (TransitionEnv sm) [Action sm v] PersistentState RaftNodeState

data SendRPCAction v

Constructors

SendAppendEntriesRPC (AppendEntriesData v)

SendAppendEntriesResponseRPC AppendEntriesResponse

SendRequestVoteRPC RequestVote

SendRequestVoteResponseRPC RequestVoteResponse

Instances

Show v => Show (SendRPCAction v)

Defined in Raft.Action

Methods

showsPrec :: Int -> SendRPCAction v -> ShowS

show :: SendRPCAction v -> String

showList :: [SendRPCAction v] -> ShowS