mqttproxy

type Auth struct {
	UserName   string `yaml:"userName" jsonschema:"required"`
	PassBase64 string `yaml:"passBase64" jsonschema:"required"`
}

type Broker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Certificate struct {
	Name string `yaml:"name" jsonschema:"required"`
	Cert string `yaml:"cert" jsonschema:"required"`
	Key  string `yaml:"key" jsonschema:"required"`
}

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type HTTPJsonData struct {
	Topic       string `json:"topic"`
	QoS         int    `json:"qos"`
	Payload     string `json:"payload"`
	Base64      bool   `json:"base64"`
	Distributed bool   `json:"distributed"`
}

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

type KafkaSpec struct {
	Backend []string `yaml:"backend" jsonschema:"required,uniqueItems=true"`
}

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

type Message struct {
	Topic      string `yaml:"topic"`
	B64Payload string `yaml:"b64Payload"`
	QoS        int    `yaml:"qos"`
}

type Policy struct {
	Name       string         `yaml:"name" jsonschema:"required"`
	TopicIndex int            `yaml:"topicIndex" jsonschema:"required"`
	Route      []TopicRe      `yaml:"route" jsonschema:"required"`
	Headers    map[int]string `yaml:"headers" jsonschema:"required"`
}

type PolicyRe struct {
	Name      string `yaml:"name" jsonschema:"required"`
	MatchExpr string `yaml:"matchExpr" jsonschema:"required"`
}

type Session struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type SessionInfo struct {
	// map subscribe topic to qos
	EGName    string         `yaml:"egName"`
	Name      string         `yaml:"name"`
	Topics    map[string]int `yaml:"topics"`
	ClientID  string         `yaml:"clientID"`
	CleanFlag bool           `yaml:"cleanFlag"`
}

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

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

type Spec struct {
	EGName         string        `yaml:"-"`
	Name           string        `yaml:"-"`
	Port           uint16        `yaml:"port" jsonschema:"required"`
	BackendType    string        `yaml:"backendType" jsonschema:"required"`
	Auth           []Auth        `yaml:"auth" jsonschema:"required"`
	TopicMapper    *TopicMapper  `yaml:"topicMapper" jsonschema:"omitempty"`
	Kafka          *KafkaSpec    `yaml:"kafkaBroker" jsonschema:"omitempty"`
	UseTLS         bool          `yaml:"useTLS" jsonschema:"omitempty"`
	Certificate    []Certificate `yaml:"certificate" jsonschema:"omitempty"`
	TopicCacheSize int           `yaml:"topicCacheSize" jsonschema:"omitempty"`
}

type TopicManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type TopicMapper struct {
	MatchIndex int         `yaml:"matchIndex" jsonschema:"required"`
	Route      []*PolicyRe `yaml:"route" jsonschema:"required"`
	Policies   []*Policy   `yaml:"policies" jsonschema:"required"`
}

type TopicRe struct {
	Topic string   `yaml:"topic" jsonschema:"required"`
	Exprs []string `yaml:"exprs" jsonschema:"required"`
}