topics

Documentation

Index

• type Topic
  • func NewTopic(topic string) *Topic
  • func (t *Topic) AddSub(c *clients.Client)
  • func (t *Topic) CheckTopicAuth(c *clients.Client)
  • func (t *Topic) GetSubs() []*clients.Client
• type TopicMgr
  • func NewTopicMgr() *TopicMgr
  • func (t *TopicMgr) GetSubs(topic string) []*clients.Client
  • func (t *TopicMgr) Subscribe(topic string, c *clients.Client)
  • func (t *TopicMgr) Unsubscribe(topic string, c *clients.Client)

Types

type Topic

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

TopicsProvider

func NewTopic

func NewTopic(topic string) *Topic

func (*Topic) AddSub

func (t *Topic) AddSub(c *clients.Client)

func (*Topic) CheckTopicAuth

func (t *Topic) CheckTopicAuth(c *clients.Client)

func (*Topic) GetSubs

func (t *Topic) GetSubs() []*clients.Client

type TopicMgr

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

func NewTopicMgr

func NewTopicMgr() *TopicMgr

func (*TopicMgr) GetSubs

func (t *TopicMgr) GetSubs(topic string) []*clients.Client

func (*TopicMgr) Subscribe

func (t *TopicMgr) Subscribe(topic string, c *clients.Client)

func (*TopicMgr) Unsubscribe

func (t *TopicMgr) Unsubscribe(topic string, c *clients.Client)