generated

type BoundsInfo struct {
	// HasData Whether the model has any data
	HasData bool `json:"has_data"`

	// LagApplied Lag applied to external model (if applicable)
	LagApplied *int `json:"lag_applied,omitempty"`

	// Max Maximum available position (for external) or last processed end (for transformation)
	Max int `json:"max"`

	// Min Minimum available position
	Min int `json:"min"`
}

type CoverageDebug struct {
	// CanProcess Whether this position can be processed
	CanProcess bool `json:"can_process"`

	// Dependencies Recursive dependency analysis
	Dependencies []DependencyDebugInfo `json:"dependencies"`

	// EndPosition End position (position + interval)
	EndPosition *int `json:"end_position,omitempty"`

	// Interval Interval size checked
	Interval int `json:"interval"`

	// ModelCoverage Coverage information for the target model itself
	ModelCoverage ModelCoverageInfo `json:"model_coverage"`

	// ModelId The model being debugged
	ModelId string `json:"model_id"`

	// Position Position being checked
	Position int `json:"position"`

	// Validation Validation results using the same logic as backfill/dependency checking
	Validation ValidationDebugInfo `json:"validation"`
}

type CoverageDetail struct {
	// Id Fully qualified model ID (database.table)
	Id string `json:"id"`

	// Ranges All processed ranges from admin_incremental table
	Ranges []Range `json:"ranges"`
}

type CoverageSummary struct {
	// Id Fully qualified model ID (database.table)
	Id string `json:"id"`

	// Ranges Processed ranges from admin_incremental table
	Ranges []Range `json:"ranges"`
}

type DependencyDebugInfo struct {
	// Blocking Whether this dependency is blocking processing
	Blocking *bool `json:"blocking,omitempty"`

	// Bounds Position bounds for a model
	Bounds BoundsInfo `json:"bounds"`

	// ChildDependencies Recursive dependencies of this dependency
	ChildDependencies *[]DependencyDebugInfo `json:"child_dependencies,omitempty"`

	// CoverageStatus Coverage status for the requested position
	CoverageStatus *DependencyDebugInfoCoverageStatus `json:"coverage_status,omitempty"`

	// Gaps Gaps found in this dependency for the requested range
	Gaps *[]GapInfo `json:"gaps,omitempty"`

	// Id Dependency model ID
	Id string `json:"id"`

	// IsIncremental Whether this is an incremental transformation (can have gaps)
	IsIncremental *bool `json:"is_incremental,omitempty"`

	// NodeType Type of dependency model
	NodeType DependencyDebugInfoNodeType `json:"node_type"`

	// OrGroupMembers For OR groups, debug info for each member
	OrGroupMembers *[]DependencyDebugInfo `json:"or_group_members,omitempty"`

	// Type Dependency type (AND or OR group)
	Type DependencyDebugInfoType `json:"type"`
}

type DependencyDebugInfoCoverageStatus string

type DependencyDebugInfoNodeType string

type DependencyDebugInfoType string

type Error struct {
	// Code HTTP status code
	Code int `json:"code"`

	// Error Human-readable error message
	Error string `json:"error"`
}

type ExternalBounds struct {
	// Id Fully qualified model ID (database.table)
	Id string `json:"id"`

	// InitialScanComplete Whether initial scan is complete
	InitialScanComplete *bool `json:"initial_scan_complete,omitempty"`

	// InitialScanStarted Timestamp when initial scan started
	InitialScanStarted *time.Time `json:"initial_scan_started,omitempty"`

	// LastFullScan Timestamp of last full scan
	LastFullScan *time.Time `json:"last_full_scan,omitempty"`

	// LastIncrementalScan Timestamp of last incremental scan
	LastIncrementalScan *time.Time `json:"last_incremental_scan,omitempty"`

	// Max Maximum position in external source
	Max int `json:"max"`

	// Min Minimum position in external source
	Min int `json:"min"`

	// PreviousMax Previous maximum position (for tracking changes)
	PreviousMax *int `json:"previous_max,omitempty"`

	// PreviousMin Previous minimum position (for tracking changes)
	PreviousMin *int `json:"previous_min,omitempty"`
}

type ExternalModel struct {
	// Cache Cache configuration for external source
	Cache *struct {
		// FullScanInterval Interval for full cache refresh
		FullScanInterval *string `json:"full_scan_interval,omitempty"`

		// IncrementalScanInterval Interval for incremental cache updates
		IncrementalScanInterval *string `json:"incremental_scan_interval,omitempty"`
	} `json:"cache,omitempty"`
	Database    string  `json:"database"`
	Description *string `json:"description,omitempty"`

	// Id Fully qualified ID (database.table)
	Id string `json:"id"`

	// Interval Interval configuration for external source
	Interval *struct {
		// Type Type of interval (e.g., "second", "slot", "epoch", "block")
		Type *string `json:"type,omitempty"`
	} `json:"interval,omitempty"`

	// Lag Number of blocks/slots to lag behind head
	Lag *int `json:"lag,omitempty"`

	// Metadata System-managed metadata
	Metadata *struct {
		CreatedAt    *time.Time `json:"created_at,omitempty"`
		LastSyncedAt *time.Time `json:"last_synced_at,omitempty"`

		// RowCount Approximate row count in destination table
		RowCount *int `json:"row_count,omitempty"`

		// SizeBytes Approximate table size in bytes
		SizeBytes *int       `json:"size_bytes,omitempty"`
		UpdatedAt *time.Time `json:"updated_at,omitempty"`
	} `json:"metadata,omitempty"`
	Table string `json:"table"`
}

type FiberServerOptions struct {
	BaseURL     string
	Middlewares []MiddlewareFunc
}

type GapInfo struct {
	// End Gap end position
	End int `json:"end"`

	// OverlapsRequest Whether this gap overlaps with the requested position range
	OverlapsRequest *bool `json:"overlaps_request,omitempty"`

	// Size Gap size in interval units
	Size int `json:"size"`

	// Start Gap start position
	Start int `json:"start"`
}

type InternalError = Error

type IntervalTypeTransformation struct {
	// Expression Optional CEL (Common Expression Language) expression to transform the value.
	// Uses 'value' as the input variable.
	// Supports math functions via math.* namespace (e.g., math.floor, math.ceil, math.round).
	// If omitted, value is passed through unchanged (identity transformation).
	Expression *string `json:"expression,omitempty"`

	// Format Optional display format hint for the frontend.
	// - datetime: Format as full date and time (e.g., "2024-01-15 14:30:00")
	// - date: Format as date only (e.g., "2024-01-15")
	// - time: Format as time only (e.g., "14:30:00")
	// - duration: Format as human-readable duration (e.g., "2h 30m")
	// - relative: Format as relative time (e.g., "2 hours ago")
	// If omitted, value is displayed as a raw number.
	Format *IntervalTypeTransformationFormat `json:"format,omitempty"`

	// Name Display name for this transformation
	Name string `json:"name"`
}

type IntervalTypeTransformationFormat string

type ListAllModelsParams struct {
	// Type Filter by model type
	Type *ListAllModelsParamsType `form:"type,omitempty" json:"type,omitempty"`

	// Database Filter by database name
	Database *string `form:"database,omitempty" json:"database,omitempty"`

	// Search Search by model ID or description (case-insensitive)
	Search *string `form:"search,omitempty" json:"search,omitempty"`
}

type ListAllModelsParamsType string

type ListExternalModelsParams struct {
	// Database Filter by database name
	Database *string `form:"database,omitempty" json:"database,omitempty"`
}

type ListScheduledRunsParams struct {
	// Database Filter by database name
	Database *string `form:"database,omitempty" json:"database,omitempty"`
}

type ListTransformationCoverageParams struct {
	// Database Filter by database name
	Database *string `form:"database,omitempty" json:"database,omitempty"`
}

type ListTransformationsParams struct {
	// Database Filter by database name
	Database *string `form:"database,omitempty" json:"database,omitempty"`

	// Type Filter by transformation type
	Type *ListTransformationsParamsType `form:"type,omitempty" json:"type,omitempty"`

	// Status Filter by last run status
	Status *ListTransformationsParamsStatus `form:"status,omitempty" json:"status,omitempty"`
}

type ListTransformationsParamsStatus string

type ListTransformationsParamsType string

type MiddlewareFunc fiber.Handler

type ModelCoverageInfo struct {
	// FirstPosition First processed position
	FirstPosition int `json:"first_position"`

	// GapsInWindow Gaps detected in the requested position window
	GapsInWindow *[]GapInfo `json:"gaps_in_window,omitempty"`

	// HasData Whether model has any processed data
	HasData bool `json:"has_data"`

	// LastEndPosition Last processed end position (max(position + interval))
	LastEndPosition int `json:"last_end_position"`

	// RangesInWindow Processed ranges overlapping the requested position window
	RangesInWindow *[]Range `json:"ranges_in_window,omitempty"`
}

type ModelSummary struct {
	Database    string  `json:"database"`
	Description *string `json:"description,omitempty"`

	// Id Fully qualified ID (database.table)
	Id    string `json:"id"`
	Table string `json:"table"`

	// Type Model type
	Type ModelSummaryType `json:"type"`
}

type ModelSummaryType string

type NotFound = Error

type Range struct {
	// Interval Size of processed range
	Interval int `json:"interval"`

	// Position Starting position of processed range
	Position int `json:"position"`
}

type ScheduledRun struct {
	// Id Fully qualified model ID (database.table)
	Id string `json:"id"`

	// LastRun Timestamp of last execution
	LastRun *time.Time `json:"last_run,omitempty"`
}

type ServerInterface interface {
	// Get interval type transformations
	// (GET /interval/types)
	GetIntervalTypes(c fiber.Ctx) error
	// List all models (lightweight)
	// (GET /models)
	ListAllModels(c fiber.Ctx, params ListAllModelsParams) error
	// List external models
	// (GET /models/external)
	ListExternalModels(c fiber.Ctx, params ListExternalModelsParams) error
	// List external model bounds
	// (GET /models/external/bounds)
	ListExternalBounds(c fiber.Ctx) error
	// Get external model by ID
	// (GET /models/external/{id})
	GetExternalModel(c fiber.Ctx, id string) error
	// Get external model bounds by ID
	// (GET /models/external/{id}/bounds)
	GetExternalBounds(c fiber.Ctx, id string) error
	// List transformation models
	// (GET /models/transformations)
	ListTransformations(c fiber.Ctx, params ListTransformationsParams) error
	// List transformation coverage
	// (GET /models/transformations/coverage)
	ListTransformationCoverage(c fiber.Ctx, params ListTransformationCoverageParams) error
	// List scheduled transformation runs
	// (GET /models/transformations/runs)
	ListScheduledRuns(c fiber.Ctx, params ListScheduledRunsParams) error
	// Get transformation model by ID
	// (GET /models/transformations/{id})
	GetTransformation(c fiber.Ctx, id string) error
	// Get transformation coverage by ID
	// (GET /models/transformations/{id}/coverage)
	GetTransformationCoverage(c fiber.Ctx, id string) error
	// Debug coverage and dependency status for a specific position
	// (GET /models/transformations/{id}/coverage/{position})
	DebugCoverageAtPosition(c fiber.Ctx, id string, position int) error
	// Get scheduled transformation run by ID
	// (GET /models/transformations/{id}/runs)
	GetScheduledRun(c fiber.Ctx, id string) error
}

type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

type TransformationModel struct {
	// Content SQL query or exec command defining the transformation
	Content string `json:"content"`

	// ContentType Execution method (SQL query or shell command)
	ContentType TransformationModelContentType `json:"content_type"`
	Database    string                         `json:"database"`

	// DependsOn Upstream model dependencies preserving AND/OR semantics.
	// - String elements represent required dependencies (AND logic)
	// - Array elements represent OR groups (at least one required)
	DependsOn   *[]TransformationModel_DependsOn_Item `json:"depends_on,omitempty"`
	Description *string                               `json:"description,omitempty"`

	// Fill Fill behavior (present when type=incremental)
	Fill *struct {
		// AllowGapSkipping Whether to allow skipping gaps in dependency data
		AllowGapSkipping *bool `json:"allow_gap_skipping,omitempty"`

		// Buffer Stay N positions behind dependency max (0 = no buffer)
		Buffer *int `json:"buffer,omitempty"`

		// Direction Fill direction (head or tail)
		Direction *TransformationModelFillDirection `json:"direction,omitempty"`
	} `json:"fill,omitempty"`

	// Id Fully qualified ID (database.table)
	Id string `json:"id"`

	// Interval Interval configuration (present when type=incremental)
	Interval *struct {
		// Max Maximum interval size
		Max *int `json:"max,omitempty"`

		// Min Minimum interval size
		Min *int `json:"min,omitempty"`

		// Type Type of interval (e.g., "second", "slot", "epoch", "block")
		Type *string `json:"type,omitempty"`
	} `json:"interval,omitempty"`

	// Limits Limits (present when type=incremental)
	Limits *struct {
		// Max Maximum position limit
		Max *int `json:"max,omitempty"`

		// Min Minimum position limit
		Min *int `json:"min,omitempty"`
	} `json:"limits,omitempty"`

	// Metadata System-managed metadata
	Metadata *struct {
		CreatedAt     *time.Time                                `json:"created_at,omitempty"`
		LastRunAt     *time.Time                                `json:"last_run_at,omitempty"`
		LastRunStatus *TransformationModelMetadataLastRunStatus `json:"last_run_status,omitempty"`
		RowCount      *int                                      `json:"row_count,omitempty"`
		SizeBytes     *int                                      `json:"size_bytes,omitempty"`
		UpdatedAt     *time.Time                                `json:"updated_at,omitempty"`
	} `json:"metadata,omitempty"`

	// Schedule Cron expression (present when type=scheduled)
	Schedule *string `json:"schedule,omitempty"`

	// Schedules Schedules (present when type=incremental)
	Schedules *struct {
		// Backfill Backfill schedule
		Backfill *string `json:"backfill,omitempty"`

		// Forwardfill Forward fill schedule
		Forwardfill *string `json:"forwardfill,omitempty"`
	} `json:"schedules,omitempty"`
	Table string `json:"table"`

	// Tags Tags for categorization
	Tags *[]string `json:"tags,omitempty"`

	// Type Transformation type (scheduled or incremental)
	Type TransformationModelType `json:"type"`
}

type TransformationModelBase struct {
	// Content SQL query or exec command defining the transformation
	Content string `json:"content"`

	// ContentType Execution method (SQL query or shell command)
	ContentType TransformationModelBaseContentType `json:"content_type"`
	Database    string                             `json:"database"`

	// DependsOn Upstream model dependencies preserving AND/OR semantics.
	// - String elements represent required dependencies (AND logic)
	// - Array elements represent OR groups (at least one required)
	DependsOn   *[]TransformationModelBase_DependsOn_Item `json:"depends_on,omitempty"`
	Description *string                                   `json:"description,omitempty"`

	// Id Fully qualified ID (database.table)
	Id string `json:"id"`

	// Metadata System-managed metadata
	Metadata *struct {
		CreatedAt     *time.Time                                    `json:"created_at,omitempty"`
		LastRunAt     *time.Time                                    `json:"last_run_at,omitempty"`
		LastRunStatus *TransformationModelBaseMetadataLastRunStatus `json:"last_run_status,omitempty"`
		RowCount      *int                                          `json:"row_count,omitempty"`
		SizeBytes     *int                                          `json:"size_bytes,omitempty"`
		UpdatedAt     *time.Time                                    `json:"updated_at,omitempty"`
	} `json:"metadata,omitempty"`
	Table string `json:"table"`

	// Tags Tags for categorization
	Tags *[]string `json:"tags,omitempty"`

	// Type Transformation type (scheduled or incremental)
	Type TransformationModelBaseType `json:"type"`
}

type TransformationModelBaseContentType string

type TransformationModelBaseDependsOn0 = string

type TransformationModelBaseDependsOn1 = []string

type TransformationModelBaseMetadataLastRunStatus string

type TransformationModelBaseType string

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

type TransformationModelContentType string

type TransformationModelDependsOn0 = string

type TransformationModelDependsOn1 = []string

type TransformationModelFillDirection string

type TransformationModelMetadataLastRunStatus string

type TransformationModelType string

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

type ValidationDebugInfo struct {
	// BlockingGaps List of gaps blocking processing
	BlockingGaps *[]struct {
		DependencyId string `json:"dependency_id"`

		// Gap Information about a gap in coverage
		Gap GapInfo `json:"gap"`
	} `json:"blocking_gaps,omitempty"`

	// HasDependencyGaps Whether any dependencies have gaps in the requested range
	HasDependencyGaps bool `json:"has_dependency_gaps"`

	// InBounds Whether position is within valid bounds of all dependencies
	InBounds bool `json:"in_bounds"`

	// NextValidPosition Next position where dependencies are available (if blocked)
	NextValidPosition *int `json:"next_valid_position,omitempty"`

	// Reasons Human-readable reasons why position cannot be processed
	Reasons *[]string `json:"reasons,omitempty"`

	// ValidRange Valid position range calculated from dependencies
	ValidRange *struct {
		Max int `json:"max"`
		Min int `json:"min"`
	} `json:"valid_range,omitempty"`
}