Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MigrateDataToDucklake ¶
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
Click to show internal directories.
Click to hide internal directories.