connection

Documentation

Index

• func AddWsConn2Pool(conn *WsConnInfo) error
• func DeleteWsConnFromPool(uniqId int) error
• func HandleRead(ctx context.Context, conn *WsConnInfo, message []byte) error
• func Init(groupCount, maxConnCount int) error
• func Monitor(conn *WsConnInfo) error
• func PingWsConn(uniqId int) error
• func PongWsConn(uniqId int) error
• type ConnGroup
  • func (g *ConnGroup) AddWsConn(conn *WsConnInfo) error
  • func (g *ConnGroup) DeleteWsConn(uniqId int) error
  • func (g *ConnGroup) GetWsConn(uniqId int) (*WsConnInfo, error)
• type ConnPool
  • func (p *ConnPool) GetIndexGroup(index int) (*ConnGroup, error)
• type WsConnInfo
  • func GetWsConnFromPool(uniqId int) (*WsConnInfo, error)
  • func (conn *WsConnInfo) Close() (err error)
  • func (conn *WsConnInfo) Ping() error
  • func (conn *WsConnInfo) Pong() error
  • func (conn *WsConnInfo) Read() ([]byte, error)
  • func (conn *WsConnInfo) Write(data []byte) error

Functions

func AddWsConn2Pool

func AddWsConn2Pool(conn *WsConnInfo) error

func DeleteWsConnFromPool

func DeleteWsConnFromPool(uniqId int) error

func HandleRead

func HandleRead(ctx context.Context, conn *WsConnInfo, message []byte) error

grpc send

func Init

func Init(groupCount, maxConnCount int) error

func Monitor

func Monitor(conn *WsConnInfo) error

func PingWsConn

func PingWsConn(uniqId int) error

func PongWsConn

func PongWsConn(uniqId int) error

Types

type ConnGroup

type ConnGroup struct {
	GroupId               int
	CurrentGroupUserCount int32
	// contains filtered or unexported fields
}

func (*ConnGroup) AddWsConn

func (g *ConnGroup) AddWsConn(conn *WsConnInfo) error

func (*ConnGroup) DeleteWsConn

func (g *ConnGroup) DeleteWsConn(uniqId int) error

func (*ConnGroup) GetWsConn

func (g *ConnGroup) GetWsConn(uniqId int) (*WsConnInfo, error)

type ConnPool

type ConnPool struct {
	GroupCount            int32
	MaxLimitUserCount     int32
	CurrentTotalUserCount int32
	// contains filtered or unexported fields
}

func (*ConnPool) GetIndexGroup

func (p *ConnPool) GetIndexGroup(index int) (*ConnGroup, error)

type WsConnInfo

type WsConnInfo struct {
	UniqId    int
	Actor     int
	Timestamp int64
	EpollFd   *netpoll.Desc
	WsConn    *websocket.Conn
}

func GetWsConnFromPool

func GetWsConnFromPool(uniqId int) (*WsConnInfo, error)

func (*WsConnInfo) Close

func (conn *WsConnInfo) Close() (err error)

func (*WsConnInfo) Ping

func (conn *WsConnInfo) Ping() error

func (*WsConnInfo) Pong

func (conn *WsConnInfo) Pong() error

func (*WsConnInfo) Read

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

func (*WsConnInfo) Write

func (conn *WsConnInfo) Write(data []byte) error