migration

package
v0.7.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Sep 16, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MigrateDataToDucklake

func MigrateDataToDucklake(ctx context.Context) error

MigrateDataToDucklake performs migration of views from tailpipe.db and associated parquet files into the new DuckLake metadata catalog

Types

type MigrationStatus

type MigrationStatus struct {
	Status          string  `json:"status"`
	Total           int     `json:"total"`
	Migrated        int     `json:"migrated"`
	Failed          int     `json:"failed"`
	Remaining       int     `json:"remaining"`
	ProgressPercent float64 `json:"progress_percent"`

	TotalFiles     int `json:"total_files"`
	MigratedFiles  int `json:"migrated_files"`
	FailedFiles    int `json:"failed_files"`
	RemainingFiles int `json:"remaining_files"`

	FailedTables []string      `json:"failed_tables,omitempty"`
	StartTime    time.Time     `json:"start_time"`
	Duration     time.Duration `json:"duration"`
}

func NewMigrationStatus

func NewMigrationStatus(total int) *MigrationStatus

func (*MigrationStatus) Finish

func (s *MigrationStatus) Finish(outcome string)

func (*MigrationStatus) OnFilesFailed

func (s *MigrationStatus) OnFilesFailed(n int)

func (*MigrationStatus) OnFilesMigrated

func (s *MigrationStatus) OnFilesMigrated(n int)

func (*MigrationStatus) OnTableFailed

func (s *MigrationStatus) OnTableFailed(tableName string)

func (*MigrationStatus) OnTableMigrated

func (s *MigrationStatus) OnTableMigrated()

func (*MigrationStatus) StatusMessage

func (s *MigrationStatus) StatusMessage() string

StatusMessage returns a user-facing status message (with stats) based on current migration status

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL