Versions in this module Expand all Collapse all v2 v2.0.0 Jun 18, 2023 Changes in this version + type Config struct + Broker string + Insecure bool + Password string + Publish string + QoS int + Subscribe string + TransmitPreDelay string + Type string + Username string + type Endpoint struct + Client paho.Client + Config Config + GatewayCfg *gwTY.Config + func New(logger *zap.Logger, gwCfg *gwTY.Config, protocol cmap.CustomMap, ...) (*Endpoint, error) + func (ep *Endpoint) Close() error + func (ep *Endpoint) Subscribe(topicsStr string) error + func (ep *Endpoint) Write(rawMsg *msgTY.RawMessage) error
Go to main page