cli

type Client struct {
	context.Context
	// contains filtered or unexported fields
}

type ClientOptions struct {
	NetProtocol                 NetProtocol            // NetProtocol 选择 TCP 或 WebSocket。
	TCPNoDelay                  *bool                  // TCPNoDelay 为 nil 时沿用系统默认值。
	TCPQuickAck                 *bool                  // TCPQuickAck 为 nil 时沿用系统默认值。
	TCPRecvBuf                  *int                   // TCPRecvBuf 是接收缓冲区字节数；nil 沿用系统默认值。
	TCPSendBuf                  *int                   // TCPSendBuf 是发送缓冲区字节数；nil 沿用系统默认值。
	TCPLinger                   *int                   // TCPLinger 是关闭等待秒数；nil 沿用系统默认值。
	WebSocketOrigin             string                 // WebSocketOrigin 为空时根据 endpoint 和用户 ID 生成。
	TLSConfig                   *tls.Config            // TLSConfig 非 nil 时为 TCP 或安全 WebSocket 启用 TLS。
	IOTimeout                   time.Duration          // IOTimeout 是单次网络 I/O 的超时。
	IORetryTimes                int                    // IORetryTimes 是 I/O 超时后的重试次数。
	IOBufferCap                 int                    // IOBufferCap 是断线重连时保留的发送数据字节上限。
	MsgCreator                  gtp.IMsgCreator        // MsgCreator 用于按消息 ID 创建 GTP 解码目标。
	EncCipherSuite              gtp.CipherSuite        // EncCipherSuite 是客户端提出的密码套件。
	EncSignatureAlgorithm       gtp.SignatureAlgorithm // EncSignatureAlgorithm 是客户端握手签名算法。
	EncSignaturePrivateKey      crypto.PrivateKey      // EncSignaturePrivateKey 是客户端握手签名私钥。
	EncVerifyServerSignature    bool                   // EncVerifyServerSignature 要求验证服务端握手签名。
	EncVerifySignaturePublicKey crypto.PublicKey       // EncVerifySignaturePublicKey 是服务端签名验证公钥。
	Compression                 gtp.Compression        // Compression 是客户端提出的压缩算法。
	CompressionThreshold        int                    // CompressionThreshold 是启用压缩的字节阈值；小于等于 0 时禁用。
	MaxUncompressedSize         int                    // MaxUncompressedSize 限制解压后负载，防御压缩炸弹。
	MaxPacketSize               int                    // MaxPacketSize 限制单个 GTP 包大小。
	AutoReconnect               bool                   // AutoReconnect 在连接失活后自动迁移会话连接。
	AutoReconnectInterval       time.Duration          // AutoReconnectInterval 是相邻重连尝试的间隔。
	AutoReconnectRetryTimes     int                    // AutoReconnectRetryTimes 小于等于 0 时无限重试。
	InactiveTimeout             time.Duration          // InactiveTimeout 是未启用自动重连时的失活等待时间。
	FutureTimeout               time.Duration          // FutureTimeout 是时间探测等关联请求的默认超时。
	AuthUserId                  string                 // AuthUserId 是握手提交的用户 ID。
	AuthToken                   string                 // AuthToken 是握手提交的鉴权令牌。
	AuthExtensions              []byte                 // AuthExtensions 是握手提交的扩展数据。
	AutoRecover                 bool                   // AutoRecover 控制监听器 panic 是否自动恢复。
	ReportError                 chan error             // ReportError 接收自动恢复的 panic 错误。
	DataListenerInboxSize       int                    // DataListenerInboxSize 是每个数据监听器的收件箱容量。
	EventListenerInboxSize      int                    // EventListenerInboxSize 是每个事件监听器的收件箱容量。
	Logger                      *zap.Logger            // Logger 是客户端日志器；nil 时不输出日志。
}

type DataHandler = generic.DelegateVoid1[[]byte]

type EventHandler = transport.EventHandler

type IDataIO interface {
	// Send 复制 data 并将其加入发送队列。
	Send(data []byte) error
	// Listen 注册监听器，直到 ctx 取消或客户端关闭。
	Listen(ctx context.Context, handler DataHandler) error
}

type IEventIO interface {
	// Send 将 event 加入发送队列；调用方须保证事件在处理完成前保持有效。
	Send(event transport.IEvent) error
	// Listen 注册监听器，直到 ctx 取消或客户端关闭。
	Listen(ctx context.Context, handler EventHandler) error
}

type NetAddr struct {
	Local, Remote net.Addr // Local 是客户端地址，Remote 是服务端地址。
}

type NetProtocol int32

type TimeSample struct {
	OriginTime       time.Time // OriginTime 是请求方发送请求的 t1。
	ReceiveTime      time.Time // ReceiveTime 是响应方收到请求的 t2。
	TransmitTime     time.Time // TransmitTime 是响应方发送响应的 t3。
	DestinationTime  time.Time // DestinationTime 是请求方收到响应的 t4。
	RemoteZoneOffset int       // RemoteZoneOffset 是响应方相对 UTC 的偏移秒数。
}