sys

Documentation

Overview

系统主题

Index

• Variables
• func NewMemProvider() *memTopics
• type TopicProvider

Variables

var UnSupportTopic = errors.New("the system topic is not supported")

Functions

func NewMemProvider

func NewMemProvider() *memTopics

Types

type TopicProvider

type TopicProvider interface {
	Subscribe(subs topic.Sub, subscriber interface{}) (byte, error)
	Unsubscribe(topic []byte, subscriber interface{}) error
	Subscribers(topic []byte, qos byte, subs *[]interface{}, qoss *[]topic.Sub) error
	Close() error
}

TopicProvider 系统主题