observability

type ActionType int

type Alert struct {
	RuleName   string                 `json:"rule_name"`
	Service    string                 `json:"service"`
	Operation  string                 `json:"operation"`
	Severity   AlertSeverity          `json:"severity"`
	State      AlertState             `json:"state"`
	Message    string                 `json:"message"`
	Timestamp  time.Time              `json:"timestamp"`
	Values     map[string]float64     `json:"values"`
	Dimensions map[string]string      `json:"dimensions"`
	Actions    []AlertAction          `json:"actions"`
	Context    map[string]interface{} `json:"context"`
}

type AlertAction struct {
	Type    ActionType             `json:"type"`
	Config  map[string]interface{} `json:"config"`
	Enabled bool                   `json:"enabled"`
}

type AlertHistory struct {
	RuleName         string     `json:"rule_name"`
	LastFired        time.Time  `json:"last_fired"`
	LastResolved     time.Time  `json:"last_resolved"`
	FireCount        int        `json:"fire_count"`
	CurrentState     AlertState `json:"current_state"`
	LastLatency      float64    `json:"last_latency_ms"`
	LastP95          float64    `json:"last_p95_ms"`
	LastP99          float64    `json:"last_p99_ms"`
	ConsecutiveFires int        `json:"consecutive_fires"`
}

type AlertRequest struct {
	Type        string                 `json:"type"`
	Severity    string                 `json:"severity"`
	Priority    string                 `json:"priority,omitempty"`
	Title       string                 `json:"title"`
	Description string                 `json:"description"`
	Message     string                 `json:"message,omitempty"`
	Service     string                 `json:"service"`
	Region      string                 `json:"region"`
	Source      string                 `json:"source"`
	RunbookURL  string                 `json:"runbook_url,omitempty"`
	Dimensions  map[string]string      `json:"dimensions,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	Values      map[string]float64     `json:"values,omitempty"`
	Thresholds  map[string]float64     `json:"thresholds,omitempty"`
}

type AlertRoute struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Enabled     bool   `json:"enabled"`

	// Matching criteria
	AlertTypes     []string `json:"alert_types,omitempty"`     // error_rate, latency, cost, etc.
	SeverityLevels []string `json:"severity_levels,omitempty"` // critical, error, warning, info
	Services       []string `json:"services,omitempty"`        // api, federation, etc.
	Priorities     []string `json:"priorities,omitempty"`      // P0, P1, P2, P3

	// Delivery configuration
	WebhookURLs    []string `json:"webhook_urls"`
	SNSTopicARNs   []string `json:"sns_topic_arns,omitempty"`
	EmailAddresses []string `json:"email_addresses,omitempty"`
	SlackChannels  []string `json:"slack_channels,omitempty"`

	// Timing and throttling
	Throttle        *ThrottleConfig   `json:"throttle,omitempty"`
	Schedule        *ScheduleConfig   `json:"schedule,omitempty"`
	EscalationRules []*EscalationRule `json:"escalation_rules,omitempty"`
}

type AlertRule struct {
	Name          string        `json:"name"`
	Operation     string        `json:"operation"`
	Service       string        `json:"service"`
	Threshold     float64       `json:"threshold_ms"`
	P95Threshold  float64       `json:"p95_threshold_ms"`
	P99Threshold  float64       `json:"p99_threshold_ms"`
	WindowSize    time.Duration `json:"window_size"`
	MinDataPoints int           `json:"min_data_points"`
	AlertCooldown time.Duration `json:"alert_cooldown"`
	Severity      AlertSeverity `json:"severity"`
	Enabled       bool          `json:"enabled"`
	Conditions    []Condition   `json:"conditions"`
	Actions       []AlertAction `json:"actions"`
}

type AlertSeverity int

type AlertState int

type AlertStats struct {
	TotalAlerts         int64
	ActiveAlerts        int64
	ResolvedAlerts      int64
	CriticalAlerts      int64
	WarningAlerts       int64
	InfoAlerts          int64
	DeliverySuccessRate float64
	AverageResponseTime time.Duration
}

type AlertSummary struct {
	AlertID    string    `json:"alert_id"`
	Type       string    `json:"type"`
	Severity   string    `json:"severity"`
	Priority   string    `json:"priority"`
	Status     string    `json:"status"`
	Title      string    `json:"title"`
	Service    string    `json:"service"`
	FiredAt    time.Time `json:"fired_at"`
	RunbookURL string    `json:"runbook_url,omitempty"`
}

type AlertingConfig struct {
	Logger         *zap.Logger
	DB             core.DB
	TableName      string
	CostService    *cost.TrackingService
	SNSClient      snsPublishAPI
	SNSTopicArn    string
	WebhookURL     string
	WebhookHeaders map[string]string
	Environment    string
	Region         string
	ServiceName    string
	Enabled        bool
}

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

type AnnotationConfig struct {
	Horizontal []HorizontalAnnotation `json:"horizontal,omitempty"`
	Vertical   []VerticalAnnotation   `json:"vertical,omitempty"`
}

type AxisConfig struct {
	Min   float64 `json:"min,omitempty"`
	Max   float64 `json:"max,omitempty"`
	Label string  `json:"label,omitempty"`
}

type CacheMetrics struct {
	HitRate      float64 `json:"hit_rate"`
	MissRate     float64 `json:"miss_rate"`
	TotalHits    int64   `json:"total_hits"`
	TotalMisses  int64   `json:"total_misses"`
	EvictionRate float64 `json:"eviction_rate"`
}

type CapacityMetrics struct {
	ReadCapacityUnits     float64 `json:"read_capacity_units"`
	WriteCapacityUnits    float64 `json:"write_capacity_units"`
	ReadThrottles         int64   `json:"read_throttles"`
	WriteThrottles        int64   `json:"write_throttles"`
	ConsumedReadCapacity  float64 `json:"consumed_read_capacity"`
	ConsumedWriteCapacity float64 `json:"consumed_write_capacity"`
}

type Condition struct {
	Type       ConditionType `json:"type"`                 // "latency", "error_rate", "throughput"
	Operator   string        `json:"operator"`             // ">", "<", ">=", "<=", "=="
	Value      float64       `json:"value"`                // Threshold value
	Percentile string        `json:"percentile,omitempty"` // "p50", "p95", "p99"
}

type ConditionType int

type DashboardConfig struct {
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Widgets     []DashboardWidget      `json:"widgets"`
	Period      int                    `json:"period"`
	Region      string                 `json:"region"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

type DashboardWidget struct {
	Type       string                 `json:"type"`
	X          int                    `json:"x"`
	Y          int                    `json:"y"`
	Width      int                    `json:"width"`
	Height     int                    `json:"height"`
	Properties DashboardWidgetProps   `json:"properties"`
	Metadata   map[string]interface{} `json:"metadata,omitempty"`
}

type DashboardWidgetProps struct {
	Title       string            `json:"title"`
	View        string            `json:"view,omitempty"`
	Stacked     bool              `json:"stacked,omitempty"`
	Region      string            `json:"region"`
	Period      int               `json:"period,omitempty"`
	Stat        string            `json:"stat,omitempty"`
	YAxis       *YAxisConfig      `json:"yAxis,omitempty"`
	Metrics     [][]interface{}   `json:"metrics"`
	Annotations *AnnotationConfig `json:"annotations,omitempty"`
}

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

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

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

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

type EMFCloudWatchMetrics struct {
	Namespace  string                `json:"Namespace"`
	Dimensions [][]string            `json:"Dimensions"`
	Metrics    []EMFMetricDefinition `json:"Metrics"`
}

type EMFDimension struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type EMFLog struct {
	AWS        EMFMetadata            `json:"_aws"`
	Timestamp  int64                  `json:"Timestamp,omitempty"`
	Dimensions map[string]string      `json:",inline"`
	Metrics    map[string]interface{} `json:",inline"`
}

type EMFLogEntry struct {
	AWS        EMFMetadata            `json:"_aws"`
	Timestamp  int64                  `json:"timestamp,omitempty"`
	Message    string                 `json:"message,omitempty"`
	Level      string                 `json:"level,omitempty"`
	Service    string                 `json:"service"`
	Namespace  string                 `json:"namespace"`
	Dimensions map[string]string      `json:"dimensions,omitempty"`
	Metrics    map[string]interface{} `json:"metrics"`
	Properties map[string]interface{} `json:"properties,omitempty"`
}

type EMFMetadata struct {
	Timestamp         int64                  `json:"Timestamp"`
	LogGroup          string                 `json:"LogGroup,omitempty"`
	LogStream         string                 `json:"LogStream,omitempty"`
	CloudWatchMetrics []EMFCloudWatchMetrics `json:"CloudWatchMetrics"`
}

type EMFMetric struct {
	Name       string
	Value      float64
	Unit       string
	Dimensions map[string]string
	Timestamp  int64
}

type EMFMetricData struct {
	MetricName string  `json:"metric_name"`
	Value      float64 `json:"value"`
	Unit       string  `json:"unit"`
	Timestamp  int64   `json:"timestamp"`
}

type EMFMetricDefinition struct {
	Name string `json:"Name"`
	Unit string `json:"Unit"`
}

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

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

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

type EMFPayload struct {
	Version    string                 `json:"_aws"`
	Timestamp  int64                  `json:"timestamp"`
	LogGroup   string                 `json:"log_group,omitempty"`
	LogStream  string                 `json:"log_stream,omitempty"`
	Namespace  string                 `json:"namespace"`
	Dimensions [][]string             `json:"dimensions"`
	Metrics    []EMFMetricData        `json:"metrics"`
	Properties map[string]interface{} `json:"properties,omitempty"`
}

type EnhancedMetric struct {
	Name        string                 `json:"name"`
	Type        MetricType             `json:"type"`
	Level       MetricLevel            `json:"level"`
	Value       float64                `json:"value"`
	Unit        string                 `json:"unit"`
	Description string                 `json:"description"`
	Labels      map[string]string      `json:"labels"`
	Timestamp   time.Time              `json:"timestamp"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

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

type ErrorRateMetric struct {
	Total     int64            `json:"total_requests"`
	Errors    int64            `json:"error_count"`
	ErrorRate float64          `json:"error_rate"`
	By4xx     int64            `json:"4xx_errors"`
	By5xx     int64            `json:"5xx_errors"`
	ByType    map[string]int64 `json:"errors_by_type"`
}

type EscalationRule struct {
	Level              int           `json:"level"`               // 1, 2, 3, etc.
	TriggerAfter       time.Duration `json:"trigger_after"`       // Escalate after this duration
	AdditionalChannels []string      `json:"additional_channels"` // Additional delivery channels
	RequiresManualAck  bool          `json:"requires_manual_ack"` // Requires manual acknowledgment
}

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

type HTTPMetrics struct {
	URL           string
	Method        string
	StatusCode    int
	RequestSize   int64
	ResponseSize  int64
	DNSTime       time.Duration
	TCPTime       time.Duration
	TLSTime       time.Duration
	FirstByteTime time.Duration
	TotalTime     time.Duration
	Success       bool
	ErrorType     string
	RetryAttempts int
}

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

type HealthCheck struct {
	Name      string                 `json:"name"`
	Status    string                 `json:"status"`
	Message   string                 `json:"message,omitempty"`
	LastCheck time.Time              `json:"last_check"`
	Duration  time.Duration          `json:"duration"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
}

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

type HealthConfig struct {
	TableName        string
	QueueURL         string
	CheckTimeout     time.Duration
	CacheTimeout     time.Duration
	DependencyChecks bool
}

type HealthResponse struct {
	Status    string                 `json:"status"`
	Timestamp time.Time              `json:"timestamp"`
	Version   string                 `json:"version"`
	Service   string                 `json:"service"`
	Region    string                 `json:"region"`
	Checks    []HealthCheck          `json:"checks,omitempty"`
	Summary   map[string]interface{} `json:"summary,omitempty"`
}

type HistoricalMetricsReader interface {
	GetMetricsByService(ctx context.Context, serviceName string, startTime, endTime time.Time) ([]*models.MetricRecord, error)
}

type HorizontalAnnotation struct {
	Value   float64 `json:"value"`
	Label   string  `json:"label,omitempty"`
	Color   string  `json:"color,omitempty"`
	Fill    string  `json:"fill,omitempty"`
	Visible bool    `json:"visible,omitempty"`
}

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

type LatencyAggregatorOption func(*LatencyAggregator)

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

type LatencyBucket struct {
	Operation    string
	Service      string
	WindowStart  time.Time
	WindowEnd    time.Time
	Measurements []float64
	Count        int64
	Sum          float64
	Min          float64
	Max          float64
	// contains filtered or unexported fields
}

type LatencyDataPoint struct {
	Timestamp   time.Time          `json:"timestamp"`
	Average     float64            `json:"average"`
	Count       int64              `json:"count"`
	Percentiles map[string]float64 `json:"percentiles"`
}

type LatencyMetric struct {
	Operation string
	Start     time.Time
	Context   context.Context
}

type LatencyStats struct {
	Operation   string             `json:"operation"`
	Service     string             `json:"service"`
	WindowStart time.Time          `json:"window_start"`
	WindowEnd   time.Time          `json:"window_end"`
	Count       int64              `json:"count"`
	Sum         float64            `json:"sum"`
	Average     float64            `json:"average"`
	Min         float64            `json:"min"`
	Max         float64            `json:"max"`
	Percentiles map[string]float64 `json:"percentiles"`
	StdDev      float64            `json:"std_dev"`
}

type LatencyTrend struct {
	Operation     string               `json:"operation"`
	Service       string               `json:"service"`
	TimeRange     string               `json:"time_range"`
	DataPoints    []LatencyDataPoint   `json:"data_points"`
	TrendAnalysis TrendAnalysis        `json:"trend_analysis"`
	Percentiles   map[string][]float64 `json:"percentiles"`
}

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

type MetricLevel string

type MetricType string

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

type MetricsRecorder interface {
	RecordLatency(ctx context.Context, operation, table string, duration time.Duration, success bool, dimensions map[string]string) error
}

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

type MonitoringServiceConfig struct {
	Logger      *zap.Logger
	DB          core.DB
	TableName   string
	CostService *cost.TrackingService

	// AWS services
	SNSClient   *sns.Client
	SNSTopicArn string

	// Webhook configuration
	WebhookURL     string
	WebhookHeaders map[string]string

	// Service identification
	Environment string
	ServiceName string
	Region      string

	// Alert routing
	AlertRoutes  []*AlertRoute
	DefaultRoute *AlertRoute

	Enabled bool
}

type PercentileMetric struct {
	P50 float64 `json:"p50"`
	P75 float64 `json:"p75"`
	P90 float64 `json:"p90"`
	P95 float64 `json:"p95"`
	P99 float64 `json:"p99"`
}

type PerformanceMetric struct {
	Operation       string
	TotalTime       time.Duration
	CallCount       int64
	MaxTime         time.Duration
	MinTime         time.Duration
	LastUpdated     time.Time
	OverheadPercent float64
}

type PerformanceMetrics struct {
	ColdStartDuration time.Duration
	ExecutionDuration time.Duration
	MemoryUsed        int64
	MemoryAllocated   int64
	CPUUtilization    float64
	GoroutineCount    int
	GCPauseTime       time.Duration
}

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

type ScheduleConfig struct {
	BusinessHoursOnly bool     `json:"business_hours_only"`
	Timezone          string   `json:"timezone"`
	BusinessHours     string   `json:"business_hours"`  // e.g., "9:00-17:00"
	BusinessDays      []string `json:"business_days"`   // e.g., ["mon", "tue", "wed", "thu", "fri"]
	SuppressDuring    []string `json:"suppress_during"` // Maintenance windows
}

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

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

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

type ThrottleConfig struct {
	MaxAlertsPerMinute int           `json:"max_alerts_per_minute"`
	MaxAlertsPerHour   int           `json:"max_alerts_per_hour"`
	CooldownPeriod     time.Duration `json:"cooldown_period"`
	GroupBy            []string      `json:"group_by"` // Fields to group alerts by for throttling
}

type TraceContext struct {
	TraceID   string
	SegmentID string
	ParentID  string
	Sampled   bool
	RequestID string
	UserID    string
	TenantID  string
	// contains filtered or unexported fields
}

type TracingConfig struct {
	ServiceName    string
	ServiceVersion string
	SamplingRate   float64
	DaemonAddress  string
	UseECS         bool
	LocalTesting   bool
	Enabled        bool
}

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

type TrendAnalysis struct {
	Slope                float64 `json:"slope"`                 // Trend direction (positive = increasing)
	RSquared             float64 `json:"r_squared"`             // Trend strength (0-1)
	TrendDirection       string  `json:"trend_direction"`       // "increasing", "decreasing", "stable"
	PercentChange        float64 `json:"percent_change"`        // Change from first to last data point
	Volatility           float64 `json:"volatility"`            // Standard deviation of changes
	IsSignificant        bool    `json:"is_significant"`        // Whether trend is statistically significant
	ChangeClassification string  `json:"change_classification"` // "significant_improvement", "significant_degradation", "stable"
}

type VerticalAnnotation struct {
	Value   string `json:"value"`
	Label   string `json:"label,omitempty"`
	Color   string `json:"color,omitempty"`
	Visible bool   `json:"visible,omitempty"`
}

type WebhookConfig struct {
	ID             string            `json:"id"`
	URL            string            `json:"url"`
	Headers        map[string]string `json:"headers"`
	Timeout        time.Duration     `json:"timeout"`
	MaxAttempts    int               `json:"max_attempts"`
	RetryInterval  time.Duration     `json:"retry_interval"`
	SecretToken    string            `json:"secret_token,omitempty"`
	VerifySSL      bool              `json:"verify_ssl"`
	Enabled        bool              `json:"enabled"`
	AlertTypes     []string          `json:"alert_types,omitempty"`     // Filter by alert types
	SeverityLevels []string          `json:"severity_levels,omitempty"` // Filter by severity
	Services       []string          `json:"services,omitempty"`        // Filter by services
}

type WebhookDeliveryConfig struct {
	Logger               *zap.Logger
	WebhookRepository    *StandaloneWebhookRepository
	AlertRepository      *StandaloneAlertRepository
	DeadLetterRepository *StandaloneDeadLetterRepository
	HTTPTimeout          time.Duration
	MaxAttempts          int
	RetryInterval        time.Duration
	Enabled              bool
}

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

type XRayConfig struct {
	ServiceName    string
	ServiceVersion string
	Enabled        bool
	LocalTesting   bool
}

type YAxisConfig struct {
	Left  *AxisConfig `json:"left,omitempty"`
	Right *AxisConfig `json:"right,omitempty"`
}