rule

type ClientDetail struct {
	Name         string
	Subscription []mqtt.QOSTopic
	Info         ClientInfo
}

type ClientInfo struct {
	Name  string                 `yaml:"name" json:"name" validate:"nonzero"`
	Kind  kind                   `yaml:"kind" json:"kind" validate:"nonzero"`
	Value map[string]interface{} `yaml:",inline" json:",inline"`
}

type ClientRef struct {
	Client string `yaml:"client" json:"client" default:"baetyl-broker"`
	QOS    int    `yaml:"qos" json:"qos" default:"0"`
	Topic  string `yaml:"topic" json:"topic" default:""`
	Path   string `yaml:"path" json:"path" default:""`
	Method string `yaml:"method" json:"method" default:"POST"`
}

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

type Config struct {
	Clients []ClientInfo `yaml:"clients" json:"clients"`
	Rules   []RuleInfo   `yaml:"rules" json:"rules"`
}

type FunctionInfo struct {
	Name string `yaml:"name" json:"name" validate:"nonzero"`
}

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

type HandlerFunc func(ctx *routing.Context) (interface{}, error)

type MqttCMFTInfo struct {
	Address      string `yaml:"address" json:"address" validate:"nonzero"`
	ProductId    string `yaml:"productId" json:"productId" validate:"nonzero"`
	DeviceId     string `yaml:"deviceId" json:"deviceId" validate:"nonzero"`
	DeviceSecret string `yaml:"deviceSecret" json:"deviceSecret" validate:"nonzero"`
}

type RuleInfo struct {
	Name     string        `yaml:"name" json:"name" validate:"nonzero"`
	Source   *ClientRef    `yaml:"source" json:"source" validate:"nonzero"`
	Target   *ClientRef    `yaml:"target" json:"target"`
	Function *FunctionInfo `yaml:"function" json:"function"`
}

type ServerConfig struct {
	Port int32 `yaml:"port" json:"port"`
	utils.Certificate
}

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