mqtt

type ConnectedClient struct {
	Connection    io.Writer
	ClientID      string
	ClientGroup   string
	IsConnected   bool
	IsClean       bool
	Subscriptions map[string]packets.SubOptions
}

type MqttBase interface {
	AddClient(io.Writer, *packets.Connect) (reasonCode byte, sessionExists bool, maxQos byte)
	Disconnect(io.Writer, *packets.Disconnect)
	Publish(*packets.Publish)
	Subscribe(io.Writer, *packets.Subscribe) []byte
	Unsubscribe(io.Writer, *packets.Unsubscribe) []byte

	ReservePacketID(io.Writer, *packets.Publish) error
	FreePacketID(io.Writer, *packets.Pubrel) error
}

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

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