listener

Documentation

Index

• Variables
• func New(id string, logger *zap.Logger, mesh cluster.Mesh, config Config) *endpoint
• func SigningKey() string
• type Broker
• type Config
• type DeadlineSetter
• type Endpoint
• type QueuesStore
• type Token
  • func DecodeSessionToken(signKey string, signedToken string) (Token, error)

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 SigningKey

func SigningKey() string

Types

type Broker

type Broker interface {
	Connect(context.Context, transport.Metadata, *packet.Connect) (string, 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 DeadlineSetter

type DeadlineSetter interface {
	SetDeadline(time.Time) error
}

type Endpoint

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

type QueuesStore

type QueuesStore interface {
	StreamMessages(ctx context.Context, id string, f func(uint64, *packet.Publish) error) error
	AckMessage(ctx context.Context, id string, ackOffset uint64) error
}

type Token

type Token struct {
	SessionID     string `json:"session_id"`
	SessionTenant string `json:"session_tenant"`
	jwt.StandardClaims
}

func DecodeSessionToken

func DecodeSessionToken(signKey string, signedToken string) (Token, error)