mqtt

Documentation

Overview

Package mqtt contains the domain concept definitions needed to support Magistrala MQTT adapter functionality.

Index

• type Subscriber
  • func NewBroker(svc lora.Service, client mqtt.Client, t time.Duration, log *slog.Logger) Subscriber

Types

type Subscriber

type Subscriber interface {
	// Subscribes to given subject and receives events.
	Subscribe(string) error
}

Subscriber represents the MQTT broker.

func NewBroker

func NewBroker(svc lora.Service, client mqtt.Client, t time.Duration, log *slog.Logger) Subscriber

NewBroker returns new MQTT broker instance.