manager

type Config struct {
	// 资源限制
	MaxStreams     int     // 最大流数量（0 表示无限制）
	MaxBandwidth   int64   // 最大总带宽（bps，0 表示无限制）
	MaxCPUPercent  float64 // 最大 CPU 使用率（0-100，0 表示无限制）
	MaxMemoryBytes int64   // 最大内存使用（字节，0 表示无限制）

	// 健康检查
	HealthCheckInterval time.Duration // 健康检查间隔
	HealthCheckTimeout  time.Duration // 健康检查超时
	UnhealthyThreshold  int           // 连续失败次数阈值

	// 重连策略
	AutoReconnect     bool          // 是否自动重连
	ReconnectDelay    time.Duration // 重连延迟
	MaxReconnectDelay time.Duration // 最大重连延迟
	MaxReconnects     int           // 最大重连次数（0 表示无限制）

	// 清理策略
	IdleTimeout  time.Duration // 空闲超时（自动停止）
	StaleTimeout time.Duration // 过期超时（自动移除）
}

type Event struct {
	Type      EventType
	StreamID  string
	Stream    *ManagedStream
	Timestamp time.Time
	Data      map[string]interface{}
	Error     error
}

type EventHandler func(Event)

type EventType string

type ManagedStream struct {
	ID       string
	Name     string
	Config   StreamConfig
	Tags     map[string]string
	Metadata map[string]interface{}
	// contains filtered or unexported fields
}

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

type ManagerStats struct {
	TotalStreams    int64         // 总流数
	ActiveStreams   int64         // 活跃流数
	FailedStreams   int64         // 失败流数
	TotalBandwidth  int64         // 总带宽
	TotalBytesIn    int64         // 总输入字节
	TotalBytesOut   int64         // 总输出字节
	TotalReconnects int64         // 总重连次数
	Uptime          time.Duration // 运行时间
	StartTime       time.Time     // 启动时间
}

type StreamConfig struct {
	ID         string                 // 流 ID（为空则自动生成）
	Name       string                 // 流名称
	InputURL   string                 // 输入 URL
	OutputURLs []string               // 输出 URL 列表
	Tags       map[string]string      // 标签
	Metadata   map[string]interface{} // 元数据

	// 重连设置（覆盖管理器默认值）
	AutoReconnect     *bool
	MaxReconnects     *int
	ReconnectDelay    *time.Duration
	MaxReconnectDelay *time.Duration
}

type StreamState int32

type StreamStats struct {
	BytesIn     int64
	BytesOut    int64
	PacketsIn   int64
	PacketsOut  int64
	FramesIn    int64
	FramesOut   int64
	Errors      int64
	Reconnects  int64
	Duration    time.Duration
	Bitrate     float64
	FPS         float64
	LastError   error
	LastErrorAt time.Time
}