listener

Documentation

Index

• Variables
• type Broker
• type Config
• type Endpoint
  • func New(broker Broker, config Config) Endpoint

Variables

var (
	ErrSessionDisconnected = errors.New("session disconnected")
	ErrConnectNotDone      = errors.New("CONNECT not done")
)

var CONNECT_DEADLINE int64 = 15

var (
	ErrSessionNotFound = errors.New("session not found on this endpoint")
)

Types

type Broker

type Broker interface {
	Connect(transport.Metadata, *packet.Connect) (string, *packet.ConnAck, error)
	Disconnect(string, *packet.Disconnect) error
	Publish(string, *packet.Publish) (*packet.PubAck, error)
	Subscribe(string, *packet.Subscribe) (*packet.SubAck, error)
	Unsubscribe(string, *packet.Unsubscribe) (*packet.UnsubAck, error)
	RemoveSession(string) error
}

type Config

type Config struct {
	TCPPort int
	TLS     *tls.Config
	TLSPort int
	WSSPort int
	WSPort  int
}

type Endpoint

type Endpoint interface {
	Publish(id string, publish *packet.Publish) error
	CloseSession(string) error
	Close() error
}

func New

func New(broker Broker, config Config) Endpoint