Safe Haskell	None
Language	Haskell2010

Examples.Raft.Socket.Client

Synopsis

data ClientSocketEnv = ClientSocketEnv {
- clientPort :: ServiceName
- clientHost :: HostName
- clientSocket :: Socket
}
newtype RaftSocketClientM a = RaftSocketClientM {
- unRaftSocketClientM :: ReaderT ClientSocketEnv IO a
}
runRaftSocketClientM :: ClientSocketEnv -> RaftSocketClientM a -> IO a
selectRndNode :: NodeIds -> IO NodeId
sendReadRndNode :: (Serialize sm, Serialize v) => Proxy v -> NodeIds -> RaftSocketClientM (Either [Char] (ClientResponse sm))
sendWriteRndNode :: (Serialize v, Serialize sm) => v -> NodeIds -> RaftSocketClientM (Either [Char] (ClientResponse sm))
sendRead :: forall v sm. (Serialize sm, Serialize v) => Proxy v -> NodeId -> RaftSocketClientM (Either [Char] (ClientResponse sm))
sendWrite :: (Serialize v, Serialize sm) => v -> NodeId -> RaftSocketClientM (Either [Char] (ClientResponse sm))
acceptClientConnections :: Serialize sm => RaftSocketClientM (Either [Char] (ClientResponse sm))

Documentation

data ClientSocketEnv Source #

Constructors

ClientSocketEnv
Fields clientPort :: ServiceName clientHost :: HostName clientSocket :: Socket

Instances

Show ClientSocketEnv Source #
Instance details Defined in Examples.Raft.Socket.Client Methods showsPrec :: Int -> ClientSocketEnv -> ShowS # show :: ClientSocketEnv -> String # showList :: [ClientSocketEnv] -> ShowS #
MonadReader ClientSocketEnv RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods ask :: RaftSocketClientM ClientSocketEnv # local :: (ClientSocketEnv -> ClientSocketEnv) -> RaftSocketClientM a -> RaftSocketClientM a # reader :: (ClientSocketEnv -> a) -> RaftSocketClientM a #

newtype RaftSocketClientM a Source #

Constructors

RaftSocketClientM
Fields unRaftSocketClientM :: ReaderT ClientSocketEnv IO a

Instances

Monad RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods (>>=) :: RaftSocketClientM a -> (a -> RaftSocketClientM b) -> RaftSocketClientM b # (>>) :: RaftSocketClientM a -> RaftSocketClientM b -> RaftSocketClientM b # return :: a -> RaftSocketClientM a # fail :: String -> RaftSocketClientM a #
Functor RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods fmap :: (a -> b) -> RaftSocketClientM a -> RaftSocketClientM b # (<$) :: a -> RaftSocketClientM b -> RaftSocketClientM a #
Applicative RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods pure :: a -> RaftSocketClientM a # (<>) :: RaftSocketClientM (a -> b) -> RaftSocketClientM a -> RaftSocketClientM b # liftA2 :: (a -> b -> c) -> RaftSocketClientM a -> RaftSocketClientM b -> RaftSocketClientM c # (>) :: RaftSocketClientM a -> RaftSocketClientM b -> RaftSocketClientM b # (<*) :: RaftSocketClientM a -> RaftSocketClientM b -> RaftSocketClientM a #
Alternative RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods empty :: RaftSocketClientM a # (<\|>) :: RaftSocketClientM a -> RaftSocketClientM a -> RaftSocketClientM a # some :: RaftSocketClientM a -> RaftSocketClientM [a] # many :: RaftSocketClientM a -> RaftSocketClientM [a] #
MonadPlus RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods mzero :: RaftSocketClientM a # mplus :: RaftSocketClientM a -> RaftSocketClientM a -> RaftSocketClientM a #
MonadIO RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods liftIO :: IO a -> RaftSocketClientM a #
MonadReader ClientSocketEnv RaftSocketClientM Source #
Instance details Defined in Examples.Raft.Socket.Client Methods ask :: RaftSocketClientM ClientSocketEnv # local :: (ClientSocketEnv -> ClientSocketEnv) -> RaftSocketClientM a -> RaftSocketClientM a # reader :: (ClientSocketEnv -> a) -> RaftSocketClientM a #

runRaftSocketClientM :: ClientSocketEnv -> RaftSocketClientM a -> IO a Source #

selectRndNode :: NodeIds -> IO NodeId Source #

Randomly select a node from a set of nodes a send a message to it

sendReadRndNode :: (Serialize sm, Serialize v) => Proxy v -> NodeIds -> RaftSocketClientM (Either [Char] (ClientResponse sm)) Source #

Randomly read the state of a random node

sendWriteRndNode :: (Serialize v, Serialize sm) => v -> NodeIds -> RaftSocketClientM (Either [Char] (ClientResponse sm)) Source #

Randomly write to a random node

sendRead :: forall v sm. (Serialize sm, Serialize v) => Proxy v -> NodeId -> RaftSocketClientM (Either [Char] (ClientResponse sm)) Source #

Request the state of a node. It blocks until the node responds

sendWrite :: (Serialize v, Serialize sm) => v -> NodeId -> RaftSocketClientM (Either [Char] (ClientResponse sm)) Source #

Write to a node. It blocks until the node responds

acceptClientConnections :: Serialize sm => RaftSocketClientM (Either [Char] (ClientResponse sm)) Source #

Accept a connection and return the client response synchronously