wswrapper

Documentation

Index

• type WSWrapper
  • func (w *WSWrapper) ReadJSON(v interface{}) error
  • func (w *WSWrapper) Run(notifyFirstConn *sync.Cond) error
  • func (w *WSWrapper) Setup()
  • func (w *WSWrapper) WriteJSON(v interface{}) error
  • func (w *WSWrapper) WriteJSONUnbuffered(v interface{}) error

Types

type WSWrapper

type WSWrapper struct {
	DisableTLSVerification bool
	Endpoint               string
	Headers                http.Header
	MaximumDropoutTime     time.Duration
	// contains filtered or unexported fields
}

The WSWrapper adds a buffer layer to the underlying websocket connection It gracefully handles connection dropouts/reconnects in a manner that is transparent to the handler

func (*WSWrapper) ReadJSON

func (w *WSWrapper) ReadJSON(v interface{}) error

func (*WSWrapper) Run

func (w *WSWrapper) Run(notifyFirstConn *sync.Cond) error

func (*WSWrapper) Setup

func (w *WSWrapper) Setup()

func (*WSWrapper) WriteJSON

func (w *WSWrapper) WriteJSON(v interface{}) error

func (*WSWrapper) WriteJSONUnbuffered

func (w *WSWrapper) WriteJSONUnbuffered(v interface{}) error

For heartbeats, as there's no reason to buffer them