topic

Documentation

Index

• func NewMemManager() *memManager
• type Manager
• type Subscription
  • func NewSubscription(clientID string, topic string, qos byte, shared bool, group string) Subscription
• type Topic

Functions

func NewMemManager

func NewMemManager() *memManager

NewMemManager returns an new instance of the memManager, which is implements the Manager interface. memManager is a hidden struct that stores the topic subscriptions and retained messages in memory. The content is not persistend so when the server goes, everything will be gone. Use with care.

Types

type Manager

type Manager interface {
	Subscribe(sub Subscription) (byte, error)
	Unsubscribe(sub Subscription) error
	Subscribers(topic []byte, qos byte, subs *[]interface{}, qoss *[]byte) error
	Retain(msg *packets.PublishPacket) error
	Retained(topic []byte, msgs *[]*packets.PublishPacket) error
	Close() error
}

Manager

type Subscription

type Subscription struct {
	ClientID string
	Topic    string
	QoS      byte
	Shared   bool
	Group    string
}

func NewSubscription

func NewSubscription(clientID string, topic string, qos byte, shared bool, group string) Subscription

type Topic

type Topic struct {
	Subs map[string]Subscription
	Mu   sync.RWMutex
}