storage

type AggregationResult struct {
	Function  string            `json:"function"`
	Filters   map[string]string `json:"filters"`
	Value     float64           `json:"value"`
	Count     int               `json:"count"`
	Timestamp time.Time         `json:"timestamp"`
}

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

type MemoryStorageBackup struct {
	Timestamp time.Time          `json:"timestamp"`
	Entries   []*MetricEntry     `json:"entries"`
	Stats     MemoryStorageStats `json:"stats"`
}

type MemoryStorageConfig struct {
	MaxEntries      int           `json:"max_entries"      yaml:"max_entries"`
	Retention       time.Duration `json:"retention"        yaml:"retention"`
	CleanupInterval time.Duration `json:"cleanup_interval" yaml:"cleanup_interval"`
	EnableStats     bool          `json:"enable_stats"     yaml:"enable_stats"`
}

type MemoryStorageStats struct {
	EntriesCount     int64         `json:"entries_count"`
	MaxEntries       int           `json:"max_entries"`
	StorageSize      int64         `json:"storage_size"`
	TotalWrites      int64         `json:"total_writes"`
	TotalReads       int64         `json:"total_reads"`
	TotalDeletes     int64         `json:"total_deletes"`
	CleanupRuns      int64         `json:"cleanup_runs"`
	LastCleanup      time.Time     `json:"last_cleanup"`
	AverageEntrySize float64       `json:"average_entry_size"`
	OldestEntry      time.Time     `json:"oldest_entry"`
	NewestEntry      time.Time     `json:"newest_entry"`
	MemoryUsage      int64         `json:"memory_usage"`
	HitRate          float64       `json:"hit_rate"`
	Uptime           time.Duration `json:"uptime"`
	// contains filtered or unexported fields
}

type MetricEntry struct {
	Name        string            `json:"name"`
	Type        shared.MetricType `json:"type"`
	Value       any               `json:"value"`
	Tags        map[string]string `json:"tags"`
	Timestamp   time.Time         `json:"timestamp"`
	LastUpdated time.Time         `json:"last_updated"`
	AccessCount int64             `json:"access_count"`
	Metadata    map[string]any    `json:"metadata"`
}

type MetricsAggregation struct {
	Function string            `json:"function"`
	Filters  map[string]string `json:"filters"`
	GroupBy  []string          `json:"group_by"`
}

type MetricsQuery struct {
	Filters   map[string]string `json:"filters"`
	StartTime time.Time         `json:"start_time"`
	EndTime   time.Time         `json:"end_time"`
	SortBy    string            `json:"sort_by"`
	SortOrder string            `json:"sort_order"`
	Limit     int               `json:"limit"`
	Offset    int               `json:"offset"`
}

type MetricsStorage interface {
	Store(ctx context.Context, entry *MetricEntry) error
	Retrieve(ctx context.Context, name string, tags map[string]string) (*MetricEntry, error)
	Delete(ctx context.Context, name string, tags map[string]string) error
	List(ctx context.Context, filters map[string]string) ([]*MetricEntry, error)
	Count(ctx context.Context) (int64, error)
	Clear(ctx context.Context) error
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Health(ctx context.Context) error
	Stats(ctx context.Context) (any, error)
}

type QueryResult struct {
	Entries    []*MetricEntry `json:"entries"`
	TotalCount int            `json:"total_count"`
	Query      MetricsQuery   `json:"query"`
	Timestamp  time.Time      `json:"timestamp"`
}

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

type RedisStorageBackup struct {
	Timestamp time.Time         `json:"timestamp"`
	Entries   []*MetricEntry    `json:"entries"`
	Stats     RedisStorageStats `json:"stats"`
}

type RedisStorageConfig struct {
	Address         string        `json:"address"          yaml:"address"`
	Password        string        `json:"password"         yaml:"password"`
	Database        int           `json:"database"         yaml:"database"`
	KeyPrefix       string        `json:"key_prefix"       yaml:"key_prefix"`
	PoolSize        int           `json:"pool_size"        yaml:"pool_size"`
	MinIdleConns    int           `json:"min_idle_conns"   yaml:"min_idle_conns"`
	MaxRetries      int           `json:"max_retries"      yaml:"max_retries"`
	DialTimeout     time.Duration `json:"dial_timeout"     yaml:"dial_timeout"`
	ReadTimeout     time.Duration `json:"read_timeout"     yaml:"read_timeout"`
	WriteTimeout    time.Duration `json:"write_timeout"    yaml:"write_timeout"`
	Retention       time.Duration `json:"retention"        yaml:"retention"`
	CleanupInterval time.Duration `json:"cleanup_interval" yaml:"cleanup_interval"`
	EnableStats     bool          `json:"enable_stats"     yaml:"enable_stats"`
}

type RedisStorageStats struct {
	Address          string        `json:"address"`
	Connected        bool          `json:"connected"`
	PoolSize         int           `json:"pool_size"`
	TotalConns       int           `json:"total_conns"`
	IdleConns        int           `json:"idle_conns"`
	StaleConns       int           `json:"stale_conns"`
	EntriesCount     int64         `json:"entries_count"`
	TotalWrites      int64         `json:"total_writes"`
	TotalReads       int64         `json:"total_reads"`
	TotalDeletes     int64         `json:"total_deletes"`
	FailedWrites     int64         `json:"failed_writes"`
	FailedReads      int64         `json:"failed_reads"`
	FailedDeletes    int64         `json:"failed_deletes"`
	CleanupRuns      int64         `json:"cleanup_runs"`
	LastCleanup      time.Time     `json:"last_cleanup"`
	AverageEntrySize float64       `json:"average_entry_size"`
	KeyspaceSize     int64         `json:"keyspace_size"`
	HitRate          float64       `json:"hit_rate"`
	Uptime           time.Duration `json:"uptime"`
	// contains filtered or unexported fields
}

type TimeAggregationData struct {
	Name     string            `json:"name"`
	Tags     map[string]string `json:"tags"`
	Function string            `json:"function"`
	Windows  []*TimeWindow     `json:"windows"`
}

type TimeAggregationQuery struct {
	Filters  map[string]string `json:"filters"`
	Start    time.Time         `json:"start"`
	End      time.Time         `json:"end"`
	Step     time.Duration     `json:"step"`
	Function string            `json:"function"`
}

type TimeAggregationResult struct {
	Data      []*TimeAggregationData `json:"data"`
	Query     TimeAggregationQuery   `json:"query"`
	Timestamp time.Time              `json:"timestamp"`
}

type TimeRangeQuery struct {
	Filters map[string]string `json:"filters"`
	Start   time.Time         `json:"start"`
	End     time.Time         `json:"end"`
	Step    time.Duration     `json:"step"`
}

type TimeRangeResult struct {
	Data      []*TimeSeriesData `json:"data"`
	Query     TimeRangeQuery    `json:"query"`
	Timestamp time.Time         `json:"timestamp"`
}

type TimeSeries struct {
	Name        string                `json:"name"`
	Tags        map[string]string     `json:"tags"`
	Type        shared.MetricType     `json:"type"`
	Unit        string                `json:"unit"`
	Points      []*TimeSeriesPoint    `json:"points"`
	Buckets     map[int64]*TimeWindow `json:"buckets"`
	Created     time.Time             `json:"created"`
	Updated     time.Time             `json:"updated"`
	AccessCount int64                 `json:"access_count"`
	Metadata    map[string]any        `json:"metadata"`
	// contains filtered or unexported fields
}

type TimeSeriesData struct {
	Name   string             `json:"name"`
	Tags   map[string]string  `json:"tags"`
	Points []*TimeSeriesPoint `json:"points"`
}

type TimeSeriesPoint struct {
	Timestamp time.Time         `json:"timestamp"`
	Value     float64           `json:"value"`
	Tags      map[string]string `json:"tags,omitempty"`
	Metadata  map[string]any    `json:"metadata,omitempty"`
}

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

type TimeSeriesStorageConfig struct {
	Retention          time.Duration `json:"retention"             yaml:"retention"`
	Resolution         time.Duration `json:"resolution"            yaml:"resolution"`
	MaxSeries          int           `json:"max_series"            yaml:"max_series"`
	MaxPointsPerSeries int           `json:"max_points_per_series" yaml:"max_points_per_series"`
	CompressionEnabled bool          `json:"compression_enabled"   yaml:"compression_enabled"`
	CompressionDelay   time.Duration `json:"compression_delay"     yaml:"compression_delay"`
	CleanupInterval    time.Duration `json:"cleanup_interval"      yaml:"cleanup_interval"`
	EnableStats        bool          `json:"enable_stats"          yaml:"enable_stats"`
}

type TimeSeriesStorageStats struct {
	SeriesCount       int64         `json:"series_count"`
	TotalPoints       int64         `json:"total_points"`
	CompressedPoints  int64         `json:"compressed_points"`
	TotalWrites       int64         `json:"total_writes"`
	TotalReads        int64         `json:"total_reads"`
	TotalDeletes      int64         `json:"total_deletes"`
	RejectedSeries    int64         `json:"rejected_series"`
	CompressionRuns   int64         `json:"compression_runs"`
	CleanupRuns       int64         `json:"cleanup_runs"`
	LastCleanup       time.Time     `json:"last_cleanup"`
	LastCompression   time.Time     `json:"last_compression"`
	AverageSeriesSize float64       `json:"average_series_size"`
	OldestPoint       time.Time     `json:"oldest_point"`
	NewestPoint       time.Time     `json:"newest_point"`
	CompressionRatio  float64       `json:"compression_ratio"`
	MemoryUsage       int64         `json:"memory_usage"`
	Uptime            time.Duration `json:"uptime"`
	// contains filtered or unexported fields
}

type TimeWindow struct {
	Start      time.Time `json:"start"`
	End        time.Time `json:"end"`
	Count      int64     `json:"count"`
	Sum        float64   `json:"sum"`
	Min        float64   `json:"min"`
	Max        float64   `json:"max"`
	Mean       float64   `json:"mean"`
	StdDev     float64   `json:"stddev"`
	Compressed bool      `json:"compressed"`
}