itest

Documentation

Overview

Package itest provides tests which integrate MQTT client and server.

Index

• type Adapter
  • func (a *Adapter) Connect(srv *server.Server, c server.Client, p *packet.Connect) (server.ClientAdapter, error)
  • func (a *Adapter) Disconnect(srv *server.Server, ca server.ClientAdapter, err error)

Types

type Adapter

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

Adapter provides simple MQTT server behavior

func (*Adapter) Connect

func (a *Adapter) Connect(srv *server.Server, c server.Client, p *packet.Connect) (server.ClientAdapter, error)

Connect is called when new client is connected.

func (*Adapter) Disconnect

func (a *Adapter) Disconnect(srv *server.Server, ca server.ClientAdapter, err error)

Disconnect is called when a known client is disconnected some reason.