pubDev

Documentation

Index

• func Check(conf conf.DevLinkConf) error
• type MqttClient
  • func (d *MqttClient) CheckIsOnline(ctx context.Context, clientID string) (bool, error)
  • func (d *MqttClient) Publish(ctx context.Context, topic string, payload []byte) error
• type PubDev
  • func NewPubDev(conf conf.DevLinkConf) (PubDev, error)

Functions

func Check

func Check(conf conf.DevLinkConf) error

Types

type MqttClient

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

func (*MqttClient) CheckIsOnline

func (d *MqttClient) CheckIsOnline(ctx context.Context, clientID string) (bool, error)

func (*MqttClient) Publish

func (d *MqttClient) Publish(ctx context.Context, topic string, payload []byte) error

type PubDev

type PubDev interface {
	Publish(ctx context.Context, topic string, payload []byte) error
	CheckIsOnline(ctx context.Context, clientID string) (bool, error)
}

PubDev 发送消息到设备

func NewPubDev

func NewPubDev(conf conf.DevLinkConf) (PubDev, error)