websocket

Documentation

Index

• type Connection
  • func NewConnection(conn *websocket.Conn, errChan chan error) *Connection
  • func Upgrade(ctx *gin.Context, errChan chan error) (success bool, connection *Connection)
  • func (c *Connection) Close()
  • func (c *Connection) Read() <-chan []byte
  • func (c *Connection) Serve()
  • func (c *Connection) Write(jsonBytes []byte)

Types

type Connection

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

func NewConnection

func NewConnection(conn *websocket.Conn, errChan chan error) *Connection

func Upgrade

func Upgrade(ctx *gin.Context, errChan chan error) (success bool, connection *Connection)

Upgrade 将HTTP连接升级为Websocket连接

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Read

func (c *Connection) Read() <-chan []byte

func (*Connection) Serve

func (c *Connection) Serve()

Serve 启动WebsocketConnection的服务协程

func (*Connection) Write

func (c *Connection) Write(jsonBytes []byte)