qos1

Documentation

Index

• type Option
  • func WithPublishWriter(writer broker.PublishWriter) Option
  • func WithSession(session Session) Option
  • func WithSubOption(option *proto.SubOption) Option
• type PublishQueue
  • func NewPublishQueue(writer broker.PublishWriter) *PublishQueue
  • func (q *PublishQueue) HandlePublishAck(publishAck *packets.Puback) bool
  • func (q *PublishQueue) WritePacket(packet *packet.PublishMessage)
• type QoS1
  • func NewQos1(topic string, options ...Option) *QoS1
  • func (q *QoS1) Close() error
  • func (q *QoS1) HandlePublishAck(pubAck *packets.Puback)
  • func (q *QoS1) Publish(publish *packet.PublishMessage) error
  • func (q *QoS1) Start(ctx context.Context)
• type Session
• type StoreEvent

Types

type Option

type Option func(q *QoS1)

func WithPublishWriter

func WithPublishWriter(writer broker.PublishWriter) Option

func WithSession

func WithSession(session Session) Option

func WithSubOption

func WithSubOption(option *proto.SubOption) Option

type PublishQueue

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

func NewPublishQueue

func NewPublishQueue(writer broker.PublishWriter) *PublishQueue

func (*PublishQueue) HandlePublishAck

func (q *PublishQueue) HandlePublishAck(publishAck *packets.Puback) bool

HandlePublishAck handles the publishing ack packet. match the packet id of the ack packet with the packet id in the queue. packet id means the identifier of the packet. If the packet id of the ack packet is in the queue, it will be removed from the queue. and the retry task will be deleted. return true if the packet id is in the queue, otherwise return false.

func (*PublishQueue) WritePacket

func (q *PublishQueue) WritePacket(packet *packet.PublishMessage)

WritePacket writes the publishing packet to the publishing queue.

type QoS1

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

func NewQos1

func NewQos1(topic string, options ...Option) *QoS1

func (*QoS1) Close

func (q *QoS1) Close() error

func (*QoS1) HandlePublishAck

func (q *QoS1) HandlePublishAck(pubAck *packets.Puback)

func (*QoS1) Publish

func (q *QoS1) Publish(publish *packet.PublishMessage) error

func (*QoS1) Start

func (q *QoS1) Start(ctx context.Context)

type Session

type Session interface {
	broker.SessionTopicLatestPushedMessage
	broker.SessionTopicUnFinishedMessage
}

type StoreEvent

type StoreEvent interface {
	CreateListenMessageStoreEvent(topic string, handler func(...interface{}))
	DeleteListenMessageStoreEvent(topic string, handler func(i ...interface{}))
}