admin

type BoundsCache struct {
	ModelID string `json:"model_id"`
	Min     uint64 `json:"min"`
	Max     uint64 `json:"max"`

	// Track scan times
	LastIncrementalScan time.Time `json:"last_incremental_scan"`
	LastFullScan        time.Time `json:"last_full_scan"`

	// For optimization hints
	PreviousMin uint64 `json:"previous_min"`
	PreviousMax uint64 `json:"previous_max"`

	// Initial scan tracking
	InitialScanComplete bool       `json:"initial_scan_complete"`
	InitialScanStarted  *time.Time `json:"initial_scan_started,omitempty"`

	// Metadata
	UpdatedAt time.Time `json:"updated_at"`
}

type BoundsLock interface {
	Unlock(ctx context.Context) error
}

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

type ConfigOverride struct {
	ModelID   string          `json:"model_id"`
	ModelType string          `json:"model_type"` // "transformation" or "external"
	Enabled   *bool           `json:"enabled,omitempty"`
	Override  json.RawMessage `json:"override"`
	UpdatedAt time.Time       `json:"updated_at"`
}

type GapInfo struct {
	StartPos uint64
	EndPos   uint64
}

type ProcessedRange struct {
	Position uint64 `ch:"position"`
	Interval uint64 `ch:"interval"`
}

type Service interface {
	// Position tracking (for incremental transformations)
	GetNextUnprocessedPosition(ctx context.Context, modelID string) (uint64, error) // Returns next position for forward fill
	GetLastProcessedPosition(ctx context.Context, modelID string) (uint64, error)   // Returns position of last record
	GetFirstPosition(ctx context.Context, modelID string) (uint64, error)
	RecordCompletion(ctx context.Context, modelID string, position, interval uint64) error

	// Scheduled transformation tracking
	RecordScheduledCompletion(ctx context.Context, modelID string, startDateTime time.Time) error
	GetLastScheduledExecution(ctx context.Context, modelID string) (*time.Time, error)
	GetAllLastScheduledExecutions(ctx context.Context, modelIDs []string) (map[string]*time.Time, error)

	// Coverage and gap management
	GetCoverage(ctx context.Context, modelID string, startPos, endPos uint64) (bool, error)
	GetProcessedRanges(ctx context.Context, modelID string) ([]ProcessedRange, error)
	GetAllProcessedRanges(ctx context.Context, modelIDs []string) (map[string][]ProcessedRange, error)
	FindGaps(ctx context.Context, modelID string, minPos, maxPos, interval uint64) ([]GapInfo, error)

	// Consolidation
	ConsolidateHistoricalData(ctx context.Context, modelID string) (uint64, error)

	// Period deletion
	DeletePeriod(ctx context.Context, modelID string, startPos, endPos uint64) (uint64, error)

	// External bounds cache
	GetExternalBounds(ctx context.Context, modelID string) (*BoundsCache, error)
	SetExternalBounds(ctx context.Context, cache *BoundsCache) error
	DeleteExternalBounds(ctx context.Context, modelID string) error

	// Distributed locking for bounds updates
	AcquireBoundsLock(ctx context.Context, modelID string) (BoundsLock, error)

	// Admin table info
	GetIncrementalAdminDatabase() string
	GetIncrementalAdminTable() string
	GetScheduledAdminDatabase() string
	GetScheduledAdminTable() string

	// Config override operations
	GetConfigOverride(ctx context.Context, modelID string) (*ConfigOverride, error)
	GetAllConfigOverrides(ctx context.Context) ([]ConfigOverride, error)
	SetConfigOverride(ctx context.Context, override *ConfigOverride) error
	DeleteConfigOverride(ctx context.Context, modelID string) error
	DeleteAllConfigOverrides(ctx context.Context) error
	GetConfigOverrideVersion(ctx context.Context) (int64, error)

	// GetCacheManager returns the underlying cache manager
	GetCacheManager() *CacheManager
}

type TableConfig struct {
	IncrementalDatabase string
	IncrementalTable    string
	ScheduledDatabase   string
	ScheduledTable      string
}