websocket

package

v0.0.0-...-0f16109 Latest Latest Go to latest Published: Jun 18, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	ReadBufferSize  int `koanf:"read_buffer_size"`
	WriteBufferSize int `koanf:"write_buffer_size"`
}

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

func (c *GorillaConnection) Close() error

func (c *GorillaConnection) ReadMessage() (int, []byte, error)

func (c *GorillaConnection) RemoteAddr() string

func (c *GorillaConnection) SetCloseHandler(h func(code int, text string) error)

SetCloseHandler sets the handler for close messages received from the peer.

func (c *GorillaConnection) SetPongHandler(h func(appData string) error)

SetPongHandler sets the handler for pong messages received from the peer.

func (c *GorillaConnection) SetReadDeadline(t time.Time) error

SetReadDeadline sets the read deadline on the underlying connection.

func (c *GorillaConnection) SetReadLimit(limit int64)

SetReadLimit sets the maximum size for a message read from the peer.

func (c *GorillaConnection) SetWriteDeadline(t time.Time) error

SetWriteDeadline sets the write deadline on the underlying connection.

func (c *GorillaConnection) WriteMessage(messageType int, data []byte) error

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

func NewGorillaUpgrader(cfg Config, checkOrigin func(r *http.Request) bool) *GorillaUpgrader

func (u *GorillaUpgrader) Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (*GorillaConnection, error)