Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + func DecodeMessage(b *bytes.Buffer) (msg *gmqtt.Message, err error) + func DecodeMessageFromBytes(b []byte) (msg *gmqtt.Message, err error) + func DecodeSession(b *bytes.Buffer) (sess *gmqtt.Session, err error) + func EncodeMessage(msg *gmqtt.Message, b *bytes.Buffer) + func EncodeSession(sess *gmqtt.Session, b *bytes.Buffer) + func ReadBool(r *bytes.Buffer) (bool, error) + func ReadString(r *bytes.Buffer) (b []byte, err error) + func ReadUint16(r *bytes.Buffer) (uint16, error) + func ReadUint32(r *bytes.Buffer) (uint32, error) + func WriteBool(w *bytes.Buffer, b bool) + func WriteString(w *bytes.Buffer, s []byte) + func WriteUint16(w *bytes.Buffer, i uint16) + func WriteUint32(w *bytes.Buffer, i uint32)
Go to main page