stats

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

type AggregatorStorage interface {
	AggregateDailyStats(date time.Time) error
	PurgeDetailedLogs(before time.Time) (int64, error)
	PurgeAggregatedStats(before time.Time) (int64, error)
}

type BufferStats struct {
	Size           int     `json:"size"`
	Capacity       int     `json:"capacity"`
	FillPercentage float64 `json:"fill_percentage"`
}

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

type Config struct {
	// Enabled controls whether statistics collection is active.
	Enabled bool

	// Buffer configuration
	BufferSize     int
	FlushInterval  time.Duration
	FlushThreshold float64

	// Capture options
	CaptureClientIP    bool
	CaptureUserAgent   bool
	CaptureQueryParams bool

	// GeoIP configuration
	GeoIPEnabled bool
	GeoIPDBPath  string

	// Retention
	DetailedRetention   time.Duration
	AggregatedRetention time.Duration

	// Endpoints to track (empty = all federation endpoints)
	Endpoints []string
}

type DailyStats struct {
	ID        uint      `gorm:"primaryKey;autoIncrement" json:"id"`
	CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
	UpdatedAt time.Time `gorm:"autoUpdateTime" json:"updated_at"`

	// Primary key fields for grouping
	Date       time.Time `gorm:"type:date;uniqueIndex:idx_ds_date_endpoint_status;not null" json:"date"`
	Endpoint   string    `gorm:"size:100;uniqueIndex:idx_ds_date_endpoint_status;not null" json:"endpoint"`
	StatusCode int       `gorm:"type:smallint;uniqueIndex:idx_ds_date_endpoint_status;not null" json:"status_code"`

	// Counts
	RequestCount int64 `gorm:"not null;default:0" json:"request_count"`
	ErrorCount   int64 `gorm:"not null;default:0" json:"error_count"`

	// Duration statistics (in milliseconds)
	DurationP50Ms int `gorm:"default:0" json:"duration_p50_ms"`
	DurationP95Ms int `gorm:"default:0" json:"duration_p95_ms"`
	DurationP99Ms int `gorm:"default:0" json:"duration_p99_ms"`
	DurationAvgMs int `gorm:"default:0" json:"duration_avg_ms"`
	DurationMinMs int `gorm:"default:0" json:"duration_min_ms"`
	DurationMaxMs int `gorm:"default:0" json:"duration_max_ms"`

	// Top entries as JSON arrays
	TopUserAgents json.RawMessage `gorm:"type:json" json:"top_user_agents,omitempty"`
	TopCountries  json.RawMessage `gorm:"type:json" json:"top_countries,omitempty"`
	TopClientIPs  json.RawMessage `gorm:"type:json" json:"top_client_ips,omitempty"`
	TopParams     json.RawMessage `gorm:"type:json" json:"top_params,omitempty"`
}

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

type FlusherStats struct {
	TotalFlushed  int64     `json:"total_flushed"`
	TotalDropped  int64     `json:"total_dropped"`
	LastFlushTime time.Time `json:"last_flush_time"`
	LastFlushSize int       `json:"last_flush_size"`
	BufferSize    int       `json:"buffer_size"`
	BufferFill    float64   `json:"buffer_fill"`
}

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

type GeoIPProvider interface {
	LookupCountry(ip string) string
	Close() error
}

type Interval string

type LatencyStats struct {
	P50Ms int     `json:"p50_ms"`
	P75Ms int     `json:"p75_ms"`
	P90Ms int     `json:"p90_ms"`
	P95Ms int     `json:"p95_ms"`
	P99Ms int     `json:"p99_ms"`
	AvgMs float64 `json:"avg_ms"`
	MinMs int     `json:"min_ms"`
	MaxMs int     `json:"max_ms"`
}

type MiddlewareConfig struct {
	// CaptureClientIP enables capturing the client IP address.
	CaptureClientIP bool

	// CaptureUserAgent enables capturing the User-Agent header.
	CaptureUserAgent bool

	// CaptureQueryParams enables capturing URL query parameters.
	CaptureQueryParams bool

	// GeoIP provides country lookup from IP addresses. Can be nil.
	GeoIP GeoIPProvider

	// TrackedEndpoints is a map of endpoints to track. If empty, all requests are tracked.
	// Keys should be normalized endpoint names (e.g., "well-known", "fetch", "resolve").
	TrackedEndpoints map[string]bool

	// Buffer is the ring buffer to write entries to.
	Buffer *RingBuffer
}

type NoOpGeoIPLookup struct{}

type RequestLog struct {
	ID        uint64    `gorm:"primaryKey;autoIncrement" json:"id"`
	Timestamp time.Time `gorm:"index:idx_rl_ts;not null" json:"timestamp"`

	// Request info
	Endpoint   string `gorm:"size:100;index:idx_rl_endpoint;not null" json:"endpoint"`
	Method     string `gorm:"size:10;not null" json:"method"`
	StatusCode int    `gorm:"type:smallint;not null" json:"status_code"`
	DurationMs int    `gorm:"not null" json:"duration_ms"`

	// Client info
	ClientIP      string `gorm:"size:45;index:idx_rl_ip" json:"client_ip,omitempty"`
	CountryCode   string `gorm:"size:2" json:"country_code,omitempty"`
	UserAgent     string `gorm:"type:text" json:"user_agent,omitempty"`
	UserAgentHash uint32 `gorm:"index:idx_rl_ua_hash" json:"user_agent_hash,omitempty"`

	// Request details
	QueryParams  json.RawMessage `gorm:"type:json" json:"query_params,omitempty"`
	RequestSize  int             `gorm:"default:0" json:"request_size"`
	ResponseSize int             `gorm:"default:0" json:"response_size"`

	// Error info
	ErrorType string `gorm:"size:100" json:"error_type,omitempty"`
}

type RingBuffer struct {

	// NotifyThreshold is signaled when the buffer reaches the threshold percentage.
	// It's a buffered channel (size 1) so sends never block.
	NotifyThreshold chan struct{}
	// contains filtered or unexported fields
}

type StorageBackend interface {
	InsertBatch(entries []*RequestLog) error
}

type Summary struct {
	TotalRequests      int64            `json:"total_requests"`
	TotalErrors        int64            `json:"total_errors"`
	ErrorRate          float64          `json:"error_rate"`
	AvgLatencyMs       float64          `json:"avg_latency_ms"`
	P50LatencyMs       int              `json:"p50_latency_ms"`
	P95LatencyMs       int              `json:"p95_latency_ms"`
	P99LatencyMs       int              `json:"p99_latency_ms"`
	UniqueClients      int64            `json:"unique_clients"`
	UniqueUserAgents   int64            `json:"unique_user_agents"`
	RequestsByStatus   map[int]int64    `json:"requests_by_status"`
	RequestsByEndpoint map[string]int64 `json:"requests_by_endpoint"`
}

type TimeSeriesPoint struct {
	Timestamp    time.Time `json:"timestamp"`
	RequestCount int64     `json:"request_count"`
	ErrorCount   int64     `json:"error_count"`
	AvgLatencyMs float64   `json:"avg_latency_ms"`
}

type TopEntry struct {
	Value string `json:"value"`
	Count int64  `json:"count"`
}