metrics

type AggregatedMetrics struct {
	ExtensionName string            `json:"extension_name"`
	MetricType    string            `json:"metric_type"`
	Values        []TimeSeriesPoint `json:"values"`
	Aggregation   string            `json:"aggregation"` // "sum", "avg", "max", "min", "count", "raw"
}

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

type ExtensionMetrics struct {
	Name          string    `json:"name"`
	LoadTime      int64     `json:"load_time_ms"`   // Load time in milliseconds
	InitTime      int64     `json:"init_time_ms"`   // Init time in milliseconds
	LoadedAt      time.Time `json:"loaded_at"`      // When extension was loaded
	InitializedAt time.Time `json:"initialized_at"` // When extension was initialized
	Status        string    `json:"status"`         // "loading", "active", "failed", "stopped"

	// Atomic counters for concurrent access (use atomic.Int64 internally but convert for JSON)
	ServiceCalls        int64 `json:"service_calls"`
	ServiceErrors       int64 `json:"service_errors"`
	EventsPublished     int64 `json:"events_published"`
	EventsReceived      int64 `json:"events_received"`
	CircuitBreakerTrips int64 `json:"circuit_breaker_trips"`
	// contains filtered or unexported fields
}

type HealthStatus struct {
	Enabled       bool              `json:"enabled"`
	StorageType   string            `json:"storage_type"`
	StorageHealth string            `json:"storage_health"` // "healthy", "degraded", "unhealthy"
	LastError     *MetricError      `json:"last_error,omitempty"`
	Stats         map[string]any    `json:"stats"`
	Extensions    map[string]string `json:"extensions"` // extension_name -> status
}

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

type MetricError struct {
	Operation string    `json:"operation"` // "store", "query", "cleanup", etc.
	Message   string    `json:"message"`
	Timestamp time.Time `json:"timestamp"`
	Err       error     `json:"-"` // Original error (not serialized)
}

type QueryOptions struct {
	ExtensionName string            `json:"extension_name,omitempty"`
	MetricType    string            `json:"metric_type,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
	StartTime     time.Time         `json:"start_time"`
	EndTime       time.Time         `json:"end_time"`
	Aggregation   string            `json:"aggregation"` // "sum", "avg", "max", "min", "count", "raw"
	Interval      time.Duration     `json:"interval"`    // aggregation interval (0 = no interval aggregation)
	Limit         int               `json:"limit"`       // maximum number of results
}

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

type Snapshot struct {
	ExtensionName string            `json:"extension_name"`
	MetricType    string            `json:"metric_type"`
	Value         int64             `json:"value"`
	Labels        map[string]string `json:"labels,omitempty"`
	Timestamp     time.Time         `json:"timestamp"`
}

type Storage interface {
	// Store single metric snapshot
	Store(snapshot *Snapshot) error

	// StoreBatch stores multiple snapshots efficiently
	StoreBatch(snapshots []*Snapshot) error

	// Query historical metrics with aggregation and filtering
	Query(opts *QueryOptions) ([]*AggregatedMetrics, error)

	// GetLatest retrieves latest metrics for an extension
	GetLatest(extensionName string, limit int) ([]*Snapshot, error)

	// Cleanup removes old metrics before the specified time
	Cleanup(before time.Time) error

	// GetStats returns storage statistics and health information
	GetStats() map[string]any
}

type StorageStats struct {
	Type        string     `json:"type"`                   // "memory", "redis", etc.
	Total       int64      `json:"total"`                  // Total number of stored snapshots
	Keys        int        `json:"keys"`                   // Number of storage keys
	MemoryMB    float64    `json:"memory_mb"`              // Memory usage in MB
	Retention   string     `json:"retention"`              // Retention policy
	LastCleanup *time.Time `json:"last_cleanup,omitempty"` // Last cleanup time
	Errors      int64      `json:"errors"`                 // Number of storage errors
}

type SystemMetrics struct {
	StartTime          time.Time `json:"start_time"`
	MemoryUsageMB      int64     `json:"memory_usage_mb"`
	GoroutineCount     int       `json:"goroutine_count"`
	GCCycles           uint32    `json:"gc_cycles"`
	ServicesRegistered int       `json:"services_registered"`
	ServiceCacheHits   int64     `json:"service_cache_hits"`
	ServiceCacheMisses int64     `json:"service_cache_misses"`
}

type TimeSeriesPoint struct {
	Timestamp time.Time `json:"timestamp"`
	Value     int64     `json:"value"`
}