federated

type AttributeMismatch struct {
	RowID         uuid.UUID
	AttributeName string
	FederatedVal  any
	PostgresVal   any
}

type CompactionResult struct {
	FilesCompacted int
	FilesCreated   int
	RowsMerged     int64
	Duration       time.Duration
}

type ComparisonReport struct {
	Match               bool
	FederatedCount      int64
	PostgresCount       int64
	MissingInFed        []uuid.UUID
	MissingInPG         []uuid.UUID
	AttributeMismatches []AttributeMismatch
	FederatedChecksum   string
	PostgresChecksum    string
}

type FederatedTestHarness struct {
	*e2e_harness.TestHarness

	// Configuration
	SchemaID  int16
	S3Bucket  string
	S3Prefix  string
	CDCConfig cdc.CDCConfig
	Registry  forma.SchemaRegistry

	// Postgres connection info for DuckDB postgres_scan
	PGHost     string
	PGPort     string
	PGUser     string
	PGPassword string
	PGDatabase string
	PGSSLMode  string

	// S3 connection info shared by DuckDB and direct client access.
	S3Region    string
	S3AccessKey string
	S3SecretKey string
	// contains filtered or unexported fields
}

type Filter struct {
	RowID      uuid.UUID
	Conditions map[string]any
}

type FlushResult struct {
	Flushed      bool
	RowsFlushed  int64
	FilesCreated []string
	Duration     time.Duration
}

type GeneratorOptions struct {
	SchemaID       int16
	TimeRangeHours int     // Range of time for records (hours ago)
	TimeOffset     int     // Offset from now (hours ago)
	DeletedRatio   float64 // Ratio of records to mark as deleted (0.0-1.0)
	Seed           int64   // Random seed for reproducibility (0 = use time)
}

type LatencyStats struct {
	Min   time.Duration
	Max   time.Duration
	Avg   time.Duration
	P50   time.Duration
	P95   time.Duration
	P99   time.Duration
	Count int
}

type ParquetMetadata struct {
	RowCount   int64
	RowIDMin   string
	RowIDMax   string
	CreatedMin int64
	CreatedMax int64
	SizeBytes  int64
}

type PerformanceDataset struct {
	Base  []TestRecord
	Delta []TestRecord
	Hot   []TestRecord
}

type PresetScenarios struct{}

type QueryOptions struct {
	Limit          int
	Offset         int
	Filter         *Filter
	SortBy         string
	SortDesc       bool
	PreferHot      bool
	TradeTimeStart int64
	TradeTimeEnd   int64
	CountOnly      bool
	KeysetCursor   *internal.KeysetCursor
}

type QueryResult struct {
	Records      []*internal.PersistentRecord
	TotalRecords int64
	Plan         *internal.ExecutionPlan
	Duration     time.Duration
}

type TestRecord struct {
	RowID      uuid.UUID
	SchemaID   int16
	Attributes map[string]any
	ChangedAt  int64
	DeletedAt  int64
	FlushedAt  int64
}