hub

type AvailableSession struct {
	ID              string `json:"id"`
	SessionHostName string `json:"name"`
	Size            int    `json:"size"`
}

type Client struct {
	Hub     *Hub
	Session *string
	Id      string
	Name    *string

	Socket ISocket
	Events map[string]*signals.Signal[[]byte]

	Ready bool
	// contains filtered or unexported fields
}

type ClientHandler interface {
	Close() error
	Write(p []byte) error
}

type ClientHubUDPWrapper struct {
	LastPing time.Time
	// contains filtered or unexported fields
}

type ClientHubWSWrapper struct {
	Conn *websocket.Conn
}

type ClosedMessage struct {
	Session string
}

type ConnectionOptions struct {
	UseCompression bool
	UseSSL         bool
	Proxy          func(*http.Request) (*url.URL, error)
	Subprotocols   []string
}

type Empty struct {
}

type HostJoinMessage struct {
	Id      string
	Name    string
	Session string
}

type Hub struct {
	// Registered clients.
	Clients        map[*Client]bool
	IdClients      map[string]*Client
	SessionManager *SessionManager

	// Register requests from the clients.
	Register chan *Client

	// Unregister requests from clients.
	Unregister chan *Client
	// contains filtered or unexported fields
}

type ISocket interface {
	SocketHandler() *SocketHandler
	Connect()
	Close()
	SendBinary(messageType int, data []byte)
	IsConnected() bool
}

type KcpSocket struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

type LeavingMessage struct {
	Id string
}

type MembersMessage struct {
	Session string
}

type MembersMessageResponse struct {
	Members map[string]*string
	Host    string
}

type ReconnectionOptions struct {
}

type RegisteredMessage struct {
	Id string
}

type Session struct {
	Id           string
	Host         *Client
	Participants map[*Client]bool
}

type SessionManager struct {
	Sessions map[string]*Session
	// contains filtered or unexported fields
}

type SessionMessage struct {
	Session string
	Sender  string
	Channel string
	Target  *string
	Message string
}

type Socket struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

type SocketHandler struct {
	OnConnected     func(socket interface{})
	OnTextMessage   func(message string, socket interface{})
	OnBinaryMessage func(data []byte, socket interface{})
	OnConnectError  func(err error, socket interface{})
	OnDisconnected  func(err error, socket interface{})
	OnPingReceived  func(data string, socket interface{})
	OnPongReceived  func(data string, socket interface{})
}