mqtt

Documentation

Index

• type Client
  • func NewPahoClient(options ClientOptions) Client
• type ClientOptions
• type Message

Types

type Client

type Client interface {
	Start() error
	PublishMessage(topic string, message []byte)
	StartSubscription(topic string, callback func(message Message)) error
}

func NewPahoClient

func NewPahoClient(options ClientOptions) Client

type ClientOptions

type ClientOptions struct {
	Broker, ClientId   string
	Username, Password string
	OnConnectionLost   func(error)
}

type Message

type Message interface {
	Topic() string
	Payload() []byte
}