websocket

type Client struct {
	// ID is the unique identifier for this client connection
	ID string
	// UserID is the user identifier
	UserID string
	// TenantID is the tenant identifier
	TenantID string
	// Token stores JWT token for authenticated API calls
	Token string
	// Metadata stores custom key-value data for application use
	Metadata map[string]interface{}
	// contains filtered or unexported fields
}

type ClientOption func(*Client)

type Config struct {
	// WriteWait is the time allowed to write a message to the peer
	WriteWait time.Duration
	// PongWait is the time allowed to read the next pong message from the peer
	PongWait time.Duration
	// PingPeriod is the period to send pings to the peer (must be less than PongWait)
	PingPeriod time.Duration
	// MaxMessageSize is the maximum message size allowed from peer
	MaxMessageSize int64
	// SendBufferSize is the size of the send channel buffer
	SendBufferSize int
	// ReadBufferSize is the WebSocket read buffer size
	ReadBufferSize int
	// WriteBufferSize is the WebSocket write buffer size
	WriteBufferSize int
}

type DisconnectHandler func(client *Client)

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

type HubInterface interface {
	Register(client *Client)
	Unregister(client *Client)
	Run()
}

type MessageHandler func(client *Client, message []byte)

type OriginChecker func(r *http.Request) bool