sse

type Client struct {
	// ID 客户端唯一标识
	ID string
	// ResponseWriter 客户端连接的响应写入器
	ResponseWriter http.ResponseWriter
	// Request 客户端请求
	Request *http.Request
	// MessageChan 消息通道
	MessageChan chan *Event
	// Disconnected 断开连接信号
	Disconnected chan struct{}
	// CloseOnce 确保只关闭一次
	CloseOnce sync.Once
	// LastEventID 最后接收的事件ID
	LastEventID string
	// EventFilters 事件过滤器，只接收指定事件
	EventFilters []string
	// contains filtered or unexported fields
}

type ClientOption func(*Client)

type Config struct {
	// HistorySize 历史记录大小
	HistorySize int
	// PingTimeout 心跳超时时间
	PingTimeout time.Duration
	// PingInterval 心跳间隔
	PingInterval time.Duration
	// RetryInterval 重试间隔（毫秒）
	RetryInterval int
}

type Event struct {
	// Event 事件名称
	Event string `json:"event"`
	// Data 事件数据
	Data any `json:"data"`
	// ID 事件ID
	ID string `json:"id"`
	// Retry 重试时间（毫秒）
	Retry int `json:"retry"`
}

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