mqttClient

Documentation

Index

• type Client
• type ClientStruct
  • func NewV5(cfg Config) (client *ClientStruct)
  • func (c *ClientStruct) AddRoute(subscribeTopic string, messageHandler MessageHandler)
  • func (c *ClientStruct) GetCtx() context.Context
  • func (c *ClientStruct) Name() string
  • func (c *ClientStruct) Publish(topic string, payload []byte, qos byte, retain bool)
  • func (c *ClientStruct) Run()
  • func (c *ClientStruct) Shutdown()
• type Config
• type Message
  • func (m Message) Payload() []byte
  • func (m Message) Topic() string
• type MessageHandler
• type MqttSectionConfig

Types

type Client

type Client interface {
	Name() string
	GetCtx() context.Context
	Run()
	Shutdown()
	Publish(topic string, payload []byte, qos byte, retain bool)
	AddRoute(subscribeTopic string, messageHandler MessageHandler)
}

type ClientStruct

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

func NewV5

func NewV5(
	cfg Config,
) (client *ClientStruct)

func (*ClientStruct) AddRoute

func (c *ClientStruct) AddRoute(subscribeTopic string, messageHandler MessageHandler)

func (*ClientStruct) GetCtx

func (c *ClientStruct) GetCtx() context.Context

func (*ClientStruct) Name

func (c *ClientStruct) Name() string

func (*ClientStruct) Publish

func (c *ClientStruct) Publish(topic string, payload []byte, qos byte, retain bool)

func (*ClientStruct) Run

func (c *ClientStruct) Run()

func (*ClientStruct) Shutdown

func (c *ClientStruct) Shutdown()

type Config

type Config interface {
	Name() string
	Broker() *url.URL

	User() string
	Password() string
	ClientId() string

	KeepAlive() time.Duration
	ConnectRetryDelay() time.Duration
	ConnectTimeout() time.Duration
	TopicPrefix() string
	ReadOnly() bool
	MaxBacklogSize() int

	AvailabilityClient() MqttSectionConfig
	AvailabilityClientTopic() string

	LogDebug() bool
	LogMessages() bool
}

type Message

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

func (Message) Payload

func (m Message) Payload() []byte

func (Message) Topic

func (m Message) Topic() string

type MessageHandler

type MessageHandler func(Message)

type MqttSectionConfig

type MqttSectionConfig interface {
	Enabled() bool
	Interval() time.Duration
	Retain() bool
	Qos() byte
}