Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

wsstat

package module

Go to main page

Versions in this module

v2

v2.2.2

Jun 16, 2026

v2.2.2-rc.2

Jun 16, 2026

v2.2.2-rc.1

Jun 16, 2026

v2.2.1

Jun 16, 2026

v2.2.0

Feb 3, 2026

v2.1.3

Jan 19, 2026

v2.1.2

Jan 19, 2026

Changes in this version

+ type CertificateDetails struct

+ CommonName string

+ DNSNames []string

+ IPAddresses []net.IP

+ Issuer string

+ NotAfter time.Time

+ NotBefore time.Time

+ PublicKeyAlgorithm x509.PublicKeyAlgorithm

+ SignatureAlgorithm x509.SignatureAlgorithm

+ URIs []*url.URL

+ type Option func(*options)

+ func WithBufferSize(n int) Option

+ func WithLogger(logger zerolog.Logger) Option

+ func WithResolves(resolves map[string]string) Option

+ func WithTLSConfig(cfg *tls.Config) Option

+ func WithTimeout(d time.Duration) Option

+ type Result struct

+ DNSLookup time.Duration

+ DNSLookupDone time.Duration

+ FirstMessageResponse time.Duration

+ IPs []string

+ MessageCount int

+ MessageRTT time.Duration

+ RequestHeaders http.Header

+ ResponseHeaders http.Header

+ SubscriptionFirstEvent time.Duration

+ SubscriptionLastEvent time.Duration

+ Subscriptions map[string]SubscriptionStats

+ TCPConnected time.Duration

+ TCPConnection time.Duration

+ TLSHandshake time.Duration

+ TLSHandshakeDone time.Duration

+ TLSState *tls.ConnectionState

+ TotalTime time.Duration

+ URL *url.URL

+ WSHandshake time.Duration

+ WSHandshakeDone time.Duration

+ func MeasureLatency(targetURL *url.URL, msg string, customHeaders http.Header) (*Result, []byte, error)

+ func MeasureLatencyBurst(targetURL *url.URL, msgs []string, customHeaders http.Header) (*Result, []string, error)

+ func MeasureLatencyBurstWithContext(ctx context.Context, targetURL *url.URL, msgs []string, ...) (*Result, []string, error)

+ func MeasureLatencyJSON(targetURL *url.URL, v any, customHeaders http.Header) (*Result, any, error)

+ func MeasureLatencyJSONBurst(targetURL *url.URL, v []any, customHeaders http.Header) (*Result, []any, error)

+ func MeasureLatencyJSONBurstWithContext(ctx context.Context, targetURL *url.URL, v []any, customHeaders http.Header, ...) (*Result, []any, error)

+ func MeasureLatencyPing(targetURL *url.URL, customHeaders http.Header) (*Result, error)

+ func MeasureLatencyPingBurst(targetURL *url.URL, pingCount int, customHeaders http.Header) (*Result, error)

+ func MeasureLatencyPingBurstWithContext(ctx context.Context, targetURL *url.URL, pingCount int, ...) (*Result, error)

+ func (r *Result) CertificateDetails() []CertificateDetails

+ func (r *Result) Format(s fmt.State, verb rune)

+ type Subscription struct

+ ID string

+ func (s *Subscription) ByteCount() uint64

+ func (s *Subscription) Cancel()

+ func (s *Subscription) Done() <-chan struct{}

+ func (s *Subscription) MessageCount() uint64

+ func (s *Subscription) Unsubscribe()

+ func (s *Subscription) Updates() <-chan SubscriptionMessage

+ type SubscriptionMessage struct

+ Data []byte

+ Decoded any

+ Err error

+ MessageType int

+ Received time.Time

+ Size int

+ type SubscriptionOptions struct

+ Buffer int

+ ID string

+ MessageType int

+ Payload []byte

+ type SubscriptionStats struct

+ ByteCount uint64

+ Error error

+ FirstEvent time.Duration

+ LastEvent time.Duration

+ MeanInterArrival time.Duration

+ MessageCount uint64

+ type WSStat struct

+ func New(opts ...Option) *WSStat

+ func (ws *WSStat) Close()

+ func (ws *WSStat) Dial(targetURL *url.URL, customHeaders http.Header) error

+ func (ws *WSStat) ExtractResult() *Result

+ func (ws *WSStat) OneHitMessage(messageType int, data []byte) ([]byte, error)

+ func (ws *WSStat) OneHitMessageJSON(v any) (any, error)

+ func (ws *WSStat) PingPong() error

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

+ func (ws *WSStat) ReadMessageJSON() (any, error)

+ func (ws *WSStat) ReadPong() error

+ func (ws *WSStat) Subscribe(ctx context.Context, opts SubscriptionOptions) (*Subscription, error)

+ func (ws *WSStat) SubscribeOnce(ctx context.Context, opts SubscriptionOptions) (SubscriptionMessage, error)

+ func (ws *WSStat) WriteMessage(messageType int, data []byte)

+ func (ws *WSStat) WriteMessageJSON(v any)

Other modules containing this package

github.com/jkbrsn/wsstat

github.com/jkbrsn/wsstat/v3