Copyright	(c) Lars Petersen 2016
License	MIT
Maintainer	info@lars-petersen.net
Stability	experimental
Safe Haskell	None
Language	Haskell2010

Network.MQTT.Broker.Server

Description

Documentation

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

data MQTT transport Source #

Instances

Eq (ServerException (MQTT transport)) Source #
Methods (==) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool # (/=) :: ServerException (MQTT transport) -> ServerException (MQTT transport) -> Bool #
Ord (ServerException (MQTT transport)) Source #
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)) Source #
Methods showsPrec :: Int -> ServerException (MQTT transport) -> ShowS # show :: ServerException (MQTT transport) -> String # showList :: [ServerException (MQTT transport)] -> ShowS #
Show (ServerConnectionInfo transport) => Show (ServerConnectionInfo (MQTT transport)) Source #
Methods showsPrec :: Int -> ServerConnectionInfo (MQTT transport) -> ShowS # show :: ServerConnectionInfo (MQTT transport) -> String # showList :: [ServerConnectionInfo (MQTT transport)] -> ShowS #
Typeable * transport => Exception (ServerException (MQTT transport)) Source #
Methods toException :: ServerException (MQTT transport) -> SomeException # fromException :: SomeException -> Maybe (ServerException (MQTT transport)) # displayException :: ServerException (MQTT transport) -> String #
StreamServerStack transport => MessageServerStack (MQTT transport) Source #
Associated Types type ClientMessage (MQTT transport) :: * Source # type ServerMessage (MQTT transport) :: * Source # Methods sendMessage :: ServerConnection (MQTT transport) -> ServerMessage (MQTT transport) -> IO Int64 Source # sendMessages :: Foldable t => ServerConnection (MQTT transport) -> t (ServerMessage (MQTT transport)) -> IO Int64 Source # receiveMessage :: ServerConnection (MQTT transport) -> Int64 -> IO (ClientMessage (MQTT transport)) Source # consumeMessages :: ServerConnection (MQTT transport) -> Int64 -> (ClientMessage (MQTT transport) -> IO Bool) -> IO () Source #
StreamServerStack transport => ServerStack (MQTT transport) Source #
Associated Types data Server (MQTT transport) :: * Source # data ServerConfig (MQTT transport) :: * Source # data ServerException (MQTT transport) :: * Source # data ServerConnection (MQTT transport) :: * Source # data ServerConnectionInfo (MQTT transport) :: * Source # Methods withServer :: ServerConfig (MQTT transport) -> (Server (MQTT transport) -> IO b) -> IO b Source # withConnection :: Server (MQTT transport) -> (ServerConnection (MQTT transport) -> ServerConnectionInfo (MQTT transport) -> IO b) -> IO (Async b) Source #
type ClientMessage (MQTT transport) Source #
type ClientMessage (MQTT transport) = ClientPacket
type ServerMessage (MQTT transport) Source #
type ServerMessage (MQTT transport) = ServerPacket
data Server (MQTT transport) Source #
data Server (MQTT transport) = MqttServer { mqttTransportServer :: Server transport }
data ServerConfig (MQTT transport) Source #
data ServerConfig (MQTT transport) = MqttServerConfig { mqttTransportConfig :: ServerConfig transport }
data ServerException (MQTT transport) Source #
data ServerException (MQTT transport) = ProtocolViolation String \| MessageTooLong \| ConnectionRejected RejectReason \| KeepAliveTimeoutException
data ServerConnection (MQTT transport) Source #
data ServerConnection (MQTT transport) = MqttServerConnection { mqttTransportConnection :: ServerConnection transport mqttTransportLeftover :: MVar ByteString }
data ServerConnectionInfo (MQTT transport) Source #
data ServerConnectionInfo (MQTT transport) = MqttServerConnectionInfo { mqttTransportServerConnectionInfo :: ServerConnectionInfo transport }

class ServerStack a => MqttServerTransportStack a where Source #

Minimal complete definition

getConnectionRequest

Methods

getConnectionRequest :: ServerConnectionInfo a -> IO ConnectionRequest Source #

Instances

(StreamServerStack a, MqttServerTransportStack a) => MqttServerTransportStack (WebSocket a) Source #
Methods getConnectionRequest :: ServerConnectionInfo (WebSocket a) -> IO ConnectionRequest Source #
(StreamServerStack a, MqttServerTransportStack a) => MqttServerTransportStack (TLS a) Source #
Methods getConnectionRequest :: ServerConnectionInfo (TLS a) -> IO ConnectionRequest Source #
(Typeable * f, Typeable * t, Typeable * p, Family f, Protocol p, Type t, HasNameInfo f) => MqttServerTransportStack (Socket f t p) Source #
Methods getConnectionRequest :: ServerConnectionInfo (Socket f t p) -> IO ConnectionRequest Source #