websocket

Documentation

Index

• Constants
• func Acceptor(limit int64, verifier Verifier) acceptor.Dialer
• func Connector() connector.Dialer
• type Conn
  • func (conn *Conn) Addr() string
  • func (conn *Conn) Close() error
  • func (conn *Conn) Data() *sync.Map
  • func (conn *Conn) Deadline(time time.Time) error
  • func (conn *Conn) Read() ([]byte, error)
  • func (conn *Conn) Write(stream []byte) error
• type Listener
  • func (listener *Listener) Accept() (session.Conn, error)
  • func (listener *Listener) Close() error
• type Verifier

Constants

const HandshakeTimeout = time.Second * 3

握手超时时间

const Path = "/ws"

响应路径

Functions

func Acceptor

func Acceptor(limit int64, verifier Verifier) acceptor.Dialer

func Connector

func Connector() connector.Dialer

Types

type Conn

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

func (*Conn) Addr

func (conn *Conn) Addr() string

func (*Conn) Close

func (conn *Conn) Close() error

func (*Conn) Data

func (conn *Conn) Data() *sync.Map

func (*Conn) Deadline

func (conn *Conn) Deadline(time time.Time) error

func (*Conn) Read

func (conn *Conn) Read() ([]byte, error)

func (*Conn) Write

func (conn *Conn) Write(stream []byte) error

type Listener

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

侦听器

func (*Listener) Accept

func (listener *Listener) Accept() (session.Conn, error)

获取会话

func (*Listener) Close

func (listener *Listener) Close() error

停止服务

type Verifier

type Verifier func(*gin.Context) (*sync.Map, bool)