websocket

Documentation

Index

• type WebSocketConnector
  • func NewWebSocketConnector(url string) *WebSocketConnector
  • func (wsc *WebSocketConnector) Connect(ctx context.Context) error
  • func (wsc *WebSocketConnector) Disconnect() error
  • func (wsc *WebSocketConnector) OpenStream(ctx context.Context, protocolID string) (types.Stream, error)
• type WebSocketStream
  • func NewWebSocketStream(conn *websocket.Conn, ctx context.Context) *WebSocketStream
  • func (ws *WebSocketStream) Close() error
  • func (ws *WebSocketStream) Context() context.Context
  • func (ws *WebSocketStream) Flush() error
  • func (ws *WebSocketStream) Read(msg []byte) (int, error)
  • func (ws *WebSocketStream) Write(msg []byte) (int, error)

Types

type WebSocketConnector

type WebSocketConnector struct {
	URL  string
	Conn *websocket.Conn
}

func NewWebSocketConnector

func NewWebSocketConnector(url string) *WebSocketConnector

func (*WebSocketConnector) Connect

func (wsc *WebSocketConnector) Connect(ctx context.Context) error

func (*WebSocketConnector) Disconnect

func (wsc *WebSocketConnector) Disconnect() error

func (*WebSocketConnector) OpenStream

func (wsc *WebSocketConnector) OpenStream(ctx context.Context, protocolID string) (types.Stream, error)

type WebSocketStream

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

func NewWebSocketStream

func NewWebSocketStream(conn *websocket.Conn, ctx context.Context) *WebSocketStream

func (*WebSocketStream) Close

func (ws *WebSocketStream) Close() error

func (*WebSocketStream) Context

func (ws *WebSocketStream) Context() context.Context

func (*WebSocketStream) Flush

func (ws *WebSocketStream) Flush() error

func (*WebSocketStream) Read

func (ws *WebSocketStream) Read(msg []byte) (int, error)

func (*WebSocketStream) Write

func (ws *WebSocketStream) Write(msg []byte) (int, error)