engine

type Engine struct {
	MessageChan chan *Message // 处理MQTT消息的队列
	// contains filtered or unexported fields
}

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

type Message struct {
	FromTag string
	Topic   string
	Payload []byte
}

type MqttAddress struct {
	Address  string
	UserName string
	Password string
}

type MqttOption func(*MqttAddress)

type Node struct {
	Value string
	Child map[string]*Node
}

type Router struct {
	FromTags  []string
	ToTags    []string
	TopicTags []string
}

type SubTopic struct {
	Topic string
	Qos   byte
}

type TopicFilter struct {
	Tag    string
	Qos    byte
	Filter []string
}

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