Interface PersistenceStore

backend-go/internal/metrics/persistence.go:8–44

PersistenceStore 持久化存储接口

// PersistenceStore 持久化存储接口
type PersistenceStore interface {
	// AddRecord 添加记录到写入缓冲区（非阻塞）
	AddRecord(record PersistentRecord)

	// LoadRecords 加载指定时间范围内的记录
	LoadRecords(since time.Time, apiType string) ([]PersistentRecord, error)

	// LoadLatestTimestamps 从全量历史记录中查询每个 key 的最后成功/失败时间
	// 用于启动时补全超出 24h 窗口的时间戳
	LoadLatestTimestamps(apiType string) (map[string]*KeyLatestTimestamps, error)

	// LoadCircuitStates 加载指定 API 类型的熔断状态
	LoadCircuitStates(apiType string) (map[string]*PersistentCircuitState, error)

	// UpsertCircuitState 写入或更新熔断状态
	UpsertCircuitState(state PersistentCircuitState) error

	// QueryAggregatedHistory 查询聚合历史数据（按时间桶分组）
	// 用于 >24h 的长时间范围查询（1周/1月），内存中仅保留 24h
	QueryAggregatedHistory(apiType string, since time.Time, intervalSeconds int64, metricsKey string, baseURL string) ([]AggregatedBucket, error)

	// QueryModelAggregatedHistory 查询按模型和时间桶分组的聚合历史数据。
	QueryModelAggregatedHistory(apiType string, since time.Time, intervalSeconds int64, metricsKey string, baseURL string) ([]ModelAggregatedBucket, error)

	// CleanupOldRecords 清理过期数据
	CleanupOldRecords(before time.Time) (int64, error)

	// DeleteRecordsByMetricsKeys 按 metrics_key 和 api_type 批量删除记录（用于删除渠道时清理数据）
	// apiType: 接口类型（messages/responses/gemini），避免误删其他接口的数据
	DeleteRecordsByMetricsKeys(metricsKeys []string, apiType string) (int64, error)

	// DeleteCircuitStatesByMetricsKeys 按 metrics_key 和 api_type 批量删除熔断状态
	DeleteCircuitStatesByMetricsKeys(metricsKeys []string, apiType string) (int64, error)

	// Close 关闭存储（会先刷新缓冲区）
	Close() error
}

// KeyLatestTimestamps 每个 key 的最后成功/失败时间
type KeyLatestTimestamps struct {