network

type Agent interface {
	Run()
	OnClose()
}

type CAFile struct {
	CertFile string
	Keyfile  string
}

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

type ConnSet map[net.Conn]struct{}

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

type KCPClient struct {
	sync.Mutex
	Addr            string
	ConnNum         int
	ConnectInterval time.Duration
	PendingWriteNum int
	ReadDeadline    time.Duration
	WriteDeadline   time.Duration
	AutoReconnect   bool
	NewAgent        func(conn *NetConn) Agent

	// msg parser
	MsgParser
	// contains filtered or unexported fields
}

type KCPServer struct {
	NewAgent func(Conn) Agent
	// contains filtered or unexported fields
}

type KcpCfg struct {
	ListenAddr string // 监听地址
	MaxConnNum int    //最大连接数
	NoDelay    *NoDelayCfg

	Mtu               *int           // mtu大小
	SndWndSize        *int           // 发送窗口大小,默认1024
	RcvWndSize        *int           // 接收窗口大小,默认1024
	ReadDeadlineMill  *time.Duration // 读超时毫秒
	WriteDeadlineMill *time.Duration // 写超时毫秒
	StreamMode        *bool          // 是否打开流模式,默认true
	DSCP              *int           // 差分服务代码点，默认46
	ReadBuffSize      *int           // 读Buff大小,默认
	WriteBuffSize     *int           // 写Buff大小

	// 用于 FEC（前向纠错）的数据分片和校验分片数量,，默认10,0
	DataShards   *int
	ParityShards *int

	LittleEndian    bool   //是否小端序
	LenMsgLen       int    //消息头占用byte数量，只能是1byte,2byte,4byte。如果是4byte，意味着消息最大可以是math.MaxUint32(4GB)
	MinMsgLen       uint32 //最小消息长度
	MaxMsgLen       uint32 //最大消息长度,超过判定不合法,断开连接
	PendingWriteNum int    //写channel最大消息数量
}

type MsgParser struct {
	LenMsgLen    int
	MinMsgLen    uint32
	MaxMsgLen    uint32
	LittleEndian bool

	bytespool.IBytesMemPool
}

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

type NoDelayCfg struct {
	NoDelay           int // 是否启用 nodelay模式，0不启用；1启用
	IntervalMill      int // 协议内部工作的 interval，单位毫秒，比如 10ms或者 20ms
	Resend            int // 快速重传模式，默认0关闭，可以设置2（2次ACK跨越将会直接重传）
	CongestionControl int // 是否关闭流控，默认是0代表不关闭，1代表关闭
}

type TCPClient struct {
	sync.Mutex
	Addr            string
	ConnNum         int
	ConnectInterval time.Duration
	PendingWriteNum int
	ReadDeadline    time.Duration
	WriteDeadline   time.Duration
	AutoReconnect   bool
	NewAgent        func(conn *NetConn) Agent

	// msg parser
	MsgParser
	// contains filtered or unexported fields
}

type TCPServer struct {
	Addr            string
	MaxConnNum      int
	PendingWriteNum int
	ReadDeadline    time.Duration
	WriteDeadline   time.Duration

	NewAgent func(conn Conn) Agent

	MsgParser
	// contains filtered or unexported fields
}

type WSClient struct {
	sync.Mutex
	Addr             string
	ConnNum          int
	ConnectInterval  time.Duration
	PendingWriteNum  int
	MaxMsgLen        uint32
	MessageType      int
	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 WSHandler struct {
	// contains filtered or unexported fields
}

type WSServer struct {
	Addr            string
	MaxConnNum      int
	PendingWriteNum int
	MaxMsgLen       uint32
	CertFile        string
	KeyFile         string
	NewAgent        func(*WSConn) Agent

	HandshakeTimeout time.Duration
	ReadTimeout      time.Duration
	WriteTimeout     time.Duration
	// contains filtered or unexported fields
}

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