mqttclient

package
v0.12.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSharedTopic added in v0.12.0 

func GetSharedTopic(topic string) string

Types

type MqttService 

type MqttService struct {
	Endpoint      string
	User          string
	Password      string
	ClientID      string
	MaxPubWindow  int
	Cleansession  bool
	AutoReconnect bool
	Qos           byte
	TlsConfig     *TlsConfig

	Logger *zap.Logger
	Client mqtt.Client
	// contains filtered or unexported fields
}

func InitMqttService added in v0.12.0 

func InitMqttService(clientID string, qos byte, cleansession bool, yamlKey string) (*MqttService, error)

func (*MqttService) LogMessage 

func (m *MqttService) LogMessage(c mqtt.Client, msg mqtt.Message)

func (*MqttService) OnConnect 

func (m *MqttService) OnConnect(c mqtt.Client)

func (*MqttService) Pub added in v0.10.18 

func (m *MqttService) Pub(topic string, qos byte, retained bool, payload any) error

func (*MqttService) StartHeartbeat added in v0.10.18 

func (m *MqttService) StartHeartbeat(serviceNmae, hbSchedule string)

func (*MqttService) Sub 

func (m *MqttService) Sub(topic string, handle mqtt.MessageHandler) error

type TlsConfig added in v0.10.14 

type TlsConfig struct {
	Ca   string
	Key  string
	Cert string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.