mqtt_tunnel

Documentation

Index

• Constants
• type ArkMqttMsg
• type MqttConfig
• type MqttTunnel
  • func (m *MqttTunnel) FetchHealthData(_ context.Context, baseID string) error
  • func (m *MqttTunnel) InstallBiz(_ context.Context, deviceID string, bizModel *ark.BizModel) error
  • func (m *MqttTunnel) Name() string
  • func (m *MqttTunnel) OnBaseStart(ctx context.Context, baseID string)
  • func (m *MqttTunnel) OnBaseStop(ctx context.Context, baseID string)
  • func (m *MqttTunnel) QueryAllBizData(_ context.Context, baseID string) error
  • func (m *MqttTunnel) Register(ctx context.Context, clientID string, ...) (err error)
  • func (m *MqttTunnel) UninstallBiz(_ context.Context, deviceID string, bizModel *ark.BizModel) error

Constants

const (
	DefaultMQTTBroker       = "test-broker"
	DefaultMQTTUsername     = "test-username"
	DefaultMQTTPassword     = "public"
	DefaultMQTTClientPrefix = "koupleless"
	DefaultMQTTPort         = 1883
)

Types

type ArkMqttMsg

type ArkMqttMsg[T any] struct {
	PublishTimestamp int64 `json:"publishTimestamp"`
	Data             T     `json:"data"`
}

ArkMqttMsg is the response of mqtt message payload.

type MqttConfig

type MqttConfig struct {
	MqttBroker        string
	MqttPort          int
	MqttUsername      string
	MqttPassword      string
	MqttClientPrefix  string
	MqttCAPath        string
	MqttClientCrtPath string
	MqttClientKeyPath string
}

type MqttTunnel

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

func (*MqttTunnel) FetchHealthData

func (m *MqttTunnel) FetchHealthData(_ context.Context, baseID string) error

func (*MqttTunnel) InstallBiz

func (m *MqttTunnel) InstallBiz(_ context.Context, deviceID string, bizModel *ark.BizModel) error

func (*MqttTunnel) Name

func (m *MqttTunnel) Name() string

func (*MqttTunnel) OnBaseStart

func (m *MqttTunnel) OnBaseStart(ctx context.Context, baseID string)

func (*MqttTunnel) OnBaseStop

func (m *MqttTunnel) OnBaseStop(ctx context.Context, baseID string)

func (*MqttTunnel) QueryAllBizData

func (m *MqttTunnel) QueryAllBizData(_ context.Context, baseID string) error

func (*MqttTunnel) Register

func (m *MqttTunnel) Register(ctx context.Context, clientID string, baseDiscoveredCallback tunnel.BaseDiscoveredCallback, healthDataArrivedCallback tunnel.HealthDataArrivedCallback, queryAllBizDataArrivedCallback tunnel.QueryAllBizDataArrivedCallback) (err error)

func (*MqttTunnel) UninstallBiz

func (m *MqttTunnel) UninstallBiz(_ context.Context, deviceID string, bizModel *ark.BizModel) error