packet

package

Go to main page

Versions in this module

v0

v0.2.6

Feb 6, 2022

v0.2.5

Feb 3, 2022

Changes in this version

type Packet

+ SetSource func(clientId string)

+ Source func() string

+ type PacketImpl struct

+ ClientId string

+ func (pi *PacketImpl) Length() int

+ func (pi *PacketImpl) Pack() []byte

+ func (pi *PacketImpl) SetSource(clientId string)

+ func (pi *PacketImpl) Source() string

+ func (pi *PacketImpl) String() string

+ func (pi *PacketImpl) Type() Type

+ func (pi *PacketImpl) Unpack(buf []byte) error

+ type WillMessage struct

+ Dublicate bool

+ Flag bool

+ Payload string

+ QoS QoS

+ Retain bool

+ Topic string

+ func (m *WillMessage) Length() int

+ func (m *WillMessage) Pack() []byte

+ func (m *WillMessage) String() string

+ func (m *WillMessage) Type() Type

+ func (m *WillMessage) Unpack(buf []byte) error

v0.2.4

Jan 28, 2022

Changes in this version

type Message

+ func (m *Message) Type() Type

+ func (m *Message) Unpack(buf []byte) error

v0.2.3

Jan 8, 2022

v0.2.2

Jan 8, 2022

v0.2.1

Jan 8, 2022

v0.2.0

Jan 8, 2022

v0.1.4

Nov 26, 2021

v0.1.3

Nov 23, 2021

v0.1.2

Jun 6, 2021

Changes in this version

+ var DEBUG bool = false

+ func MatchTopic(mask string, topic string) bool

+ func WriteBytes(buf []byte, offset int, bytes []byte) int

+ func WriteLength(len int) []byte

+ func WritePacket(conn net.Conn, pkt Packet) error

+ func WriteString(buf []byte, offset int, value string) int

type ConnPacket

+ VersionName string

type Packet

+ func ReadPacket(conn net.Conn) (Packet, error)

v0.1.1

May 26, 2021

Changes in this version

+ var ErrConnect = errors.New("error connect to server")

v0.1.0

May 24, 2021

Changes in this version

+ const ConnectAccepted

+ const ConnectBadUserPass

+ const ConnectIndentifierRejected

+ const ConnectNotAuthorized

+ const ConnectServerUnavailable

+ const ConnectUnacceptableProtocol

+ var ErrInvalidPacketLength = errors.New("invalid packet Len")

+ var ErrInvalidPacketType = errors.New("invalid packet type")

+ var ErrInvalidQos = errors.New("invalid qos")

+ var ErrProtocolError = errors.New("protocol error (not supported)")

+ var ErrReadFromBuf = errors.New("error read data from buffer")

+ var ErrUnknownPacket = errors.New("unknown packet type")

+ var ErrUnsupportedVersion = errors.New("unsupported mqtt version")

+ func ReadBytes(buf []byte, offset int, length int) ([]byte, int, error)

+ func ReadInt16(buf []byte, offset int) (uint16, int, error)

+ func ReadInt8(buf []byte, offset int) (uint8, int, error)

+ func ReadString(buf []byte, offset int, length int) (string, int, error)

+ func WriteInt16(buf []byte, offset int, value uint16) int

+ func WriteInt8(buf []byte, offset int, value uint8) int

+ type ConnAckPacket struct

+ Header []byte

+ ReturnCode uint8

+ Session bool

+ func CreateConnAck(buf []byte) *ConnAckPacket

+ func NewConnAck() *ConnAckPacket

+ func (cack *ConnAckPacket) Length() int

+ func (cack *ConnAckPacket) Pack() []byte

+ func (cack *ConnAckPacket) String() string

+ func (cack *ConnAckPacket) Type() Type

+ func (cack *ConnAckPacket) Unpack(buf []byte) error

+ type ConnPacket struct

+ CleanSession bool

+ ClientID string

+ Header []byte

+ KeepAlive uint16

+ Password string

+ Username string

+ Version byte

+ Will *Message

+ func CreateConnect(buf []byte) *ConnPacket

+ func NewConnect() *ConnPacket

+ func (c *ConnPacket) Length() int

+ func (c *ConnPacket) Pack() []byte

+ func (c *ConnPacket) String() string

+ func (c *ConnPacket) Type() Type

+ func (c *ConnPacket) Unpack(buf []byte) error

+ type DisconnectPacket struct

+ Header []byte

+ func CreateDisconnect(buf []byte) *DisconnectPacket

+ func NewDisconnect() *DisconnectPacket

+ func (cack *DisconnectPacket) Length() int

+ func (cack *DisconnectPacket) Pack() []byte

+ func (cack *DisconnectPacket) String() string

+ func (cack *DisconnectPacket) Type() Type

+ func (cack *DisconnectPacket) Unpack(buf []byte) error

+ type Message struct

+ Dublicate bool

+ Flag bool

+ Payload string

+ QoS QoS

+ Retain bool

+ Topic string

+ func (m *Message) Length() int

+ func (m *Message) Pack() []byte

+ func (m *Message) String() string

+ type Packet interface

+ Length func() int

+ Pack func() []byte

+ String func() string

+ Type func() Type

+ Unpack func(buf []byte) error

+ func Create(buf []byte) (Packet, error)

+ func NewPacket(t Type) Packet

+ type PingPacket struct

+ Header []byte

+ func CreatePing(buf []byte) *PingPacket

+ func NewPing() *PingPacket

+ func (p *PingPacket) Length() int

+ func (p *PingPacket) Pack() []byte

+ func (p *PingPacket) String() string

+ func (p *PingPacket) Type() Type

+ func (p *PingPacket) Unpack(buf []byte) error

+ type PongPacket struct

+ Header []byte

+ func CreatePong(buf []byte) *PongPacket

+ func NewPong() *PongPacket

+ func (p *PongPacket) Length() int

+ func (p *PongPacket) Pack() []byte

+ func (p *PongPacket) String() string

+ func (p *PongPacket) Type() Type

+ func (p *PongPacket) Unpack(buf []byte) error

+ type PubAckPacket struct

+ Header []byte

+ Id uint16

+ func CreatePubAck(buf []byte) *PubAckPacket

+ func NewPubAck() *PubAckPacket

+ func (pack *PubAckPacket) Length() int

+ func (pack *PubAckPacket) Pack() []byte

+ func (pack *PubAckPacket) String() string

+ func (pack *PubAckPacket) Type() Type

+ func (pack *PubAckPacket) Unpack(buf []byte) error

+ type PubCompPacket struct

+ Header []byte

+ Id uint16

+ func CreatePubComp(buf []byte) *PubCompPacket

+ func NewPubComp() *PubCompPacket

+ func (p *PubCompPacket) Length() int

+ func (p *PubCompPacket) Pack() []byte

+ func (p *PubCompPacket) String() string

+ func (p *PubCompPacket) Type() Type

+ func (p *PubCompPacket) Unpack(buf []byte) error

+ type PubRecPacket struct

+ Header []byte

+ Id uint16

+ func CreatePubRec(buf []byte) *PubRecPacket

+ func NewPubRec() *PubRecPacket

+ func (p *PubRecPacket) Length() int

+ func (p *PubRecPacket) Pack() []byte

+ func (p *PubRecPacket) String() string

+ func (p *PubRecPacket) Type() Type

+ func (p *PubRecPacket) Unpack(buf []byte) error

+ type PubRelPacket struct

+ Header []byte

+ Id uint16

+ func CreatePubRel(buf []byte) *PubRelPacket

+ func NewPubRel() *PubRelPacket

+ func (p *PubRelPacket) Length() int

+ func (p *PubRelPacket) Pack() []byte

+ func (p *PubRelPacket) String() string

+ func (p *PubRelPacket) Type() Type

+ func (p *PubRelPacket) Unpack(buf []byte) error

+ type PublishPacket struct

+ DUP bool

+ Header []byte

+ Id uint16

+ Payload string

+ QoS QoS

+ Retain bool

+ Topic string

+ func CreatePublish(buf []byte) *PublishPacket

+ func NewPublish() *PublishPacket

+ func (p *PublishPacket) Length() int

+ func (p *PublishPacket) Pack() []byte

+ func (p *PublishPacket) String() string

+ func (p *PublishPacket) Type() Type

+ func (p *PublishPacket) Unpack(buf []byte) error

+ type QoS byte

+ const AtLeastOnce

+ const AtMostOnce

+ const ExactlyOnce

+ func (q QoS) Int() int

+ func (q QoS) String() string

+ func (q QoS) Valid() bool

+ type SubAckPacket struct

+ Header []byte

+ Id uint16

+ ReturnCodes []QoS

+ func CreateSubAck(buf []byte) *SubAckPacket

+ func NewSubAck() *SubAckPacket

+ func (sack *SubAckPacket) Length() int

+ func (sack *SubAckPacket) Pack() []byte

+ func (sack *SubAckPacket) String() string

+ func (sack *SubAckPacket) Type() Type

+ func (sack *SubAckPacket) Unpack(buf []byte) error

+ type SubscribePacket struct

+ Header []byte

+ Id uint16

+ Topics []SubscribePayload

+ func CreateSubscribe(buf []byte) *SubscribePacket

+ func NewSubscribe() *SubscribePacket

+ func (s *SubscribePacket) Length() int

+ func (s *SubscribePacket) Pack() []byte

+ func (s *SubscribePacket) String() string

+ func (s *SubscribePacket) Type() Type

+ func (s *SubscribePacket) Unpack(buf []byte) error

+ type SubscribePayload struct

+ QoS QoS

+ Topic string

+ func (p *SubscribePayload) Length() int

+ func (p *SubscribePayload) Pack() []byte

+ func (p *SubscribePayload) String() string

+ type Type byte

+ const CONNACK

+ const CONNECT

+ const DISCONNECT

+ const PING

+ const PONG

+ const PUBACK

+ const PUBCOMP

+ const PUBLISH

+ const PUBREC

+ const PUBREL

+ const RESERVED

+ const SUBACK

+ const SUBSCRIBE

+ const UNSUBACK

+ const UNSUBSCRIBE

+ func Types() []Type

+ func (t Type) String() string

+ type UnSubAckPacket struct

+ Header []byte

+ Id uint16

+ func CreateUnSubAck(buf []byte) *UnSubAckPacket

+ func NewUnSubAck() *UnSubAckPacket

+ func (uack *UnSubAckPacket) Length() int

+ func (uack *UnSubAckPacket) Pack() []byte

+ func (uack *UnSubAckPacket) String() string

+ func (uack *UnSubAckPacket) Type() Type

+ func (uack *UnSubAckPacket) Unpack(buf []byte) error

+ type UnSubscribePacket struct

+ Header []byte

+ Id uint16

+ Topics []SubscribePayload

+ func CreateUnSubscribe(buf []byte) *UnSubscribePacket

+ func NewUnSub() *UnSubscribePacket

+ func (u *UnSubscribePacket) Length() int

+ func (u *UnSubscribePacket) Pack() []byte

+ func (u *UnSubscribePacket) String() string

+ func (u *UnSubscribePacket) Type() Type

+ func (u *UnSubscribePacket) Unpack(buf []byte) error

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