network

type Agent interface {
	Run()
	OnClose()
}

type Conn interface {
	ReadMsg() (int, []byte, error)
	WriteMsg(args *common.TWSData) error
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	Close()
	Destroy()
}

type Processor interface {
	// must goroutine safe
	Route(msg interface{}, userData interface{}) error
	// must goroutine safe
	Unmarshal(data []byte) (interface{}, error)
	UnmarshalMul(nType int, data []byte) (interface{}, error)
	// must goroutine safe
	Marshal(msg interface{}) (*common.TWSData, error)
	// 是否使用压解包模式
	UsePacketMode() bool
}

type WSClient struct {
	sync.Mutex
	Addr             string
	ConnNum          int
	ConnectInterval  time.Duration
	PendingWriteNum  int
	MaxMsgLen        uint32
	HandshakeTimeout time.Duration
	AutoReconnect    bool
	NewAgent         func(*WSConn) Agent
	// contains filtered or unexported fields
}

type WSConn struct {
	sync.Mutex

	//add by hl
	SessionId string
	AppParam  common.TAppParam
	AppURL    string
	CookieVal string
	// contains filtered or unexported fields
}

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

type WSServer struct {
	Addr            string
	MaxConnNum      int
	PendingWriteNum int
	MaxMsgLen       uint32
	HTTPTimeout     time.Duration
	CertFile        string
	KeyFile         string
	NewAgent        func(*WSConn) Agent
	// contains filtered or unexported fields
}

type WebsocketConnSet map[*websocket.Conn]struct{}