wsconnadapter

Documentation

Index

• Variables
• type Adapter
  • func New(conn *websocket.Conn) *Adapter
  • func (a *Adapter) Close() error
  • func (a *Adapter) LocalAddr() net.Addr
  • func (a *Adapter) Ping() chan bool
  • func (a *Adapter) Read(b []byte) (int, error)
  • func (a *Adapter) RemoteAddr() net.Addr
  • func (a *Adapter) SetDeadline(t time.Time) error
  • func (a *Adapter) SetReadDeadline(t time.Time) error
  • func (a *Adapter) SetWriteDeadline(t time.Time) error
  • func (a *Adapter) WithDevice(tenant string, device string) *Adapter
  • func (a *Adapter) WithID(requestID string) *Adapter
  • func (a *Adapter) Write(b []byte) (int, error)

Variables

var ErrUnexpectedMessageType = errors.New("unexpected websocket message type")

Types

type Adapter

type Adapter struct {
	Logger *log.Entry
	// contains filtered or unexported fields
}

func New

func New(conn *websocket.Conn) *Adapter

func (*Adapter) Close

func (a *Adapter) Close() error

func (*Adapter) LocalAddr

func (a *Adapter) LocalAddr() net.Addr

func (*Adapter) Ping

func (a *Adapter) Ping() chan bool

func (*Adapter) Read

func (a *Adapter) Read(b []byte) (int, error)

func (*Adapter) RemoteAddr

func (a *Adapter) RemoteAddr() net.Addr

func (*Adapter) SetDeadline

func (a *Adapter) SetDeadline(t time.Time) error

func (*Adapter) SetReadDeadline

func (a *Adapter) SetReadDeadline(t time.Time) error

func (*Adapter) SetWriteDeadline

func (a *Adapter) SetWriteDeadline(t time.Time) error

func (*Adapter) WithDevice

func (a *Adapter) WithDevice(tenant string, device string) *Adapter

func (*Adapter) WithID

func (a *Adapter) WithID(requestID string) *Adapter

func (*Adapter) Write

func (a *Adapter) Write(b []byte) (int, error)