client

Documentation

Overview

Websocket client implementation. This will be used in tests.

Index

• type WSClient
  • func NewWSClient(addr string) *WSClient
  • func (this *WSClient) Close()
  • func (this *WSClient) Dial() (*http.Response, error)
  • func (this *WSClient) StartRead() <-chan []byte
  • func (this *WSClient) WriteMsg(msg []byte)

Types

type WSClient

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

A websocket client subscribes and unsubscribes to events

func NewWSClient

func NewWSClient(addr string) *WSClient

create a new connection

func (*WSClient) Close

func (this *WSClient) Close()

func (*WSClient) Dial

func (this *WSClient) Dial() (*http.Response, error)

func (*WSClient) StartRead

func (this *WSClient) StartRead() <-chan []byte

returns a channel from which messages can be pulled from a go routine that reads the socket. if the ws returns an error (eg. closes), we return

func (*WSClient) WriteMsg

func (this *WSClient) WriteMsg(msg []byte)