websocket

Documentation

Index

• Variables
• type IncomingMessage
• type Websocket
  • func New(wsURL string) *Websocket
  • func (w *Websocket) Auth(token string, timeout time.Duration) error
  • func (w *Websocket) Close() error
  • func (w *Websocket) Connect(handshakeTimeout time.Duration) error
  • func (w *Websocket) Recv(timeout time.Duration) (msg IncomingMessage, err error)

Variables

var ErrInvalidToken = errors.New("invalid token")

Types

type IncomingMessage

type IncomingMessage struct {
	Type  string          `json:"type"`
	Value json.RawMessage `json:"value"`
}

type Websocket

type Websocket struct {
	// contains filtered or unexported fields
}

func New

func New(wsURL string) *Websocket

func (*Websocket) Auth

func (w *Websocket) Auth(token string, timeout time.Duration) error

func (*Websocket) Close

func (w *Websocket) Close() error

func (*Websocket) Connect

func (w *Websocket) Connect(handshakeTimeout time.Duration) error

func (*Websocket) Recv

func (w *Websocket) Recv(timeout time.Duration) (msg IncomingMessage, err error)