gemq

type AuthAPI struct {
	AuthFunc MqttFunc
	AclFunc  MqttFunc
}

type AuthRequest struct {
	Username   string `json:"username,omitempty"`
	Password   string `json:"password,omitempty"`
	ClientId   string `json:"clientid,omitempty"`
	PeerHost   string `json:"peerhost,omitempty"`
	ProtoName  string `json:"proto_name,omitempty"`
	MountPoint string `json:"mountpoint,omitempty"`
	Action     string `json:"action,omitempty"`
	Topic      string `json:"topic,omitempty"`
	Qos        string `json:"qos,omitempty"`
	Retain     string `json:"retain,omitempty"`
}

type AuthResult struct {
	Result      string `json:"result"`
	IsSuperuser bool   `json:"is_superuser,omitempty"`
}

type DialOptions struct {
	AppName string
	//tcp://host:port
	Broker   string
	Username string
	Password string
	// on connect handler
	OnConnectHandler mqtt.OnConnectHandler
}

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

type MqttFunc func(c iris.Context, d *AuthRequest) (result *AuthResult, err error)

type MqttTopicOption struct {
	Timeout time.Duration `json:"timeout,omitempty"`
	Retain  bool          `json:"retain,omitempty"`
	Qos     byte          `json:"qos,omitempty"`
}