websocket

type Callback func(client *Client, message []byte)

type Client struct {
	Addr         string // client address
	User         string
	Socket       *websocket.Conn // user connection
	IsActive     bool
	Send         chan []byte // data to send
	AccessTime   int64       // access timestamp
	OnDisconnect func(*Client)
}

type ConnManagerIface interface {
	Register(cli *Client)
	Unregister(cli *Client)
	Heartbeat(cli *Client)
	DestroyTask()
	BroadcastSession(sessionID string, msg []byte)
}

type RecvMsg struct {
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}

type SendMsg struct {
	Status  int8   `json:"status"`
	MsgFrom string `json:"msg_from"`
	Msg     string `json:"msg"`
}

type Server struct {
	Register    chan *Client     // register connection handler
	Unregister  chan *Client     // unregister connection handler
	Heartbeat   chan *Client     // heartbeat handler
	ConnManager ConnManagerIface // connection manager
}

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