baize/framework/core/mqtt_api/options.go

package mqtt_api

type Options struct {
	// topic前缀
	topicPrefix string

	// 日志跳过的打印路径
	logSkipPaths []string

	// mqtt配置
	mqttOptions *MqttClientOptions
}

func (options Options) GetTopicPrefix() string {
	return options.topicPrefix
}

type Option func(options *Options)

// WithTopicPrefix 设置topic前缀
func WithTopicPrefix(topicPrefix string) Option {
	return func(options *Options) {
		options.topicPrefix = topicPrefix
	}
}

// WithLogSkipPaths 设置日志跳过的打印路径
func WithLogSkipPaths(logSkipPaths ...string) Option {
	return func(options *Options) {
		options.logSkipPaths = logSkipPaths
	}
}

// WithMqttOptions 设置mqtt配置
func WithMqttOptions(mqttOptions *MqttClientOptions) Option {
	return func(options *Options) {
		options.mqttOptions = mqttOptions
	}
}