conn

Documentation

Index

• type Conn
• type WebSocket
  • func NewWebSocket(conn *websocket.Conn, msgType int) *WebSocket
  • func (w *WebSocket) Close() error
  • func (w *WebSocket) LocalAddr() net.Addr
  • func (w *WebSocket) ReadMessage() (p []byte, err error)
  • func (w *WebSocket) RemoteAddr() net.Addr
  • func (w *WebSocket) SetReadDeadline(t time.Time) error
  • func (w *WebSocket) SetReadLimit(limit int64)
  • func (w *WebSocket) SetWriteDeadline(t time.Time) error
  • func (w *WebSocket) Write(p []byte) (n int, err error)

Types

type Conn

type Conn interface {
	// SetWriteDeadline 写入超时
	SetWriteDeadline(t time.Time) error

	// SetReadDeadline 读取超时
	SetReadDeadline(t time.Time) error

	// SetReadLimit 读取限制
	SetReadLimit(limit int64)

	// LocalAddr 本地地址
	LocalAddr() net.Addr

	// RemoteAddr 远程地址
	RemoteAddr() net.Addr

	// ReadMessage 读取消息
	ReadMessage() (p []byte, err error)

	io.Writer
	io.Closer
}

Conn 连接

type WebSocket

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

WebSocket webSocket连接

func NewWebSocket

func NewWebSocket(conn *websocket.Conn, msgType int) *WebSocket

NewWebSocket 创建WebSocket

func (*WebSocket) Close

func (w *WebSocket) Close() error

Close 关闭连接

func (*WebSocket) LocalAddr

func (w *WebSocket) LocalAddr() net.Addr

LocalAddr 本机地址

func (*WebSocket) ReadMessage

func (w *WebSocket) ReadMessage() (p []byte, err error)

ReadMessage 读取消息

func (*WebSocket) RemoteAddr

func (w *WebSocket) RemoteAddr() net.Addr

RemoteAddr 远程地址

func (*WebSocket) SetReadDeadline

func (w *WebSocket) SetReadDeadline(t time.Time) error

SetReadDeadline 设置读取超时时间

func (*WebSocket) SetReadLimit

func (w *WebSocket) SetReadLimit(limit int64)

SetReadLimit 设置读取限制

func (*WebSocket) SetWriteDeadline

func (w *WebSocket) SetWriteDeadline(t time.Time) error

SetWriteDeadline 设置写入超时时间

func (*WebSocket) Write

func (w *WebSocket) Write(p []byte) (n int, err error)

Write 写入消息