ws

package

v0.2.2 Latest Latest Go to latest Published: May 21, 2019 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Channel wraps a websocket connection.

func NewWebsocketChannel(config Config) (*Channel, error)

NewWebsocketChannel creates a new channel to send and receive messages over the websocket.

func (c *Channel) ReadChannel() chan []byte

ReadChannel returns a channel to read from the websocket connection

func (c *Channel) Send(msg []byte) error

Send sends a mesage over the websocket connection

type Config struct {
	ConnectRetryWaitDuration time.Duration
	SendReceiveBufferSize    int
	URL                      string
}

Config containers the configuratinos for the websocket channel

type Interface interface {
	Send(req []byte) error
	ReadChannel() chan []byte
	Closed() chan int
}

Interface exposes the websocket interface