generated

package
v0.0.46 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 13, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Overview

Package generated provides primitives to interact with the openapi HTTP API.

Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.5.0 DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSwagger 

func GetSwagger() (swagger *openapi3.T, err error)

GetSwagger returns the Swagger specification corresponding to the generated code in this file. The external references of Swagger specification are resolved. The logic of resolving external references is tightly connected to "import-mapping" feature. Externally referenced files must be embedded in the corresponding golang packages. Urls can be supported but this task was out of the scope.

func PathToRawSpec 

func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

Constructs a synthetic filesystem for resolving external references when loading openapi specifications.

func RegisterHandlers 

func RegisterHandlers(router fiber.Router, si ServerInterface)

RegisterHandlers creates http.Handler with routing matching OpenAPI spec.

func RegisterHandlersWithOptions 

func RegisterHandlersWithOptions(router fiber.Router, si ServerInterface, options FiberServerOptions)

RegisterHandlersWithOptions creates http.Handler with additional options

Types

type BoundsInfo added in v0.0.36 

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"`
}

BoundsInfo Position bounds for a model

type CoverageDebug added in v0.0.36 

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"`
}

CoverageDebug Comprehensive debug information for coverage and dependencies at a specific position

type CoverageDetail 

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"`
}

CoverageDetail defines model for CoverageDetail.

type CoverageSummary 

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"`
}

CoverageSummary defines model for CoverageSummary.

type DependencyDebugInfo added in v0.0.36 

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"`
}

DependencyDebugInfo Debug information for a single dependency

type DependencyDebugInfoCoverageStatus added in v0.0.36 

type DependencyDebugInfoCoverageStatus string

DependencyDebugInfoCoverageStatus Coverage status for the requested position 

const (
	FullCoverage   DependencyDebugInfoCoverageStatus = "full_coverage"
	HasGaps        DependencyDebugInfoCoverageStatus = "has_gaps"
	NoData         DependencyDebugInfoCoverageStatus = "no_data"
	NotInitialized DependencyDebugInfoCoverageStatus = "not_initialized"
)

Defines values for DependencyDebugInfoCoverageStatus.

type DependencyDebugInfoNodeType added in v0.0.36 

type DependencyDebugInfoNodeType string

DependencyDebugInfoNodeType Type of dependency model 

const (
	DependencyDebugInfoNodeTypeExternal       DependencyDebugInfoNodeType = "external"
	DependencyDebugInfoNodeTypeTransformation DependencyDebugInfoNodeType = "transformation"
)

Defines values for DependencyDebugInfoNodeType.

type DependencyDebugInfoType added in v0.0.36 

type DependencyDebugInfoType string

DependencyDebugInfoType Dependency type (AND or OR group) 

const (
	OrGroup  DependencyDebugInfoType = "or_group"
	Required DependencyDebugInfoType = "required"
)

Defines values for DependencyDebugInfoType.

type Error 

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

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

Error defines model for Error.

type ExternalBounds 

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"`
}

ExternalBounds defines model for ExternalBounds.

type ExternalModel 

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"`
}

ExternalModel defines model for ExternalModel.

type FiberServerOptions 

type FiberServerOptions struct {
	BaseURL     string
	Middlewares []MiddlewareFunc
}

FiberServerOptions provides options for the Fiber server.

type GapInfo added in v0.0.36 

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"`
}

GapInfo Information about a gap in coverage

type InternalError 

type InternalError = Error

InternalError defines model for InternalError.

type IntervalTypeTransformation 

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"`
}

IntervalTypeTransformation A single transformation step for an interval type

type IntervalTypeTransformationFormat 

type IntervalTypeTransformationFormat string

IntervalTypeTransformationFormat 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. 

const (
	Date     IntervalTypeTransformationFormat = "date"
	Datetime IntervalTypeTransformationFormat = "datetime"
	Duration IntervalTypeTransformationFormat = "duration"
	Relative IntervalTypeTransformationFormat = "relative"
	Time     IntervalTypeTransformationFormat = "time"
)

Defines values for IntervalTypeTransformationFormat.

type ListAllModelsParams 

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"`
}

ListAllModelsParams defines parameters for ListAllModels.

type ListAllModelsParamsType 

type ListAllModelsParamsType string

ListAllModelsParamsType defines parameters for ListAllModels. 

const (
	External       ListAllModelsParamsType = "external"
	Transformation ListAllModelsParamsType = "transformation"
)

Defines values for ListAllModelsParamsType.

type ListExternalModelsParams 

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

ListExternalModelsParams defines parameters for ListExternalModels.

type ListScheduledRunsParams 

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

ListScheduledRunsParams defines parameters for ListScheduledRuns.

type ListTransformationCoverageParams 

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

ListTransformationCoverageParams defines parameters for ListTransformationCoverage.

type ListTransformationsParams 

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"`
}

ListTransformationsParams defines parameters for ListTransformations.

type ListTransformationsParamsStatus 

type ListTransformationsParamsStatus string

ListTransformationsParamsStatus defines parameters for ListTransformations. 

const (
	Failed  ListTransformationsParamsStatus = "failed"
	Pending ListTransformationsParamsStatus = "pending"
	Running ListTransformationsParamsStatus = "running"
	Success ListTransformationsParamsStatus = "success"
)

Defines values for ListTransformationsParamsStatus.

type ListTransformationsParamsType 

type ListTransformationsParamsType string

ListTransformationsParamsType defines parameters for ListTransformations. 

const (
	Incremental ListTransformationsParamsType = "incremental"
	Scheduled   ListTransformationsParamsType = "scheduled"
)

Defines values for ListTransformationsParamsType.

type MiddlewareFunc 

type MiddlewareFunc fiber.Handler

type ModelCoverageInfo added in v0.0.36 

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"`
}

ModelCoverageInfo Coverage information for the target model itself

type ModelSummary 

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"`
}

ModelSummary Lightweight model representation for listings

type ModelSummaryType 

type ModelSummaryType string

ModelSummaryType Model type 

const (
	ModelSummaryTypeExternal       ModelSummaryType = "external"
	ModelSummaryTypeTransformation ModelSummaryType = "transformation"
)

Defines values for ModelSummaryType.

type NotFound 

type NotFound = Error

NotFound defines model for NotFound.

type Range 

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

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

Range defines model for Range.

type ScheduledRun 

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"`
}

ScheduledRun defines model for ScheduledRun.

type ServerInterface 

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
}

ServerInterface represents all server handlers.

type ServerInterfaceWrapper 

type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) DebugCoverageAtPosition added in v0.0.36 

func (siw *ServerInterfaceWrapper) DebugCoverageAtPosition(c fiber.Ctx) error

DebugCoverageAtPosition operation middleware

func (*ServerInterfaceWrapper) GetExternalBounds 

func (siw *ServerInterfaceWrapper) GetExternalBounds(c fiber.Ctx) error

GetExternalBounds operation middleware

func (*ServerInterfaceWrapper) GetExternalModel 

func (siw *ServerInterfaceWrapper) GetExternalModel(c fiber.Ctx) error

GetExternalModel operation middleware

func (*ServerInterfaceWrapper) GetIntervalTypes 

func (siw *ServerInterfaceWrapper) GetIntervalTypes(c fiber.Ctx) error

GetIntervalTypes operation middleware

func (*ServerInterfaceWrapper) GetScheduledRun 

func (siw *ServerInterfaceWrapper) GetScheduledRun(c fiber.Ctx) error

GetScheduledRun operation middleware

func (*ServerInterfaceWrapper) GetTransformation 

func (siw *ServerInterfaceWrapper) GetTransformation(c fiber.Ctx) error

GetTransformation operation middleware

func (*ServerInterfaceWrapper) GetTransformationCoverage 

func (siw *ServerInterfaceWrapper) GetTransformationCoverage(c fiber.Ctx) error

GetTransformationCoverage operation middleware

func (*ServerInterfaceWrapper) ListAllModels 

func (siw *ServerInterfaceWrapper) ListAllModels(c fiber.Ctx) error

ListAllModels operation middleware

func (*ServerInterfaceWrapper) ListExternalBounds 

func (siw *ServerInterfaceWrapper) ListExternalBounds(c fiber.Ctx) error

ListExternalBounds operation middleware

func (*ServerInterfaceWrapper) ListExternalModels 

func (siw *ServerInterfaceWrapper) ListExternalModels(c fiber.Ctx) error

ListExternalModels operation middleware

func (*ServerInterfaceWrapper) ListScheduledRuns 

func (siw *ServerInterfaceWrapper) ListScheduledRuns(c fiber.Ctx) error

ListScheduledRuns operation middleware

func (*ServerInterfaceWrapper) ListTransformationCoverage 

func (siw *ServerInterfaceWrapper) ListTransformationCoverage(c fiber.Ctx) error

ListTransformationCoverage operation middleware

func (*ServerInterfaceWrapper) ListTransformations 

func (siw *ServerInterfaceWrapper) ListTransformations(c fiber.Ctx) error

ListTransformations operation middleware

type TransformationModel 

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"`
}

TransformationModel defines model for TransformationModel.

type TransformationModelBase 

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"`
}

TransformationModelBase defines model for TransformationModelBase.

type TransformationModelBaseContentType 

type TransformationModelBaseContentType string

TransformationModelBaseContentType Execution method (SQL query or shell command) 

const (
	TransformationModelBaseContentTypeExec TransformationModelBaseContentType = "exec"
	TransformationModelBaseContentTypeSql  TransformationModelBaseContentType = "sql"
)

Defines values for TransformationModelBaseContentType.

type TransformationModelBaseDependsOn0 added in v0.0.26 

type TransformationModelBaseDependsOn0 = string

TransformationModelBaseDependsOn0 Single required dependency (AND logic)

type TransformationModelBaseDependsOn1 added in v0.0.26 

type TransformationModelBaseDependsOn1 = []string

TransformationModelBaseDependsOn1 OR group - at least one dependency required

type TransformationModelBaseMetadataLastRunStatus 

type TransformationModelBaseMetadataLastRunStatus string

TransformationModelBaseMetadataLastRunStatus defines model for TransformationModelBase.Metadata.LastRunStatus. 

const (
	TransformationModelBaseMetadataLastRunStatusFailed  TransformationModelBaseMetadataLastRunStatus = "failed"
	TransformationModelBaseMetadataLastRunStatusPending TransformationModelBaseMetadataLastRunStatus = "pending"
	TransformationModelBaseMetadataLastRunStatusRunning TransformationModelBaseMetadataLastRunStatus = "running"
	TransformationModelBaseMetadataLastRunStatusSuccess TransformationModelBaseMetadataLastRunStatus = "success"
)

Defines values for TransformationModelBaseMetadataLastRunStatus.

type TransformationModelBaseType 

type TransformationModelBaseType string

TransformationModelBaseType Transformation type (scheduled or incremental) 

const (
	TransformationModelBaseTypeIncremental TransformationModelBaseType = "incremental"
	TransformationModelBaseTypeScheduled   TransformationModelBaseType = "scheduled"
)

Defines values for TransformationModelBaseType.

type TransformationModelBase_DependsOn_Item added in v0.0.26 

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

TransformationModelBase_DependsOn_Item defines model for TransformationModelBase.depends_on.Item.

func (TransformationModelBase_DependsOn_Item) AsTransformationModelBaseDependsOn0 added in v0.0.26 

func (t TransformationModelBase_DependsOn_Item) AsTransformationModelBaseDependsOn0() (TransformationModelBaseDependsOn0, error)

AsTransformationModelBaseDependsOn0 returns the union data inside the TransformationModelBase_DependsOn_Item as a TransformationModelBaseDependsOn0

func (TransformationModelBase_DependsOn_Item) AsTransformationModelBaseDependsOn1 added in v0.0.26 

func (t TransformationModelBase_DependsOn_Item) AsTransformationModelBaseDependsOn1() (TransformationModelBaseDependsOn1, error)

AsTransformationModelBaseDependsOn1 returns the union data inside the TransformationModelBase_DependsOn_Item as a TransformationModelBaseDependsOn1

func (*TransformationModelBase_DependsOn_Item) FromTransformationModelBaseDependsOn0 added in v0.0.26 

func (t *TransformationModelBase_DependsOn_Item) FromTransformationModelBaseDependsOn0(v TransformationModelBaseDependsOn0) error

FromTransformationModelBaseDependsOn0 overwrites any union data inside the TransformationModelBase_DependsOn_Item as the provided TransformationModelBaseDependsOn0

func (*TransformationModelBase_DependsOn_Item) FromTransformationModelBaseDependsOn1 added in v0.0.26 

func (t *TransformationModelBase_DependsOn_Item) FromTransformationModelBaseDependsOn1(v TransformationModelBaseDependsOn1) error

FromTransformationModelBaseDependsOn1 overwrites any union data inside the TransformationModelBase_DependsOn_Item as the provided TransformationModelBaseDependsOn1

func (TransformationModelBase_DependsOn_Item) MarshalJSON added in v0.0.26 

func (t TransformationModelBase_DependsOn_Item) MarshalJSON() ([]byte, error)

func (*TransformationModelBase_DependsOn_Item) MergeTransformationModelBaseDependsOn0 added in v0.0.26 

func (t *TransformationModelBase_DependsOn_Item) MergeTransformationModelBaseDependsOn0(v TransformationModelBaseDependsOn0) error

MergeTransformationModelBaseDependsOn0 performs a merge with any union data inside the TransformationModelBase_DependsOn_Item, using the provided TransformationModelBaseDependsOn0

func (*TransformationModelBase_DependsOn_Item) MergeTransformationModelBaseDependsOn1 added in v0.0.26 

func (t *TransformationModelBase_DependsOn_Item) MergeTransformationModelBaseDependsOn1(v TransformationModelBaseDependsOn1) error

MergeTransformationModelBaseDependsOn1 performs a merge with any union data inside the TransformationModelBase_DependsOn_Item, using the provided TransformationModelBaseDependsOn1

func (*TransformationModelBase_DependsOn_Item) UnmarshalJSON added in v0.0.26 

func (t *TransformationModelBase_DependsOn_Item) UnmarshalJSON(b []byte) error

type TransformationModelContentType 

type TransformationModelContentType string

TransformationModelContentType Execution method (SQL query or shell command) 

const (
	TransformationModelContentTypeExec TransformationModelContentType = "exec"
	TransformationModelContentTypeSql  TransformationModelContentType = "sql"
)

Defines values for TransformationModelContentType.

type TransformationModelDependsOn0 added in v0.0.26 

type TransformationModelDependsOn0 = string

TransformationModelDependsOn0 Single required dependency (AND logic)

type TransformationModelDependsOn1 added in v0.0.26 

type TransformationModelDependsOn1 = []string

TransformationModelDependsOn1 OR group - at least one dependency required

type TransformationModelFillDirection added in v0.0.43 

type TransformationModelFillDirection string

TransformationModelFillDirection Fill direction (head or tail) 

const (
	Head TransformationModelFillDirection = "head"
	Tail TransformationModelFillDirection = "tail"
)

Defines values for TransformationModelFillDirection.

type TransformationModelMetadataLastRunStatus 

type TransformationModelMetadataLastRunStatus string

TransformationModelMetadataLastRunStatus defines model for TransformationModel.Metadata.LastRunStatus. 

const (
	TransformationModelMetadataLastRunStatusFailed  TransformationModelMetadataLastRunStatus = "failed"
	TransformationModelMetadataLastRunStatusPending TransformationModelMetadataLastRunStatus = "pending"
	TransformationModelMetadataLastRunStatusRunning TransformationModelMetadataLastRunStatus = "running"
	TransformationModelMetadataLastRunStatusSuccess TransformationModelMetadataLastRunStatus = "success"
)

Defines values for TransformationModelMetadataLastRunStatus.

type TransformationModelType 

type TransformationModelType string

TransformationModelType Transformation type (scheduled or incremental) 

const (
	TransformationModelTypeIncremental TransformationModelType = "incremental"
	TransformationModelTypeScheduled   TransformationModelType = "scheduled"
)

Defines values for TransformationModelType.

type TransformationModel_DependsOn_Item added in v0.0.26 

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

TransformationModel_DependsOn_Item defines model for TransformationModel.depends_on.Item.

func (TransformationModel_DependsOn_Item) AsTransformationModelDependsOn0 added in v0.0.26 

func (t TransformationModel_DependsOn_Item) AsTransformationModelDependsOn0() (TransformationModelDependsOn0, error)

AsTransformationModelDependsOn0 returns the union data inside the TransformationModel_DependsOn_Item as a TransformationModelDependsOn0

func (TransformationModel_DependsOn_Item) AsTransformationModelDependsOn1 added in v0.0.26 

func (t TransformationModel_DependsOn_Item) AsTransformationModelDependsOn1() (TransformationModelDependsOn1, error)

AsTransformationModelDependsOn1 returns the union data inside the TransformationModel_DependsOn_Item as a TransformationModelDependsOn1

func (*TransformationModel_DependsOn_Item) FromTransformationModelDependsOn0 added in v0.0.26 

func (t *TransformationModel_DependsOn_Item) FromTransformationModelDependsOn0(v TransformationModelDependsOn0) error

FromTransformationModelDependsOn0 overwrites any union data inside the TransformationModel_DependsOn_Item as the provided TransformationModelDependsOn0

func (*TransformationModel_DependsOn_Item) FromTransformationModelDependsOn1 added in v0.0.26 

func (t *TransformationModel_DependsOn_Item) FromTransformationModelDependsOn1(v TransformationModelDependsOn1) error

FromTransformationModelDependsOn1 overwrites any union data inside the TransformationModel_DependsOn_Item as the provided TransformationModelDependsOn1

func (TransformationModel_DependsOn_Item) MarshalJSON added in v0.0.26 

func (t TransformationModel_DependsOn_Item) MarshalJSON() ([]byte, error)

func (*TransformationModel_DependsOn_Item) MergeTransformationModelDependsOn0 added in v0.0.26 

func (t *TransformationModel_DependsOn_Item) MergeTransformationModelDependsOn0(v TransformationModelDependsOn0) error

MergeTransformationModelDependsOn0 performs a merge with any union data inside the TransformationModel_DependsOn_Item, using the provided TransformationModelDependsOn0

func (*TransformationModel_DependsOn_Item) MergeTransformationModelDependsOn1 added in v0.0.26 

func (t *TransformationModel_DependsOn_Item) MergeTransformationModelDependsOn1(v TransformationModelDependsOn1) error

MergeTransformationModelDependsOn1 performs a merge with any union data inside the TransformationModel_DependsOn_Item, using the provided TransformationModelDependsOn1

func (*TransformationModel_DependsOn_Item) UnmarshalJSON added in v0.0.26 

func (t *TransformationModel_DependsOn_Item) UnmarshalJSON(b []byte) error

type ValidationDebugInfo added in v0.0.36 

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"`
}

ValidationDebugInfo Validation results using the same logic as backfill/dependency checking

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.