nettyws

Dec 6, 2024

Changes in this version

type Conn

+ Request func() *http.Request

Dec 5, 2024

Changes in this version

type Option

+ func WithDialTimeout(timeout time.Duration) Option

Dec 22, 2023

Changes in this version

+ type Dialer interface

+ Dial func(network, addr string) (c net.Conn, err error)

type Option

+ func WithDialer(dialer Dialer) Option

type Websocket

+ func (ws *Websocket) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Nov 30, 2023

Changes in this version

type Option

+ func WithClientHeader(header http.Header) Option

+ func WithServerHeader(header http.Header) Option

Aug 23, 2023

Changes in this version

+ var ErrServerClosed = netty.ErrServerClosed

+ type ClosedError struct

+ Code int

+ Reason string

+ func (err ClosedError) Error() string

+ type Conn interface

+ Close func() error

+ Context func() context.Context

+ Header func() http.Header

+ LocalAddr func() string

+ RemoteAddr func() string

+ SetDeadline func(t time.Time) error

+ SetReadDeadline func(t time.Time) error

+ SetUserdata func(userdata interface{})

+ SetWriteDeadline func(t time.Time) error

+ Userdata func() interface{}

+ Write func(message []byte) error

+ WriteClose func(code int, reason string) error

+ type MessageType int

+ const MsgBinary

+ const MsgText

+ type OnCloseFunc func(conn Conn, err error)

+ type OnDataFunc func(conn Conn, data []byte)

+ type OnOpenFunc func(conn Conn)

+ type Option func(*options)

+ func WithAsyncWrite(writeQueueSize int, writeForever bool) Option

+ func WithBinary() Option

+ func WithBufferSize(readBufferSize, writeBufferSize int) Option

+ func WithCompress(compressLevel int, compressThreshold int64) Option

+ func WithMaxFrameSize(maxFrameSize int64) Option

+ func WithNoDelay(noDelay bool) Option

+ func WithServeMux(serveMux *http.ServeMux) Option

+ func WithServeTLS(tls *tls.Config) Option

+ func WithValidUTF8() Option

+ type Websocket struct

+ OnClose OnCloseFunc

+ OnData OnDataFunc

+ OnOpen OnOpenFunc

+ func NewWebsocket(options ...Option) *Websocket

+ func (ws *Websocket) Close() error

+ func (ws *Websocket) Listen(addr string) error

+ func (ws *Websocket) Open(addr string) error

+ func (ws *Websocket) UpgradeHTTP(writer http.ResponseWriter, request *http.Request) (conn Conn, err error)