mqtt

Dec 29, 2020

Changes in this version

+ type MessageMarshaller func(v interface{}) ([]byte, error)

+ type MessageUnmarshaller func(data []byte, v interface{}) error

Mar 6, 2020

Changes in this version

+ var TlsSchemes = []string

type ClientCreator

+ func ClientCreatorWithCertLoader(certCreator X509KeyPairCreator, certLoader X509KeyLoader) ClientCreator

type MQTTClientOptions

+ AutoReconnect bool

+ CertFile string

+ CertPEMBlock string

+ ConnectTimeout int

+ KeyFile string

+ KeyPEMBlock string

+ SkipCertVerify bool

+ type X509KeyLoader func(certFile string, keyFile string) (tls.Certificate, error)

+ type X509KeyPairCreator func(certPEMBlock []byte, keyPEMBlock []byte) (tls.Certificate, error)

Jan 23, 2020

Changes in this version

+ const ClientId

+ const ConnectOperation

+ const ConnectionPayload

+ const KeepAlive

+ const Password

+ const PublishOperation

+ const Qos

+ const Retained

+ const SubscribeOperation

+ const Topic

+ const Username

+ type Client struct

+ func NewMQTTClient(options types.MessageBusConfig) (Client, error)

+ func NewMQTTClientWithCreator(options types.MessageBusConfig, marshaler MessageMarshaler, ...) (Client, error)

+ func (mc Client) Connect() error

+ func (mc Client) Disconnect() error

+ func (mc Client) Publish(message types.MessageEnvelope, topic string) error

+ func (mc Client) Subscribe(topics []types.TopicChannel, messageErrors chan error) error

+ type ClientCreator func(config types.MessageBusConfig) (mqtt.Client, error)

+ func DefaultClientCreator() ClientCreator

+ type ConnectionOptions struct

+ BrokerURL string

+ type MQTTClientConfig struct

+ BrokerURL string

+ func CreateMQTTClientConfiguration(messageBusConfig types.MessageBusConfig) (MQTTClientConfig, error)

+ type MQTTClientOptions struct

+ ClientId string

+ ConnectionPayload string

+ KeepAlive int

+ Password string

+ Qos int

+ Retained bool

+ Topic string

+ Username string

+ func CreateMQTTClientOptionsWithDefaults() MQTTClientOptions

+ type MessageMarshaler func(v interface{}) ([]byte, error)

+ type MessageUnmarshaler func(data []byte, v interface{}) error

+ type OperationErr struct

+ func NewOperationErr(operation string, message string) OperationErr

+ func (oe OperationErr) Error() string

+ type TimeoutErr struct

+ func NewTimeoutError(operation string, message string) TimeoutErr

+ func (te TimeoutErr) Error() string