service

Documentation

Index

• type IMqttMsgRecord
  • func MqttMsgRecord() IMqttMsgRecord
• type IMqttStatus
  • func MqttStatus() IMqttStatus
• type IMqttTopic
  • func MqttTopic() IMqttTopic
• type IMqttTopicRecord
  • func MqttTopicRecord() IMqttTopicRecord

Types

type IMqttMsgRecord

type IMqttMsgRecord interface {
	List(ctx context.Context, req *mqtt.MqttMsgRecordSearchReq) (total, page int, list []*entity.MqttMsgRecord, err error)
	Get(ctx context.Context, id int) (info *entity.MqttMsgRecord, err error)
	Add(ctx context.Context, req *mqtt.MqttMsgRecordAddReq) (err error)
	Edit(ctx context.Context, req *mqtt.MqttMsgRecordEditReq) error
	DeleteByIds(ctx context.Context, ids []int) (err error)
}

type mqttMsgRecord struct { } var MqttMsgRecord = new(mqttMsgRecord)

func MqttMsgRecord

func MqttMsgRecord() IMqttMsgRecord

type IMqttStatus

type IMqttStatus interface {
	List(ctx context.Context, req *mqtt.MqttStatusSearchReq) (total, page int, list []*entity.MqttStatus, err error)
	Get(ctx context.Context, id int) (info *entity.MqttStatus, err error)
	Add(ctx context.Context, req *mqtt.MqttStatusAddReq) (err error)
	Update(ctx context.Context, UserName, ClientId, Name string, Status int) error
	Edit(ctx context.Context, req *mqtt.MqttStatusEditReq) error
	DeleteByIds(ctx context.Context, ids []int) (err error)
	ChangeStatus(ctx context.Context, req *mqtt.MqttStatusStatusReq) error
}

type mqttStatus struct { } var MqttStatus = new(mqttStatus)

func MqttStatus

func MqttStatus() IMqttStatus

type IMqttTopic

type IMqttTopic interface {
	List(ctx context.Context, req *mqtt.MqttTopicSearchReq) (total, page int, list []*entity.MqttTopic, err error)
	Get(ctx context.Context, id int) (info *entity.MqttTopic, err error)
	Add(ctx context.Context, req *mqtt.MqttTopicAddReq) (err error)
	Edit(ctx context.Context, req *mqtt.MqttTopicEditReq) error
	DeleteByIds(ctx context.Context, ids []int) (err error)
	DeleteByClientId(ctx context.Context, clientId string) (err error)
	DeleteByClientIdAndTopic(ctx context.Context, clientId, topic string) (err error)
}

type mqttTopic struct { } var MqttTopic = new(mqttTopic)

func MqttTopic

func MqttTopic() IMqttTopic

type IMqttTopicRecord

type IMqttTopicRecord interface {
	List(ctx context.Context, req *mqtt.MqttTopicRecordSearchReq) (total, page int, list []*entity.MqttTopicRecord, err error)
	Get(ctx context.Context, id int) (info *entity.MqttTopicRecord, err error)
	Add(ctx context.Context, req *mqtt.MqttTopicRecordAddReq) (err error)
	Edit(ctx context.Context, req *mqtt.MqttTopicRecordEditReq) error
	DeleteByIds(ctx context.Context, ids []int) (err error)
}

type mqttTopicRecord struct { } var MqttTopicRecord = new(mqttTopicRecord)

func MqttTopicRecord

func MqttTopicRecord() IMqttTopicRecord