mqtt

Documentation

Index

• type Broker
  • func NewBroker(bindAddress string, wsPort int, wsPath string, workerCount int, ...) (*Broker, error)
  • func (b *Broker) GetConfig() *broker.Config
  • func (b *Broker) HasSubscribers(topic string) bool
  • func (b *Broker) Send(topic string, payload []byte)
  • func (b *Broker) Start()
• type OnSubscribeHandler
• type OnUnsubscribeHandler

Types

type Broker

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

Broker is a simple mqtt publisher abstraction.

func NewBroker

func NewBroker(bindAddress string, wsPort int, wsPath string, workerCount int, onSubscribe OnSubscribeHandler, onUnsubscribe OnUnsubscribeHandler) (*Broker, error)

NewBroker creates a new broker.

func (*Broker) GetConfig

func (b *Broker) GetConfig() *broker.Config

GetConfig returns the broker config instance.

func (*Broker) HasSubscribers

func (b *Broker) HasSubscribers(topic string) bool

func (*Broker) Send

func (b *Broker) Send(topic string, payload []byte)

Send publishes a message.

func (*Broker) Start

func (b *Broker) Start()

Start the broker.

type OnSubscribeHandler

type OnSubscribeHandler func(topic []byte)

type OnUnsubscribeHandler

type OnUnsubscribeHandler func(topic []byte)