pkg

Documentation

Index

• type Message
• type Packet
  • func NewPacket(id, topic string, pubPacket *packets.Publish) *Packet
  • func (p *Packet) Decode() packets.Packet
  • func (p *Packet) GetID() string
  • func (p *Packet) GetPayload() []byte
  • func (p *Packet) GetQoS() byte
  • func (p *Packet) GetTopic() string
  • func (p *Packet) PubPacket() *packets.Publish

Types

type Message

type Message interface {
	GetID() string
	GetPayload() []byte
	GetTopic() string
	GetQoS() byte
	Decode() packets.Packet
}

type Packet

type Packet struct {
	// contains filtered or unexported fields
}

func NewPacket

func NewPacket(id, topic string, pubPacket *packets.Publish) *Packet

func (*Packet) Decode

func (p *Packet) Decode() packets.Packet

func (*Packet) GetID

func (p *Packet) GetID() string

func (*Packet) GetPayload

func (p *Packet) GetPayload() []byte

func (*Packet) GetQoS

func (p *Packet) GetQoS() byte

func (*Packet) GetTopic

func (p *Packet) GetTopic() string

func (*Packet) PubPacket

func (p *Packet) PubPacket() *packets.Publish