cp

Documentation

Overview

Copyright (c) YugabyteDB, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• func GetSchemaList(schema string) []string
• func SplitTableNameForPG(tableName string) (string, string)
• type BaseEvent
• type BaseUpdateRowCountEvent
• type ControlPlane
• type ExportSchemaCompletedEvent
• type ExportSchemaStartedEvent
• type ImportSchemaCompletedEvent
• type ImportSchemaStartedEvent
• type MigrationAssessmentCompletedEvent
• type MigrationAssessmentStartedEvent
• type MigrationEndedEvent
• type SchemaAnalysisIterationCompletedEvent
• type SchemaAnalysisStartedEvent
• type SnapshotExportCompletedEvent
• type SnapshotExportStartedEvent
• type SnapshotImportCompletedEvent
• type SnapshotImportStartedEvent
• type UpdateExportedRowCountEvent
• type UpdateImportedRowCountEvent

Variables

var EXPORT_OR_IMPORT_DATA_STATUS_INT_TO_STR = map[int]string{
	0: "NOT STARTED",
	1: "IN PROGRESS",
	2: "DONE",
	3: "COMPLETED",
}

Functions

func GetSchemaList

func GetSchemaList(schema string) []string

func SplitTableNameForPG

func SplitTableNameForPG(tableName string) (string, string)

Types

type BaseEvent

type BaseEvent struct {
	EventType     string
	MigrationUUID uuid.UUID
	DBType        string
	DatabaseName  string
	SchemaNames   []string
}

type BaseUpdateRowCountEvent

type BaseUpdateRowCountEvent struct {
	BaseEvent
	TableName         string
	Status            string
	TotalRowCount     int64
	CompletedRowCount int64
}

type ControlPlane

type ControlPlane interface {
	Init() error
	Finalize()

	MigrationAssessmentStarted(*MigrationAssessmentStartedEvent)
	MigrationAssessmentCompleted(*MigrationAssessmentCompletedEvent)

	ExportSchemaStarted(*ExportSchemaStartedEvent)
	ExportSchemaCompleted(*ExportSchemaCompletedEvent) // Only success is reported.

	SchemaAnalysisStarted(*SchemaAnalysisStartedEvent)
	SchemaAnalysisIterationCompleted(*SchemaAnalysisIterationCompletedEvent)

	SnapshotExportStarted(*SnapshotExportStartedEvent)
	UpdateExportedRowCount([]*UpdateExportedRowCountEvent)
	SnapshotExportCompleted(*SnapshotExportCompletedEvent)

	ImportSchemaStarted(*ImportSchemaStartedEvent)
	ImportSchemaCompleted(*ImportSchemaCompletedEvent)

	SnapshotImportStarted(*SnapshotImportStartedEvent)
	UpdateImportedRowCount([]*UpdateImportedRowCountEvent)
	SnapshotImportCompleted(*SnapshotImportCompletedEvent)

	MigrationEnded(*MigrationEndedEvent)
}

type ExportSchemaCompletedEvent

type ExportSchemaCompletedEvent struct {
	BaseEvent
}

type ExportSchemaStartedEvent

type ExportSchemaStartedEvent struct {
	BaseEvent
}

type ImportSchemaCompletedEvent

type ImportSchemaCompletedEvent struct {
	BaseEvent
}

type ImportSchemaStartedEvent

type ImportSchemaStartedEvent struct {
	BaseEvent
}

type MigrationAssessmentCompletedEvent

type MigrationAssessmentCompletedEvent struct {
	BaseEvent
	Report string
}

type MigrationAssessmentStartedEvent

type MigrationAssessmentStartedEvent struct {
	BaseEvent
}

type MigrationEndedEvent

type MigrationEndedEvent struct {
	BaseEvent
}

type SchemaAnalysisIterationCompletedEvent

type SchemaAnalysisIterationCompletedEvent struct {
	BaseEvent
	AnalysisReport utils.SchemaReport
}

type SchemaAnalysisStartedEvent

type SchemaAnalysisStartedEvent struct {
	BaseEvent
}

type SnapshotExportCompletedEvent

type SnapshotExportCompletedEvent struct {
	BaseEvent
}

type SnapshotExportStartedEvent

type SnapshotExportStartedEvent struct {
	BaseEvent
}

type SnapshotImportCompletedEvent

type SnapshotImportCompletedEvent struct {
	BaseEvent
}

type SnapshotImportStartedEvent

type SnapshotImportStartedEvent struct {
	BaseEvent
}

type UpdateExportedRowCountEvent

type UpdateExportedRowCountEvent struct {
	BaseUpdateRowCountEvent
}

type UpdateImportedRowCountEvent

type UpdateImportedRowCountEvent struct {
	BaseUpdateRowCountEvent
}