pointsub

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

type ClientConfig struct {
	ReadTimeout       time.Duration // 读取超时时间
	WriteTimeout      time.Duration // 写入超时时间
	ConnectTimeout    time.Duration // 连接超时时间
	MaxRetries        int           // 最大重试次数
	RetryInterval     time.Duration // 重试间隔时间
	MaxBlockSize      int           // 最大数据块大小
	EnableCompression bool          // 是否启用压缩
	MaxIdleConns      int           // 最大空闲连接数
	IdleConnTimeout   time.Duration // 空闲连接超时时间
}

type ConnectionInfo struct {
	RemoteAddr string        // 远程地址
	LastActive time.Time     // 最后活跃时间
	IdleTime   time.Duration // 空闲时间
}

type LimitedConn struct {
	net.Conn // 底层连接
	// contains filtered or unexported fields
}

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

type ServerConfig struct {
	// 连接相关配置
	ReadTimeout  time.Duration // 读取超时时间
	WriteTimeout time.Duration // 写入超时时间
	MaxBlockSize int           // 最大消息大小

	// 并发控制
	MaxConcurrentConns int           // 最大并发连接数
	ConnectTimeout     time.Duration // 连接建立超时时间

	// 资源控制
	MaxRequestsPerConn int           // 每个连接最大请求数
	IdleTimeout        time.Duration // 空闲连接超时时间

	// 内存控制
	BufferPoolSize    int  // 缓冲池大小
	EnableCompression bool // 是否启用压缩

	// 连接清理相关配置
	CleanupInterval time.Duration // 清理检查间隔
	MaxIdleTime     time.Duration // 最大空闲时间

	// 告警相关配置
	MaxMemoryUsage uint64 // 最大内存使用量
}

type StreamHandler func(request []byte) (response []byte, err error)