Raft.Client

Documentation

class RaftSendClient m sm where

Interface for Raft nodes to send messages to clients

Methods

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

Instances

(MonadIO m, MonadConc m, Serialize sm) => RaftSendClient (RaftSocketT v m) sm

Defined in Examples.Raft.Socket.Node

Methods

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

class Show (RaftRecvClientError m v) => RaftRecvClient m v where

Interface for Raft nodes to receive messages from clients

Associated Types

type RaftRecvClientError m v

Methods

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

Instances

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

Defined in Examples.Raft.Socket.Node

Associated Types

type RaftRecvClientError (RaftSocketT v m) v :: Type

Methods

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

data ClientRequest v

Representation of a client request coupled with the client id

Constructors

ClientRequest ClientId (ClientReq v)

Instances

Show v => Show (ClientRequest v)

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientRequest v -> ShowS

show :: ClientRequest v -> String

showList :: [ClientRequest v] -> ShowS

Generic (ClientRequest v)

Defined in Raft.Client

Associated Types

type Rep (ClientRequest v) :: Type -> Type

Methods

from :: ClientRequest v -> Rep (ClientRequest v) x

to :: Rep (ClientRequest v) x -> ClientRequest v

Serialize v => Serialize (ClientRequest v)

Defined in Raft.Client

Methods

put :: Putter (ClientRequest v)

get :: Get (ClientRequest v)

type Rep (ClientRequest v)

Defined in Raft.Client

type Rep (ClientRequest v) = D1 (MetaData "ClientRequest" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "ClientRequest" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ClientId) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ClientReq v))))

data ClientReq v

Representation of a client request

Constructors

ClientReadReq

Request the latest state of the state machine

ClientWriteReq v

Write a command

Instances

Show v => Show (ClientReq v)

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientReq v -> ShowS

show :: ClientReq v -> String

showList :: [ClientReq v] -> ShowS

Generic (ClientReq v)

Defined in Raft.Client

Associated Types

type Rep (ClientReq v) :: Type -> Type

Methods

from :: ClientReq v -> Rep (ClientReq v) x

to :: Rep (ClientReq v) x -> ClientReq v

Serialize v => Serialize (ClientReq v)

Defined in Raft.Client

Methods

put :: Putter (ClientReq v)

get :: Get (ClientReq v)

type Rep (ClientReq v)

Defined in Raft.Client

type Rep (ClientReq v) = D1 (MetaData "ClientReq" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "ClientReadReq" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "ClientWriteReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 v)))

data ClientResponse s

Representation of a client response

Constructors

ClientReadResponse (ClientReadResp s)

Respond with the latest state of the state machine.

ClientWriteResponse ClientWriteResp

Respond with the index of the entry appended to the log

ClientRedirectResponse ClientRedirResp

Respond with the node id of the current leader

Instances

Show s => Show (ClientResponse s)

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientResponse s -> ShowS

show :: ClientResponse s -> String

showList :: [ClientResponse s] -> ShowS

Generic (ClientResponse s)

Defined in Raft.Client

Associated Types

type Rep (ClientResponse s) :: Type -> Type

Methods

from :: ClientResponse s -> Rep (ClientResponse s) x

to :: Rep (ClientResponse s) x -> ClientResponse s

Serialize s => Serialize (ClientResponse s)

Defined in Raft.Client

Methods

put :: Putter (ClientResponse s)

get :: Get (ClientResponse s)

type Rep (ClientResponse s)

Defined in Raft.Client

type Rep (ClientResponse s) = D1 (MetaData "ClientResponse" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "ClientReadResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ClientReadResp s))) :+: (C1 (MetaCons "ClientWriteResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ClientWriteResp)) :+: C1 (MetaCons "ClientRedirectResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ClientRedirResp))))

newtype ClientReadResp s

Representation of a read response to a client The s stands for the "current" state of the state machine

Constructors

ClientReadResp s

Instances

Show s => Show (ClientReadResp s)

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientReadResp s -> ShowS

show :: ClientReadResp s -> String

showList :: [ClientReadResp s] -> ShowS

Generic (ClientReadResp s)

Defined in Raft.Client

Associated Types

type Rep (ClientReadResp s) :: Type -> Type

Methods

from :: ClientReadResp s -> Rep (ClientReadResp s) x

to :: Rep (ClientReadResp s) x -> ClientReadResp s

Serialize s => Serialize (ClientReadResp s)

Defined in Raft.Client

Methods

put :: Putter (ClientReadResp s)

get :: Get (ClientReadResp s)

type Rep (ClientReadResp s)

Defined in Raft.Client

type Rep (ClientReadResp s) = D1 (MetaData "ClientReadResp" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" True) (C1 (MetaCons "ClientReadResp" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 s)))

data ClientWriteResp

Representation of a write response to a client

Constructors

ClientWriteResp Index

Index of the entry appended to the log due to the previous client request

Instances

Show ClientWriteResp

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientWriteResp -> ShowS

show :: ClientWriteResp -> String

showList :: [ClientWriteResp] -> ShowS

Generic ClientWriteResp

Defined in Raft.Client

Associated Types

type Rep ClientWriteResp :: Type -> Type

Methods

from :: ClientWriteResp -> Rep ClientWriteResp x

to :: Rep ClientWriteResp x -> ClientWriteResp

Serialize ClientWriteResp

Defined in Raft.Client

Methods

put :: Putter ClientWriteResp

get :: Get ClientWriteResp

type Rep ClientWriteResp

Defined in Raft.Client

type Rep ClientWriteResp = D1 (MetaData "ClientWriteResp" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "ClientWriteResp" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Index)))

data ClientRedirResp

Representation of a redirect response to a client

Constructors

ClientRedirResp CurrentLeader

Instances

Show ClientRedirResp

Defined in Raft.Client

Methods

showsPrec :: Int -> ClientRedirResp -> ShowS

show :: ClientRedirResp -> String

showList :: [ClientRedirResp] -> ShowS

Generic ClientRedirResp

Defined in Raft.Client

Associated Types

type Rep ClientRedirResp :: Type -> Type

Methods

from :: ClientRedirResp -> Rep ClientRedirResp x

to :: Rep ClientRedirResp x -> ClientRedirResp

Serialize ClientRedirResp

Defined in Raft.Client

Methods

put :: Putter ClientRedirResp

get :: Get ClientRedirResp

type Rep ClientRedirResp

Defined in Raft.Client

type Rep ClientRedirResp = D1 (MetaData "ClientRedirResp" "Raft.Client" "libraft-0.1.1.0-8nwazCMBvi7EUIW9UIbZhF" False) (C1 (MetaCons "ClientRedirResp" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CurrentLeader)))