Examples.Raft.Socket.Node

Documentation

data ResponseSignal sm v

Constructors

OkResponse (ClientResponse sm v)

we managed to write a valid response to the TMVar

DeadResponse

if we get overlapping requests coming in with the same client id, we "kill" one of them

data NodeSocketEnv sm v

Constructors

NodeSocketEnv

Fields

• nsMsgQueue :: TChan (RPCMessage v)

  Queue of RPC messages to be processed by event handlers

• nsClientReqQueue :: TChan (ClientRequest v)

  Queue of client request messages to be processed by event handlers

• nsClientReqResps :: TVar (Map ClientId (TMVar (ResponseSignal sm v)))

  Map of variables to which responses to a request are written. N.B.: this assumes a client id uniquely identifies a request; A client will never send a request without having either 1) given up on the a previous request because of a timeout, or 2) received a response to each previous request issued.

Instances

Monad m => MonadReader (NodeSocketEnv sm v) (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

ask :: RaftSocketT sm v m (NodeSocketEnv sm v)

local :: (NodeSocketEnv sm v -> NodeSocketEnv sm v) -> RaftSocketT sm v m a -> RaftSocketT sm v m a

reader :: (NodeSocketEnv sm v -> a) -> RaftSocketT sm v m a

newtype RaftSocketT sm v m a

Constructors

RaftSocketT

Fields

• unRaftSocketT :: ReaderT (NodeSocketEnv sm v) m a

Instances

MonadRaftChan v m => MonadRaftChan v (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftEventChan v (RaftSocketT sm v m) :: Type

Methods

readRaftChan :: RaftEventChan v (RaftSocketT sm v m) -> RaftSocketT sm v m (Event v)

writeRaftChan :: RaftEventChan v (RaftSocketT sm v m) -> Event v -> RaftSocketT sm v m ()

newRaftChan :: RaftSocketT sm v m (RaftEventChan v (RaftSocketT sm v m))

MonadTrans (RaftSocketT sm v)

Defined in Examples.Raft.Socket.Node

Methods

lift :: Monad m => m a -> RaftSocketT sm v m a

Monad m => MonadReader (NodeSocketEnv sm v) (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

ask :: RaftSocketT sm v m (NodeSocketEnv sm v)

local :: (NodeSocketEnv sm v -> NodeSocketEnv sm v) -> RaftSocketT sm v m a -> RaftSocketT sm v m a

reader :: (NodeSocketEnv sm v -> a) -> RaftSocketT sm v m a

Monad m => Monad (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

(>>=) :: RaftSocketT sm v m a -> (a -> RaftSocketT sm v m b) -> RaftSocketT sm v m b

(>>) :: RaftSocketT sm v m a -> RaftSocketT sm v m b -> RaftSocketT sm v m b

return :: a -> RaftSocketT sm v m a

fail :: String -> RaftSocketT sm v m a

Functor m => Functor (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

fmap :: (a -> b) -> RaftSocketT sm v m a -> RaftSocketT sm v m b

(<$) :: a -> RaftSocketT sm v m b -> RaftSocketT sm v m a

MonadFail m => MonadFail (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

fail :: String -> RaftSocketT sm v m a

Applicative m => Applicative (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

pure :: a -> RaftSocketT sm v m a

(<*>) :: RaftSocketT sm v m (a -> b) -> RaftSocketT sm v m a -> RaftSocketT sm v m b

liftA2 :: (a -> b -> c) -> RaftSocketT sm v m a -> RaftSocketT sm v m b -> RaftSocketT sm v m c

(*>) :: RaftSocketT sm v m a -> RaftSocketT sm v m b -> RaftSocketT sm v m b

(<*) :: RaftSocketT sm v m a -> RaftSocketT sm v m b -> RaftSocketT sm v m a

Alternative m => Alternative (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

empty :: RaftSocketT sm v m a

(<|>) :: RaftSocketT sm v m a -> RaftSocketT sm v m a -> RaftSocketT sm v m a

some :: RaftSocketT sm v m a -> RaftSocketT sm v m [a]

many :: RaftSocketT sm v m a -> RaftSocketT sm v m [a]

MonadPlus m => MonadPlus (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

mzero :: RaftSocketT sm v m a

mplus :: RaftSocketT sm v m a -> RaftSocketT sm v m a -> RaftSocketT sm v m a

MonadIO m => MonadIO (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

liftIO :: IO a -> RaftSocketT sm v m a

MonadThrow m => MonadThrow (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

throwM :: Exception e => e -> RaftSocketT sm v m a

MonadCatch m => MonadCatch (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

catch :: Exception e => RaftSocketT sm v m a -> (e -> RaftSocketT sm v m a) -> RaftSocketT sm v m a

MonadMask m => MonadMask (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Methods

mask :: ((forall a. RaftSocketT sm v m a -> RaftSocketT sm v m a) -> RaftSocketT sm v m b) -> RaftSocketT sm v m b

uninterruptibleMask :: ((forall a. RaftSocketT sm v m a -> RaftSocketT sm v m a) -> RaftSocketT sm v m b) -> RaftSocketT sm v m b

generalBracket :: RaftSocketT sm v m a -> (a -> ExitCase b -> RaftSocketT sm v m c) -> (a -> RaftSocketT sm v m b) -> RaftSocketT sm v m (b, c)

(MonadIO m, RaftPersist m) => RaftPersist (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftPersistError (RaftSocketT sm v m) :: Type

Methods

initializePersistentState :: RaftSocketT sm v m (Either (RaftPersistError (RaftSocketT sm v m)) ())

readPersistentState :: RaftSocketT sm v m (Either (RaftPersistError (RaftSocketT sm v m)) PersistentState)

writePersistentState :: PersistentState -> RaftSocketT sm v m (Either (RaftPersistError (RaftSocketT sm v m)) ())

(MonadIO m, MonadRaftFork m) => MonadRaftFork (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftThreadId (RaftSocketT sm v m) :: Type

Methods

raftFork :: RaftThreadRole -> RaftSocketT sm v m () -> RaftSocketT sm v m (RaftThreadId (RaftSocketT sm v m))

RaftReadLog m v => RaftReadLog (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftReadLogError (RaftSocketT sm v m) :: Type

Methods

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

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

readLastLogEntry :: RaftSocketT sm v m (Either (RaftReadLogError (RaftSocketT sm v m)) (Maybe (Entry v)))

RaftDeleteLog m v => RaftDeleteLog (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftDeleteLogError (RaftSocketT sm v m) :: Type

Methods

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

RaftWriteLog m v => RaftWriteLog (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftWriteLogError (RaftSocketT sm v m) :: Type

Methods

writeLogEntries :: Entries v -> RaftSocketT sm v m (Either (RaftWriteLogError (RaftSocketT sm v m)) ())

(MonadIO m, RaftInitLog m v) => RaftInitLog (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftInitLogError (RaftSocketT sm v m) :: Type

Methods

initializeLog :: Proxy v -> RaftSocketT sm v m (Either (RaftInitLogError (RaftSocketT sm v m)) ())

(MonadIO m, Show v) => RaftRecvRPC (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftRecvRPCError (RaftSocketT sm v m) v :: Type

Methods

receiveRPC :: RaftSocketT sm v m (Either (RaftRecvRPCError (RaftSocketT sm v m) v) (RPCMessage v))

(MonadCatch m, MonadMask m, MonadIO m, Serialize v, Show v) => RaftSendRPC (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Methods

sendRPC :: NodeId -> RPCMessage v -> RaftSocketT sm v m ()

(MonadIO m, Serialize v) => RaftRecvClient (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftRecvClientError (RaftSocketT sm v m) v :: Type

Methods

receiveClient :: RaftSocketT sm v m (Either (RaftRecvClientError (RaftSocketT sm v m) v) (ClientRequest v))

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

Defined in Examples.Raft.Socket.Node

Methods

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

preprocessCmd :: v -> RaftSocketT sm v m v

askRaftStateMachinePureCtx :: RaftSocketT sm v m (RaftStateMachinePureCtx sm v)

(RaftStateMachinePure sm v, MonadMask m, MonadCatch m, MonadIO m, Serialize sm, Serialize v) => RaftSendClient (RaftSocketT sm v m) sm v

Defined in Examples.Raft.Socket.Node

Methods

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

type RaftEventChan v (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftEventChan v (RaftSocketT sm v m) = RaftEventChan v m

type RaftPersistError (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftPersistError (RaftSocketT sm v m) = RaftPersistError m

type RaftReadLogError (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftReadLogError (RaftSocketT sm v m) = RaftReadLogError m

type RaftDeleteLogError (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftDeleteLogError (RaftSocketT sm v m) = RaftDeleteLogError m

type RaftWriteLogError (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftWriteLogError (RaftSocketT sm v m) = RaftWriteLogError m

type RaftInitLogError (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftInitLogError (RaftSocketT sm v m) = RaftInitLogError m

type RaftThreadId (RaftSocketT sm v m)

Defined in Examples.Raft.Socket.Node

type RaftThreadId (RaftSocketT sm v m) = RaftThreadId m

type RaftRecvRPCError (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

type RaftRecvRPCError (RaftSocketT sm v m) v = Text

type RaftRecvClientError (RaftSocketT sm v m) v

Defined in Examples.Raft.Socket.Node

type RaftRecvClientError (RaftSocketT sm v m) v = Text

runRaftSocketT :: MonadIO m => NodeSocketEnv sm v -> RaftSocketT sm v m a -> m a

acceptConnections :: forall sm v m. (Serialize sm, Serialize v, Serialize (RaftStateMachinePureError sm v), Show (RaftStateMachinePureError sm v), MonadIO m) => HostName -> ServiceName -> RaftSocketT sm v m ()