Copyright | (c) Dustin Sallings 2019 |
---|---|
License | BSD3 |
Maintainer | dustin@spy.net |
Stability | experimental |
Safe Haskell | Safe |
Language | Haskell2010 |
MQTT Types.
Synopsis
- data LastWill = LastWill {
- _willRetain :: Bool
- _willQoS :: QoS
- _willTopic :: ByteString
- _willMsg :: ByteString
- data MQTTPkt
- = ConnPkt ConnectRequest
- | ConnACKPkt ConnACKFlags
- | PublishPkt PublishRequest
- | PubACKPkt PubACK
- | PubRECPkt PubREC
- | PubRELPkt PubREL
- | PubCOMPPkt PubCOMP
- | SubscribePkt SubscribeRequest
- | SubACKPkt SubscribeResponse
- | UnsubscribePkt UnsubscribeRequest
- | UnsubACKPkt UnsubscribeResponse
- | PingPkt
- | PongPkt
- | DisconnectPkt
- data QoS
- data ConnectRequest = ConnectRequest {}
- connectRequest :: ConnectRequest
- data ConnACKFlags = ConnACKFlags Bool ConnACKRC
- data ConnACKRC
- data PublishRequest = PublishRequest {
- _pubDup :: Bool
- _pubQoS :: QoS
- _pubRetain :: Bool
- _pubTopic :: ByteString
- _pubPktID :: Word16
- _pubBody :: ByteString
- newtype PubACK = PubACK Word16
- newtype PubREC = PubREC Word16
- newtype PubREL = PubREL Word16
- newtype PubCOMP = PubCOMP Word16
- data SubscribeRequest = SubscribeRequest Word16 [(ByteString, QoS)]
- data SubscribeResponse = SubscribeResponse Word16 [Maybe QoS]
- data UnsubscribeRequest = UnsubscribeRequest Word16 [ByteString]
- newtype UnsubscribeResponse = UnsubscribeResponse Word16
- parsePacket :: Parser MQTTPkt
- class ByteMe a where
- toByteString :: a -> ByteString
- encodeLength :: Int -> [Word8]
- parseHdrLen :: Parser Int
- connACKRC :: Word8 -> ConnACKRC
Documentation
An MQTT Will message.
LastWill | |
|
QoS values for publishing and subscribing.
data ConnectRequest Source #
ConnectRequest | |
|
Instances
Eq ConnectRequest Source # | |
Defined in Network.MQTT.Types (==) :: ConnectRequest -> ConnectRequest -> Bool # (/=) :: ConnectRequest -> ConnectRequest -> Bool # | |
Show ConnectRequest Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> ConnectRequest -> ShowS # show :: ConnectRequest -> String # showList :: [ConnectRequest] -> ShowS # | |
ByteMe ConnectRequest Source # | |
Defined in Network.MQTT.Types toBytes :: ConnectRequest -> [Word8] |
data ConnACKFlags Source #
Instances
Eq ConnACKFlags Source # | |
Defined in Network.MQTT.Types (==) :: ConnACKFlags -> ConnACKFlags -> Bool # (/=) :: ConnACKFlags -> ConnACKFlags -> Bool # | |
Show ConnACKFlags Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> ConnACKFlags -> ShowS # show :: ConnACKFlags -> String # showList :: [ConnACKFlags] -> ShowS # | |
ByteMe ConnACKFlags Source # | |
Defined in Network.MQTT.Types toBytes :: ConnACKFlags -> [Word8] |
ConnAccepted | |
UnacceptableProtocol | |
IdentifierRejected | |
ServerUnavailable | |
BadCredentials | |
NotAuthorized | |
InvalidConnACKRC Word8 |
data PublishRequest Source #
PublishRequest | |
|
Instances
Eq PublishRequest Source # | |
Defined in Network.MQTT.Types (==) :: PublishRequest -> PublishRequest -> Bool # (/=) :: PublishRequest -> PublishRequest -> Bool # | |
Show PublishRequest Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> PublishRequest -> ShowS # show :: PublishRequest -> String # showList :: [PublishRequest] -> ShowS # | |
ByteMe PublishRequest Source # | |
Defined in Network.MQTT.Types toBytes :: PublishRequest -> [Word8] |
data SubscribeRequest Source #
Instances
Eq SubscribeRequest Source # | |
Defined in Network.MQTT.Types (==) :: SubscribeRequest -> SubscribeRequest -> Bool # (/=) :: SubscribeRequest -> SubscribeRequest -> Bool # | |
Show SubscribeRequest Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> SubscribeRequest -> ShowS # show :: SubscribeRequest -> String # showList :: [SubscribeRequest] -> ShowS # | |
ByteMe SubscribeRequest Source # | |
Defined in Network.MQTT.Types toBytes :: SubscribeRequest -> [Word8] |
data SubscribeResponse Source #
Instances
Eq SubscribeResponse Source # | |
Defined in Network.MQTT.Types (==) :: SubscribeResponse -> SubscribeResponse -> Bool # (/=) :: SubscribeResponse -> SubscribeResponse -> Bool # | |
Show SubscribeResponse Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> SubscribeResponse -> ShowS # show :: SubscribeResponse -> String # showList :: [SubscribeResponse] -> ShowS # | |
ByteMe SubscribeResponse Source # | |
Defined in Network.MQTT.Types toBytes :: SubscribeResponse -> [Word8] |
data UnsubscribeRequest Source #
Instances
Eq UnsubscribeRequest Source # | |
Defined in Network.MQTT.Types (==) :: UnsubscribeRequest -> UnsubscribeRequest -> Bool # (/=) :: UnsubscribeRequest -> UnsubscribeRequest -> Bool # | |
Show UnsubscribeRequest Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> UnsubscribeRequest -> ShowS # show :: UnsubscribeRequest -> String # showList :: [UnsubscribeRequest] -> ShowS # | |
ByteMe UnsubscribeRequest Source # | |
Defined in Network.MQTT.Types toBytes :: UnsubscribeRequest -> [Word8] |
newtype UnsubscribeResponse Source #
Instances
Eq UnsubscribeResponse Source # | |
Defined in Network.MQTT.Types (==) :: UnsubscribeResponse -> UnsubscribeResponse -> Bool # (/=) :: UnsubscribeResponse -> UnsubscribeResponse -> Bool # | |
Show UnsubscribeResponse Source # | |
Defined in Network.MQTT.Types showsPrec :: Int -> UnsubscribeResponse -> ShowS # show :: UnsubscribeResponse -> String # showList :: [UnsubscribeResponse] -> ShowS # | |
ByteMe UnsubscribeResponse Source # | |
Defined in Network.MQTT.Types toBytes :: UnsubscribeResponse -> [Word8] |
Nothing
toByteString :: a -> ByteString Source #
Instances
encodeLength :: Int -> [Word8] Source #
parseHdrLen :: Parser Int Source #