Network.MQTT.Broker.Server

Documentation

serveConnection :: forall transport auth. (StreamServerStack transport, MqttServerTransportStack transport, Authenticator auth) => Broker auth -> ServerConnection (MQTT transport) -> ServerConnectionInfo (MQTT transport) -> IO ()

data MQTT transport

Instances

Eq (ServerException (MQTT transport))

Methods

(==) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

(/=) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

Ord (ServerException (MQTT transport))

Methods

compare :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Ordering

(<) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

(<=) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

(>) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

(>=) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool

max :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> ServerException (MQTT transport)

min :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> ServerException (MQTT transport)

Show (ServerException (MQTT transport))

Methods

showsPrec :: Int -> ServerException (MQTT transport) -> ShowS

show :: ServerException (MQTT transport) -> String

showList :: [ServerException (MQTT transport)] -> ShowS

Show (ServerConnectionInfo transport) => Show (ServerConnectionInfo (MQTT transport))

Methods

showsPrec :: Int -> ServerConnectionInfo (MQTT transport) -> ShowS

show :: ServerConnectionInfo (MQTT transport) -> String

showList :: [ServerConnectionInfo (MQTT transport)] -> ShowS

Typeable * transport => Exception (ServerException (MQTT transport))

Methods

toException :: ServerException (MQTT transport) -> SomeException

fromException :: SomeException -> Maybe (ServerException (MQTT transport))

displayException :: ServerException (MQTT transport) -> String

StreamServerStack transport => MessageServerStack (MQTT transport)

Associated Types

type ClientMessage (MQTT transport) :: *

type ServerMessage (MQTT transport) :: *

Methods

sendMessage :: ServerConnection (MQTT transport) -> ServerMessage (MQTT transport) -> IO Int64

sendMessages :: Foldable t => ServerConnection (MQTT transport) -> t (ServerMessage (MQTT transport)) -> IO Int64

receiveMessage :: ServerConnection (MQTT transport) -> Int64 -> IO (ClientMessage (MQTT transport))

consumeMessages :: ServerConnection (MQTT transport) -> Int64 -> (ClientMessage (MQTT transport) -> IO Bool) -> IO ()

StreamServerStack transport => ServerStack (MQTT transport)

Associated Types

data Server (MQTT transport) :: *

data ServerConfig (MQTT transport) :: *

data ServerException (MQTT transport) :: *

data ServerConnection (MQTT transport) :: *

data ServerConnectionInfo (MQTT transport) :: *

Methods

withServer :: ServerConfig (MQTT transport) -> (Server (MQTT transport) -> IO b) -> IO b

withConnection :: Server (MQTT transport) -> (ServerConnection (MQTT transport) -> ServerConnectionInfo (MQTT transport) -> IO b) -> IO (Async b)

type ClientMessage (MQTT transport)

type ClientMessage (MQTT transport) = ClientPacket

type ServerMessage (MQTT transport)

type ServerMessage (MQTT transport) = ServerPacket

data Server (MQTT transport)

data Server (MQTT transport) = MqttServer {

• mqttTransportServer :: Server transport

}

data ServerConfig (MQTT transport)

data ServerConfig (MQTT transport) = MqttServerConfig {

• mqttTransportConfig :: ServerConfig transport

}

data ServerException (MQTT transport)

data ServerException (MQTT transport)

• = ProtocolViolation String
• | MessageTooLong
• | ConnectionRejected RejectReason
• | KeepAliveTimeoutException

data ServerConnection (MQTT transport)

data ServerConnection (MQTT transport) = MqttServerConnection {

• mqttTransportConnection :: ServerConnection transport
• mqttTransportLeftover :: MVar ByteString

}

data ServerConnectionInfo (MQTT transport)

data ServerConnectionInfo (MQTT transport) = MqttServerConnectionInfo {

• mqttTransportServerConnectionInfo :: ServerConnectionInfo transport

}

class ServerStack a => MqttServerTransportStack a where

Minimal complete definition

getConnectionRequest

Methods

getConnectionRequest :: ServerConnectionInfo a -> IO ConnectionRequest

Instances

(StreamServerStack a, MqttServerTransportStack a) => MqttServerTransportStack (WebSocket a)

Methods

getConnectionRequest :: ServerConnectionInfo (WebSocket a) -> IO ConnectionRequest

(StreamServerStack a, MqttServerTransportStack a) => MqttServerTransportStack (TLS a)

Methods

getConnectionRequest :: ServerConnectionInfo (TLS a) -> IO ConnectionRequest

(Typeable * f, Typeable * t, Typeable * p, Family f, Protocol p, Type t, HasNameInfo f) => MqttServerTransportStack (Socket f t p)

Methods

getConnectionRequest :: ServerConnectionInfo (Socket f t p) -> IO ConnectionRequest