mqtt

Documentation

Index

• type Client
  • func NewClient(opts ClientOptions) (Client, error)
• type ClientOptions
• type ClientOptions_TLSConfig
  • func GetTLSConfigFromFile(certFile, keyFile, rootCaFile string) *ClientOptions_TLSConfig
• type Message

Types

type Client

type Client interface {
	Publish(topic string, payload interface{}) error
	Subscribe(topic string) (rxgo.Observable, error)
	SubscribeReturnMessage(topic string) (rxgo.Observable, error)
	Unsubscribe(topic string) error
	IsConnected() bool
	Close()
}

func NewClient

func NewClient(opts ClientOptions) (Client, error)

type ClientOptions

type ClientOptions struct {
	Server    string // tcp://host:port
	TLSConfig *ClientOptions_TLSConfig
	ClientID  string
}

type ClientOptions_TLSConfig

type ClientOptions_TLSConfig struct {
	Cert   []byte
	Key    []byte
	RootCa []byte
}

func GetTLSConfigFromFile

func GetTLSConfigFromFile(certFile, keyFile, rootCaFile string) *ClientOptions_TLSConfig

type Message

type Message struct {
	Topic   string
	Payload []byte
}