network

type Agent interface {
	OnInit()
	React([]byte)
	OnClose()
}

type Conn interface {
	ReadMsg(buf []byte) ([]byte, error)
	WriteMsg(msg []byte) error
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	Close() error
}

type ConnSet map[net.Conn]struct{}

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

type Processor interface {
	// must goroutine safe
	Route(buf []byte, userData interface{}) error
	// must goroutine safe
	Unmarshal(buf []byte) ([]byte, error)
	// must goroutine safe
	Marshal(msg []byte) ([]byte, error)
}

type TCPClient struct {
	sync.Mutex
	Addr            string
	ConnNum         int
	ConnectInterval time.Duration
	PendingWriteNum int
	AutoReconnect   bool
	NewAgent        func(Conn) Agent

	// msg parser
	LenMsgLen      int
	MinMsgLen      uint32
	MaxMsgLen      uint32
	LittleEndian   bool
	LenMsgLenInMsg bool // if the msg len contain in "header" len

	Client_log bool
	ChanStop   bool
	// contains filtered or unexported fields
}

type TCPConn struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TCPServer struct {
	Addr       string
	MaxConnNum int
	NewAgent   func(Conn) Agent

	// msg parser
	LenMsgLen      int
	MinMsgLen      uint32
	MaxMsgLen      uint32
	LittleEndian   bool
	LenMsgLenInMsg bool // if the msg len contain in "header" len

	ChanStop bool
	gnet.EventHandler
	Close func()
	// contains filtered or unexported fields
}

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
	// contains filtered or unexported fields
}

type WSServer struct {
	Addr        string
	MaxConnNum  int
	MaxMsgLen   uint32
	CertFile    string
	KeyFile     string
	CaFile      string
	HTTPTimeout time.Duration
	NewAgent    func(Conn) Agent

	ConnNum int32
	gnet.EventHandler
	Close func()
	// contains filtered or unexported fields
}