metrics

type AggregatedValue struct {
	// Metric name
	Metric string `json:"metric"`

	// Group labels (if grouped)
	Labels map[string]string `json:"labels,omitempty"`

	// Aggregated value
	Value float64 `json:"value"`

	// Number of samples aggregated
	SampleCount int64 `json:"sample_count"`
}

type AggregationFunc string

type AggregationOptions struct {
	// 要聚合的指標
	Metrics []string `json:"metrics"`

	// 聚合的時間範圍
	TimeRange TimeRange `json:"time_range"`

	// 聚合函數
	Function AggregationFunc `json:"function"`

	// 按標籤分組
	GroupBy []string `json:"group_by,omitempty"`

	// 額外的篩選條件
	Filters map[string]string `json:"filters,omitempty"`
}

type AggregationResult struct {
	// Aggregation options used
	Options *AggregationOptions `json:"options"`

	// Aggregated values
	Values []AggregatedValue `json:"values"`

	// Warnings from the aggregation
	Warnings []string `json:"warnings,omitempty"`
}

type CachedResult struct {
	Result    *QueryResult
	Timestamp time.Time
}

type CircuitBreakerConfig struct {
	Enabled          bool          `yaml:"enabled" json:"enabled"`
	FailureThreshold int64         `yaml:"failure_threshold" json:"failure_threshold"`
	RecoveryTimeout  time.Duration `yaml:"recovery_timeout" json:"recovery_timeout"`
}

type CircuitBreakerState int

type DataPoint struct {
	Timestamp time.Time `json:"timestamp"`
	Value     float64   `json:"value"`
}

type DownsampledQuery struct {
	MetricQuery

	// Downsampling method (avg, max, min)
	Method string `json:"method"`

	// Target resolution
	Resolution time.Duration `json:"resolution"`
}

type HistoricalQuery struct {
	MetricQuery

	// Downsampling resolution for long-term data
	Resolution time.Duration `json:"resolution"`

	// Whether to include raw samples
	IncludeRaw bool `json:"include_raw"`
}

type HistoricalResult struct {
	QueryResult

	// Data retention information
	RetentionInfo *RetentionInfo `json:"retention_info"`
}

type LongTermMetricsProvider interface {
	MetricsProvider

	// QueryHistorical 查詢超出正常保留期的歷史數據
	QueryHistorical(ctx context.Context, query HistoricalQuery) (*HistoricalResult, error)

	// QueryDownsampled 查詢降採樣數據，在長時間範圍內獲得更好的性能
	QueryDownsampled(ctx context.Context, query DownsampledQuery) (*QueryResult, error)

	// QueryTenant 查詢特定租戶的指標（多租戶支援）
	QueryTenant(ctx context.Context, tenantID string, query MetricQuery) (*QueryResult, error)
}

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

type MetricQuery struct {
	// 指標名稱（例如："cpu_usage", "http_request_duration_seconds"）
	Metric string `json:"metric"`

	// 用於過濾的標籤（例如：{"service": "api", "env": "prod"}）
	Labels map[string]string `json:"labels"`

	// 查詢的時間範圍
	TimeRange TimeRange `json:"time_range"`

	// 範圍查詢的步長（例如：1m, 5m, 1h）
	Step time.Duration `json:"step"`

	// 聚合函數（avg, max, min, sum, count, p50, p95, p99）
	Aggregation string `json:"aggregation,omitempty"`

	// 額外的提供者特定選項
	Options map[string]interface{} `json:"options,omitempty"`
}

type MetricsProvider interface {
	// Query 執行單一指標查詢並返回結果
	Query(ctx context.Context, query MetricQuery) (*QueryResult, error)

	// BatchQuery 並行執行多個查詢以提高效率
	BatchQuery(ctx context.Context, queries []MetricQuery) ([]*QueryResult, error)

	// GetAggregation 對指標執行聚合查詢
	GetAggregation(ctx context.Context, opts AggregationOptions) (*AggregationResult, error)

	// HealthCheck 驗證指標提供者是否可訪問且功能正常
	HealthCheck(ctx context.Context) error

	// Close 釋放提供者持有的任何資源
	Close() error
}

type PrometheusConfig struct {
	// Prometheus 服務器地址
	Address string `yaml:"address" json:"address"`

	// 基本認證
	Username string `yaml:"username" json:"username"`
	Password string `yaml:"password" json:"password"`

	// Bearer Token 認證
	BearerToken string `yaml:"bearer_token" json:"bearer_token"`

	// TLS 配置
	TLS struct {
		Enabled            bool   `yaml:"enabled" json:"enabled"`
		InsecureSkipVerify bool   `yaml:"insecure_skip_verify" json:"insecure_skip_verify"`
		CertFile           string `yaml:"cert_file" json:"cert_file"`
		KeyFile            string `yaml:"key_file" json:"key_file"`
		CAFile             string `yaml:"ca_file" json:"ca_file"`
	} `yaml:"tls" json:"tls"`

	// 查詢配置
	Query struct {
		Timeout    time.Duration `yaml:"timeout" json:"timeout"`
		MaxSamples int           `yaml:"max_samples" json:"max_samples"`
	} `yaml:"query" json:"query"`

	// 快取配置
	Cache struct {
		Enabled bool          `yaml:"enabled" json:"enabled"`
		TTL     time.Duration `yaml:"ttl" json:"ttl"`
		MaxSize int           `yaml:"max_size" json:"max_size"`
	} `yaml:"cache" json:"cache"`

	// 並發控制
	Concurrency struct {
		MaxConcurrent int `yaml:"max_concurrent" json:"max_concurrent"`
	} `yaml:"concurrency" json:"concurrency"`

	// 電路斷路器配置
	CircuitBreaker CircuitBreakerConfig `yaml:"circuit_breaker" json:"circuit_breaker"`
}

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

type ProviderConfig struct {
	// Provider type: "prometheus", "mimir", "memory"
	Type string `json:"type"`

	// Provider-specific configuration
	Config interface{} `json:"config"`

	// Query routing configuration
	QueryRouter *QueryRouterConfig `json:"query_router,omitempty"`

	// Result limits configuration
	Limits *ResultLimits `json:"limits,omitempty"`
}

type QueryResult struct {
	// Query that produced this result
	Query *MetricQuery `json:"query"`

	// Series contains the time series data
	Series []TimeSeries `json:"series"`

	// Warnings from the query execution
	Warnings []string `json:"warnings,omitempty"`

	// Stats contains query statistics
	Stats *QueryStats `json:"stats,omitempty"`

	// Truncated indicates if results were truncated due to size limits
	Truncated bool `json:"truncated,omitempty"`

	// MaxSeriesExceeded indicates if max series limit was exceeded
	MaxSeriesExceeded bool `json:"max_series_exceeded,omitempty"`

	// MaxDataPointsExceeded indicates if max data points limit was exceeded
	MaxDataPointsExceeded bool `json:"max_data_points_exceeded,omitempty"`
}

type QueryRouterConfig struct {
	// Short-term query threshold in days
	ShortTermDays int `json:"short_term_days"`

	// Provider for short-term queries
	ShortTermProvider string `json:"short_term_provider"`

	// Provider for long-term queries
	LongTermProvider string `json:"long_term_provider"`
}

type QueryStats struct {
	Duration       time.Duration `json:"duration"`
	SamplesScanned int64         `json:"samples_scanned"`
	SeriesScanned  int64         `json:"series_scanned"`
}

type ResultLimits struct {
	// Maximum number of time series per query
	MaxSeries int `json:"max_series"`

	// Maximum number of data points per series
	MaxDataPointsPerSeries int `json:"max_data_points_per_series"`

	// Maximum total data points per query
	MaxTotalDataPoints int `json:"max_total_data_points"`

	// Maximum query result size in bytes
	MaxResultSizeBytes int64 `json:"max_result_size_bytes"`
}

type RetentionInfo struct {
	// Oldest available data point
	OldestDataPoint time.Time `json:"oldest_data_point"`

	// Retention policy applied
	RetentionPolicy string `json:"retention_policy"`

	// Data completeness percentage
	Completeness float64 `json:"completeness"`
}

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

type TimeRange struct {
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}

type TimeSeries struct {
	// Labels identifying this series
	Labels map[string]string `json:"labels"`

	// Values contains the data points
	Values []DataPoint `json:"values"`
}