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

gws

package module

Go to main page

Versions in this module

v0

v0.5.0

Sep 4, 2020

Changes in this version

+ var DefaultConnectParams = ConnectParams

+ type ConnectParams struct

+ Backoff backoff.Config

+ MinConnectTimeout time.Duration

type DialOption

+ func WithConnectParams(p ConnectParams) DialOption

+ type ErrUnsupportedMsgType string

+ func (e ErrUnsupportedMsgType) Error() string

type ServerOption

+ func WithKeepAlive(period time.Duration) ServerOption

v0.4.0

Jun 17, 2020

Changes in this version

+ const MessageBinary

+ const MessageText

type ConnOption

+ func WithMessageType(typ MessageType) ConnOption

+ type MessageType websocket.MessageType

v0.3.2

Jun 17, 2020

v0.3.1

Jun 17, 2020

Changes in this version

+ var ErrStreamClosed = errors.New("gws: stream is closed")

+ var ErrUnsubscribed = errors.New("gws: received cancelled due to unsubscribe")

+ func NewHandler(h Handler, opts ...ServerOption) http.Handler

+ type Client interface

+ Query func(context.Context, *Request) (*Response, error)

+ Subscribe func(context.Context, *Request) (*Subscription, error)

+ func NewClient(conn *Conn) Client

+ type CompressionMode websocket.CompressionMode

+ const CompressionContextTakeover

+ const CompressionDisabled

+ const CompressionNoContextTakeover

+ type Conn struct

+ func Dial(ctx context.Context, endpoint string, opts ...DialOption) (*Conn, error)

+ func (c *Conn) Close() error

+ type ConnOption interface

+ func WithCompression(mode CompressionMode, threshold int) ConnOption

+ type DialOption interface

+ SetDial func(*dialOpts)

+ func WithHTTPClient(client *http.Client) DialOption

+ func WithHeaders(headers http.Header) DialOption

+ type ErrIO struct

+ Err error

+ Msg string

+ func (e ErrIO) Error() string

+ func (e ErrIO) Unwrap() error

+ type ErrUnexpectedMessage struct

+ Expected string

+ Received string

+ func (e ErrUnexpectedMessage) Error() string

+ type Handler interface

+ ServeGraphQL func(*Stream, *Request) error

+ type HandlerFunc func(*Stream, *Request) error

+ func (f HandlerFunc) ServeGraphQL(s *Stream, req *Request) error

+ type Request struct

+ OperationName string

+ Query string

+ Variables map[string]interface{}

+ type Response struct

+ Data json.RawMessage

+ Errors []json.RawMessage

+ type ServerError struct

+ Msg string

+ func (e *ServerError) Error() string

+ type ServerOption interface

+ SetServer func(*options)

+ func WithOrigins(origins ...string) ServerOption

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Send(ctx context.Context, resp *Response) error

+ type Subscription struct

+ func (s *Subscription) Recv(ctx context.Context) (*Response, error)

+ func (s *Subscription) Unsubscribe() error