server

Documentation

Index

• Constants
• type MQTTClient
• type MessageEvent
• type QUICBroker
  • func NewQUICBroker(addr string, insecure bool) (*QUICBroker, error)
  • func (b *QUICBroker) Start() error
  • func (b *QUICBroker) Stop()

Constants

const (
	CONNECT    = 1
	CONNACK    = 2
	PUBLISH    = 3
	PUBACK     = 4
	SUBSCRIBE  = 8
	SUBACK     = 9
	DISCONNECT = 14
)

Constants for MQTT packet types

Types

type MQTTClient

type MQTTClient struct {
	ID      string
	Session quic.Connection
	Stream  quic.Stream
}

MQTTClient represents a connected MQTT client

type MessageEvent

type MessageEvent struct {
	Topic   string
	Payload []byte
	QoS     byte
}

MessageEvent represents a published message

type QUICBroker

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

QUICBroker is a simple MQTT broker using QUIC transport

func NewQUICBroker

func NewQUICBroker(addr string, insecure bool) (*QUICBroker, error)

NewQUICBroker creates a new MQTT broker using QUIC transport

func (*QUICBroker) Start

func (b *QUICBroker) Start() error

Start starts the MQTT broker

func (*QUICBroker) Stop

func (b *QUICBroker) Stop()

Stop gracefully stops the broker