qos2

Documentation

Index

• type Option
  • func WithPublishWriter(writer broker.PublishWriter) Option
  • func WithSession(session Session) Option
  • func WithSubOption(option *proto.SubOption) Option
• type QoS2
  • func NewQos2(topic string, options ...Option) *QoS2
  • func (q *QoS2) Close() error
  • func (q *QoS2) HandelPublishComp(pubcomp *packets.Pubcomp)
  • func (q *QoS2) HandlePublishRec(pubrec *packets.Pubrec)
  • func (q *QoS2) Publish(publish *packet.PublishMessage) error
  • func (q *QoS2) Start(ctx context.Context)
• type QoS2Task
• type Queue
  • func NewQoS2Queue(writer broker.PublishWriter) *Queue
  • func (q *Queue) Close() error
  • func (q *Queue) HandlePublishComp(pubcomp *packets.Pubcomp)
  • func (q *Queue) HandlePublishRec(pubrec *packets.Pubrec) bool
  • func (q *Queue) WritePacket(message *packet.PublishMessage)
• type Session

Types

type Option

type Option func(q *QoS2)

func WithPublishWriter

func WithPublishWriter(writer broker.PublishWriter) Option

func WithSession

func WithSession(session Session) Option

func WithSubOption

func WithSubOption(option *proto.SubOption) Option

type QoS2

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

func NewQos2

func NewQos2(topic string, options ...Option) *QoS2

func (*QoS2) Close

func (q *QoS2) Close() error

func (*QoS2) HandelPublishComp

func (q *QoS2) HandelPublishComp(pubcomp *packets.Pubcomp)

func (*QoS2) HandlePublishRec

func (q *QoS2) HandlePublishRec(pubrec *packets.Pubrec)

func (*QoS2) Publish

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

func (*QoS2) Start

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

type QoS2Task

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

type Queue

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

func NewQoS2Queue

func NewQoS2Queue(writer broker.PublishWriter) *Queue

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) HandlePublishComp

func (q *Queue) HandlePublishComp(pubcomp *packets.Pubcomp)

func (*Queue) HandlePublishRec

func (q *Queue) HandlePublishRec(pubrec *packets.Pubrec) bool

func (*Queue) WritePacket

func (q *Queue) WritePacket(message *packet.PublishMessage)

type Session

type Session interface {
	broker.SessionTopicUnFinishedMessage
	broker.SessionTopicLatestPushedMessage
}