ws

package

v0.0.0-...-73ddb9c Latest Latest Go to latest Published: Jun 23, 2021 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func DelConn(sessionID string) error

DelConn 删除 ConnWrapper，找不到也返回 nil

func WriteToUser(userID int64, v interface{}) error

WriteToUser 将信息写给某个 user 的所有 session

type ConnWrapper struct {
	SessionID string
	UserID    int64
	// contains filtered or unexported fields
}

func GetConn(sessionID string) *ConnWrapper

GetConn 获得 ConnWrapper，找不到则返回 nil

func GetConnByUserID(userID int64) []*ConnWrapper

GetConnByUserID 获得某个 user 的全部 conn

func New(sessionID string, userID int64, conn *websocket.Conn) *ConnWrapper

func PutConn(sessionID string, userID int64, conn *websocket.Conn) *ConnWrapper

PutConn 加入新的 ConnWrapper

func (wrapper *ConnWrapper) Close() error

Close 关闭连接，返回 conn.Close 的错误

func (wrapper *ConnWrapper) Start()

Start 开始遍历消息队列

func (wrapper *ConnWrapper) Write(v interface{}) error

Write 向消息队列中写入 json object 的指针