driver

type AttemptMetricsDataPoint struct {
	TimeBucket *time.Time
	// Measures
	Count           *int
	SuccessfulCount *int
	FailedCount     *int
	ErrorRate       *float64
	// NOTE: The following three measures are equivalent to using "count" with
	// the corresponding filters (attempt_number=1 AND manual=false, attempt_number>1,
	// manual=true). They exist for composability — callers can request multiple
	// measures in a single query instead of issuing separate filtered queries.
	// Consider whether they're worth the added surface area or if callers should
	// use count+filters.
	FirstAttemptCount *int
	RetryCount        *int
	ManualRetryCount  *int
	AvgAttemptNumber  *float64
	Rate              *float64
	SuccessfulRate    *float64
	FailedRate        *float64
	// Dimensions
	TenantID      *string
	DestinationID *string
	Topic         *string
	Status        *string
	Code          *string
	Manual        *bool
	AttemptNumber *int
}

type AttemptMetricsResponse struct {
	Data     []AttemptMetricsDataPoint
	Metadata MetricsMetadata
}

type AttemptRecord struct {
	Attempt *models.Attempt
	Event   *models.Event // optionally populated for query results
}

type EventMetricsDataPoint struct {
	TimeBucket *time.Time
	// Measures
	Count *int
	Rate  *float64
	// Dimensions
	TenantID      *string
	Topic         *string
	DestinationID *string
}

type EventMetricsResponse struct {
	Data     []EventMetricsDataPoint
	Metadata MetricsMetadata
}

type Granularity struct {
	Value int
	Unit  string // s, m, h, d, w, M
}

type ListAttemptRequest struct {
	Next           string
	Prev           string
	Limit          int
	TimeFilter     TimeFilter // optional - filter attempts by time
	TenantIDs      []string   // optional - filter by tenant (if empty, returns all tenants)
	EventIDs       []string   // optional - filter by event ID
	DestinationIDs []string   // optional
	Status         string     // optional: "success", "failed"
	Topics         []string   // optional
	SortOrder      string     // optional: "asc", "desc" (default: "desc")
}

type ListAttemptResponse struct {
	Data []*AttemptRecord
	Next string
	Prev string
}

type ListEventRequest struct {
	Next           string
	Prev           string
	Limit          int
	TimeFilter     TimeFilter // optional - filter events by time
	TenantIDs      []string   // optional - filter by tenant (if empty, returns all tenants)
	EventIDs       []string   // optional - filter by event ID
	DestinationIDs []string   // optional
	Topics         []string   // optional
	SortOrder      string     // optional: "asc", "desc" (default: "desc")
}

type ListEventResponse struct {
	Data []*models.Event
	Next string
	Prev string
}

type LogStore interface {
	Records
	Metrics
}

type Metrics interface {
	QueryEventMetrics(ctx context.Context, req MetricsRequest) (*EventMetricsResponse, error)
	QueryAttemptMetrics(ctx context.Context, req MetricsRequest) (*AttemptMetricsResponse, error)
}

type MetricsMetadata struct {
	QueryTimeMs int64
	RowCount    int
	RowLimit    int
	Truncated   bool
}

type MetricsRequest struct {
	TimeRange   TimeRange
	Granularity *Granularity
	Measures    []string
	Dimensions  []string
	Filters     map[string][]string
}

type Records interface {
	ListEvent(context.Context, ListEventRequest) (ListEventResponse, error)
	ListAttempt(context.Context, ListAttemptRequest) (ListAttemptResponse, error)
	RetrieveEvent(ctx context.Context, request RetrieveEventRequest) (*models.Event, error)
	RetrieveAttempt(ctx context.Context, request RetrieveAttemptRequest) (*AttemptRecord, error)
	InsertMany(context.Context, []*models.LogEntry) error
}

type RetrieveAttemptRequest struct {
	TenantID  string // optional - filter by tenant (if empty, searches all tenants)
	AttemptID string // required
}

type RetrieveEventRequest struct {
	TenantID string // optional - filter by tenant (if empty, searches all tenants)
	EventID  string // required
}

type TimeFilter struct {
	GTE *time.Time // Greater than or equal (>=)
	LTE *time.Time // Less than or equal (<=)
	GT  *time.Time // Greater than (>)
	LT  *time.Time // Less than (<)
}

type TimeRange struct {
	Start time.Time
	End   time.Time
}