gows

package

Go to main page

Versions in this module

v1

v1.2.2

Apr 13, 2023

v1.2.1

Apr 2, 2023

v1.2.0

Mar 27, 2023

Changes in this version

type ChuckReadHandler

+ OnRead func(ws *WebSocket, opcode int, fin bool, buff *ByteBuffer) error

type WebSocket

+ func (ws *WebSocket) ServeRead(handler MessageHandler)

+ func (ws *WebSocket) WriteString(data string) error

v1.1.8

Mar 24, 2023

Changes in this version

type WebSocket

+ func (ws *WebSocket) CloseHandshake(code CloseCode, text string) error

+ func (ws *WebSocket) SetReadTimeOut(readTimeOut time.Duration)

v1.1.7

Mar 16, 2023

Changes in this version

+ func SetOriginCheckFunc(fn OriginCheckFunc)

type AcceptOptions

+ func (this *AcceptOptions) SetOriginCheckFunc(fn OriginCheckFunc)

+ type ChuckReadHandler interface

+ OnData func(ws *WebSocket, opcode int, fin bool, buff *ByteBuffer) error

type CloseInfo

+ Info string

+ func (cc *CloseInfo) Error() string

type CompressAlloter

+ FlushWriter func(fw io.WriteCloser) error

+ WebsocketExtension func(args []string) string

type FlateAlloter

+ func (this *FlateAlloter) FlushWriter(fw io.WriteCloser) error

+ func (this *FlateAlloter) WebsocketExtension(params []string) string

+ type OriginCheckFunc func(r *http.Request) bool

type WebSocket

+ func (ws *WebSocket) ServeChunk(handler ChuckReadHandler)

v1.1.6

Mar 3, 2023

Changes in this version

type WebSocket

+ func (ws *WebSocket) ReadMessage() (int, []byte, error)

v1.1.5

Feb 28, 2023

v1.1.4

Feb 13, 2023

v1.1.3

Feb 13, 2023

Changes in this version

+ const Frame_Binary

+ const Frame_Close

+ const Frame_Continue

+ const Frame_Null

+ const Frame_Ping

+ const Frame_Pong

+ const Frame_Text

+ func BytesToString(bytes []byte) string

+ func CloseReader(r *MessageReader) error

+ func CloseWriter(writer *MessageWriter) error

+ func HeaderValueCheck(header http.Header, key string, val string) bool

+ func MarshalCloseInfo(code CloseCode, text string) ([]byte, error)

+ func OriginHostCheck(r *http.Request) bool

+ func PutByteBuffer(b *ByteBuffer)

+ func SetDebugLogger(logger DebugLogger)

+ func SetFrameReadBuffSize(size int)

+ func SetLoggerPrefix(prefix string)

+ func SetMessageBufferSize(size int)

+ func SetMinCompressSize(size int)

+ func ShowDebugLog(show bool)

+ func StringToBytes(s string) []byte

+ func UseFlate(val ...CompressAlloter)

+ func WriteAllTo(buff []byte, dst io.Writer) error

+ type AcceptOptions struct

+ SubProtocols []string

+ func DefaultAcceptOptions() *AcceptOptions

+ func NewAcceptOptions() *AcceptOptions

+ func (this *AcceptOptions) SetFrameReadBuffSize(size int)

+ func (this *AcceptOptions) SetMessageBufferSize(size int)

+ func (this *AcceptOptions) SetMinCompressSize(size int)

+ func (this *AcceptOptions) UseFlate(val ...CompressAlloter)

+ type ByteBuffer struct

+ func GetByteBuffer(opts *AcceptOptions) *ByteBuffer

+ func (b *ByteBuffer) CloneBytes() []byte

+ func (b *ByteBuffer) Close()

+ func (b *ByteBuffer) GetBytes() []byte

+ func (b *ByteBuffer) GetString() string

+ func (b *ByteBuffer) GetVolatileString() string

+ func (b *ByteBuffer) ReadAll(reader io.Reader) error

+ func (b *ByteBuffer) ReadFull(reader io.Reader) error

+ func (b *ByteBuffer) Reset()

+ func (b *ByteBuffer) Size() int

+ type CloseCode int

+ const CloseAbnormalClosure

+ const CloseBadGateway

+ const CloseGoingAway

+ const CloseInternalError

+ const CloseInvalidPayload

+ const CloseMandatoryExtension

+ const CloseMessageTooBig

+ const CloseNoCloseRcvd

+ const CloseNormalClosure

+ const ClosePolicyViolation

+ const CloseProtocolError

+ const CloseReserved

+ const CloseServiceRestart

+ const CloseTLSHandshake

+ const CloseTryAgainLater

+ const CloseUnsupportedData

+ type CloseInfo struct

+ Code CloseCode

+ Text string

+ type CompressAlloter interface

+ NewReader func(mr *FrameReader) (io.ReadCloser, error)

+ NewWriter func(mw *FrameWriter) (io.WriteCloser, error)

+ ResetReader func(fr io.ReadCloser, mr *FrameReader) error

+ ResetWriter func(fw io.WriteCloser, mw *FrameWriter) error

+ type CompressMode int

+ const CompressContextTakeover

+ const CompressDisabled

+ const CompressNoContextTakeover

+ type DebugLogger interface

+ Output func(prefix string, msg string)

+ type ExtParam struct

+ type FlateAlloter struct

+ func NewFlateAlloter(level int) *FlateAlloter

+ func (this *FlateAlloter) NewReader(mr *FrameReader) (io.ReadCloser, error)

+ func (this *FlateAlloter) NewWriter(mw *FrameWriter) (io.WriteCloser, error)

+ func (this *FlateAlloter) ResetReader(fr io.ReadCloser, mr *FrameReader) error

+ func (this *FlateAlloter) ResetWriter(fw io.WriteCloser, mw *FrameWriter) error

+ type FrameHeader struct

+ type FrameReader struct

+ func (mr *FrameReader) BufferSize() int

+ func (mr *FrameReader) Close() error

+ func (mr *FrameReader) Init(ws *WebSocket, br *bufio.Reader)

+ func (mr *FrameReader) Read(p []byte) (int, error)

+ func (mr *FrameReader) ReadMessagePayload(p []byte) (int, error)

+ type FrameWriter struct

+ func NewFrameWriter(ws *WebSocket, opcode int) *FrameWriter

+ func (w *FrameWriter) Close() error

+ func (w *FrameWriter) GetPayload() []byte

+ func (w *FrameWriter) GetPayloadLength() int

+ func (w *FrameWriter) Reset(ws *WebSocket, opcode int) error

+ func (w *FrameWriter) SetTrimlength(trim int)

+ func (w *FrameWriter) Write(p []byte) (int, error)

+ func (w *FrameWriter) WriteAll(data []byte) error

+ func (w *FrameWriter) WriteControlFrame(data []byte) error

+ func (w *FrameWriter) WriteString(str string) error

+ type MessageHandler interface

+ OnMessage func(ws *WebSocket, opcode int, buff *ByteBuffer) error

+ type MessageReader struct

+ func (mr *MessageReader) Close() error

+ func (mr *MessageReader) Read(p []byte) (int, error)

+ func (mr *MessageReader) ReadAll() (*ByteBuffer, error)

+ type MessageWriter struct

+ func (w *MessageWriter) Close() error

+ func (w *MessageWriter) Write(p []byte) (int, error)

+ func (w *MessageWriter) WriteAll(data []byte) error

+ func (w *MessageWriter) WriteControlFrame(data []byte) error

+ func (w *MessageWriter) WriteString(str string) error

+ type SimpleLogger struct

+ func NewSimpleLogger() *SimpleLogger

+ func (lg *SimpleLogger) Output(prefix string, msg string)

+ type SocketHandler interface

+ OnClose func(ws *WebSocket)

+ type StreamReadHandler interface

+ OnData func(ws *WebSocket, opcode int, fin bool, buff *ByteBuffer) error

+ type TokenInfo struct

+ Flag int

+ Index int

+ Value string

+ type WebSocket struct

+ func Accept(w http.ResponseWriter, r *http.Request, opts *AcceptOptions, ...) (*WebSocket, error)

+ func NewWebSocket(cnn net.Conn, opts *AcceptOptions, br *bufio.Reader) *WebSocket

+ func (ws *WebSocket) Close() error

+ func (ws *WebSocket) LocalAddr() net.Addr

+ func (ws *WebSocket) NextReader() (FrameHeader, *MessageReader, error)

+ func (ws *WebSocket) NextWriter(opcode int) *MessageWriter

+ func (ws *WebSocket) RemoteAddr() net.Addr

+ func (ws *WebSocket) Serve(handler SocketHandler)

+ func (ws *WebSocket) ServeMessage(handler MessageHandler)

+ func (ws *WebSocket) ServeStream(handler StreamReadHandler)

+ func (ws *WebSocket) SetWriteTimeOut(writeTimeOut time.Duration)

+ func (ws *WebSocket) WiteCloseError(code CloseCode, err error) error

+ func (ws *WebSocket) WiteCloseProtocolError(err error) error

+ func (ws *WebSocket) WiteCloseText(code CloseCode, text string) error

+ func (ws *WebSocket) WriteBinary(data []byte) error

+ func (ws *WebSocket) WriteClose(data []byte) error

+ func (ws *WebSocket) WriteJSON(v interface{}) error

+ func (ws *WebSocket) WriteMessage(opcode int, data []byte) error

+ func (ws *WebSocket) WritePing(data []byte) error

+ func (ws *WebSocket) WritePong(data []byte) error

+ func (ws *WebSocket) WriteText(data []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL