client_message_sender

Documentation

Index

• Constants
• type ClientMessageSender
  • func NewClientMessageSender(conn net.Conn) *ClientMessageSender
  • func (cms *ClientMessageSender) Close()
  • func (cms *ClientMessageSender) ProcessControlMessage(messageID uint16, messageType byte)
  • func (cms *ClientMessageSender) Publish(topic string, qos byte, retained bool, payload []byte)
  • func (cms *ClientMessageSender) SendPacket(packet packets.ControlPacket)

Constants

const MessageDeliveryAttempts = 3

const MessageDeliveryTimeout = 5 * time.Second

Types

type ClientMessageSender

type ClientMessageSender struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewClientMessageSender

func NewClientMessageSender(conn net.Conn) *ClientMessageSender

func (*ClientMessageSender) Close

func (cms *ClientMessageSender) Close()

func (*ClientMessageSender) ProcessControlMessage

func (cms *ClientMessageSender) ProcessControlMessage(messageID uint16, messageType byte)

func (*ClientMessageSender) Publish

func (cms *ClientMessageSender) Publish(topic string, qos byte, retained bool, payload []byte)

func (*ClientMessageSender) SendPacket

func (cms *ClientMessageSender) SendPacket(packet packets.ControlPacket)