Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

websocket

package module

Go to main page

Versions in this module

v1

v1.2.1

Feb 7, 2024

Changes in this version

type Option

+ func WithConnectHeader(header http.Header) Option[Client]

+ func WithDelayReconnect(delay time.Duration) Option[Client]

v1.2.0

Jan 23, 2024

v1.1.9

Jan 17, 2024

Changes in this version

+ func EventStrings() []string

+ type BeforeReconnectHandler func(*Client)

type Client

+ func (c *Client) Status() Status

+ func (c *Client) URL() string

+ type Event uint

+ const EventDecompress

+ const EventNormal

+ const EventRead

+ const EventReconnect

+ const EventUnmarshal

+ const EventWrite

+ func EventString(s string) (Event, error)

+ func EventValues() []Event

+ func (Event) Values() []string

+ func (i *Event) UnmarshalJSON(data []byte) error

+ func (i *Event) UnmarshalText(text []byte) error

+ func (i Event) IsAEvent() bool

+ func (i Event) MarshalJSON() ([]byte, error)

+ func (i Event) MarshalText() ([]byte, error)

+ func (i Event) String() string

type FrameType

+ const FrameTypeNoFrame

+ type Logger interface

+ Error func(string, ...any)

+ Info func(string, ...any)

type Option

+ func WithBeforeReconnect(handler BeforeReconnectHandler) Option[Client]

+ type ReaderReceiver struct

+ func NewReaderReceiver() *ReaderReceiver

+ func (r *ReaderReceiver) Unmarshal(_ FrameType, reader io.Reader) (any, error)

+ type Unmarshaler interface

+ Unmarshal func(frameType FrameType, reader io.Reader) (any, error)

v1.1.8

Jan 4, 2024

v1.1.7

Jan 3, 2024

v1.1.6

Jan 3, 2024

v1.1.5

Jan 2, 2024

v1.1.4

Jan 2, 2024

Changes in this version

+ const FrameTypeBinary

+ const FrameTypeClose

+ const FrameTypePing

+ const FrameTypePong

+ const FrameTypeText

+ func AesDecryptECB(encrypted, key []byte) (decrypted []byte)

+ func AesEncryptECB(src []byte, key []byte) (encrypted []byte)

+ func AesSha1Prng(key []byte, length int) ([]byte, error)

+ func FrameTypeStrings() []string

+ func HexMD5(src []byte) string

+ func HexSha1(src []byte) (digest []byte)

+ func HmacMD5(src, secret []byte) string

+ func HmacSHA256(src, secret []byte) string

+ func MD5(src []byte) []byte

+ func Sha1(src []byte) []byte

+ func StatusStrings() []string

+ type Client struct

+ func NewClient(ctx context.Context, wsURL string, receiver Receiver, opts ...Option[Client]) (*Client, error)

+ func (c *Client) SendBinary(message []byte)

+ func (c *Client) SendClose(message []byte)

+ func (c *Client) SendJson(message any) error

+ func (c *Client) SendMessage(message []byte)

+ func (c *Client) SendPing(message []byte)

+ func (c *Client) SendPong(message []byte)

+ func (c *Client) Shutdown() (err error)

+ type DecompressHandler func(io.Reader) (io.Reader, error)

+ type ErrorHandler func(FrameType, error)

+ type FrameType int

+ func FrameTypeString(s string) (FrameType, error)

+ func FrameTypeValues() []FrameType

+ func (FrameType) Values() []string

+ func (i *FrameType) UnmarshalJSON(data []byte) error

+ func (i *FrameType) UnmarshalText(text []byte) error

+ func (i FrameType) IsAFrameType() bool

+ func (i FrameType) MarshalJSON() ([]byte, error)

+ func (i FrameType) MarshalText() ([]byte, error)

+ func (i FrameType) String() string

+ type HeartbeatHandler func(*Client)

+ type Message struct

+ Msg []byte

+ Type FrameType

+ type OnCloseHandler func(code int, text string) error

+ type OnConnectedHandler func(*Client)

+ type Option func(*T)

+ func WithAutoReConnect() Option[Client]

+ func WithCloseHandler(handler OnCloseHandler) Option[Client]

+ func WithCompression(compression bool) Option[Client]

+ func WithCompressionLevel(level int) Option[Client]

+ func WithConnectTimeout(timeout time.Duration) Option[Client]

+ func WithConnected(handler OnConnectedHandler) Option[Client]

+ func WithDecompressHandler(handler DecompressHandler) Option[Client]

+ func WithDialer(dialer websocket.Dialer) Option[Client]

+ func WithErrorHandler(handler ErrorHandler) Option[Client]

+ func WithHeartbeatHandler(handler HeartbeatHandler) Option[Client]

+ func WithHeartbeatInterval(interval time.Duration) Option[Client]

+ func WithLogger(logger *slog.Logger) Option[Client]

+ func WithPingHandler(handler PingHandler) Option[Client]

+ func WithPongHandler(handler PongHandler) Option[Client]

+ func WithProxyURL(proxyURL string) Option[Client]

+ func WithReadLimit(limit int64) Option[Client]

+ func WithReadTimeout(timeout time.Duration) Option[Client]

+ func WithReconnected(handler ReConnectedHandler) Option[Client]

+ func WithRequestHeader(header http.Header) Option[Client]

+ type PingHandler func(appData string) error

+ type PongHandler func(appData string) error

+ type ReConnectedHandler func(*Client)

+ type Receiver interface

+ OnMessage func(any)

+ Unmarshal func(frameType FrameType, reader io.Reader) (any, error)

+ type Status uint32

+ const StatusConnected

+ const StatusConnecting

+ const StatusDisconnected

+ const StatusDisconnecting

+ const StatusEstablish

+ const StatusInactive

+ const StatusReConnecting

+ func StatusString(s string) (Status, error)

+ func StatusValues() []Status

+ func (Status) Values() []string

+ func (i *Status) UnmarshalText(text []byte) error

+ func (i Status) IsAStatus() bool

+ func (i Status) MarshalText() ([]byte, error)

+ func (i Status) String() string

JackTT - Gopher 🇻🇳