starter

README

yomo-rcvr-mqtt-starter

Documentation

Index

• type Broker
  • func NewBroker(conf *BrokerConf) Broker
  • func (b Broker) Run(handle func(topic string, payload []byte))
• type BrokerConf

Types

type Broker

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

func NewBroker

func NewBroker(conf *BrokerConf) Broker

func (Broker) Run

func (b Broker) Run(handle func(topic string, payload []byte))

type BrokerConf

type BrokerConf struct {
	Addr           string
	Topics         []string
	Username       string
	Password       string
	ConnectTimeout int
	WaitTimeout    int
}

var DefaultConfig *BrokerConf = &BrokerConf{
	Addr:           "tcp://localhost:1883",
	Topics:         []string{"modbus", "test"},
	Username:       "admin",
	Password:       "public",
	ConnectTimeout: 60,
	WaitTimeout:    60,
}