acl

type Authenticator interface {
	CheckPub(clientInfo *ClientInfo, topic string) bool
	CheckSub(clientInfo *ClientInfo, topic string) bool
	ProcessUnSub(clientInfo *ClientInfo, topic string)
	SetAuthFunc(f GetAuthFunc)
}

type ClientInfo struct {
	GmToken        string // mqtt password
	GmUserName     string
	GmUserId       string
	GmSdkInfo      map[string]string //from mqtt userName
	ConnectMessage *message.ConnectMessage
	SubTopicLimit  int
}

type GetAuthFunc func(clientInfo *ClientInfo, topic string) interface{}

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