examples
→
README
T
Connack
T
ConnackReturnCode
T
Connect
T
ConnectFlags
T
FixedHeader
T
MessageType
T
Packet
T
PacketId
T
Publish
T
QoS
T
Suback
T
SubackReturnCode
T
Subscribe
T
SubscribeTopic
T
Unsuback
T
Unsubscribe
V
decode_binary
V
decode_connack
V
decode_connect
V
decode_disconnect
V
decode_fixed_header
V
decode_packet
V
decode_pingreq
V
decode_pingresp
V
decode_puback
V
decode_pubcomp
V
decode_publish
V
decode_pubrec
V
decode_pubrel
V
decode_remaining_length
V
decode_string
V
decode_suback
V
decode_subscribe
V
decode_unsuback
V
decode_unsubscribe
V
encode_binary
V
encode_connack
V
encode_connect
V
encode_disconnect
V
encode_packet
V
encode_pingreq
V
encode_pingresp
V
encode_puback
V
encode_pubcomp
V
encode_publish
V
encode_pubrec
V
encode_pubrel
V
encode_remaining_length
V
encode_string
V
encode_suback
V
encode_subscribe
V
encode_unsuback
V
encode_unsubscribe
V
has_complete_packet
V
is_pingresp
V
packet_total_length

moonbit-mqtt

MQTT 3.1.1 packet codec helpers for MoonBit without transport or client runtime

mqtt

iot

codec

protocol

moonbit

moon add zbhzs1/moonbit-mqtt@0.1.0

Download zip

Author

zbhzs1

Version

0.1.0

License

Apache-2.0

Repository

github.com/zbhzs1/moonbit-mqtt

Last updated

last month

Downloads

README

#zbhzs1/moonbit-mqtt

MQTT 3.1.1 packet codec helpers for MoonBit.

This package focuses on byte-level encode/decode helpers. It does not implement network transport, a client runtime, broker sessions, TLS, or MQTT 5.0.

#
Connack

source

pub(all) struct Connack {
  session_present : Bool
  return_code : ConnackReturnCode
} derive(@moonbitlang/core/debug.Debug
Debug)

#
ConnackReturnCode

source

pub(all) enum ConnackReturnCode {
  ConnectionAccepted
  UnacceptableProtocolVersion
  IdentifierRejected
  ServerUnavailable
  BadUserNameOrPassword
  NotAuthorized
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

#
Connect

source

pub(all) struct Connect {
  client_id : String
  username : String?
  password : Bytes?
  will_topic : String?
  will_message : Bytes?
  keep_alive : Int
  flags : ConnectFlags
} derive(@moonbitlang/core/debug.Debug
Debug)

#
ConnectFlags

source

pub(all) struct ConnectFlags {
  username : Bool
  password : Bool
  will_retain : Bool
  will_qos : QoS
  will_flag : Bool
  clean_session : Bool
} derive(@moonbitlang/core/debug.Debug
Debug)

#
FixedHeader

source

pub(all) struct FixedHeader {
  message_type : MessageType
  dup : Bool
  qos : QoS
  retain : Bool
  remaining_length : Int
  header_len : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

#
MessageType

source

pub(all) enum MessageType {
  CONNECT
  CONNACK
  PUBLISH
  PUBACK
  PUBREC
  PUBREL
  PUBCOMP
  SUBSCRIBE
  SUBACK
  UNSUBSCRIBE
  UNSUBACK
  PINGREQ
  PINGRESP
  DISCONNECT
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

#
Packet

source

pub(all) enum Packet {
  ConnectPacket(Connect)
  ConnackPacket(Connack)
  PublishPacket(Publish)
  PubackPacket(PacketId)
  PubrecPacket(PacketId)
  PubrelPacket(PacketId)
  PubcompPacket(PacketId)
  SubscribePacket(Subscribe)
  SubackPacket(Suback)
  UnsubscribePacket(Unsubscribe)
  UnsubackPacket(Unsuback)
  PingreqPacket
  PingrespPacket
  DisconnectPacket
} derive(@moonbitlang/core/debug.Debug
Debug)

#
PacketId

source

pub(all) struct PacketId {
  message_id : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

#
Publish

source

pub(all) struct Publish {
  topic : String
  payload : Bytes
  qos : QoS
  message_id : Int?
  retain : Bool
  dup : Bool
} derive(@moonbitlang/core/debug.Debug
Debug)

#
QoS

source

pub(all) enum QoS {
  QoS0
  QoS1
  QoS2
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

#
Suback

source

pub(all) struct Suback {
  message_id : Int
  return_codes : Array[SubackReturnCode]
} derive(@moonbitlang/core/debug.Debug
Debug)

#
SubackReturnCode

source

pub(all) enum SubackReturnCode {
  SuccessQoS0
  SuccessQoS1
  SuccessQoS2
  Failure
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

pub(all) struct Subscribe {
  topics : Array[SubscribeTopic]
  message_id : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

#
SubscribeTopic

source

pub(all) struct SubscribeTopic {
  topic : String
  qos : QoS
} derive(@moonbitlang/core/debug.Debug
Debug)

#
Unsuback

source

pub(all) struct Unsuback {
  message_id : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

#
Unsubscribe

source

pub(all) struct Unsubscribe {
  topics : Array[String]
  message_id : Int
} derive(@moonbitlang/core/debug.Debug
Debug)

#
decode_binary

source

fn decode_binary(bytes : Array[Byte], offset : Int) -> Result[(Bytes, Int), String]

#
decode_connack

source

fn decode_connack(bytes : Array[Byte]) -> Result[Connack, String]

#
decode_connect

source

fn decode_connect(bytes : Array[Byte]) -> Result[Connect, String]

#
decode_disconnect

source

fn decode_disconnect(bytes : Array[Byte]) -> Result[Unit, String]

#
decode_fixed_header

source

fn decode_fixed_header(bytes : Array[Byte]) -> Result[FixedHeader, String]

#
decode_packet

source

fn decode_packet(bytes : Array[Byte]) -> Result[Packet, String]

#
decode_pingreq

source

fn decode_pingreq(bytes : Array[Byte]) -> Result[Unit, String]

#
decode_pingresp

source

fn decode_pingresp(bytes : Array[Byte]) -> Result[Unit, String]

#
decode_puback

source

fn decode_puback(bytes : Array[Byte]) -> Result[PacketId, String]

#
decode_pubcomp

source

fn decode_pubcomp(bytes : Array[Byte]) -> Result[PacketId, String]

#
decode_publish

source

fn decode_publish(bytes : Array[Byte]) -> Result[Publish, String]

#
decode_pubrec

source

fn decode_pubrec(bytes : Array[Byte]) -> Result[PacketId, String]

#
decode_pubrel

source

fn decode_pubrel(bytes : Array[Byte]) -> Result[PacketId, String]

#
decode_remaining_length

source

fn decode_remaining_length(bytes : Array[Byte], offset : Int) -> Result[(Int, Int), String]

#
decode_string

source

fn decode_string(bytes : Array[Byte], offset : Int) -> Result[(String, Int), String]

#
decode_suback

source

fn decode_suback(bytes : Array[Byte]) -> Result[Suback, String]

#
decode_subscribe

source

fn decode_subscribe(bytes : Array[Byte]) -> Result[Subscribe, String]

#
decode_unsuback

source

fn decode_unsuback(bytes : Array[Byte]) -> Result[Unsuback, String]

#
decode_unsubscribe

source

fn decode_unsubscribe(bytes : Array[Byte]) -> Result[Unsubscribe, String]

#
encode_binary

source

fn encode_binary(value : Bytes) -> Result[Array[Byte], String]

#
encode_connack

source

fn encode_connack(connack : Connack) -> Result[Array[Byte], String]

#
encode_connect

source

fn encode_connect(connect : Connect) -> Result[Array[Byte], String]

#
encode_disconnect

source

fn encode_disconnect() -> Result[Array[Byte], String]

#
encode_packet

source

fn encode_packet(packet : Packet) -> Result[Array[Byte], String]

#
encode_pingreq

source

fn encode_pingreq() -> Result[Array[Byte], String]

#
encode_pingresp

source

fn encode_pingresp() -> Result[Array[Byte], String]

#
encode_puback

source

fn encode_puback(message_id : Int) -> Result[Array[Byte], String]

#
encode_pubcomp

source

fn encode_pubcomp(message_id : Int) -> Result[Array[Byte], String]

#
encode_publish

source

fn encode_publish(publish : Publish) -> Result[Array[Byte], String]

#
encode_pubrec

source

fn encode_pubrec(message_id : Int) -> Result[Array[Byte], String]

#
encode_pubrel

source

fn encode_pubrel(message_id : Int) -> Result[Array[Byte], String]

#
encode_remaining_length

source

fn encode_remaining_length(length : Int) -> Result[Array[Byte], String]

#
encode_string

source

fn encode_string(value : String) -> Result[Array[Byte], String]

#
encode_suback

source

fn encode_suback(suback : Suback) -> Result[Array[Byte], String]

#
encode_subscribe

source

fn encode_subscribe(subscribe : Subscribe) -> Result[Array[Byte], String]

#
encode_unsuback

source

fn encode_unsuback(message_id : Int) -> Result[Array[Byte], String]

#
encode_unsubscribe

source

fn encode_unsubscribe(unsubscribe : Unsubscribe) -> Result[Array[Byte], String]

#
has_complete_packet

source

fn has_complete_packet(bytes : Array[Byte]) -> Bool

#
is_pingresp

source

fn is_pingresp(bytes : Array[Byte]) -> Bool

#
packet_total_length

source

fn packet_total_length(bytes : Array[Byte]) -> Result[Int, String]

Source Files

moonbit-mqtt.mbt

Site source Report issue Packages Build queue Skills Statistics

moonbit-mqtt

#zbhzs1/moonbit-mqtt

#Connack

#ConnackReturnCode

#Connect

#ConnectFlags

#FixedHeader

#MessageType

#Packet

#PacketId

#Publish

#QoS

#Suback

#SubackReturnCode

#Subscribe

#SubscribeTopic

#Unsuback

#Unsubscribe

#decode_binary

#decode_connack

#decode_connect

#decode_disconnect

#decode_fixed_header

#decode_packet

#decode_pingreq

#decode_pingresp

#decode_puback

#decode_pubcomp

#decode_publish

#decode_pubrec

#decode_pubrel

#decode_remaining_length

#decode_string

#decode_suback

#decode_subscribe

#decode_unsuback

#decode_unsubscribe

#encode_binary

#encode_connack

#encode_connect

#encode_disconnect

#encode_packet

#encode_pingreq

#encode_pingresp

#encode_puback

#encode_pubcomp

#encode_publish

#encode_pubrec

#encode_pubrel

#encode_remaining_length

#encode_string

#encode_suback

#encode_subscribe

#encode_unsuback

#encode_unsubscribe

#has_complete_packet

#is_pingresp

#packet_total_length

Source Files

#
Connack

#
ConnackReturnCode

#
Connect

#
ConnectFlags

#
FixedHeader

#
MessageType

#
Packet

#
PacketId

#
Publish

#
QoS

#
Suback

#
SubackReturnCode

#
Subscribe

#
SubscribeTopic

#
Unsuback

#
Unsubscribe

#
decode_binary

#
decode_connack

#
decode_connect

#
decode_disconnect

#
decode_fixed_header

#
decode_packet

#
decode_pingreq

#
decode_pingresp

#
decode_puback

#
decode_pubcomp

#
decode_publish

#
decode_pubrec

#
decode_pubrel

#
decode_remaining_length

#
decode_string

#
decode_suback

#
decode_subscribe

#
decode_unsuback

#
decode_unsubscribe

#
encode_binary

#
encode_connack

#
encode_connect

#
encode_disconnect

#
encode_packet

#
encode_pingreq

#
encode_pingresp

#
encode_puback

#
encode_pubcomp

#
encode_publish

#
encode_pubrec

#
encode_pubrel

#
encode_remaining_length

#
encode_string

#
encode_suback

#
encode_subscribe

#
encode_unsuback

#
encode_unsubscribe

#
has_complete_packet

#
is_pingresp

#
packet_total_length