listener

Documentation

Index

• Variables
• func New(id string, logger *zap.Logger, mesh cluster.Mesh, config Config) *endpoint
• func Serve(local Endpoint, port int) net.Listener
• type Broker
• type Config
• type Endpoint

Variables

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

var CONNECT_DEADLINE int32 = 15

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

Functions

func New

func New(id string, logger *zap.Logger, mesh cluster.Mesh, config Config) *endpoint

func Serve

func Serve(local Endpoint, port int) net.Listener

Types

type Broker

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

type Config

type Config struct {
	TCPPort       int
	TLSCommonName string
	TLSPort       int
	WSSPort       int
	WSPort        int
}

type Endpoint

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