topic

Documentation

Index

• type Option
  • func WithWindowSize(size int) Option
  • func WithWriter(writer broker.PublishWriter) Option
• type QoS1Handle
• type QoS2Handle
• type Topic
• type Topics
  • func NewTopicWithSession(ctx context.Context, session broker.SessionTopic, op ...Option) *Topics
  • func NewTopics(ctx context.Context, ops ...Option) *Topics
  • func (t *Topics) Close() error
  • func (t *Topics) CreateTopic(topicName string, option *proto.SubOption)
  • func (t *Topics) DeleteTopic(topicName string)
  • func (t *Topics) HandelPublishComp(topic string, pubcomp *packets.Pubcomp)
  • func (t *Topics) HandlePublishAck(topic string, puback *packets.Puback)
  • func (t *Topics) HandlePublishRec(topic string, pubrec *packets.Pubrec)
  • func (t *Topics) Publish(topic string, message *packet.PublishMessage) error

Types

type Option

type Option func(topics *Topics)

func WithWindowSize

func WithWindowSize(size int) Option

func WithWriter

func WithWriter(writer broker.PublishWriter) Option

type QoS1Handle

type QoS1Handle interface {
	HandlePublishAck(pubAck *packets.Puback)
}

type QoS2Handle

type QoS2Handle interface {
	HandlePublishRec(pubRec *packets.Pubrec)
	HandelPublishComp(pubComp *packets.Pubcomp)
}

type Topic

type Topic interface {
	Start(ctx context.Context)
	Close() error
	Publish(publish *packet.PublishMessage) error
}

type Topics

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

func NewTopicWithSession

func NewTopicWithSession(ctx context.Context, session broker.SessionTopic, op ...Option) *Topics

func NewTopics

func NewTopics(ctx context.Context, ops ...Option) *Topics

func (*Topics) Close

func (t *Topics) Close() error

func (*Topics) CreateTopic

func (t *Topics) CreateTopic(topicName string, option *proto.SubOption)

func (*Topics) DeleteTopic

func (t *Topics) DeleteTopic(topicName string)

func (*Topics) HandelPublishComp

func (t *Topics) HandelPublishComp(topic string, pubcomp *packets.Pubcomp)

func (*Topics) HandlePublishAck

func (t *Topics) HandlePublishAck(topic string, puback *packets.Puback)

func (*Topics) HandlePublishRec

func (t *Topics) HandlePublishRec(topic string, pubrec *packets.Pubrec)

func (*Topics) Publish

func (t *Topics) Publish(topic string, message *packet.PublishMessage) error