driver

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

type ListAttemptRequest struct {
	Next           string
	Prev           string
	Limit          int
	TimeFilter     TimeFilter // optional - filter attempts by time
	TenantID       string     // optional - filter by tenant (if empty, returns all tenants)
	EventID        string     // optional - filter for specific event
	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
	TenantID       string     // optional - filter by tenant (if empty, returns all tenants)
	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 {
	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 (<)
}