mqtt

Documentation

Index

• Constants
• type Config
• type MQTT
  • func (p *MQTT) Init(logger *zap.Logger, tracer trace.Tracer, cfg interface{})
  • func (p *MQTT) Name() string
  • func (p *MQTT) Run()
  • func (p *MQTT) SetChannel(c <-chan model.ChanneledEvent)

Constants

const (
	PingTimeout       = 1 * time.Second
	ReconnectInterval = 10 * time.Second
	DisconnectTimeout = 250
)

Types

type Config

type Config struct {
	URL       string        `koanf:"url"`
	ClientID  string        `koanf:"clientid"`
	Username  string        `koanf:"username"`
	Password  string        `koanf:"password"`
	KeepAlive time.Duration `koanf:"keepalive"`
}

type MQTT

type MQTT struct {
	// contains filtered or unexported fields
}

MQTT is a plugin for the saf app. this plugin consumes event and publish them over mqtt.

func (*MQTT) Init

func (p *MQTT) Init(logger *zap.Logger, tracer trace.Tracer, cfg interface{})

func (*MQTT) Name

func (p *MQTT) Name() string

func (*MQTT) Run

func (p *MQTT) Run()

func (*MQTT) SetChannel

func (p *MQTT) SetChannel(c <-chan model.ChanneledEvent)