mqtt

May 3, 2024

Changes in this version

+ const MqttTcp

+ const MqttsTcp

+ const Ws

+ const Wss

+ type Broker struct

+ func NewBrokerBuilder() *Broker

+ func (b *Broker) Build() Option

+ func (b *Broker) WithHost(host string) *Broker

+ func (b *Broker) WithPort(port int) *Broker

+ func (b *Broker) WithProtocol(protocol protocol) *Broker

+ func (b *Broker) WithSkipVerification() *Broker

+ func (b *Broker) WithTlsCertificates(caPemPath, clientCrtPath, clientKeyPath string) *Broker

+ func (b *Broker) WithUsernameAndPassword(username, password string) *Broker

+ type Client struct

+ func CreateClient(ip string, port int, clientId string) *Client

+ func NewClient(options ...Option) *Client

+ func (c *Client) Connect() error

+ func (c *Client) Disconnect() error

+ func (c *Client) LoopForever()

+ func (c *Client) Publish(message *Message)

+ func (c *Client) Subscribe(topic string, fn func(message Message))

+ type Message struct

+ Topic string

+ Value any

+ func (m Message) FromJson() string

+ func (m Message) ToRawString() string

+ func (m Message) ToStruct(target any)

+ type Option func(options *pahoMqtt.ClientOptions)

+ func WithBroker(ip string, port int) Option

+ func WithClientId(clientId string) Option

+ func WithOrderMatters(orderMatters bool) Option

+ type StatusPublishMessage struct

+ Status string

+ Timestamp time.Time

+ Type StatusType

+ type StatusType string

+ const Error

+ const Info

+ const Warn