basictestserver

Documentation

Index

• type Logger
• type TestServer
  • func New(logger Logger) *TestServer
  • func (t *TestServer) ClientConn() net.Conn
  • func (t *TestServer) ReceivedPubacks() []packets.Puback
  • func (t *TestServer) ReceivedPubrecs() []packets.Pubrec
  • func (t *TestServer) Run()
  • func (t *TestServer) SendPacket(p packets.Packet) error
  • func (t *TestServer) SetResponse(pt byte, p packets.Packet)
  • func (t *TestServer) Stop()

Types

type Logger

type Logger interface {
	Println(v ...interface{})
	Printf(format string, v ...interface{})
}

Logger mirrors paho.Logger

type TestServer

type TestServer struct {
	ServerConn net.Conn
	// contains filtered or unexported fields
}

func New

func New(logger Logger) *TestServer

func (*TestServer) ClientConn

func (t *TestServer) ClientConn() net.Conn

func (*TestServer) ReceivedPubacks

func (t *TestServer) ReceivedPubacks() []packets.Puback

func (*TestServer) ReceivedPubrecs

func (t *TestServer) ReceivedPubrecs() []packets.Pubrec

func (*TestServer) Run

func (t *TestServer) Run()

func (*TestServer) SendPacket

func (t *TestServer) SendPacket(p packets.Packet) error

func (*TestServer) SetResponse

func (t *TestServer) SetResponse(pt byte, p packets.Packet)

func (*TestServer) Stop

func (t *TestServer) Stop()