client

Documentation

Index

• type Connection
  • func NewConnection(d Dialer, secure bool, name, host, path, token string, query string) (*Connection, error)
  • func (c *Connection) Read(ctx context.Context, msgCh chan []byte)
  • func (c *Connection) Write(b []byte) error
• type Dialer

Types

type Connection

type Connection struct {
	Name string
	Conn websocketIO
}

func NewConnection

func NewConnection(d Dialer, secure bool, name, host, path, token string, query string) (*Connection, error)

creates new Connection

func (*Connection) Read

func (c *Connection) Read(ctx context.Context, msgCh chan []byte)

read loop for wesocket

func (*Connection) Write

func (c *Connection) Write(b []byte) error

write to websocket

type Dialer

type Dialer interface {
	Dial(urlStr string, requestHeader http.Header) (*websocket.Conn, *http.Response, error)
}