websocket

type Config struct {
	// ReadBufferSize specifies the I/O buffer size in bytes for reads
	ReadBufferSize int
	// WriteBufferSize specifies the I/O buffer size in bytes for writes
	WriteBufferSize int
	// PingInterval is the interval between ping messages
	PingInterval time.Duration
	// PongTimeout is the timeout for pong response
	PongTimeout time.Duration
	// MaxMessageSize is the maximum message size in bytes
	MaxMessageSize int64
	// CheckOrigin is a function to validate the request origin
	CheckOrigin func(r *http.Request) bool
}

type Connection struct {
	// ID is a unique identifier for this connection
	ID string
	// contains filtered or unexported fields
}

type Handler interface {
	// OnConnect is called when a client connects
	OnConnect(conn *Connection) error
	// OnMessage is called when a message is received
	OnMessage(conn *Connection, messageType int, data []byte) error
	// OnDisconnect is called when a client disconnects
	OnDisconnect(conn *Connection, err error)
}

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

type Message[T any] struct {
	Type      string    `json:"type"`
	Payload   T         `json:"payload"`
	Timestamp time.Time `json:"timestamp"`
	ID        string    `json:"id,omitempty"`
}

type Route struct {
	Summary     string
	Description string
	Tags        []string
	Protocols   []string // Sub-protocols supported
}