network

type Agent interface {
	Run()
	OnClose()
	Close()
}

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

type ConnSet map[net.Conn]struct{}

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

type KCPServer struct {
	Addr            string
	MaxConnNum      int
	PendingWriteNum int
	NewAgent        func(*KCPConn) Agent

	// msg parser
	LenMsgLen    int
	MinMsgLen    uint32
	MaxMsgLen    uint32
	LittleEndian bool
	// contains filtered or unexported fields
}

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

type UDPAgentSet map[Agent]struct{}

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

type UDPServer struct {
	Addr       string
	MaxConnNum int
	NewAgent   func(*UDPConn) Agent

	MaxMsgLen uint32
	// contains filtered or unexported fields
}

type UDPSessionSet map[*rudpsession.Session]struct{}