engine

package

v0.0.0-...-394f01a Latest Latest Go to latest Published: Feb 22, 2023 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (e *Engine) Close()

func (e *Engine) Dial() error

func (e *Engine) Release()

func (e *Engine) Start(ctx context.Context) error

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

func NewEngineHelper() *EngineHelper

func (m *EngineHelper) AddClient(tag string, address string, opts ...MqttOption) error

func (e *EngineHelper) AddRouting(fromTags, toTags, topicTags []string)

func (e *EngineHelper) AddTopicFilter(tag string, qos byte, filter ...string) error

func (e *EngineHelper) BuildEngine() (*Engine, error)

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
}

func NewTopicFilterTree() *TopicFilterTree

func (t *TopicFilterTree) AddFilter(topics ...string) *TopicFilterTree

func (t *TopicFilterTree) MathFilter(topic string) (string, error)