mqtt

package module

Go to main page

Versions in this module

v1

v1.1.3

Apr 4, 2022

Changes in this version

+ var ErrInvalidTopicEmptyString = errors.New("invalid Topic; empty string")

+ var ErrInvalidTopicMultilevel = errors.New("invalid Topic; multi-level wildcard must be last level")

+ var ErrInvalidWildcardTopic = errors.New("invalid Topic; topic should not contain wildcard")

+ func NewPacketError(code, desc string) *packetError

+ func ValidatePattern(pattern string) error

+ func ValidateTopic(topic string) error

type PublishPacket

+ func (p *PublishPacket) Validate() error

+ func (s *PublishPacket) StrictValidate() error

type SubscribePacket

+ func (s *SubscribePacket) StrictValidate() error

+ func (s *SubscribePacket) Validate() error

type UnsubscribePacket

+ func (s *UnsubscribePacket) StrictValidate() error

+ func (s *UnsubscribePacket) Validate() error

v1.1.2

Mar 25, 2022

Changes in this version

type ConnackPacket

+ func (ca *ConnackPacket) WriteTo(w io.Writer) (n int64, err error)

type ConnectPacket

+ func (c *ConnectPacket) WriteTo(w io.Writer) (n int64, err error)

type DisconnectPacket

+ func (d *DisconnectPacket) WriteTo(w io.Writer) (n int64, err error)

type PingreqPacket

+ func (pr *PingreqPacket) WriteTo(w io.Writer) (n int64, err error)

type PingrespPacket

+ func (pr *PingrespPacket) WriteTo(w io.Writer) (n int64, err error)

type PubackPacket

+ func (pa *PubackPacket) WriteTo(w io.Writer) (n int64, err error)

type PubcompPacket

+ func (pc *PubcompPacket) WriteTo(w io.Writer) (n int64, err error)

type PublishPacket

+ func (p *PublishPacket) WriteTo(w io.Writer) (n int64, err error)

type PubrecPacket

+ func (pr *PubrecPacket) WriteTo(w io.Writer) (n int64, err error)

type PubrelPacket

+ func (pr *PubrelPacket) WriteTo(w io.Writer) (n int64, err error)

type SubackPacket

+ func (sa *SubackPacket) WriteTo(w io.Writer) (n int64, err error)

type SubscribePacket

+ func (s *SubscribePacket) WriteTo(w io.Writer) (n int64, err error)

type UnsubackPacket

+ func (ua *UnsubackPacket) WriteTo(w io.Writer) (n int64, err error)

type UnsubscribePacket

+ func (u *UnsubscribePacket) WriteTo(w io.Writer) (n int64, err error)

v1.1.1

Mar 22, 2022

Changes in this version

+ type ConnackReturnCode byte

v1.1.0

Mar 13, 2022

v1.0.1

Mar 13, 2022

Changes in this version

+ const Accepted

+ const Connack

+ const Connect

+ const Disconnect

+ const ErrNetworkError

+ const ErrProtocolViolation

+ const ErrRefusedBadProtocolVersion

+ const ErrRefusedBadUsernameOrPassword

+ const ErrRefusedIDRejected

+ const ErrRefusedNotAuthorised

+ const ErrRefusedServerUnavailable

+ const Pingreq

+ const Pingresp

+ const Puback

+ const Pubcomp

+ const Publish

+ const Pubrec

+ const Pubrel

+ const Suback

+ const Subscribe

+ const Unsuback

+ const Unsubscribe

+ var ConnErrors = map[byte]error

+ var ConnackReturnCodes = map[uint8]string

+ var ErrorNetworkError = errors.New("network Error")

+ var ErrorProtocolViolation = errors.New("protocol Violation")

+ var ErrorRefusedBadProtocolVersion = errors.New("unacceptable protocol version")

+ var ErrorRefusedBadUsernameOrPassword = errors.New("bad user name or password")

+ var ErrorRefusedIDRejected = errors.New("identifier rejected")

+ var ErrorRefusedNotAuthorised = errors.New("not Authorized")

+ var ErrorRefusedServerUnavailable = errors.New("server Unavailable")

+ var PacketNames = map[uint8]string

+ type ConnackPacket struct

+ ReturnCode byte

+ SessionPresent bool

+ func (ca *ConnackPacket) Details() Details

+ func (ca *ConnackPacket) String() string

+ func (ca *ConnackPacket) Unpack(b io.Reader) error

+ func (ca *ConnackPacket) Write(w io.Writer) error

+ type ConnectPacket struct

+ CleanSession bool

+ ClientIdentifier string

+ 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 *ConnectPacket) Details() Details

+ func (c *ConnectPacket) String() string

+ func (c *ConnectPacket) Unpack(b io.Reader) error

+ func (c *ConnectPacket) Validate() byte

+ func (c *ConnectPacket) Write(w io.Writer) error

+ type ControlPacket interface

+ Details func() Details

+ String func() string

+ Type func() byte

+ Unpack func(io.Reader) error

+ Write func(io.Writer) error

+ func NewControlPacket(packetType byte) ControlPacket

+ func NewControlPacketWithHeader(fh FixedHeader) (ControlPacket, error)

+ func ReadPacket(r io.Reader) (ControlPacket, error)

+ type Details struct

+ MessageID uint16

+ Qos byte

+ type DisconnectPacket struct

+ func (d *DisconnectPacket) Details() Details

+ func (d *DisconnectPacket) String() string

+ func (d *DisconnectPacket) Unpack(b io.Reader) error

+ func (d *DisconnectPacket) Write(w io.Writer) error

+ type FixedHeader struct

+ Dup bool

+ MessageType byte

+ Qos byte

+ RemainingLength int

+ Retain bool

+ func (fh FixedHeader) String() string

+ func (fh FixedHeader) Type() byte

+ type PingreqPacket struct

+ func (pr *PingreqPacket) Details() Details

+ func (pr *PingreqPacket) String() string

+ func (pr *PingreqPacket) Unpack(b io.Reader) error

+ func (pr *PingreqPacket) Write(w io.Writer) error

+ type PingrespPacket struct

+ func (pr *PingrespPacket) Details() Details

+ func (pr *PingrespPacket) String() string

+ func (pr *PingrespPacket) Unpack(b io.Reader) error

+ func (pr *PingrespPacket) Write(w io.Writer) error

+ type PubackPacket struct

+ MessageID uint16

+ func (pa *PubackPacket) Details() Details

+ func (pa *PubackPacket) String() string

+ func (pa *PubackPacket) Unpack(b io.Reader) error

+ func (pa *PubackPacket) Write(w io.Writer) error

+ type PubcompPacket struct

+ MessageID uint16

+ func (pc *PubcompPacket) Details() Details

+ func (pc *PubcompPacket) String() string

+ func (pc *PubcompPacket) Unpack(b io.Reader) error

+ func (pc *PubcompPacket) Write(w io.Writer) error

+ type PublishPacket struct

+ MessageID uint16

+ Payload []byte

+ TopicName string

+ func (p *PublishPacket) Copy() *PublishPacket

+ func (p *PublishPacket) Details() Details

+ func (p *PublishPacket) String() string

+ func (p *PublishPacket) Unpack(b io.Reader) error

+ func (p *PublishPacket) Write(w io.Writer) error

+ type PubrecPacket struct

+ MessageID uint16

+ func (pr *PubrecPacket) Details() Details

+ func (pr *PubrecPacket) String() string

+ func (pr *PubrecPacket) Unpack(b io.Reader) error

+ func (pr *PubrecPacket) Write(w io.Writer) error

+ type PubrelPacket struct

+ MessageID uint16

+ func (pr *PubrelPacket) Details() Details

+ func (pr *PubrelPacket) String() string

+ func (pr *PubrelPacket) Unpack(b io.Reader) error

+ func (pr *PubrelPacket) Write(w io.Writer) error

+ type SubackPacket struct

+ MessageID uint16

+ ReturnCodes []byte

+ func (sa *SubackPacket) Details() Details

+ func (sa *SubackPacket) String() string

+ func (sa *SubackPacket) Unpack(b io.Reader) error

+ func (sa *SubackPacket) Write(w io.Writer) error

+ type SubscribePacket struct

+ MessageID uint16

+ Qoss []byte

+ Topics []string

+ func (s *SubscribePacket) Details() Details

+ func (s *SubscribePacket) String() string

+ func (s *SubscribePacket) Unpack(b io.Reader) error

+ func (s *SubscribePacket) Write(w io.Writer) error

+ type UnsubackPacket struct

+ MessageID uint16

+ func (ua *UnsubackPacket) Details() Details

+ func (ua *UnsubackPacket) String() string

+ func (ua *UnsubackPacket) Unpack(b io.Reader) error

+ func (ua *UnsubackPacket) Write(w io.Writer) error

+ type UnsubscribePacket struct

+ MessageID uint16

+ Topics []string

+ func (u *UnsubscribePacket) Details() Details

+ func (u *UnsubscribePacket) String() string

+ func (u *UnsubscribePacket) Unpack(b io.Reader) error

+ func (u *UnsubscribePacket) Write(w io.Writer) error

Other modules containing this package

github.com/hkloudou/xtransport

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL