Versions in this module Expand all Collapse all v0 v0.0.2 Jan 7, 2021 v0.0.1 Jan 7, 2021 Changes in this version + const Accepted + const ConnackType + const ConnectType + const DisconnectType + const ErrNetworkError + const ErrProtocolViolation + const ErrRefusedBadProtocolVersion + const ErrRefusedBadUsernameOrPassword + const ErrRefusedIDRejected + const ErrRefusedNotAuthorised + const ErrRefusedServerUnavailable + const PingreqType + const PingrespType + const PubackType + const PubcompType + const PublishType + const PubrecType + const PubrelType + const SubackType + const SubscribeType + const UnsubackType + const UnsubscribeType + var ConnErrors = map[byte]error + var ConnackReturnCodes = map[uint8]string + type ConnAck struct + Header Header + ReturnCode byte + SessionPresent bool + func (c *ConnAck) Marshal() ([]byte, error) + func (c *ConnAck) MarshalTo(buffer []byte) error + func (c *ConnAck) Size() int + func (c *ConnAck) Unmarshal(buffer []byte) error + type Connect struct + CleanSession bool + ClientIdentifier string + Header Header + Keepalive uint16 + Password []byte + PasswordFlag bool + ProtocolName string + ProtocolVersion byte + ReservedBit byte + Username string + UsernameFlag bool + WillFlag bool + WillMessage []byte + WillQos byte + WillRetain bool + WillTopic string + func (c *Connect) Marshal() ([]byte, error) + func (c *Connect) MarshalTo(buffer []byte) error + func (c *Connect) Size() int + func (c *Connect) Unmarshal(data []byte) error + func (c *Connect) Validate() byte + type Disconnect struct + Header Header + func (p *Disconnect) Marshal() ([]byte, error) + func (p *Disconnect) MarshalTo(buffer []byte) error + func (p *Disconnect) Size() int + func (p *Disconnect) Unmarshal(_ []byte) error + type Header struct + Dup bool + MessageType byte + Qos byte + RemainingLength int + Retain bool + func (h *Header) Marshal() ([]byte, error) + func (h *Header) MarshalTo(buffer []byte) error + func (h *Header) Size() int + type Packet interface + Marshal func() ([]byte, error) + MarshalTo func(buffer []byte) error + Size func() int + Unmarshal func(data []byte) error + func UnmarshalPacket(reader io.Reader) (Packet, []byte, error) + type PingReq struct + Header Header + func (p *PingReq) Marshal() ([]byte, error) + func (p *PingReq) MarshalTo(buffer []byte) error + func (p *PingReq) Size() int + func (p *PingReq) Unmarshal(_ []byte) error + type PingResp struct + Header Header + func (p *PingResp) Marshal() ([]byte, error) + func (p *PingResp) MarshalTo(buffer []byte) error + func (p *PingResp) Size() int + func (p *PingResp) Unmarshal(_ []byte) error + type PubAck struct + Header Header + MessageID uint16 + func (p *PubAck) Marshal() ([]byte, error) + func (p *PubAck) MarshalTo(buffer []byte) error + func (p *PubAck) Size() int + func (p *PubAck) Unmarshal(bytes []byte) error + type PubComp struct + Header Header + MessageID uint16 + func (p *PubComp) Marshal() ([]byte, error) + func (p *PubComp) MarshalTo(buffer []byte) error + func (p *PubComp) Size() int + func (p *PubComp) Unmarshal(bytes []byte) error + type PubRec struct + Header Header + MessageID uint16 + func (p *PubRec) Marshal() ([]byte, error) + func (p *PubRec) MarshalTo(buffer []byte) error + func (p *PubRec) Size() int + func (p *PubRec) Unmarshal(bytes []byte) error + type PubRel struct + Header Header + MessageID uint16 + func (p *PubRel) Marshal() ([]byte, error) + func (p *PubRel) MarshalTo(buffer []byte) error + func (p *PubRel) Size() int + func (p *PubRel) Unmarshal(bytes []byte) error + type Publish struct + Header Header + MessageID uint16 + Payload []byte + TopicName string + func (p *Publish) Marshal() ([]byte, error) + func (p *Publish) MarshalTo(buffer []byte) error + func (p *Publish) Size() int + func (p *Publish) Unmarshal(buffer []byte) error + type SubAck struct + Header Header + MessageID uint16 + ReturnCodes []byte + func (p *SubAck) Marshal() ([]byte, error) + func (p *SubAck) MarshalTo(buffer []byte) error + func (p *SubAck) Size() int + func (p *SubAck) Unmarshal(data []byte) error + type Subscribe struct + Header Header + MessageID uint16 + Qoss []byte + Topics []string + func (s *Subscribe) Marshal() ([]byte, error) + func (s *Subscribe) MarshalTo(buffer []byte) error + func (s *Subscribe) Size() int + func (s *Subscribe) Unmarshal(data []byte) error + type UnSubAck struct + Header Header + MessageID uint16 + func (p *UnSubAck) Marshal() ([]byte, error) + func (p *UnSubAck) MarshalTo(buffer []byte) error + func (p *UnSubAck) Size() int + func (p *UnSubAck) Unmarshal(bytes []byte) error + type UnSubscribe struct + Header Header + MessageID uint16 + Topics []string + func (s *UnSubscribe) Marshal() ([]byte, error) + func (s *UnSubscribe) MarshalTo(buffer []byte) error + func (s *UnSubscribe) Size() int + func (s *UnSubscribe) Unmarshal(data []byte) error