resolve

type Cacher[T any] struct {

	// CalcCacheKey 计算 cacheKey 的钩子, 需要调用方实现
	CalcCacheKey func(T) string

	// RecoverCacheKey 恢复 cacheKey 的钩子, 需要调用方实现
	RecoverCacheKey func(string) (T, bool)

	// FetchValue 获取指定入参的最新值钩子, 需要调用方实现
	FetchValue func(T) (string, error)

	// UpdateComplete 缓存刷新完成调用的钩子, 需要调用方实现
	UpdateComplete func(success, fail, remove int)
	// contains filtered or unexported fields
}

type CacherOption[T any] func(*Cacher[T])

type CommonM3U8 struct{}

type HandleParams struct {
	ChName      string      // 频道简称
	UrlEnv      string      // 存储远程地址的环境变量名
	ProxyM3U    bool        // 是否代理 m3u
	ProxyTs     bool        // 是否代理 ts
	TsProxyMode             // ts 代理模式
	Format      string      // 要处理的直播格式
	ClientIp    string      // 客户端 ip
	ClientHost  string      // 客户端请求的主机前缀
	Headers     http.Header // 请求头
}

type HandleResult struct {
	Type   ResultType  // 响应类型
	Url    string      // 响应地址, 用于重定向
	Code   int         // 响应状态码, 用于本地代理
	Header http.Header // 响应头, 用于本地代理
	Body   []byte      // 响应体, 用于本地代理
}

type Handler interface {

	// Handle 处理直播, 返回一个用于重定向的远程地址
	Handle(HandleParams) (HandleResult, error)

	// Name 处理器名称
	Name() string

	// HelpDoc 处理器说明文档
	HelpDoc() string

	// SupportProxy 是否支持 m3u 代理
	//
	// 如果返回 true, 会自动在帮助文档中加入标记
	SupportM3UProxy() bool

	// SupportCustomHeaders 是否支持自定义请求头
	//
	// 如果返回 true, 会自动在帮助文档中加入标记
	SupportCustomHeaders() bool

	// Enabled 标记处理器是否是启用状态
	Enabled() bool
}

type PreCacheReq[T any] struct {

	// T 调用方的业务参数
	T T
	// contains filtered or unexported fields
}

type ResultType string

type TsProxyMode string