Versions in this module Expand all Collapse all v1 v1.9.1 Feb 3, 2025 v1.9.0 Jan 30, 2025 Changes in this version + func NetConn(ctx context.Context, c *Conn, msgType MessageType) net.Conn + type AcceptOptions struct + CompressionMode CompressionMode + CompressionThreshold int + InsecureSkipVerify bool + OnPingReceived func(ctx context.Context, payload []byte) bool + OnPongReceived func(ctx context.Context, payload []byte) + OriginPatterns []string + Subprotocols []string + type BrowserConn struct — js/wasm + func (c *BrowserConn) Close(code StatusCode, reason string) error + func (c *BrowserConn) CloseNow() error + func (c *BrowserConn) CloseRead(ctx context.Context) context.Context + func (c *BrowserConn) Ping(ctx context.Context) error + func (c *BrowserConn) Read(ctx context.Context) (MessageType, []byte, error) + func (c *BrowserConn) Reader(ctx context.Context) (MessageType, io.Reader, error) + func (c *BrowserConn) SetReadLimit(n int64) + func (c *BrowserConn) Subprotocol() string + func (c *BrowserConn) Write(ctx context.Context, typ MessageType, p []byte) error + func (c *BrowserConn) Writer(ctx context.Context, typ MessageType) (io.WriteCloser, error) + type CloseError struct + Code StatusCode + Reason string + func (ce CloseError) Error() string + type CompressionMode int + const CompressionContextTakeover + const CompressionDisabled + const CompressionNoContextTakeover + type Conn struct + func Accept(w http.ResponseWriter, r *http.Request, opts *AcceptOptions) (*Conn, error) + func Dial(ctx context.Context, u string, opts *DialOptions) (*Conn, *http.Response, error) + func Dial(ctx context.Context, url string, opts *DialOptions) (*Conn, *http.Response, error) + type DialOptions struct + CompressionMode CompressionMode + CompressionThreshold int + HTTPClient *http.Client + HTTPHeader http.Header + Host string + OnPingReceived func(ctx context.Context, payload []byte) bool + OnPongReceived func(ctx context.Context, payload []byte) + Subprotocols []string + type MessageType int + const MessageBinary + const MessageText + func (i MessageType) String() string + type StatusCode int + const StatusAbnormalClosure + const StatusBadGateway + const StatusGoingAway + const StatusInternalError + const StatusInvalidFramePayloadData + const StatusMandatoryExtension + const StatusMessageTooBig + const StatusNoStatusRcvd + const StatusNormalClosure + const StatusPolicyViolation + const StatusProtocolError + const StatusServiceRestart + const StatusTLSHandshake + const StatusTryAgainLater + const StatusUnsupportedData + func CloseStatus(err error) StatusCode + func (i StatusCode) String() string + type StdConn struct + func (c *StdConn) Close(code StatusCode, reason string) (err error) + func (c *StdConn) CloseNow() (err error) + func (c *StdConn) CloseRead(ctx context.Context) context.Context + func (c *StdConn) Ping(ctx context.Context) error + func (c *StdConn) Read(ctx context.Context) (MessageType, []byte, error) + func (c *StdConn) Reader(ctx context.Context) (MessageType, io.Reader, error) + func (c *StdConn) SetReadLimit(n int64) + func (c *StdConn) Subprotocol() string + func (c *StdConn) Write(ctx context.Context, typ MessageType, p []byte) error + func (c *StdConn) Writer(ctx context.Context, typ MessageType) (io.WriteCloser, error) + type Stream interface + Close func(code StatusCode, reason string) (err error) + CloseNow func() (err error) + CloseRead func(ctx context.Context) context.Context + Ping func(ctx context.Context) error + Read func(ctx context.Context) (MessageType, []byte, error) + Reader func(ctx context.Context) (MessageType, io.Reader, error) + SetReadLimit func(n int64) + Subprotocol func() string + Write func(ctx context.Context, typ MessageType, p []byte) error + Writer func(ctx context.Context, typ MessageType) (io.WriteCloser, error)
Go to main page