zNet

type CloseCallBackFunc func(c *TcpServerSession)

type Config struct {
	MaxPacketDataSize int32  `toml:"max_packet_data_size" json:"max_packet_data_size"` //default 1024*1024
	ListenAddress     string `toml:"listen_address" json:"listen_address"`             //default ":9016"
	MaxClientCount    int32  `toml:"max_client_count" json:"max_client_count"`         //default 10000
	ChanSize          int32  `toml:"chan_size" json:"chan_size"`                       //session receive and send chanel size, default 2048
	HeartbeatDuration int    `toml:"heartbeat_duration" json:"heartbeat_duration"`     //default 30s
}

type HandlerFun func(session Session, protoId int32, data []byte)

type LogPrintFunc func(v ...any)

type NetPacket struct {
	ProtoId  int32  `json:"proto_id"`
	DataSize int32  `json:"data_size"`
	Data     []byte `json:"data"`
}

type Options func(*TcpServer)

type Session interface {
	Send(protoId int32, data []byte) error
	GetSid() SessionIdType
}

type SessionCallBackFunc func(sid SessionIdType)

type SessionIdType int64

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

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

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

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