Safe Haskell	None
Language	Haskell2010

Examples.Raft.Socket.Client

Synopsis

newtype ClientRespChan s v = ClientRespChan {
- clientRespChan :: TChan (STM IO) (ClientResponse s v)
}
newClientRespChan :: IO (ClientRespChan s v)
newtype RaftClientRespChanT s v m a = RaftClientRespChanT {
- unRaftClientRespChanT :: ReaderT (ClientRespChan s v) m a
}
type RaftSocketClientM s v = RaftClientT s v (RaftClientRespChanT s v IO)
runRaftSocketClientM :: ClientId -> Set NodeId -> ClientRespChan s v -> RaftSocketClientM s v a -> IO a
socketClientRead :: (Serialize s, Serialize v, Serialize (RaftStateMachinePureError s v), Show s, Show v, Show (RaftClientError s v (RaftSocketClientM s v)), Show (RaftStateMachinePureError s v)) => ClientReadReq -> RaftSocketClientM s v (Either Text (ClientReadResp s v))
socketClientWrite :: (Serialize s, Serialize v, Serialize (RaftStateMachinePureError s v), Show s, Show v, Show (RaftClientError s v (RaftSocketClientM s v)), Show (RaftStateMachinePureError s v)) => v -> RaftSocketClientM s v (Either Text (ClientWriteResp s v))

Documentation

newtype ClientRespChan s v Source #

Constructors

ClientRespChan
Fields clientRespChan :: TChan (STM IO) (ClientResponse s v)

Instances

Monad m => MonadReader (ClientRespChan s v) (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods ask :: RaftClientRespChanT s v m (ClientRespChan s v) # local :: (ClientRespChan s v -> ClientRespChan s v) -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a # reader :: (ClientRespChan s v -> a) -> RaftClientRespChanT s v m a #

newClientRespChan :: IO (ClientRespChan s v) Source #

newtype RaftClientRespChanT s v m a Source #

Constructors

RaftClientRespChanT
Fields unRaftClientRespChanT :: ReaderT (ClientRespChan s v) m a

Instances

MonadBase IO m => MonadBase IO (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods liftBase :: IO α -> RaftClientRespChanT s v m α #
MonadBaseControl IO m => MonadBaseControl IO (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Associated Types type StM (RaftClientRespChanT s v m) a :: Type # Methods liftBaseWith :: (RunInBase (RaftClientRespChanT s v m) IO -> IO a) -> RaftClientRespChanT s v m a # restoreM :: StM (RaftClientRespChanT s v m) a -> RaftClientRespChanT s v m a #
MonadTrans (RaftClientRespChanT s v) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods lift :: Monad m => m a -> RaftClientRespChanT s v m a #
MonadTransControl (RaftClientRespChanT s v) Source #
Instance details Defined in Examples.Raft.Socket.Client Associated Types type StT (RaftClientRespChanT s v) a :: Type # Methods liftWith :: Monad m => (Run (RaftClientRespChanT s v) -> m a) -> RaftClientRespChanT s v m a # restoreT :: Monad m => m (StT (RaftClientRespChanT s v) a) -> RaftClientRespChanT s v m a #
Monad m => MonadReader (ClientRespChan s v) (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods ask :: RaftClientRespChanT s v m (ClientRespChan s v) # local :: (ClientRespChan s v -> ClientRespChan s v) -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a # reader :: (ClientRespChan s v -> a) -> RaftClientRespChanT s v m a #
Monad m => Monad (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods (>>=) :: RaftClientRespChanT s v m a -> (a -> RaftClientRespChanT s v m b) -> RaftClientRespChanT s v m b # (>>) :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b -> RaftClientRespChanT s v m b # return :: a -> RaftClientRespChanT s v m a # fail :: String -> RaftClientRespChanT s v m a #
Functor m => Functor (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods fmap :: (a -> b) -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b # (<$) :: a -> RaftClientRespChanT s v m b -> RaftClientRespChanT s v m a #
Applicative m => Applicative (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods pure :: a -> RaftClientRespChanT s v m a # (<>) :: RaftClientRespChanT s v m (a -> b) -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b # liftA2 :: (a -> b -> c) -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b -> RaftClientRespChanT s v m c # (>) :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b -> RaftClientRespChanT s v m b # (<*) :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m b -> RaftClientRespChanT s v m a #
Alternative m => Alternative (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods empty :: RaftClientRespChanT s v m a # (<\|>) :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a # some :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m [a] # many :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m [a] #
MonadPlus m => MonadPlus (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods mzero :: RaftClientRespChanT s v m a # mplus :: RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a #
MonadIO m => MonadIO (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods liftIO :: IO a -> RaftClientRespChanT s v m a #
MonadSTM m => MonadSTM (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Associated Types type TVar (RaftClientRespChanT s v m) :: Type -> Type # Methods newTVar :: a -> RaftClientRespChanT s v m (TVar (RaftClientRespChanT s v m) a) # newTVarN :: String -> a -> RaftClientRespChanT s v m (TVar (RaftClientRespChanT s v m) a) # readTVar :: TVar (RaftClientRespChanT s v m) a -> RaftClientRespChanT s v m a # writeTVar :: TVar (RaftClientRespChanT s v m) a -> a -> RaftClientRespChanT s v m () #
MonadThrow m => MonadThrow (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods throwM :: Exception e => e -> RaftClientRespChanT s v m a #
MonadCatch m => MonadCatch (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods catch :: Exception e => RaftClientRespChanT s v m a -> (e -> RaftClientRespChanT s v m a) -> RaftClientRespChanT s v m a #
MonadMask m => MonadMask (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods mask :: ((forall a. RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a) -> RaftClientRespChanT s v m b) -> RaftClientRespChanT s v m b # uninterruptibleMask :: ((forall a. RaftClientRespChanT s v m a -> RaftClientRespChanT s v m a) -> RaftClientRespChanT s v m b) -> RaftClientRespChanT s v m b # generalBracket :: RaftClientRespChanT s v m a -> (a -> ExitCase b -> RaftClientRespChanT s v m c) -> (a -> RaftClientRespChanT s v m b) -> RaftClientRespChanT s v m (b, c) #
MonadException m => MonadException (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client Methods controlIO :: (RunIO (RaftClientRespChanT s v m) -> IO (RaftClientRespChanT s v m a)) -> RaftClientRespChanT s v m a #
(Serialize s, Serialize v, Serialize (RaftStateMachinePureError s v), MonadIO m) => RaftClientSend (RaftClientRespChanT s v m) v Source #
Instance details Defined in Examples.Raft.Socket.Client Associated Types type RaftClientSendError (RaftClientRespChanT s v m) v :: Type Source # Methods raftClientSend :: NodeId -> ClientRequest v -> RaftClientRespChanT s v m (Either (RaftClientSendError (RaftClientRespChanT s v m) v) ()) Source #
(Serialize s, Serialize v, MonadIO m) => RaftClientRecv (RaftClientRespChanT s v m) s v Source #
Instance details Defined in Examples.Raft.Socket.Client Associated Types type RaftClientRecvError (RaftClientRespChanT s v m) s :: Type Source # Methods raftClientRecv :: RaftClientRespChanT s v m (Either (RaftClientRecvError (RaftClientRespChanT s v m) s) (ClientResponse s v)) Source #
type StT (RaftClientRespChanT s v) a Source #
Instance details Defined in Examples.Raft.Socket.Client type StT (RaftClientRespChanT s v) a = StT (ReaderT (ClientRespChan s v) :: (Type -> Type) -> Type -> Type) a
type TVar (RaftClientRespChanT s v m) Source #
Instance details Defined in Examples.Raft.Socket.Client type TVar (RaftClientRespChanT s v m) = TVar (ReaderT (ClientRespChan s v) m)
type StM (RaftClientRespChanT s v m) a Source #
Instance details Defined in Examples.Raft.Socket.Client type StM (RaftClientRespChanT s v m) a = ComposeSt (RaftClientRespChanT s v) m a
type RaftClientRecvError (RaftClientRespChanT s v m) s Source #
Instance details Defined in Examples.Raft.Socket.Client type RaftClientRecvError (RaftClientRespChanT s v m) s = Text
type RaftClientSendError (RaftClientRespChanT s v m) v Source #
Instance details Defined in Examples.Raft.Socket.Client type RaftClientSendError (RaftClientRespChanT s v m) v = Text

type RaftSocketClientM s v = RaftClientT s v (RaftClientRespChanT s v IO) Source #

runRaftSocketClientM :: ClientId -> Set NodeId -> ClientRespChan s v -> RaftSocketClientM s v a -> IO a Source #

socketClientRead :: (Serialize s, Serialize v, Serialize (RaftStateMachinePureError s v), Show s, Show v, Show (RaftClientError s v (RaftSocketClientM s v)), Show (RaftStateMachinePureError s v)) => ClientReadReq -> RaftSocketClientM s v (Either Text (ClientReadResp s v)) Source #

Send a client read request using the example socket interface of RaftSocketClientM

socketClientWrite :: (Serialize s, Serialize v, Serialize (RaftStateMachinePureError s v), Show s, Show v, Show (RaftClientError s v (RaftSocketClientM s v)), Show (RaftStateMachinePureError s v)) => v -> RaftSocketClientM s v (Either Text (ClientWriteResp s v)) Source #