server

Documentation

Overview

Package server implements a simple MQTT server.

Index

• type Option
  • func WithAuth(iface auth.Interface) Option
  • func WithIPLimits(max int) Option
  • func WithSessionStore(sess session.Store) Option
  • func WithUserLimits(max int) Option
• type Server
  • func New(ctx context.Context, option ...Option) Server

Types

type Option

type Option func(s *server)

Option for the server

func WithAuth

func WithAuth(iface auth.Interface) Option

WithAuth returns an option that sets the authentication

func WithIPLimits

func WithIPLimits(max int) Option

WithIPLimits returns an option that sets limits on connections per IP

func WithSessionStore

func WithSessionStore(sess session.Store) Option

WithSessionStore returns an option that sets store for sessions

func WithUserLimits

func WithUserLimits(max int) Option

WithUserLimits returns an option that sets limits on connections per User

type Server

type Server interface {
	Sessions() session.Store
	Publish(pkt *packet.PublishPacket)
	Handle(conn mqttnet.Conn)
}

Server interface

func New

func New(ctx context.Context, option ...Option) Server

New returns a new MQTT server