wasp

type AuthenticationHandler interface {
	Authenticate(ctx context.Context, mqtt auth.ApplicationContext, transport auth.TransportContext) (principal auth.Principal, err error)
}

type LocalState interface {
	Get(id string) *sessions.Session
	ListSessions() []*sessions.Session
	Create(id string, session *sessions.Session) *sessions.Session
	Delete(id string) *sessions.Session
}

type Manager interface {
	Run(ctx context.Context)
	Setup(ctx context.Context, c transport.Metadata)
	DisconnectClients(ctx context.Context)
}

type NodeMemberManager interface {
	NotifyGossipJoin(id uint64)
	NotifyGossipLeave(id uint64)
}

type PacketProcessor interface {
	Process(ctx context.Context, session *sessions.Session, c io.Writer, pkt packet.Packet) error
}

type PublishDistributor struct {
	ID        uint64
	Transport publishDistributorTransport
	State     distributed.SubscriptionsState
	Storage   messageLog
	Logger    *zap.Logger
}

type PublishHandler func(sender string, publish *packet.Publish) error

type RPCServer interface {
	api.MQTTServer
	Serve(grpcServer *grpc.Server)
}

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

type Scheduler struct {
	ID uint64
	// contains filtered or unexported fields
}

type Writer interface {
	Register(sessionID string, enc transport.TimeoutReadWriteCloser)
	Unregister(sessionID string)
	Run(ctx context.Context, log messageLog) error
	Schedule(ctx context.Context, offset uint64)
	Send(ctx context.Context, recipients []string, qosses []int32, p *packet.Publish)
}