link

Documentation

Index

• type Link
• type MqttInfo
• type SendMessage

Types

type Link

type Link interface {
	Send(ctx *comctx.Context, data *SendMessage) error
	SyncSend(ctx *comctx.Context, data []byte) error
	GetLinkID() string
	GetFailMsg() chan []byte
	SetFailMsg(chan []byte)
}

type MqttInfo

type MqttInfo struct {
	Topic string
	Qos   mqtt.QOS
}

type SendMessage

type SendMessage struct {
	Message     *v1.Message
	SendMessage []byte
	MqttInfo    MqttInfo
	Times       int
}