BigQuery Migration API v2 - Package cloud.google.com/go/bigquery/migration/apiv2/migrationpb (v1.83.0)

1.83.0 (latest) 1.82.0 1.81.0 1.80.0 1.79.1 1.78.0 1.77.0 1.76.0 1.75.0 1.74.0 1.73.1 1.72.0 1.71.0 1.70.0 1.69.0 1.68.0 1.67.0 1.66.2 1.65.0 1.64.0 1.63.1 1.62.0 1.61.0 1.60.0 1.59.1 1.58.0 1.57.1 1.54.0 1.53.0 1.52.0 1.51.2 1.50.0 1.49.0 1.48.0 1.47.0 1.46.0 1.45.0 1.44.0 1.43.0 1.42.0 1.41.0 1.40.0 1.39.0 1.38.0 1.37.0 1.36.0 1.35.0 1.34.1 1.33.0 1.32.0 1.31.0 1.30.2 1.29.0 1.28.0 1.27.0 1.26.0 1.25.0 1.24.0 1.23.0 1.22.0 1.21.0 1.20.1 1.19.0 1.18.0 1.17.0 1.16.0 1.15.0

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Constants

MigrationService_CreateMigrationWorkflow_FullMethodName, MigrationService_GetMigrationWorkflow_FullMethodName, MigrationService_ListMigrationWorkflows_FullMethodName, MigrationService_DeleteMigrationWorkflow_FullMethodName, MigrationService_StartMigrationWorkflow_FullMethodName, MigrationService_GetMigrationSubtask_FullMethodName, MigrationService_ListMigrationSubtasks_FullMethodName

const (
	MigrationService_CreateMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/CreateMigrationWorkflow"
	MigrationService_GetMigrationWorkflow_FullMethodName    = "/google.cloud.bigquery.migration.v2.MigrationService/GetMigrationWorkflow"
	MigrationService_ListMigrationWorkflows_FullMethodName  = "/google.cloud.bigquery.migration.v2.MigrationService/ListMigrationWorkflows"
	MigrationService_DeleteMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/DeleteMigrationWorkflow"
	MigrationService_StartMigrationWorkflow_FullMethodName  = "/google.cloud.bigquery.migration.v2.MigrationService/StartMigrationWorkflow"
	MigrationService_GetMigrationSubtask_FullMethodName     = "/google.cloud.bigquery.migration.v2.MigrationService/GetMigrationSubtask"
	MigrationService_ListMigrationSubtasks_FullMethodName   = "/google.cloud.bigquery.migration.v2.MigrationService/ListMigrationSubtasks"
)

Variables

MigrationWorkflow_State_name, MigrationWorkflow_State_value

var (
	MigrationWorkflow_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "RUNNING",
		3: "PAUSED",
		4: "COMPLETED",
	}
	MigrationWorkflow_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"RUNNING":           2,
		"PAUSED":            3,
		"COMPLETED":         4,
	}
)

Enum value maps for MigrationWorkflow_State.

MigrationTask_State_name, MigrationTask_State_value

var (
	MigrationTask_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "ORCHESTRATING",
		3: "RUNNING",
		4: "PAUSED",
		5: "SUCCEEDED",
		6: "FAILED",
	}
	MigrationTask_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"ORCHESTRATING":     2,
		"RUNNING":           3,
		"PAUSED":            4,
		"SUCCEEDED":         5,
		"FAILED":            6,
	}
)

Enum value maps for MigrationTask_State.

MigrationSubtask_State_name, MigrationSubtask_State_value

var (
	MigrationSubtask_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "RUNNING",
		3: "SUCCEEDED",
		4: "FAILED",
		5: "PAUSED",
		6: "PENDING_DEPENDENCY",
	}
	MigrationSubtask_State_value = map[string]int32{
		"STATE_UNSPECIFIED":  0,
		"ACTIVE":             1,
		"RUNNING":            2,
		"SUCCEEDED":          3,
		"FAILED":             4,
		"PAUSED":             5,
		"PENDING_DEPENDENCY": 6,
	}
)

Enum value maps for MigrationSubtask_State.

TaskOutput_State_name, TaskOutput_State_value

var (
	TaskOutput_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "SUCCEEDED",
		3: "FAILED",
	}
	TaskOutput_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
	}
)

Enum value maps for TaskOutput_State.

LineageOutput_RecognizedInput_Type_name, LineageOutput_RecognizedInput_Type_value

var (
	LineageOutput_RecognizedInput_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "METADATA",
		2: "QUERY_LOG",
		3: "SCRIPT",
	}
	LineageOutput_RecognizedInput_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"METADATA":         1,
		"QUERY_LOG":        2,
		"SCRIPT":           3,
	}
)

Enum value maps for LineageOutput_RecognizedInput_Type.

LineageOutput_ProgressReport_ProcessingStage_name, LineageOutput_ProgressReport_ProcessingStage_value

var (
	LineageOutput_ProgressReport_ProcessingStage_name = map[int32]string{
		0:    "PROCESSING_STAGE_UNSPECIFIED",
		1000: "INPUT_INGESTION",
		2000: "POSTPROCESSING",
	}
	LineageOutput_ProgressReport_ProcessingStage_value = map[string]int32{
		"PROCESSING_STAGE_UNSPECIFIED": 0,
		"INPUT_INGESTION":              1000,
		"POSTPROCESSING":               2000,
	}
)

Enum value maps for LineageOutput_ProgressReport_ProcessingStage.

LineageOutput_ProgressReport_WorkSummary_State_name, LineageOutput_ProgressReport_WorkSummary_State_value

var (
	LineageOutput_ProgressReport_WorkSummary_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED",
		3: "IN_PROGRESS",
		4: "SKIPPED",
	}
	LineageOutput_ProgressReport_WorkSummary_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"SUCCEEDED":         1,
		"FAILED":            2,
		"IN_PROGRESS":       3,
		"SKIPPED":           4,
	}
)

Enum value maps for LineageOutput_ProgressReport_WorkSummary_State.

TeradataDialect_Mode_name, TeradataDialect_Mode_value

var (
	TeradataDialect_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "SQL",
		2: "BTEQ",
	}
	TeradataDialect_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"SQL":              1,
		"BTEQ":             2,
	}
)

Enum value maps for TeradataDialect_Mode.

NameMappingKey_Type_name, NameMappingKey_Type_value

var (
	NameMappingKey_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "DATABASE",
		2: "SCHEMA",
		3: "RELATION",
		4: "ATTRIBUTE",
		5: "RELATION_ALIAS",
		6: "ATTRIBUTE_ALIAS",
		7: "FUNCTION",
	}
	NameMappingKey_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"DATABASE":         1,
		"SCHEMA":           2,
		"RELATION":         3,
		"ATTRIBUTE":        4,
		"RELATION_ALIAS":   5,
		"ATTRIBUTE_ALIAS":  6,
		"FUNCTION":         7,
	}
)

Enum value maps for NameMappingKey_Type.

SuggestionStep_SuggestionType_name, SuggestionStep_SuggestionType_value

var (
	SuggestionStep_SuggestionType_name = map[int32]string{
		0: "SUGGESTION_TYPE_UNSPECIFIED",
		1: "QUERY_CUSTOMIZATION",
		2: "TRANSLATION_EXPLANATION",
	}
	SuggestionStep_SuggestionType_value = map[string]int32{
		"SUGGESTION_TYPE_UNSPECIFIED": 0,
		"QUERY_CUSTOMIZATION":         1,
		"TRANSLATION_EXPLANATION":     2,
	}
)

Enum value maps for SuggestionStep_SuggestionType.

SuggestionStep_RewriteTarget_name, SuggestionStep_RewriteTarget_value

var (
	SuggestionStep_RewriteTarget_name = map[int32]string{
		0: "REWRITE_TARGET_UNSPECIFIED",
		1: "SOURCE_SQL",
		2: "TARGET_SQL",
	}
	SuggestionStep_RewriteTarget_value = map[string]int32{
		"REWRITE_TARGET_UNSPECIFIED": 0,
		"SOURCE_SQL":                 1,
		"TARGET_SQL":                 2,
	}
)

Enum value maps for SuggestionStep_RewriteTarget.

TranslationReportRecord_Severity_name, TranslationReportRecord_Severity_value

var (
	TranslationReportRecord_Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "INFO",
		2: "WARNING",
		3: "ERROR",
	}
	TranslationReportRecord_Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"INFO":                 1,
		"WARNING":              2,
		"ERROR":                3,
	}
)

Enum value maps for TranslationReportRecord_Severity.

File_google_cloud_bigquery_migration_v2_assessment_task_proto

var File_google_cloud_bigquery_migration_v2_assessment_task_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_migration_entities_proto

var File_google_cloud_bigquery_migration_v2_migration_entities_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_migration_error_details_proto

var File_google_cloud_bigquery_migration_v2_migration_error_details_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_migration_metrics_proto

var File_google_cloud_bigquery_migration_v2_migration_metrics_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_migration_service_proto

var File_google_cloud_bigquery_migration_v2_migration_service_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_translation_config_proto

var File_google_cloud_bigquery_migration_v2_translation_config_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_translation_details_proto

var File_google_cloud_bigquery_migration_v2_translation_details_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_translation_suggestion_proto

var File_google_cloud_bigquery_migration_v2_translation_suggestion_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2_translation_usability_proto

var File_google_cloud_bigquery_migration_v2_translation_usability_proto protoreflect.FileDescriptor

MigrationService_ServiceDesc

var MigrationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.bigquery.migration.v2.MigrationService",
	HandlerType: (*MigrationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateMigrationWorkflow",
			Handler:    _MigrationService_CreateMigrationWorkflow_Handler,
		},
		{
			MethodName: "GetMigrationWorkflow",
			Handler:    _MigrationService_GetMigrationWorkflow_Handler,
		},
		{
			MethodName: "ListMigrationWorkflows",
			Handler:    _MigrationService_ListMigrationWorkflows_Handler,
		},
		{
			MethodName: "DeleteMigrationWorkflow",
			Handler:    _MigrationService_DeleteMigrationWorkflow_Handler,
		},
		{
			MethodName: "StartMigrationWorkflow",
			Handler:    _MigrationService_StartMigrationWorkflow_Handler,
		},
		{
			MethodName: "GetMigrationSubtask",
			Handler:    _MigrationService_GetMigrationSubtask_Handler,
		},
		{
			MethodName: "ListMigrationSubtasks",
			Handler:    _MigrationService_ListMigrationSubtasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/bigquery/migration/v2/migration_service.proto",
}

MigrationService_ServiceDesc is the grpc.ServiceDesc for MigrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMigrationServiceServer

func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)

AssessmentFeatureHandle

type AssessmentFeatureHandle struct {

	// Optional. Whether to create a dataset containing non-PII data in addition
	// to the output dataset.
	AddShareableDataset *bool `protobuf:"varint,1,opt,name=add_shareable_dataset,json=addShareableDataset,proto3,oneof" json:"add_shareable_dataset,omitempty"`
	// contains filtered or unexported fields
}

User-definable feature flags for assessment tasks.

func (*AssessmentFeatureHandle) Descriptor

func (*AssessmentFeatureHandle) Descriptor() ([]byte, []int)

Deprecated: Use AssessmentFeatureHandle.ProtoReflect.Descriptor instead.

func (*AssessmentFeatureHandle) GetAddShareableDataset

func (x *AssessmentFeatureHandle) GetAddShareableDataset() bool

func (*AssessmentFeatureHandle) ProtoMessage

func (*AssessmentFeatureHandle) ProtoMessage()

func (*AssessmentFeatureHandle) ProtoReflect

func (x *AssessmentFeatureHandle) ProtoReflect() protoreflect.Message

func (*AssessmentFeatureHandle) Reset

func (x *AssessmentFeatureHandle) Reset()

func (*AssessmentFeatureHandle) String

func (x *AssessmentFeatureHandle) String() string

AssessmentTaskDetails

type AssessmentTaskDetails struct {

	// Required. The Cloud Storage path for assessment input files.
	InputPath string `protobuf:"bytes,1,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// Required. The BigQuery dataset for output.
	OutputDataset string `protobuf:"bytes,2,opt,name=output_dataset,json=outputDataset,proto3" json:"output_dataset,omitempty"`
	// Optional. An optional Cloud Storage path to write the query logs (which is
	// then used as an input path on the translation task)
	QuerylogsPath string `protobuf:"bytes,3,opt,name=querylogs_path,json=querylogsPath,proto3" json:"querylogs_path,omitempty"`
	// Required. The data source or data warehouse type (eg: TERADATA/REDSHIFT)
	// from which the input data is extracted.
	DataSource string `protobuf:"bytes,4,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// Optional. A collection of additional feature flags for this assessment.
	FeatureHandle *AssessmentFeatureHandle `protobuf:"bytes,6,opt,name=feature_handle,json=featureHandle,proto3,oneof" json:"feature_handle,omitempty"`
	// contains filtered or unexported fields
}

Assessment task config.

func (*AssessmentTaskDetails) Descriptor

func (*AssessmentTaskDetails) Descriptor() ([]byte, []int)

Deprecated: Use AssessmentTaskDetails.ProtoReflect.Descriptor instead.

func (*AssessmentTaskDetails) GetDataSource

func (x *AssessmentTaskDetails) GetDataSource() string

func (*AssessmentTaskDetails) GetFeatureHandle

func (x *AssessmentTaskDetails) GetFeatureHandle() *AssessmentFeatureHandle

func (*AssessmentTaskDetails) GetInputPath

func (x *AssessmentTaskDetails) GetInputPath() string

func (*AssessmentTaskDetails) GetOutputDataset

func (x *AssessmentTaskDetails) GetOutputDataset() string

func (*AssessmentTaskDetails) GetQuerylogsPath

func (x *AssessmentTaskDetails) GetQuerylogsPath() string

func (*AssessmentTaskDetails) ProtoMessage

func (*AssessmentTaskDetails) ProtoMessage()

func (*AssessmentTaskDetails) ProtoReflect

func (x *AssessmentTaskDetails) ProtoReflect() protoreflect.Message

func (*AssessmentTaskDetails) Reset

func (x *AssessmentTaskDetails) Reset()

func (*AssessmentTaskDetails) String

func (x *AssessmentTaskDetails) String() string

AzureSynapseDialect

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

The dialect definition for Azure Synapse.

func (*AzureSynapseDialect) Descriptor

func (*AzureSynapseDialect) Descriptor() ([]byte, []int)

Deprecated: Use AzureSynapseDialect.ProtoReflect.Descriptor instead.

func (*AzureSynapseDialect) ProtoMessage

func (*AzureSynapseDialect) ProtoMessage()

func (*AzureSynapseDialect) ProtoReflect

func (x *AzureSynapseDialect) ProtoReflect() protoreflect.Message

func (*AzureSynapseDialect) Reset

func (x *AzureSynapseDialect) Reset()

func (*AzureSynapseDialect) String

func (x *AzureSynapseDialect) String() string

BigQueryDialect

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

The dialect definition for BigQuery.

func (*BigQueryDialect) Descriptor

func (*BigQueryDialect) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryDialect.ProtoReflect.Descriptor instead.

func (*BigQueryDialect) ProtoMessage

func (*BigQueryDialect) ProtoMessage()

func (*BigQueryDialect) ProtoReflect

func (x *BigQueryDialect) ProtoReflect() protoreflect.Message

func (*BigQueryDialect) Reset

func (x *BigQueryDialect) Reset()

func (*BigQueryDialect) String

func (x *BigQueryDialect) String() string

CreateMigrationWorkflowRequest

type CreateMigrationWorkflowRequest struct {

	// Required. The name of the project to which this migration workflow belongs.
	// Example: `projects/foo/locations/bar`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The migration workflow to create.
	MigrationWorkflow *MigrationWorkflow `protobuf:"bytes,2,opt,name=migration_workflow,json=migrationWorkflow,proto3" json:"migration_workflow,omitempty"`
	// contains filtered or unexported fields
}

Request to create a migration workflow resource.

func (*CreateMigrationWorkflowRequest) Descriptor

func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateMigrationWorkflowRequest) GetMigrationWorkflow

func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow

func (*CreateMigrationWorkflowRequest) GetParent

func (x *CreateMigrationWorkflowRequest) GetParent() string

func (*CreateMigrationWorkflowRequest) ProtoMessage

func (*CreateMigrationWorkflowRequest) ProtoMessage()

func (*CreateMigrationWorkflowRequest) ProtoReflect

func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*CreateMigrationWorkflowRequest) Reset

func (x *CreateMigrationWorkflowRequest) Reset()

func (*CreateMigrationWorkflowRequest) String

func (x *CreateMigrationWorkflowRequest) String() string

DB2Dialect

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

The dialect definition for DB2.

func (*DB2Dialect) Descriptor

func (*DB2Dialect) Descriptor() ([]byte, []int)

Deprecated: Use DB2Dialect.ProtoReflect.Descriptor instead.

func (*DB2Dialect) ProtoMessage

func (*DB2Dialect) ProtoMessage()

func (*DB2Dialect) ProtoReflect

func (x *DB2Dialect) ProtoReflect() protoreflect.Message

func (*DB2Dialect) Reset

func (x *DB2Dialect) Reset()

func (*DB2Dialect) String

func (x *DB2Dialect) String() string

DeleteMigrationWorkflowRequest

type DeleteMigrationWorkflowRequest struct {

	// Required. The unique identifier for the migration workflow.
	// Example: `projects/123/locations/us/workflows/1234`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

A request to delete a previously created migration workflow.

func (*DeleteMigrationWorkflowRequest) Descriptor

func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteMigrationWorkflowRequest) GetName

func (x *DeleteMigrationWorkflowRequest) GetName() string

func (*DeleteMigrationWorkflowRequest) ProtoMessage

func (*DeleteMigrationWorkflowRequest) ProtoMessage()

func (*DeleteMigrationWorkflowRequest) ProtoReflect

func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*DeleteMigrationWorkflowRequest) Reset

func (x *DeleteMigrationWorkflowRequest) Reset()

func (*DeleteMigrationWorkflowRequest) String

func (x *DeleteMigrationWorkflowRequest) String() string

Dialect

type Dialect struct {

	// The possible dialect options that this message represents.
	//
	// Types that are valid to be assigned to DialectValue:
	//
	//	*Dialect_BigqueryDialect
	//	*Dialect_HiveqlDialect
	//	*Dialect_RedshiftDialect
	//	*Dialect_TeradataDialect
	//	*Dialect_OracleDialect
	//	*Dialect_SparksqlDialect
	//	*Dialect_SnowflakeDialect
	//	*Dialect_NetezzaDialect
	//	*Dialect_AzureSynapseDialect
	//	*Dialect_VerticaDialect
	//	*Dialect_SqlServerDialect
	//	*Dialect_PostgresqlDialect
	//	*Dialect_PrestoDialect
	//	*Dialect_MysqlDialect
	//	*Dialect_Db2Dialect
	//	*Dialect_SqliteDialect
	//	*Dialect_GreenplumDialect
	DialectValue isDialect_DialectValue `protobuf_oneof:"dialect_value"`
	// contains filtered or unexported fields
}

The possible dialect options for translation.

func (*Dialect) Descriptor

func (*Dialect) Descriptor() ([]byte, []int)

Deprecated: Use Dialect.ProtoReflect.Descriptor instead.

func (*Dialect) GetAzureSynapseDialect

func (x *Dialect) GetAzureSynapseDialect() *AzureSynapseDialect

func (*Dialect) GetBigqueryDialect

func (x *Dialect) GetBigqueryDialect() *BigQueryDialect

func (*Dialect) GetDb2Dialect

func (x *Dialect) GetDb2Dialect() *DB2Dialect

func (*Dialect) GetDialectValue

func (x *Dialect) GetDialectValue() isDialect_DialectValue

func (*Dialect) GetGreenplumDialect

func (x *Dialect) GetGreenplumDialect() *GreenplumDialect

func (*Dialect) GetHiveqlDialect

func (x *Dialect) GetHiveqlDialect() *HiveQLDialect

func (*Dialect) GetMysqlDialect

func (x *Dialect) GetMysqlDialect() *MySQLDialect

func (*Dialect) GetNetezzaDialect

func (x *Dialect) GetNetezzaDialect() *NetezzaDialect

func (*Dialect) GetOracleDialect

func (x *Dialect) GetOracleDialect() *OracleDialect

func (*Dialect) GetPostgresqlDialect

func (x *Dialect) GetPostgresqlDialect() *PostgresqlDialect

func (*Dialect) GetPrestoDialect

func (x *Dialect) GetPrestoDialect() *PrestoDialect

func (*Dialect) GetRedshiftDialect

func (x *Dialect) GetRedshiftDialect() *RedshiftDialect

func (*Dialect) GetSnowflakeDialect

func (x *Dialect) GetSnowflakeDialect() *SnowflakeDialect

func (*Dialect) GetSparksqlDialect

func (x *Dialect) GetSparksqlDialect() *SparkSQLDialect

func (*Dialect) GetSqlServerDialect

func (x *Dialect) GetSqlServerDialect() *SQLServerDialect

func (*Dialect) GetSqliteDialect

func (x *Dialect) GetSqliteDialect() *SQLiteDialect

func (*Dialect) GetTeradataDialect

func (x *Dialect) GetTeradataDialect() *TeradataDialect

func (*Dialect) GetVerticaDialect

func (x *Dialect) GetVerticaDialect() *VerticaDialect

func (*Dialect) ProtoMessage

func (*Dialect) ProtoMessage()

func (*Dialect) ProtoReflect

func (x *Dialect) ProtoReflect() protoreflect.Message

func (*Dialect) Reset

func (x *Dialect) Reset()

func (*Dialect) String

func (x *Dialect) String() string

Dialect_AzureSynapseDialect

type Dialect_AzureSynapseDialect struct {
	// The Azure Synapse dialect
	AzureSynapseDialect *AzureSynapseDialect `protobuf:"bytes,9,opt,name=azure_synapse_dialect,json=azureSynapseDialect,proto3,oneof"`
}

Dialect_BigqueryDialect

type Dialect_BigqueryDialect struct {
	// The BigQuery dialect
	BigqueryDialect *BigQueryDialect `protobuf:"bytes,1,opt,name=bigquery_dialect,json=bigqueryDialect,proto3,oneof"`
}

Dialect_Db2Dialect

type Dialect_Db2Dialect struct {
	// DB2 dialect
	Db2Dialect *DB2Dialect `protobuf:"bytes,15,opt,name=db2_dialect,json=db2Dialect,proto3,oneof"`
}

Dialect_GreenplumDialect

type Dialect_GreenplumDialect struct {
	// Greenplum dialect
	GreenplumDialect *GreenplumDialect `protobuf:"bytes,17,opt,name=greenplum_dialect,json=greenplumDialect,proto3,oneof"`
}

Dialect_HiveqlDialect

type Dialect_HiveqlDialect struct {
	// The HiveQL dialect
	HiveqlDialect *HiveQLDialect `protobuf:"bytes,2,opt,name=hiveql_dialect,json=hiveqlDialect,proto3,oneof"`
}

Dialect_MysqlDialect

type Dialect_MysqlDialect struct {
	// The MySQL dialect
	MysqlDialect *MySQLDialect `protobuf:"bytes,14,opt,name=mysql_dialect,json=mysqlDialect,proto3,oneof"`
}

Dialect_NetezzaDialect

type Dialect_NetezzaDialect struct {
	// The Netezza dialect
	NetezzaDialect *NetezzaDialect `protobuf:"bytes,8,opt,name=netezza_dialect,json=netezzaDialect,proto3,oneof"`
}

Dialect_OracleDialect

type Dialect_OracleDialect struct {
	// The Oracle dialect
	OracleDialect *OracleDialect `protobuf:"bytes,5,opt,name=oracle_dialect,json=oracleDialect,proto3,oneof"`
}

Dialect_PostgresqlDialect

type Dialect_PostgresqlDialect struct {
	// The Postgresql dialect
	PostgresqlDialect *PostgresqlDialect `protobuf:"bytes,12,opt,name=postgresql_dialect,json=postgresqlDialect,proto3,oneof"`
}

Dialect_PrestoDialect

type Dialect_PrestoDialect struct {
	// The Presto dialect
	PrestoDialect *PrestoDialect `protobuf:"bytes,13,opt,name=presto_dialect,json=prestoDialect,proto3,oneof"`
}

Dialect_RedshiftDialect

type Dialect_RedshiftDialect struct {
	// The Redshift dialect
	RedshiftDialect *RedshiftDialect `protobuf:"bytes,3,opt,name=redshift_dialect,json=redshiftDialect,proto3,oneof"`
}

Dialect_SnowflakeDialect

type Dialect_SnowflakeDialect struct {
	// The Snowflake dialect
	SnowflakeDialect *SnowflakeDialect `protobuf:"bytes,7,opt,name=snowflake_dialect,json=snowflakeDialect,proto3,oneof"`
}

Dialect_SparksqlDialect

type Dialect_SparksqlDialect struct {
	// The SparkSQL dialect
	SparksqlDialect *SparkSQLDialect `protobuf:"bytes,6,opt,name=sparksql_dialect,json=sparksqlDialect,proto3,oneof"`
}

Dialect_SqlServerDialect

type Dialect_SqlServerDialect struct {
	// The SQL Server dialect
	SqlServerDialect *SQLServerDialect `protobuf:"bytes,11,opt,name=sql_server_dialect,json=sqlServerDialect,proto3,oneof"`
}

Dialect_SqliteDialect

type Dialect_SqliteDialect struct {
	// SQLite dialect
	SqliteDialect *SQLiteDialect `protobuf:"bytes,16,opt,name=sqlite_dialect,json=sqliteDialect,proto3,oneof"`
}

Dialect_TeradataDialect

type Dialect_TeradataDialect struct {
	// The Teradata dialect
	TeradataDialect *TeradataDialect `protobuf:"bytes,4,opt,name=teradata_dialect,json=teradataDialect,proto3,oneof"`
}

Dialect_VerticaDialect

type Dialect_VerticaDialect struct {
	// The Vertica dialect
	VerticaDialect *VerticaDialect `protobuf:"bytes,10,opt,name=vertica_dialect,json=verticaDialect,proto3,oneof"`
}

ErrorDetail

type ErrorDetail struct {

	// Optional. The exact location within the resource (if applicable).
	Location *ErrorLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Required. Describes the cause of the error with structured detail.
	ErrorInfo *errdetails.ErrorInfo `protobuf:"bytes,2,opt,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
	// contains filtered or unexported fields
}

Provides details for errors, e.g. issues that where encountered when processing a subtask.

func (*ErrorDetail) Descriptor

func (*ErrorDetail) Descriptor() ([]byte, []int)

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetErrorInfo

func (x *ErrorDetail) GetErrorInfo() *errdetails.ErrorInfo

func (*ErrorDetail) GetLocation

func (x *ErrorDetail) GetLocation() *ErrorLocation

func (*ErrorDetail) ProtoMessage

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect

func (x *ErrorDetail) ProtoReflect() protoreflect.Message

func (*ErrorDetail) Reset

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String

func (x *ErrorDetail) String() string

ErrorLocation

type ErrorLocation struct {

	// Optional. If applicable, denotes the line where the error occurred. A zero
	// value means that there is no line information.
	Line int32 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	// Optional. If applicable, denotes the column where the error occurred. A
	// zero value means that there is no columns information.
	Column int32 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	// contains filtered or unexported fields
}

Holds information about where the error is located.

func (*ErrorLocation) Descriptor

func (*ErrorLocation) Descriptor() ([]byte, []int)

Deprecated: Use ErrorLocation.ProtoReflect.Descriptor instead.

func (*ErrorLocation) GetColumn

func (x *ErrorLocation) GetColumn() int32

func (*ErrorLocation) GetLine

func (x *ErrorLocation) GetLine() int32

func (*ErrorLocation) ProtoMessage

func (*ErrorLocation) ProtoMessage()

func (*ErrorLocation) ProtoReflect

func (x *ErrorLocation) ProtoReflect() protoreflect.Message

func (*ErrorLocation) Reset

func (x *ErrorLocation) Reset()

func (*ErrorLocation) String

func (x *ErrorLocation) String() string

GcsReportLogMessage

type GcsReportLogMessage struct {

	// Severity of the translation record.
	Severity string `protobuf:"bytes,1,opt,name=severity,proto3" json:"severity,omitempty"`
	// Category of the error/warning. Example: SyntaxError
	Category string `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`
	// The file path in which the error occurred
	FilePath string `protobuf:"bytes,3,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	// The file name in which the error occurred
	Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	// Specifies the row from the source text where the error occurred (0 based,
	// -1 for messages without line location). Example: 2
	SourceScriptLine int32 `protobuf:"varint,5,opt,name=source_script_line,json=sourceScriptLine,proto3" json:"source_script_line,omitempty"`
	// Specifies the column from the source texts where the error occurred. (0
	// based, -1 for messages without column location) example: 6
	SourceScriptColumn int32 `protobuf:"varint,6,opt,name=source_script_column,json=sourceScriptColumn,proto3" json:"source_script_column,omitempty"`
	// Detailed message of the record.
	Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// The script context (obfuscated) in which the error occurred
	ScriptContext string `protobuf:"bytes,8,opt,name=script_context,json=scriptContext,proto3" json:"script_context,omitempty"`
	// Category of the error/warning. Example: SyntaxError
	Action string `protobuf:"bytes,9,opt,name=action,proto3" json:"action,omitempty"`
	// Effect of the error/warning. Example: COMPATIBILITY
	Effect string `protobuf:"bytes,10,opt,name=effect,proto3" json:"effect,omitempty"`
	// Name of the affected object in the log message.
	ObjectName string `protobuf:"bytes,11,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// contains filtered or unexported fields
}

A record in the aggregate CSV report for a migration workflow

func (*GcsReportLogMessage) Descriptor

func (*GcsReportLogMessage) Descriptor() ([]byte, []int)

Deprecated: Use GcsReportLogMessage.ProtoReflect.Descriptor instead.

func (*GcsReportLogMessage) GetAction

func (x *GcsReportLogMessage) GetAction() string

func (*GcsReportLogMessage) GetCategory

func (x *GcsReportLogMessage) GetCategory() string

func (*GcsReportLogMessage) GetEffect

func (x *GcsReportLogMessage) GetEffect() string

func (*GcsReportLogMessage) GetFilePath

func (x *GcsReportLogMessage) GetFilePath() string

func (*GcsReportLogMessage) GetFilename

func (x *GcsReportLogMessage) GetFilename() string

func (*GcsReportLogMessage) GetMessage

func (x *GcsReportLogMessage) GetMessage() string

func (*GcsReportLogMessage) GetObjectName

func (x *GcsReportLogMessage) GetObjectName() string

func (*GcsReportLogMessage) GetScriptContext

func (x *GcsReportLogMessage) GetScriptContext() string

func (*GcsReportLogMessage) GetSeverity

func (x *GcsReportLogMessage) GetSeverity() string

func (*GcsReportLogMessage) GetSourceScriptColumn

func (x *GcsReportLogMessage) GetSourceScriptColumn() int32

func (*GcsReportLogMessage) GetSourceScriptLine

func (x *GcsReportLogMessage) GetSourceScriptLine() int32

func (*GcsReportLogMessage) ProtoMessage

func (*GcsReportLogMessage) ProtoMessage()

func (*GcsReportLogMessage) ProtoReflect

func (x *GcsReportLogMessage) ProtoReflect() protoreflect.Message

func (*GcsReportLogMessage) Reset

func (x *GcsReportLogMessage) Reset()

func (*GcsReportLogMessage) String

func (x *GcsReportLogMessage) String() string

GetMigrationSubtaskRequest

type GetMigrationSubtaskRequest struct {

	// Required. The unique identifier for the migration subtask.
	// Example: `projects/123/locations/us/workflows/1234/subtasks/543`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// contains filtered or unexported fields
}

A request to get a previously created migration subtasks.

func (*GetMigrationSubtaskRequest) Descriptor

func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationSubtaskRequest) GetName

func (x *GetMigrationSubtaskRequest) GetName() string

func (*GetMigrationSubtaskRequest) GetReadMask

func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*GetMigrationSubtaskRequest) ProtoMessage

func (*GetMigrationSubtaskRequest) ProtoMessage()

func (*GetMigrationSubtaskRequest) ProtoReflect

func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message

func (*GetMigrationSubtaskRequest) Reset

func (x *GetMigrationSubtaskRequest) Reset()

func (*GetMigrationSubtaskRequest) String

func (x *GetMigrationSubtaskRequest) String() string

GetMigrationWorkflowRequest

type GetMigrationWorkflowRequest struct {

	// Required. The unique identifier for the migration workflow.
	// Example: `projects/123/locations/us/workflows/1234`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// contains filtered or unexported fields
}

A request to get a previously created migration workflow.

func (*GetMigrationWorkflowRequest) Descriptor

func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationWorkflowRequest) GetName

func (x *GetMigrationWorkflowRequest) GetName() string

func (*GetMigrationWorkflowRequest) GetReadMask

func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*GetMigrationWorkflowRequest) ProtoMessage

func (*GetMigrationWorkflowRequest) ProtoMessage()

func (*GetMigrationWorkflowRequest) ProtoReflect

func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*GetMigrationWorkflowRequest) Reset

func (x *GetMigrationWorkflowRequest) Reset()

func (*GetMigrationWorkflowRequest) String

func (x *GetMigrationWorkflowRequest) String() string

GreenplumDialect

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

The dialect definition for Greenplum.

func (*GreenplumDialect) Descriptor

func (*GreenplumDialect) Descriptor() ([]byte, []int)

Deprecated: Use GreenplumDialect.ProtoReflect.Descriptor instead.

func (*GreenplumDialect) ProtoMessage

func (*GreenplumDialect) ProtoMessage()

func (*GreenplumDialect) ProtoReflect

func (x *GreenplumDialect) ProtoReflect() protoreflect.Message

func (*GreenplumDialect) Reset

func (x *GreenplumDialect) Reset()

func (*GreenplumDialect) String

func (x *GreenplumDialect) String() string

HiveQLDialect

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

The dialect definition for HiveQL.

func (*HiveQLDialect) Descriptor

func (*HiveQLDialect) Descriptor() ([]byte, []int)

Deprecated: Use HiveQLDialect.ProtoReflect.Descriptor instead.

func (*HiveQLDialect) ProtoMessage

func (*HiveQLDialect) ProtoMessage()

func (*HiveQLDialect) ProtoReflect

func (x *HiveQLDialect) ProtoReflect() protoreflect.Message

func (*HiveQLDialect) Reset

func (x *HiveQLDialect) Reset()

func (*HiveQLDialect) String

func (x *HiveQLDialect) String() string

LineageOutput

type LineageOutput struct {

	// The URI of the webapp that visualizes the lineage.
	// The user needs the `bigquerymigration.googleapis.com/lineageDbs.query` IAM
	// permission to use the webapp.
	WebappUri string `protobuf:"bytes,1,opt,name=webapp_uri,json=webappUri,proto3" json:"webapp_uri,omitempty"`
	// Output only. Recognized lineage inputs.
	//
	// All inputs are processed only if the task succeeds and all work is in state
	// [SUCCEEDED](ProgressReport.WorkSummary.State.SUCCEEDED) (in particular,
	// nothing is [SKIPPED](ProgressReport.WorkSummary.State.SKIPPED)).
	//
	// Even with all inputs processed successfully, there may be transpiler errors
	// present leading to inaccurate lineage.
	RecognizedInputs []*LineageOutput_RecognizedInput `protobuf:"bytes,2,rep,name=recognized_inputs,json=recognizedInputs,proto3" json:"recognized_inputs,omitempty"`
	// Output only. Work processing progress reports broken up by processing
	// stage.
	ProcessingProgressReports []*LineageOutput_ProgressReport `protobuf:"bytes,3,rep,name=processing_progress_reports,json=processingProgressReports,proto3" json:"processing_progress_reports,omitempty"`
	// contains filtered or unexported fields
}

The output of a task with output type "LINEAGE".

Actual generated lineage can be queried separately (see [webapp_uri][google.cloud.bigquery.migration.v2.LineageOutput.webapp_uri]), this message contains only metadata: processing status, errors, etc.

func (*LineageOutput) Descriptor

func (*LineageOutput) Descriptor() ([]byte, []int)

Deprecated: Use LineageOutput.ProtoReflect.Descriptor instead.

func (*LineageOutput) GetProcessingProgressReports

func (x *LineageOutput) GetProcessingProgressReports() []*LineageOutput_ProgressReport

func (*LineageOutput) GetRecognizedInputs

func (x *LineageOutput) GetRecognizedInputs() []*LineageOutput_RecognizedInput

func (*LineageOutput) GetWebappUri

func (x *LineageOutput) GetWebappUri() string

func (*LineageOutput) ProtoMessage

func (*LineageOutput) ProtoMessage()

func (*LineageOutput) ProtoReflect

func (x *LineageOutput) ProtoReflect() protoreflect.Message

func (*LineageOutput) Reset

func (x *LineageOutput) Reset()

func (*LineageOutput) String

func (x *LineageOutput) String() string

LineageOutput_ProgressReport

type LineageOutput_ProgressReport struct {

	// Output only. The processing stage this progress report describes.
	ProcessingStage LineageOutput_ProgressReport_ProcessingStage `protobuf:"varint,1,opt,name=processing_stage,json=processingStage,proto3,enum=google.cloud.bigquery.migration.v2.LineageOutput_ProgressReport_ProcessingStage" json:"processing_stage,omitempty"`
	// Output only. Summaries of work broken up by the state of the work. Each
	// work summary describes how much work is in the given state.
	//
	// To get numbers for the total work covered, aggregate the numbers from all
	// summaries.
	WorkSummaries []*LineageOutput_ProgressReport_WorkSummary `protobuf:"bytes,2,rep,name=work_summaries,json=workSummaries,proto3" json:"work_summaries,omitempty"`
	// contains filtered or unexported fields
}

Breaks down processing progress of work.

func (*LineageOutput_ProgressReport) Descriptor

func (*LineageOutput_ProgressReport) Descriptor() ([]byte, []int)

Deprecated: Use LineageOutput_ProgressReport.ProtoReflect.Descriptor instead.

func (*LineageOutput_ProgressReport) GetProcessingStage

func (x *LineageOutput_ProgressReport) GetProcessingStage() LineageOutput_ProgressReport_ProcessingStage

func (*LineageOutput_ProgressReport) GetWorkSummaries

func (x *LineageOutput_ProgressReport) GetWorkSummaries() []*LineageOutput_ProgressReport_WorkSummary

func (*LineageOutput_ProgressReport) ProtoMessage

func (*LineageOutput_ProgressReport) ProtoMessage()

func (*LineageOutput_ProgressReport) ProtoReflect

func (x *LineageOutput_ProgressReport) ProtoReflect() protoreflect.Message

func (*LineageOutput_ProgressReport) Reset

func (x *LineageOutput_ProgressReport) Reset()

func (*LineageOutput_ProgressReport) String

func (x *LineageOutput_ProgressReport) String() string

LineageOutput_ProgressReport_ProcessingStage

type LineageOutput_ProgressReport_ProcessingStage int32

The processing stage the progress report describes.

LineageOutput_ProgressReport_PROCESSING_STAGE_UNSPECIFIED, LineageOutput_ProgressReport_INPUT_INGESTION, LineageOutput_ProgressReport_POSTPROCESSING

const (
	// The stage is not specified.
	LineageOutput_ProgressReport_PROCESSING_STAGE_UNSPECIFIED LineageOutput_ProgressReport_ProcessingStage = 0
	// The input ingestion stage.
	LineageOutput_ProgressReport_INPUT_INGESTION LineageOutput_ProgressReport_ProcessingStage = 1000
	// The lineage DB postprocessing stage.
	LineageOutput_ProgressReport_POSTPROCESSING LineageOutput_ProgressReport_ProcessingStage = 2000
)

func (LineageOutput_ProgressReport_ProcessingStage) Descriptor

func (LineageOutput_ProgressReport_ProcessingStage) Descriptor() protoreflect.EnumDescriptor

func (LineageOutput_ProgressReport_ProcessingStage) Enum

func (x LineageOutput_ProgressReport_ProcessingStage) Enum() *LineageOutput_ProgressReport_ProcessingStage

func (LineageOutput_ProgressReport_ProcessingStage) EnumDescriptor

func (LineageOutput_ProgressReport_ProcessingStage) EnumDescriptor() ([]byte, []int)

Deprecated: Use LineageOutput_ProgressReport_ProcessingStage.Descriptor instead.

func (LineageOutput_ProgressReport_ProcessingStage) Number

func (x LineageOutput_ProgressReport_ProcessingStage) Number() protoreflect.EnumNumber

func (LineageOutput_ProgressReport_ProcessingStage) String

func (x LineageOutput_ProgressReport_ProcessingStage) String() string

func (LineageOutput_ProgressReport_ProcessingStage) Type

func (LineageOutput_ProgressReport_ProcessingStage) Type() protoreflect.EnumType

LineageOutput_ProgressReport_WorkSummary

type LineageOutput_ProgressReport_WorkSummary struct {

	// Output only. The state of the work this summary describes.
	State LineageOutput_ProgressReport_WorkSummary_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.LineageOutput_ProgressReport_WorkSummary_State" json:"state,omitempty"`
	// Output only. Size of the work in the given State.
	//
	// Size counts "units of work". Units represent arbitrary division of
	// work; there's no expectation each unit takes similar time to process.
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// Output only. Human-readable comment.
	Comment string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

Summary of work in the given state.

func (*LineageOutput_ProgressReport_WorkSummary) Descriptor

func (*LineageOutput_ProgressReport_WorkSummary) Descriptor() ([]byte, []int)

Deprecated: Use LineageOutput_ProgressReport_WorkSummary.ProtoReflect.Descriptor instead.

func (*LineageOutput_ProgressReport_WorkSummary) GetComment

func (x *LineageOutput_ProgressReport_WorkSummary) GetComment() string

func (*LineageOutput_ProgressReport_WorkSummary) GetSize

func (x *LineageOutput_ProgressReport_WorkSummary) GetSize() int64

func (*LineageOutput_ProgressReport_WorkSummary) GetState

func (x *LineageOutput_ProgressReport_WorkSummary) GetState() LineageOutput_ProgressReport_WorkSummary_State

func (*LineageOutput_ProgressReport_WorkSummary) ProtoMessage

func (*LineageOutput_ProgressReport_WorkSummary) ProtoMessage()

func (*LineageOutput_ProgressReport_WorkSummary) ProtoReflect

func (x *LineageOutput_ProgressReport_WorkSummary) ProtoReflect() protoreflect.Message

func (*LineageOutput_ProgressReport_WorkSummary) Reset

func (x *LineageOutput_ProgressReport_WorkSummary) Reset()

func (*LineageOutput_ProgressReport_WorkSummary) String

func (x *LineageOutput_ProgressReport_WorkSummary) String() string

LineageOutput_ProgressReport_WorkSummary_State

type LineageOutput_ProgressReport_WorkSummary_State int32

States of work. Each piece of work is in exactly one state. [SUCCEEDED], [FAILED] and [SKIPPED] are terminal states; work in the [IN_PROGRESS] will eventually transition to one of the terminal states.

LineageOutput_ProgressReport_WorkSummary_STATE_UNSPECIFIED, LineageOutput_ProgressReport_WorkSummary_SUCCEEDED, LineageOutput_ProgressReport_WorkSummary_FAILED, LineageOutput_ProgressReport_WorkSummary_IN_PROGRESS, LineageOutput_ProgressReport_WorkSummary_SKIPPED

const (
	// The state is not specified.
	LineageOutput_ProgressReport_WorkSummary_STATE_UNSPECIFIED LineageOutput_ProgressReport_WorkSummary_State = 0
	// Work that was processed successfully.
	LineageOutput_ProgressReport_WorkSummary_SUCCEEDED LineageOutput_ProgressReport_WorkSummary_State = 1
	// Work that failed processing.
	LineageOutput_ProgressReport_WorkSummary_FAILED LineageOutput_ProgressReport_WorkSummary_State = 2
	// Work that is currently being processed or queued for processing.
	LineageOutput_ProgressReport_WorkSummary_IN_PROGRESS LineageOutput_ProgressReport_WorkSummary_State = 3
	// Work that was recognised as necessary to fully process inputs but was
	// skipped due to system limitations.
	LineageOutput_ProgressReport_WorkSummary_SKIPPED LineageOutput_ProgressReport_WorkSummary_State = 4
)

func (LineageOutput_ProgressReport_WorkSummary_State) Descriptor

func (LineageOutput_ProgressReport_WorkSummary_State) Descriptor() protoreflect.EnumDescriptor

func (LineageOutput_ProgressReport_WorkSummary_State) Enum

func (x LineageOutput_ProgressReport_WorkSummary_State) Enum() *LineageOutput_ProgressReport_WorkSummary_State

func (LineageOutput_ProgressReport_WorkSummary_State) EnumDescriptor

func (LineageOutput_ProgressReport_WorkSummary_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use LineageOutput_ProgressReport_WorkSummary_State.Descriptor instead.

func (LineageOutput_ProgressReport_WorkSummary_State) Number

func (x LineageOutput_ProgressReport_WorkSummary_State) Number() protoreflect.EnumNumber

func (LineageOutput_ProgressReport_WorkSummary_State) String

func (x LineageOutput_ProgressReport_WorkSummary_State) String() string

func (LineageOutput_ProgressReport_WorkSummary_State) Type

func (LineageOutput_ProgressReport_WorkSummary_State) Type() protoreflect.EnumType

LineageOutput_RecognizedInput

type LineageOutput_RecognizedInput struct {

	// Output only. The type of the input.
	Type LineageOutput_RecognizedInput_Type `protobuf:"varint,1,opt,name=type,proto3,enum=google.cloud.bigquery.migration.v2.LineageOutput_RecognizedInput_Type" json:"type,omitempty"`
	// Output only. The uncompressed size of the recognized input of the given
	// type.
	UncompressedSizeBytes int64 `protobuf:"varint,2,opt,name=uncompressed_size_bytes,json=uncompressedSizeBytes,proto3" json:"uncompressed_size_bytes,omitempty"`
	// contains filtered or unexported fields
}

Information about lineage input of the given type that lineage generation recognized.

If you expected to process more of the given input, verify your input was uploaded and is in the correct format and the request to generate lineage correctly specified the input location.

func (*LineageOutput_RecognizedInput) Descriptor

func (*LineageOutput_RecognizedInput) Descriptor() ([]byte, []int)

Deprecated: Use LineageOutput_RecognizedInput.ProtoReflect.Descriptor instead.

func (*LineageOutput_RecognizedInput) GetType

func (x *LineageOutput_RecognizedInput) GetType() LineageOutput_RecognizedInput_Type

func (*LineageOutput_RecognizedInput) GetUncompressedSizeBytes

func (x *LineageOutput_RecognizedInput) GetUncompressedSizeBytes() int64

func (*LineageOutput_RecognizedInput) ProtoMessage

func (*LineageOutput_RecognizedInput) ProtoMessage()

func (*LineageOutput_RecognizedInput) ProtoReflect

func (x *LineageOutput_RecognizedInput) ProtoReflect() protoreflect.Message

func (*LineageOutput_RecognizedInput) Reset

func (x *LineageOutput_RecognizedInput) Reset()

func (*LineageOutput_RecognizedInput) String

func (x *LineageOutput_RecognizedInput) String() string

LineageOutput_RecognizedInput_Type

type LineageOutput_RecognizedInput_Type int32

Input type recognized by the lineage processing.

LineageOutput_RecognizedInput_TYPE_UNSPECIFIED, LineageOutput_RecognizedInput_METADATA, LineageOutput_RecognizedInput_QUERY_LOG, LineageOutput_RecognizedInput_SCRIPT

const (
	// The type is not specified.
	LineageOutput_RecognizedInput_TYPE_UNSPECIFIED LineageOutput_RecognizedInput_Type = 0
	// The input is metadata.
	LineageOutput_RecognizedInput_METADATA LineageOutput_RecognizedInput_Type = 1
	// The input is a query log.
	LineageOutput_RecognizedInput_QUERY_LOG LineageOutput_RecognizedInput_Type = 2
	// The input is a SQL script.
	LineageOutput_RecognizedInput_SCRIPT LineageOutput_RecognizedInput_Type = 3
)

func (LineageOutput_RecognizedInput_Type) Descriptor

func (LineageOutput_RecognizedInput_Type) Descriptor() protoreflect.EnumDescriptor

func (LineageOutput_RecognizedInput_Type) Enum

func (x LineageOutput_RecognizedInput_Type) Enum() *LineageOutput_RecognizedInput_Type

func (LineageOutput_RecognizedInput_Type) EnumDescriptor

func (LineageOutput_RecognizedInput_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use LineageOutput_RecognizedInput_Type.Descriptor instead.

func (LineageOutput_RecognizedInput_Type) Number

func (x LineageOutput_RecognizedInput_Type) Number() protoreflect.EnumNumber

func (LineageOutput_RecognizedInput_Type) String

func (x LineageOutput_RecognizedInput_Type) String() string

func (LineageOutput_RecognizedInput_Type) Type

func (LineageOutput_RecognizedInput_Type) Type() protoreflect.EnumType

ListMigrationSubtasksRequest

type ListMigrationSubtasksRequest struct {

	// Required. The migration task of the subtasks to list.
	// Example: `projects/123/locations/us/workflows/1234`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// Optional. The maximum number of migration tasks to return. The service may
	// return fewer than this number.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from previous `ListMigrationSubtasks`
	// call. Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListMigrationSubtasks`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The filter to apply. This can be used to get the subtasks of a
	// specific tasks in a workflow, e.g. `migration_task = "ab012"` where
	// `"ab012"` is the task ID (not the name in the named map).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

A request to list previously created migration subtasks.

func (*ListMigrationSubtasksRequest) Descriptor

func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksRequest) GetFilter

func (x *ListMigrationSubtasksRequest) GetFilter() string

func (*ListMigrationSubtasksRequest) GetPageSize

func (x *ListMigrationSubtasksRequest) GetPageSize() int32

func (*ListMigrationSubtasksRequest) GetPageToken

func (x *ListMigrationSubtasksRequest) GetPageToken() string

func (*ListMigrationSubtasksRequest) GetParent

func (x *ListMigrationSubtasksRequest) GetParent() string

func (*ListMigrationSubtasksRequest) GetReadMask

func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*ListMigrationSubtasksRequest) ProtoMessage

func (*ListMigrationSubtasksRequest) ProtoMessage()

func (*ListMigrationSubtasksRequest) ProtoReflect

func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message

func (*ListMigrationSubtasksRequest) Reset

func (x *ListMigrationSubtasksRequest) Reset()

func (*ListMigrationSubtasksRequest) String

func (x *ListMigrationSubtasksRequest) String() string

ListMigrationSubtasksResponse

type ListMigrationSubtasksResponse struct {

	// The migration subtasks for the specified task.
	MigrationSubtasks []*MigrationSubtask `protobuf:"bytes,1,rep,name=migration_subtasks,json=migrationSubtasks,proto3" json:"migration_subtasks,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response object for a ListMigrationSubtasks call.

func (*ListMigrationSubtasksResponse) Descriptor

func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksResponse) GetMigrationSubtasks

func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask

func (*ListMigrationSubtasksResponse) GetNextPageToken

func (x *ListMigrationSubtasksResponse) GetNextPageToken() string

func (*ListMigrationSubtasksResponse) ProtoMessage

func (*ListMigrationSubtasksResponse) ProtoMessage()

func (*ListMigrationSubtasksResponse) ProtoReflect

func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message

func (*ListMigrationSubtasksResponse) Reset

func (x *ListMigrationSubtasksResponse) Reset()

func (*ListMigrationSubtasksResponse) String

func (x *ListMigrationSubtasksResponse) String() string

ListMigrationWorkflowsRequest

type ListMigrationWorkflowsRequest struct {

	// Required. The project and location of the migration workflows to list.
	// Example: `projects/123/locations/us`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The list of fields to be retrieved.
	ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
	// The maximum number of migration workflows to return. The service may return
	// fewer than this number.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from previous `ListMigrationWorkflows` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListMigrationWorkflows`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

A request to list previously created migration workflows.

func (*ListMigrationWorkflowsRequest) Descriptor

func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsRequest) GetPageSize

func (x *ListMigrationWorkflowsRequest) GetPageSize() int32

func (*ListMigrationWorkflowsRequest) GetPageToken

func (x *ListMigrationWorkflowsRequest) GetPageToken() string

func (*ListMigrationWorkflowsRequest) GetParent

func (x *ListMigrationWorkflowsRequest) GetParent() string

func (*ListMigrationWorkflowsRequest) GetReadMask

func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask

func (*ListMigrationWorkflowsRequest) ProtoMessage

func (*ListMigrationWorkflowsRequest) ProtoMessage()

func (*ListMigrationWorkflowsRequest) ProtoReflect

func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*ListMigrationWorkflowsRequest) Reset

func (x *ListMigrationWorkflowsRequest) Reset()

func (*ListMigrationWorkflowsRequest) String

func (x *ListMigrationWorkflowsRequest) String() string

ListMigrationWorkflowsResponse

type ListMigrationWorkflowsResponse struct {

	// The migration workflows for the specified project / location.
	MigrationWorkflows []*MigrationWorkflow `protobuf:"bytes,1,rep,name=migration_workflows,json=migrationWorkflows,proto3" json:"migration_workflows,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response object for a ListMigrationWorkflows call.

func (*ListMigrationWorkflowsResponse) Descriptor

func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsResponse) GetMigrationWorkflows

func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow

func (*ListMigrationWorkflowsResponse) GetNextPageToken

func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string

func (*ListMigrationWorkflowsResponse) ProtoMessage

func (*ListMigrationWorkflowsResponse) ProtoMessage()

func (*ListMigrationWorkflowsResponse) ProtoReflect

func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*ListMigrationWorkflowsResponse) Reset

func (x *ListMigrationWorkflowsResponse) Reset()

func (*ListMigrationWorkflowsResponse) String

func (x *ListMigrationWorkflowsResponse) String() string

Literal

type Literal struct {

	// The literal SQL contents.
	//
	// Types that are valid to be assigned to LiteralData:
	//
	//	*Literal_LiteralString
	//	*Literal_LiteralBytes
	LiteralData isLiteral_LiteralData `protobuf_oneof:"literal_data"`
	// Required. The identifier of the literal entry.
	RelativePath string `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`
	// contains filtered or unexported fields
}

Literal data.

func (*Literal) Descriptor

func (*Literal) Descriptor() ([]byte, []int)

Deprecated: Use Literal.ProtoReflect.Descriptor instead.

func (*Literal) GetLiteralBytes

func (x *Literal) GetLiteralBytes() []byte

func (*Literal) GetLiteralData

func (x *Literal) GetLiteralData() isLiteral_LiteralData

func (*Literal) GetLiteralString

func (x *Literal) GetLiteralString() string

func (*Literal) GetRelativePath

func (x *Literal) GetRelativePath() string

func (*Literal) ProtoMessage

func (*Literal) ProtoMessage()

func (*Literal) ProtoReflect

func (x *Literal) ProtoReflect() protoreflect.Message

func (*Literal) Reset

func (x *Literal) Reset()

func (*Literal) String

func (x *Literal) String() string

Literal_LiteralBytes

type Literal_LiteralBytes struct {
	// Literal byte data.
	LiteralBytes []byte `protobuf:"bytes,3,opt,name=literal_bytes,json=literalBytes,proto3,oneof"`
}

Literal_LiteralString

type Literal_LiteralString struct {
	// Literal string data.
	LiteralString string `protobuf:"bytes,2,opt,name=literal_string,json=literalString,proto3,oneof"`
}

MigrationServiceClient

type MigrationServiceClient interface {
	// Creates a migration workflow.
	CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
	// Gets a previously created migration workflow.
	GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
	// Lists previously created migration workflow.
	ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error)
	// Deletes a migration workflow by name.
	DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a previously created migration workflow. I.e., the state transitions
	// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
	// An error will be signaled if the state is anything other than DRAFT or
	// RUNNING.
	StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Gets a previously created migration subtask.
	GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error)
	// Lists previously created migration subtasks.
	ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error)
}

MigrationServiceClient is the client API for MigrationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMigrationServiceClient

func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

MigrationServiceServer

type MigrationServiceServer interface {
	// Creates a migration workflow.
	CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
	// Gets a previously created migration workflow.
	GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
	// Lists previously created migration workflow.
	ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
	// Deletes a migration workflow by name.
	DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
	// Starts a previously created migration workflow. I.e., the state transitions
	// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
	// An error will be signaled if the state is anything other than DRAFT or
	// RUNNING.
	StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
	// Gets a previously created migration subtask.
	GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
	// Lists previously created migration subtasks.
	ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
}

MigrationServiceServer is the server API for MigrationService service. All implementations should embed UnimplementedMigrationServiceServer for forward compatibility

MigrationSubtask

type MigrationSubtask struct {

	// Output only. Immutable. The resource name for the migration subtask. The ID
	// is server-generated.
	//
	// Example: `projects/123/locations/us/workflows/345/subtasks/678`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The unique ID of the task to which this subtask belongs.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The type of the Subtask. The migration service does not check whether this
	// is a known type. It is up to the task creator (i.e. orchestrator or worker)
	// to ensure it only creates subtasks for which there are compatible workers
	// polling for Subtasks.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Output only. The current state of the subtask.
	State MigrationSubtask_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationSubtask_State" json:"state,omitempty"`
	// Output only. An explanation that may be populated when the task is in
	// FAILED state.
	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
	// Output only. Provides details to errors and issues encountered while
	// processing the subtask. Presence of error details does not mean that the
	// subtask failed.
	ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
	// Output only. The number or resources with errors. Note: This is not the
	// total number of errors as each resource can have more than one error. This
	// is used to indicate truncation by having a `resource_error_count` that is
	// higher than the size of `resource_error_details`.
	ResourceErrorCount int32 `protobuf:"varint,13,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`
	// Output only. Time when the subtask was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Time when the subtask was last updated.
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// Output only. The metrics for the subtask.
	Metrics []*TimeSeries `protobuf:"bytes,11,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

A subtask for a migration which carries details about the configuration of the subtask. The content of the details should not matter to the end user, but is a contract between the subtask creator and subtask worker.

func (*MigrationSubtask) Descriptor

func (*MigrationSubtask) Descriptor() ([]byte, []int)

Deprecated: Use MigrationSubtask.ProtoReflect.Descriptor instead.

func (*MigrationSubtask) GetCreateTime

func (x *MigrationSubtask) GetCreateTime() *timestamppb.Timestamp

func (*MigrationSubtask) GetLastUpdateTime

func (x *MigrationSubtask) GetLastUpdateTime() *timestamppb.Timestamp

func (*MigrationSubtask) GetMetrics

func (x *MigrationSubtask) GetMetrics() []*TimeSeries

func (*MigrationSubtask) GetName

func (x *MigrationSubtask) GetName() string

func (*MigrationSubtask) GetProcessingError

func (x *MigrationSubtask) GetProcessingError() *errdetails.ErrorInfo

func (*MigrationSubtask) GetResourceErrorCount

func (x *MigrationSubtask) GetResourceErrorCount() int32

func (*MigrationSubtask) GetResourceErrorDetails

func (x *MigrationSubtask) GetResourceErrorDetails() []*ResourceErrorDetail

func (*MigrationSubtask) GetState

func (x *MigrationSubtask) GetState() MigrationSubtask_State

func (*MigrationSubtask) GetTaskId

func (x *MigrationSubtask) GetTaskId() string

func (*MigrationSubtask) GetType

func (x *MigrationSubtask) GetType() string

func (*MigrationSubtask) ProtoMessage

func (*MigrationSubtask) ProtoMessage()

func (*MigrationSubtask) ProtoReflect

func (x *MigrationSubtask) ProtoReflect() protoreflect.Message

func (*MigrationSubtask) Reset

func (x *MigrationSubtask) Reset()

func (*MigrationSubtask) String

func (x *MigrationSubtask) String() string

MigrationSubtask_State

type MigrationSubtask_State int32

Possible states of a migration subtask.

MigrationSubtask_STATE_UNSPECIFIED, MigrationSubtask_ACTIVE, MigrationSubtask_RUNNING, MigrationSubtask_SUCCEEDED, MigrationSubtask_FAILED, MigrationSubtask_PAUSED, MigrationSubtask_PENDING_DEPENDENCY

const (
	// The state is unspecified.
	MigrationSubtask_STATE_UNSPECIFIED MigrationSubtask_State = 0
	// The subtask is ready, i.e. it is ready for execution.
	MigrationSubtask_ACTIVE MigrationSubtask_State = 1
	// The subtask is running, i.e. it is assigned to a worker for execution.
	MigrationSubtask_RUNNING MigrationSubtask_State = 2
	// The subtask finished successfully.
	MigrationSubtask_SUCCEEDED MigrationSubtask_State = 3
	// The subtask finished unsuccessfully.
	MigrationSubtask_FAILED MigrationSubtask_State = 4
	// The subtask is paused, i.e., it will not be scheduled. If it was already
	// assigned,it might still finish but no new lease renewals will be granted.
	MigrationSubtask_PAUSED MigrationSubtask_State = 5
	// The subtask is pending a dependency. It will be scheduled once its
	// dependencies are done.
	MigrationSubtask_PENDING_DEPENDENCY MigrationSubtask_State = 6
)

func (MigrationSubtask_State) Descriptor

func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationSubtask_State) Enum

func (x MigrationSubtask_State) Enum() *MigrationSubtask_State

func (MigrationSubtask_State) EnumDescriptor

func (MigrationSubtask_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationSubtask_State.Descriptor instead.

func (MigrationSubtask_State) Number

func (x MigrationSubtask_State) Number() protoreflect.EnumNumber

func (MigrationSubtask_State) String

func (x MigrationSubtask_State) String() string

func (MigrationSubtask_State) Type

func (MigrationSubtask_State) Type() protoreflect.EnumType

MigrationTask

type MigrationTask struct {

	// The details of the task.
	//
	// Types that are valid to be assigned to TaskDetails:
	//
	//	*MigrationTask_AssessmentTaskDetails
	//	*MigrationTask_TranslationConfigDetails
	//	*MigrationTask_TranslationDetails
	TaskDetails isMigrationTask_TaskDetails `protobuf_oneof:"task_details"`
	// Output only. Immutable. The unique identifier for the migration task. The
	// ID is server-generated.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The type of the task. This must be one of the supported task types.
	//
	// Assessment:
	//
	// - `Assessment_Hive` - Assessment for Hive.
	// - `Assessment_Redshift` - Assessment for Redshift.
	// - `Assessment_Snowflake` - Assessment for Snowflake.
	// - `Assessment_Teradata_v2` - Assessment for Teradata.
	// - `Assessment_Oracle` - Assessment for Oracle.
	// - `Assessment_Hadoop` - Assessment for Hadoop.
	// - `Assessment_Informatica` - Assessment for Informatica.
	//
	// Translation:
	// See [Supported Task
	// Types](https://docs.cloud.google.com/bigquery/docs/api-sql-translator#supported_task_types)
	// for a list of supported task types.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Output only. The current state of the task.
	State MigrationTask_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationTask_State" json:"state,omitempty"`
	// Output only. An explanation that may be populated when the task is in
	// FAILED state.
	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,5,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
	// Output only. Time when the task was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Time when the task was last updated.
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// Output only. Provides details to errors and issues encountered while
	// processing the task. Presence of error details does not mean that the task
	// failed.
	ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,17,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
	// Output only. The number or resources with errors. Note: This is not the
	// total number of errors as each resource can have more than one error. This
	// is used to indicate truncation by having a `resource_error_count` that is
	// higher than the size of `resource_error_details`.
	ResourceErrorCount int32 `protobuf:"varint,18,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`
	// Output only. The metrics for the task.
	Metrics []*TimeSeries `protobuf:"bytes,19,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// Output only. The result of the task.
	TaskResult *MigrationTaskResult `protobuf:"bytes,20,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
	// Output only. Count of all the processing errors in this task and its
	// subtasks.
	TotalProcessingErrorCount int32 `protobuf:"varint,21,opt,name=total_processing_error_count,json=totalProcessingErrorCount,proto3" json:"total_processing_error_count,omitempty"`
	// Output only. Count of all the resource errors in this task and its
	// subtasks.
	TotalResourceErrorCount int32 `protobuf:"varint,22,opt,name=total_resource_error_count,json=totalResourceErrorCount,proto3" json:"total_resource_error_count,omitempty"`
	// contains filtered or unexported fields
}

A single task for a migration which has details about the configuration of the task.

func (*MigrationTask) Descriptor

func (*MigrationTask) Descriptor() ([]byte, []int)

Deprecated: Use MigrationTask.ProtoReflect.Descriptor instead.

func (*MigrationTask) GetAssessmentTaskDetails

func (x *MigrationTask) GetAssessmentTaskDetails() *AssessmentTaskDetails

func (*MigrationTask) GetCreateTime

func (x *MigrationTask) GetCreateTime() *timestamppb.Timestamp

func (*MigrationTask) GetId

func (x *MigrationTask) GetId() string

func (*MigrationTask) GetLastUpdateTime

func (x *MigrationTask) GetLastUpdateTime() *timestamppb.Timestamp

func (*MigrationTask) GetMetrics

func (x *MigrationTask) GetMetrics() []*TimeSeries

func (*MigrationTask) GetProcessingError

func (x *MigrationTask) GetProcessingError() *errdetails.ErrorInfo

func (*MigrationTask) GetResourceErrorCount

func (x *MigrationTask) GetResourceErrorCount() int32

func (*MigrationTask) GetResourceErrorDetails

func (x *MigrationTask) GetResourceErrorDetails() []*ResourceErrorDetail

func (*MigrationTask) GetState

func (x *MigrationTask) GetState() MigrationTask_State

func (*MigrationTask) GetTaskDetails

func (x *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails

func (*MigrationTask) GetTaskResult

func (x *MigrationTask) GetTaskResult() *MigrationTaskResult

func (*MigrationTask) GetTotalProcessingErrorCount

func (x *MigrationTask) GetTotalProcessingErrorCount() int32

func (*MigrationTask) GetTotalResourceErrorCount

func (x *MigrationTask) GetTotalResourceErrorCount() int32

func (*MigrationTask) GetTranslationConfigDetails

func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails

func (*MigrationTask) GetTranslationDetails

func (x *MigrationTask) GetTranslationDetails() *TranslationDetails

func (*MigrationTask) GetType

func (x *MigrationTask) GetType() string

func (*MigrationTask) ProtoMessage

func (*MigrationTask) ProtoMessage()

func (*MigrationTask) ProtoReflect

func (x *MigrationTask) ProtoReflect() protoreflect.Message

func (*MigrationTask) Reset

func (x *MigrationTask) Reset()

func (*MigrationTask) String

func (x *MigrationTask) String() string

MigrationTaskResult

type MigrationTaskResult struct {

	// Details specific to the task type.
	//
	// Types that are valid to be assigned to Details:
	//
	//	*MigrationTaskResult_TranslationTaskResult
	Details isMigrationTaskResult_Details `protobuf_oneof:"details"`
	// The map of task output types to the task outputs, e.g. "LINEAGE".
	TaskOutputs map[string]*TaskOutput `protobuf:"bytes,3,rep,name=task_outputs,json=taskOutputs,proto3" json:"task_outputs,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	// contains filtered or unexported fields
}

The migration task result.

func (*MigrationTaskResult) Descriptor

func (*MigrationTaskResult) Descriptor() ([]byte, []int)

Deprecated: Use MigrationTaskResult.ProtoReflect.Descriptor instead.

func (*MigrationTaskResult) GetDetails

func (x *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details

func (*MigrationTaskResult) GetTaskOutputs

func (x *MigrationTaskResult) GetTaskOutputs() map[string]*TaskOutput

func (*MigrationTaskResult) GetTranslationTaskResult

func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult

func (*MigrationTaskResult) ProtoMessage

func (*MigrationTaskResult) ProtoMessage()

func (*MigrationTaskResult) ProtoReflect

func (x *MigrationTaskResult) ProtoReflect() protoreflect.Message

func (*MigrationTaskResult) Reset

func (x *MigrationTaskResult) Reset()

func (*MigrationTaskResult) String

func (x *MigrationTaskResult) String() string

MigrationTaskResult_TranslationTaskResult

type MigrationTaskResult_TranslationTaskResult struct {
	// Details specific to translation task types.
	TranslationTaskResult *TranslationTaskResult `protobuf:"bytes,2,opt,name=translation_task_result,json=translationTaskResult,proto3,oneof"`
}

MigrationTask_AssessmentTaskDetails

type MigrationTask_AssessmentTaskDetails struct {
	// Task configuration for Assessment.
	AssessmentTaskDetails *AssessmentTaskDetails `protobuf:"bytes,12,opt,name=assessment_task_details,json=assessmentTaskDetails,proto3,oneof"`
}

MigrationTask_State

type MigrationTask_State int32

Possible states of a migration task.

MigrationTask_STATE_UNSPECIFIED, MigrationTask_PENDING, MigrationTask_ORCHESTRATING, MigrationTask_RUNNING, MigrationTask_PAUSED, MigrationTask_SUCCEEDED, MigrationTask_FAILED

const (
	// The state is unspecified.
	MigrationTask_STATE_UNSPECIFIED MigrationTask_State = 0
	// The task is waiting for orchestration.
	MigrationTask_PENDING MigrationTask_State = 1
	// The task is assigned to an orchestrator.
	MigrationTask_ORCHESTRATING MigrationTask_State = 2
	// The task is running, i.e. its subtasks are ready for execution.
	MigrationTask_RUNNING MigrationTask_State = 3
	// The task is paused. Assigned subtasks can continue, but no new subtasks
	// will be scheduled.
	MigrationTask_PAUSED MigrationTask_State = 4
	// The task finished successfully.
	MigrationTask_SUCCEEDED MigrationTask_State = 5
	// The task finished unsuccessfully.
	MigrationTask_FAILED MigrationTask_State = 6
)

func (MigrationTask_State) Descriptor

func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationTask_State) Enum

func (x MigrationTask_State) Enum() *MigrationTask_State

func (MigrationTask_State) EnumDescriptor

func (MigrationTask_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationTask_State.Descriptor instead.

func (MigrationTask_State) Number

func (x MigrationTask_State) Number() protoreflect.EnumNumber

func (MigrationTask_State) String

func (x MigrationTask_State) String() string

func (MigrationTask_State) Type

func (MigrationTask_State) Type() protoreflect.EnumType

MigrationTask_TranslationConfigDetails

type MigrationTask_TranslationConfigDetails struct {
	// Task configuration for CW Batch/Offline SQL Translation.
	TranslationConfigDetails *TranslationConfigDetails `protobuf:"bytes,14,opt,name=translation_config_details,json=translationConfigDetails,proto3,oneof"`
}

MigrationTask_TranslationDetails

type MigrationTask_TranslationDetails struct {
	// Task details for unified SQL Translation.
	TranslationDetails *TranslationDetails `protobuf:"bytes,16,opt,name=translation_details,json=translationDetails,proto3,oneof"`
}

MigrationWorkflow

type MigrationWorkflow struct {

	// Output only. Immutable. Identifier. The unique identifier for the migration
	// workflow. The ID is server-generated.
	//
	// Example: `projects/123/locations/us/workflows/345`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The display name of the workflow. This can be set to give a workflow
	// a descriptive name. There is no guarantee or enforcement of uniqueness.
	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// The tasks in a workflow in a named map. The name (i.e. key) has no
	// meaning and is merely a convenient way to address a specific task
	// in a workflow.
	Tasks map[string]*MigrationTask `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	// Output only. That status of the workflow.
	State MigrationWorkflow_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationWorkflow_State" json:"state,omitempty"`
	// Output only. Time when the workflow was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Time when the workflow was last updated.
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// contains filtered or unexported fields
}

A migration workflow which specifies what needs to be done for an EDW migration.

func (*MigrationWorkflow) Descriptor

func (*MigrationWorkflow) Descriptor() ([]byte, []int)

Deprecated: Use MigrationWorkflow.ProtoReflect.Descriptor instead.

func (*MigrationWorkflow) GetCreateTime

func (x *MigrationWorkflow) GetCreateTime() *timestamppb.Timestamp

func (*MigrationWorkflow) GetDisplayName

func (x *MigrationWorkflow) GetDisplayName() string

func (*MigrationWorkflow) GetLastUpdateTime

func (x *MigrationWorkflow) GetLastUpdateTime() *timestamppb.Timestamp

func (*MigrationWorkflow) GetName

func (x *MigrationWorkflow) GetName() string

func (*MigrationWorkflow) GetState

func (x *MigrationWorkflow) GetState() MigrationWorkflow_State

func (*MigrationWorkflow) GetTasks

func (x *MigrationWorkflow) GetTasks() map[string]*MigrationTask

func (*MigrationWorkflow) ProtoMessage

func (*MigrationWorkflow) ProtoMessage()

func (*MigrationWorkflow) ProtoReflect

func (x *MigrationWorkflow) ProtoReflect() protoreflect.Message

func (*MigrationWorkflow) Reset

func (x *MigrationWorkflow) Reset()

func (*MigrationWorkflow) String

func (x *MigrationWorkflow) String() string

MigrationWorkflow_State

type MigrationWorkflow_State int32

Possible migration workflow states.

MigrationWorkflow_STATE_UNSPECIFIED, MigrationWorkflow_DRAFT, MigrationWorkflow_RUNNING, MigrationWorkflow_PAUSED, MigrationWorkflow_COMPLETED

const (
	// Workflow state is unspecified.
	MigrationWorkflow_STATE_UNSPECIFIED MigrationWorkflow_State = 0
	// Workflow is in draft status, i.e. tasks are not yet eligible for
	// execution.
	MigrationWorkflow_DRAFT MigrationWorkflow_State = 1
	// Workflow is running (i.e. tasks are eligible for execution).
	MigrationWorkflow_RUNNING MigrationWorkflow_State = 2
	// Workflow is paused. Tasks currently in progress may continue, but no
	// further tasks will be scheduled.
	MigrationWorkflow_PAUSED MigrationWorkflow_State = 3
	// Workflow is complete. There should not be any task in a non-terminal
	// state, but if they are (e.g. forced termination), they will not be
	// scheduled.
	MigrationWorkflow_COMPLETED MigrationWorkflow_State = 4
)

func (MigrationWorkflow_State) Descriptor

func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationWorkflow_State) Enum

func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State

func (MigrationWorkflow_State) EnumDescriptor

func (MigrationWorkflow_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationWorkflow_State.Descriptor instead.

func (MigrationWorkflow_State) Number

func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber

func (MigrationWorkflow_State) String

func (x MigrationWorkflow_State) String() string

func (MigrationWorkflow_State) Type

func (MigrationWorkflow_State) Type() protoreflect.EnumType

MySQLDialect

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

The dialect definition for MySQL.

func (*MySQLDialect) Descriptor

func (*MySQLDialect) Descriptor() ([]byte, []int)

Deprecated: Use MySQLDialect.ProtoReflect.Descriptor instead.

func (*MySQLDialect) ProtoMessage

func (*MySQLDialect) ProtoMessage()

func (*MySQLDialect) ProtoReflect

func (x *MySQLDialect) ProtoReflect() protoreflect.Message

func (*MySQLDialect) Reset

func (x *MySQLDialect) Reset()

func (*MySQLDialect) String

func (x *MySQLDialect) String() string

NameMappingKey

type NameMappingKey struct {

	// The type of object that is being mapped.
	Type NameMappingKey_Type `protobuf:"varint,1,opt,name=type,proto3,enum=google.cloud.bigquery.migration.v2.NameMappingKey_Type" json:"type,omitempty"`
	// The database name (BigQuery project ID equivalent in the source data
	// warehouse).
	Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	// The schema name (BigQuery dataset equivalent in the source data warehouse).
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// The relation name (BigQuery table or view equivalent in the source data
	// warehouse).
	Relation string `protobuf:"bytes,4,opt,name=relation,proto3" json:"relation,omitempty"`
	// The attribute name (BigQuery column equivalent in the source data
	// warehouse).
	Attribute string `protobuf:"bytes,5,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// contains filtered or unexported fields
}

The potential components of a full name mapping that will be mapped during translation in the source data warehouse.

func (*NameMappingKey) Descriptor

func (*NameMappingKey) Descriptor() ([]byte, []int)

Deprecated: Use NameMappingKey.ProtoReflect.Descriptor instead.

func (*NameMappingKey) GetAttribute

func (x *NameMappingKey) GetAttribute() string

func (*NameMappingKey) GetDatabase

func (x *NameMappingKey) GetDatabase() string

func (*NameMappingKey) GetRelation

func (x *NameMappingKey) GetRelation() string

func (*NameMappingKey) GetSchema

func (x *NameMappingKey) GetSchema() string

func (*NameMappingKey) GetType

func (x *NameMappingKey) GetType() NameMappingKey_Type

func (*NameMappingKey) ProtoMessage

func (*NameMappingKey) ProtoMessage()

func (*NameMappingKey) ProtoReflect

func (x *NameMappingKey) ProtoReflect() protoreflect.Message

func (*NameMappingKey) Reset

func (x *NameMappingKey) Reset()

func (*NameMappingKey) String

func (x *NameMappingKey) String() string

NameMappingKey_Type

type NameMappingKey_Type int32

The type of the object that is being mapped.

NameMappingKey_TYPE_UNSPECIFIED, NameMappingKey_DATABASE, NameMappingKey_SCHEMA, NameMappingKey_RELATION, NameMappingKey_ATTRIBUTE, NameMappingKey_RELATION_ALIAS, NameMappingKey_ATTRIBUTE_ALIAS, NameMappingKey_FUNCTION

const (
	// Unspecified name mapping type.
	NameMappingKey_TYPE_UNSPECIFIED NameMappingKey_Type = 0
	// The object being mapped is a database.
	NameMappingKey_DATABASE NameMappingKey_Type = 1
	// The object being mapped is a schema.
	NameMappingKey_SCHEMA NameMappingKey_Type = 2
	// The object being mapped is a relation.
	NameMappingKey_RELATION NameMappingKey_Type = 3
	// The object being mapped is an attribute.
	NameMappingKey_ATTRIBUTE NameMappingKey_Type = 4
	// The object being mapped is a relation alias.
	NameMappingKey_RELATION_ALIAS NameMappingKey_Type = 5
	// The object being mapped is a an attribute alias.
	NameMappingKey_ATTRIBUTE_ALIAS NameMappingKey_Type = 6
	// The object being mapped is a function.
	NameMappingKey_FUNCTION NameMappingKey_Type = 7
)

func (NameMappingKey_Type) Descriptor

func (NameMappingKey_Type) Descriptor() protoreflect.EnumDescriptor

func (NameMappingKey_Type) Enum

func (x NameMappingKey_Type) Enum() *NameMappingKey_Type

func (NameMappingKey_Type) EnumDescriptor

func (NameMappingKey_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use NameMappingKey_Type.Descriptor instead.

func (NameMappingKey_Type) Number

func (x NameMappingKey_Type) Number() protoreflect.EnumNumber

func (NameMappingKey_Type) String

func (x NameMappingKey_Type) String() string

func (NameMappingKey_Type) Type

func (NameMappingKey_Type) Type() protoreflect.EnumType

NameMappingValue

type NameMappingValue struct {

	// The database name (BigQuery project ID equivalent in the target data
	// warehouse).
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// The schema name (BigQuery dataset equivalent in the target data warehouse).
	Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// The relation name (BigQuery table or view equivalent in the target data
	// warehouse).
	Relation string `protobuf:"bytes,3,opt,name=relation,proto3" json:"relation,omitempty"`
	// The attribute name (BigQuery column equivalent in the target data
	// warehouse).
	Attribute string `protobuf:"bytes,4,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// contains filtered or unexported fields
}

The potential components of a full name mapping that will be mapped during translation in the target data warehouse.

func (*NameMappingValue) Descriptor

func (*NameMappingValue) Descriptor() ([]byte, []int)

Deprecated: Use NameMappingValue.ProtoReflect.Descriptor instead.

func (*NameMappingValue) GetAttribute

func (x *NameMappingValue) GetAttribute() string

func (*NameMappingValue) GetDatabase

func (x *NameMappingValue) GetDatabase() string

func (*NameMappingValue) GetRelation

func (x *NameMappingValue) GetRelation() string

func (*NameMappingValue) GetSchema

func (x *NameMappingValue) GetSchema() string

func (*NameMappingValue) ProtoMessage

func (*NameMappingValue) ProtoMessage()

func (*NameMappingValue) ProtoReflect

func (x *NameMappingValue) ProtoReflect() protoreflect.Message

func (*NameMappingValue) Reset

func (x *NameMappingValue) Reset()

func (*NameMappingValue) String

func (x *NameMappingValue) String() string

NetezzaDialect

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

The dialect definition for Netezza.

func (*NetezzaDialect) Descriptor

func (*NetezzaDialect) Descriptor() ([]byte, []int)

Deprecated: Use NetezzaDialect.ProtoReflect.Descriptor instead.

func (*NetezzaDialect) ProtoMessage

func (*NetezzaDialect) ProtoMessage()

func (*NetezzaDialect) ProtoReflect

func (x *NetezzaDialect) ProtoReflect() protoreflect.Message

func (*NetezzaDialect) Reset

func (x *NetezzaDialect) Reset()

func (*NetezzaDialect) String

func (x *NetezzaDialect) String() string

ObjectNameMapping

type ObjectNameMapping struct {

	// The name of the object in source that is being mapped.
	Source *NameMappingKey `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// The desired target name of the object that is being mapped.
	Target *NameMappingValue `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

Represents a key-value pair of NameMappingKey to NameMappingValue to represent the mapping of SQL names from the input value to desired output.

func (*ObjectNameMapping) Descriptor

func (*ObjectNameMapping) Descriptor() ([]byte, []int)

Deprecated: Use ObjectNameMapping.ProtoReflect.Descriptor instead.

func (*ObjectNameMapping) GetSource

func (x *ObjectNameMapping) GetSource() *NameMappingKey

func (*ObjectNameMapping) GetTarget

func (x *ObjectNameMapping) GetTarget() *NameMappingValue

func (*ObjectNameMapping) ProtoMessage

func (*ObjectNameMapping) ProtoMessage()

func (*ObjectNameMapping) ProtoReflect

func (x *ObjectNameMapping) ProtoReflect() protoreflect.Message

func (*ObjectNameMapping) Reset

func (x *ObjectNameMapping) Reset()

func (*ObjectNameMapping) String

func (x *ObjectNameMapping) String() string

ObjectNameMappingList

type ObjectNameMappingList struct {

	// The elements of the object name map.
	NameMap []*ObjectNameMapping `protobuf:"bytes,1,rep,name=name_map,json=nameMap,proto3" json:"name_map,omitempty"`
	// contains filtered or unexported fields
}

Represents a map of name mappings using a list of key:value proto messages of existing name to desired output name.

func (*ObjectNameMappingList) Descriptor

func (*ObjectNameMappingList) Descriptor() ([]byte, []int)

Deprecated: Use ObjectNameMappingList.ProtoReflect.Descriptor instead.

func (*ObjectNameMappingList) GetNameMap

func (x *ObjectNameMappingList) GetNameMap() []*ObjectNameMapping

func (*ObjectNameMappingList) ProtoMessage

func (*ObjectNameMappingList) ProtoMessage()

func (*ObjectNameMappingList) ProtoReflect

func (x *ObjectNameMappingList) ProtoReflect() protoreflect.Message

func (*ObjectNameMappingList) Reset

func (x *ObjectNameMappingList) Reset()

func (*ObjectNameMappingList) String

func (x *ObjectNameMappingList) String() string

OracleDialect

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

The dialect definition for Oracle.

func (*OracleDialect) Descriptor

func (*OracleDialect) Descriptor() ([]byte, []int)

Deprecated: Use OracleDialect.ProtoReflect.Descriptor instead.

func (*OracleDialect) ProtoMessage

func (*OracleDialect) ProtoMessage()

func (*OracleDialect) ProtoReflect

func (x *OracleDialect) ProtoReflect() protoreflect.Message

func (*OracleDialect) Reset

func (x *OracleDialect) Reset()

func (*OracleDialect) String

func (x *OracleDialect) String() string

Point

type Point struct {

	// The time interval to which the data point applies.  For `GAUGE` metrics,
	// the start time does not need to be supplied, but if it is supplied, it must
	// equal the end time.  For `DELTA` metrics, the start and end time should
	// specify a non-zero interval, with subsequent points specifying contiguous
	// and non-overlapping intervals.  For `CUMULATIVE` metrics, the start and end
	// time should specify a non-zero interval, with subsequent points specifying
	// the same start time and increasing end times, until an event resets the
	// cumulative value to zero and sets a new start time for the following
	// points.
	Interval *TimeInterval `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// The value of the data point.
	Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A single data point in a time series.

func (*Point) Descriptor

func (*Point) Descriptor() ([]byte, []int)

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetInterval

func (x *Point) GetInterval() *TimeInterval

func (*Point) GetValue

func (x *Point) GetValue() *TypedValue

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) ProtoReflect

func (x *Point) ProtoReflect() protoreflect.Message

func (*Point) Reset

func (x *Point) Reset()

func (*Point) String

func (x *Point) String() string

PostgresqlDialect

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

The dialect definition for Postgresql.

func (*PostgresqlDialect) Descriptor

func (*PostgresqlDialect) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlDialect.ProtoReflect.Descriptor instead.

func (*PostgresqlDialect) ProtoMessage

func (*PostgresqlDialect) ProtoMessage()

func (*PostgresqlDialect) ProtoReflect

func (x *PostgresqlDialect) ProtoReflect() protoreflect.Message

func (*PostgresqlDialect) Reset

func (x *PostgresqlDialect) Reset()

func (*PostgresqlDialect) String

func (x *PostgresqlDialect) String() string

PrestoDialect

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

The dialect definition for Presto.

func (*PrestoDialect) Descriptor

func (*PrestoDialect) Descriptor() ([]byte, []int)

Deprecated: Use PrestoDialect.ProtoReflect.Descriptor instead.

func (*PrestoDialect) ProtoMessage

func (*PrestoDialect) ProtoMessage()

func (*PrestoDialect) ProtoReflect

func (x *PrestoDialect) ProtoReflect() protoreflect.Message

func (*PrestoDialect) Reset

func (x *PrestoDialect) Reset()

func (*PrestoDialect) String

func (x *PrestoDialect) String() string

RedshiftDialect

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

The dialect definition for Redshift.

func (*RedshiftDialect) Descriptor

func (*RedshiftDialect) Descriptor() ([]byte, []int)

Deprecated: Use RedshiftDialect.ProtoReflect.Descriptor instead.

func (*RedshiftDialect) ProtoMessage

func (*RedshiftDialect) ProtoMessage()

func (*RedshiftDialect) ProtoReflect

func (x *RedshiftDialect) ProtoReflect() protoreflect.Message

func (*RedshiftDialect) Reset

func (x *RedshiftDialect) Reset()

func (*RedshiftDialect) String

func (x *RedshiftDialect) String() string

ResourceErrorDetail

type ResourceErrorDetail struct {

	// Required. Information about the resource where the error is located.
	ResourceInfo *errdetails.ResourceInfo `protobuf:"bytes,1,opt,name=resource_info,json=resourceInfo,proto3" json:"resource_info,omitempty"`
	// Required. The error details for the resource.
	ErrorDetails []*ErrorDetail `protobuf:"bytes,2,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// Required. How many errors there are in total for the resource. Truncation
	// can be indicated by having an `error_count` that is higher than the size of
	// `error_details`.
	ErrorCount int32 `protobuf:"varint,3,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// contains filtered or unexported fields
}

Provides details for errors and the corresponding resources.

func (*ResourceErrorDetail) Descriptor

func (*ResourceErrorDetail) Descriptor() ([]byte, []int)

Deprecated: Use ResourceErrorDetail.ProtoReflect.Descriptor instead.

func (*ResourceErrorDetail) GetErrorCount

func (x *ResourceErrorDetail) GetErrorCount() int32

func (*ResourceErrorDetail) GetErrorDetails

func (x *ResourceErrorDetail) GetErrorDetails() []*ErrorDetail

func (*ResourceErrorDetail) GetResourceInfo

func (x *ResourceErrorDetail) GetResourceInfo() *errdetails.ResourceInfo

func (*ResourceErrorDetail) ProtoMessage

func (*ResourceErrorDetail) ProtoMessage()

func (*ResourceErrorDetail) ProtoReflect

func (x *ResourceErrorDetail) ProtoReflect() protoreflect.Message

func (*ResourceErrorDetail) Reset

func (x *ResourceErrorDetail) Reset()

func (*ResourceErrorDetail) String

func (x *ResourceErrorDetail) String() string

SQLServerDialect

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

The dialect definition for SQL Server.

func (*SQLServerDialect) Descriptor

func (*SQLServerDialect) Descriptor() ([]byte, []int)

Deprecated: Use SQLServerDialect.ProtoReflect.Descriptor instead.

func (*SQLServerDialect) ProtoMessage

func (*SQLServerDialect) ProtoMessage()

func (*SQLServerDialect) ProtoReflect

func (x *SQLServerDialect) ProtoReflect() protoreflect.Message

func (*SQLServerDialect) Reset

func (x *SQLServerDialect) Reset()

func (*SQLServerDialect) String

func (x *SQLServerDialect) String() string

SQLiteDialect

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

The dialect definition for SQLite.

func (*SQLiteDialect) Descriptor

func (*SQLiteDialect) Descriptor() ([]byte, []int)

Deprecated: Use SQLiteDialect.ProtoReflect.Descriptor instead.

func (*SQLiteDialect) ProtoMessage

func (*SQLiteDialect) ProtoMessage()

func (*SQLiteDialect) ProtoReflect

func (x *SQLiteDialect) ProtoReflect() protoreflect.Message

func (*SQLiteDialect) Reset

func (x *SQLiteDialect) Reset()

func (*SQLiteDialect) String

func (x *SQLiteDialect) String() string

SnowflakeDialect

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

The dialect definition for Snowflake.

func (*SnowflakeDialect) Descriptor

func (*SnowflakeDialect) Descriptor() ([]byte, []int)

Deprecated: Use SnowflakeDialect.ProtoReflect.Descriptor instead.

func (*SnowflakeDialect) ProtoMessage

func (*SnowflakeDialect) ProtoMessage()

func (*SnowflakeDialect) ProtoReflect

func (x *SnowflakeDialect) ProtoReflect() protoreflect.Message

func (*SnowflakeDialect) Reset

func (x *SnowflakeDialect) Reset()

func (*SnowflakeDialect) String

func (x *SnowflakeDialect) String() string

SourceEnv

type SourceEnv struct {

	// The default database name to fully qualify SQL objects when their database
	// name is missing.
	DefaultDatabase string `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`
	// The schema search path. When SQL objects are missing schema name,
	// translation engine will search through this list to find the value.
	SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`
	// Optional. Expects a valid BigQuery dataset ID that exists, e.g.,
	// project-123.metadata_store_123.  If specified, translation will search and
	// read the required schema information from a metadata store in this dataset.
	// If metadata store doesn't exist, translation will parse the metadata file
	// and upload the schema info to a temp table in the dataset to speed up
	// future translation jobs.
	MetadataStoreDataset string `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`
	// contains filtered or unexported fields
}

Represents the default source environment values for the translation.

func (*SourceEnv) Descriptor

func (*SourceEnv) Descriptor() ([]byte, []int)

Deprecated: Use SourceEnv.ProtoReflect.Descriptor instead.

func (*SourceEnv) GetDefaultDatabase

func (x *SourceEnv) GetDefaultDatabase() string

func (*SourceEnv) GetMetadataStoreDataset

func (x *SourceEnv) GetMetadataStoreDataset() string

func (*SourceEnv) GetSchemaSearchPath

func (x *SourceEnv) GetSchemaSearchPath() []string

func (*SourceEnv) ProtoMessage

func (*SourceEnv) ProtoMessage()

func (*SourceEnv) ProtoReflect

func (x *SourceEnv) ProtoReflect() protoreflect.Message

func (*SourceEnv) Reset

func (x *SourceEnv) Reset()

func (*SourceEnv) String

func (x *SourceEnv) String() string

SourceEnvironment

type SourceEnvironment struct {

	// The default database name to fully qualify SQL objects when their database
	// name is missing.
	DefaultDatabase string `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`
	// The schema search path. When SQL objects are missing schema name,
	// translation engine will search through this list to find the value.
	SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`
	// Optional. Expects a validQ BigQuery dataset ID that exists, e.g.,
	// project-123.metadata_store_123.  If specified, translation will search and
	// read the required schema information from a metadata store in this dataset.
	// If metadata store doesn't exist, translation will parse the metadata file
	// and upload the schema info to a temp table in the dataset to speed up
	// future translation jobs.
	MetadataStoreDataset string `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`
	// contains filtered or unexported fields
}

Represents the default source environment values for the translation.

func (*SourceEnvironment) Descriptor

func (*SourceEnvironment) Descriptor() ([]byte, []int)

Deprecated: Use SourceEnvironment.ProtoReflect.Descriptor instead.

func (*SourceEnvironment) GetDefaultDatabase

func (x *SourceEnvironment) GetDefaultDatabase() string

func (*SourceEnvironment) GetMetadataStoreDataset

func (x *SourceEnvironment) GetMetadataStoreDataset() string

func (*SourceEnvironment) GetSchemaSearchPath

func (x *SourceEnvironment) GetSchemaSearchPath() []string

func (*SourceEnvironment) ProtoMessage

func (*SourceEnvironment) ProtoMessage()

func (*SourceEnvironment) ProtoReflect

func (x *SourceEnvironment) ProtoReflect() protoreflect.Message

func (*SourceEnvironment) Reset

func (x *SourceEnvironment) Reset()

func (*SourceEnvironment) String

func (x *SourceEnvironment) String() string

SourceSpec

type SourceSpec struct {

	// The specific source SQL.
	//
	// Types that are valid to be assigned to Source:
	//
	//	*SourceSpec_BaseUri
	//	*SourceSpec_Literal
	//	*SourceSpec_GcsFilePath
	Source isSourceSpec_Source `protobuf_oneof:"source"`
	// Optional. The optional field to specify the encoding of the sql bytes.
	Encoding string `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

Represents one path to the location that holds source data.

func (*SourceSpec) Descriptor

func (*SourceSpec) Descriptor() ([]byte, []int)

Deprecated: Use SourceSpec.ProtoReflect.Descriptor instead.

func (*SourceSpec) GetBaseUri

func (x *SourceSpec) GetBaseUri() string

func (*SourceSpec) GetEncoding

func (x *SourceSpec) GetEncoding() string

func (*SourceSpec) GetGcsFilePath

func (x *SourceSpec) GetGcsFilePath() string

func (*SourceSpec) GetLiteral

func (x *SourceSpec) GetLiteral() *Literal

func (*SourceSpec) GetSource

func (x *SourceSpec) GetSource() isSourceSpec_Source

func (*SourceSpec) ProtoMessage

func (*SourceSpec) ProtoMessage()

func (*SourceSpec) ProtoReflect

func (x *SourceSpec) ProtoReflect() protoreflect.Message

func (*SourceSpec) Reset

func (x *SourceSpec) Reset()

func (*SourceSpec) String

func (x *SourceSpec) String() string

SourceSpec_BaseUri

type SourceSpec_BaseUri struct {
	// The base URI for all files to be read in as sources for translation.
	BaseUri string `protobuf:"bytes,1,opt,name=base_uri,json=baseUri,proto3,oneof"`
}

SourceSpec_GcsFilePath

type SourceSpec_GcsFilePath struct {
	// The path to a single source file in Cloud Storage.
	GcsFilePath string `protobuf:"bytes,4,opt,name=gcs_file_path,json=gcsFilePath,proto3,oneof"`
}

SourceSpec_Literal

type SourceSpec_Literal struct {
	// Source literal.
	Literal *Literal `protobuf:"bytes,2,opt,name=literal,proto3,oneof"`
}

SourceTargetMapping

type SourceTargetMapping struct {

	// The source SQL or the path to it.
	SourceSpec *SourceSpec `protobuf:"bytes,1,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"`
	// The target SQL or the path for it.
	TargetSpec *TargetSpec `protobuf:"bytes,2,opt,name=target_spec,json=targetSpec,proto3" json:"target_spec,omitempty"`
	// contains filtered or unexported fields
}

Represents one mapping from a source SQL to a target SQL.

func (*SourceTargetMapping) Descriptor

func (*SourceTargetMapping) Descriptor() ([]byte, []int)

Deprecated: Use SourceTargetMapping.ProtoReflect.Descriptor instead.

func (*SourceTargetMapping) GetSourceSpec

func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec

func (*SourceTargetMapping) GetTargetSpec

func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec

func (*SourceTargetMapping) ProtoMessage

func (*SourceTargetMapping) ProtoMessage()

func (*SourceTargetMapping) ProtoReflect

func (x *SourceTargetMapping) ProtoReflect() protoreflect.Message

func (*SourceTargetMapping) Reset

func (x *SourceTargetMapping) Reset()

func (*SourceTargetMapping) String

func (x *SourceTargetMapping) String() string

SparkSQLDialect

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

The dialect definition for SparkSQL.

func (*SparkSQLDialect) Descriptor

func (*SparkSQLDialect) Descriptor() ([]byte, []int)

Deprecated: Use SparkSQLDialect.ProtoReflect.Descriptor instead.

func (*SparkSQLDialect) ProtoMessage

func (*SparkSQLDialect) ProtoMessage()

func (*SparkSQLDialect) ProtoReflect

func (x *SparkSQLDialect) ProtoReflect() protoreflect.Message

func (*SparkSQLDialect) Reset

func (x *SparkSQLDialect) Reset()

func (*SparkSQLDialect) String

func (x *SparkSQLDialect) String() string

StartMigrationWorkflowRequest

type StartMigrationWorkflowRequest struct {

	// Required. The unique identifier for the migration workflow.
	// Example: `projects/123/locations/us/workflows/1234`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

A request to start a previously created migration workflow.

func (*StartMigrationWorkflowRequest) Descriptor

func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartMigrationWorkflowRequest) GetName

func (x *StartMigrationWorkflowRequest) GetName() string

func (*StartMigrationWorkflowRequest) ProtoMessage

func (*StartMigrationWorkflowRequest) ProtoMessage()

func (*StartMigrationWorkflowRequest) ProtoReflect

func (x *StartMigrationWorkflowRequest) ProtoReflect() protoreflect.Message

func (*StartMigrationWorkflowRequest) Reset

func (x *StartMigrationWorkflowRequest) Reset()

func (*StartMigrationWorkflowRequest) String

func (x *StartMigrationWorkflowRequest) String() string

SuggestionConfig

type SuggestionConfig struct {

	// The list of suggestion steps to skip.
	SkipSuggestionSteps []*SuggestionStep `protobuf:"bytes,1,rep,name=skip_suggestion_steps,json=skipSuggestionSteps,proto3" json:"skip_suggestion_steps,omitempty"`
	// contains filtered or unexported fields
}

The configuration for the suggestion if requested as a target type.

func (*SuggestionConfig) Descriptor

func (*SuggestionConfig) Descriptor() ([]byte, []int)

Deprecated: Use SuggestionConfig.ProtoReflect.Descriptor instead.

func (*SuggestionConfig) GetSkipSuggestionSteps

func (x *SuggestionConfig) GetSkipSuggestionSteps() []*SuggestionStep

func (*SuggestionConfig) ProtoMessage

func (*SuggestionConfig) ProtoMessage()

func (*SuggestionConfig) ProtoReflect

func (x *SuggestionConfig) ProtoReflect() protoreflect.Message

func (*SuggestionConfig) Reset

func (x *SuggestionConfig) Reset()

func (*SuggestionConfig) String

func (x *SuggestionConfig) String() string

SuggestionStep

type SuggestionStep struct {

	// The type of suggestion.
	SuggestionType SuggestionStep_SuggestionType `protobuf:"varint,1,opt,name=suggestion_type,json=suggestionType,proto3,enum=google.cloud.bigquery.migration.v2.SuggestionStep_SuggestionType" json:"suggestion_type,omitempty"`
	// The rewrite target.
	RewriteTarget SuggestionStep_RewriteTarget `protobuf:"varint,2,opt,name=rewrite_target,json=rewriteTarget,proto3,enum=google.cloud.bigquery.migration.v2.SuggestionStep_RewriteTarget" json:"rewrite_target,omitempty"`
	// contains filtered or unexported fields
}

Suggestion step to skip.

func (*SuggestionStep) Descriptor

func (*SuggestionStep) Descriptor() ([]byte, []int)

Deprecated: Use SuggestionStep.ProtoReflect.Descriptor instead.

func (*SuggestionStep) GetRewriteTarget

func (x *SuggestionStep) GetRewriteTarget() SuggestionStep_RewriteTarget

func (*SuggestionStep) GetSuggestionType

func (x *SuggestionStep) GetSuggestionType() SuggestionStep_SuggestionType

func (*SuggestionStep) ProtoMessage

func (*SuggestionStep) ProtoMessage()

func (*SuggestionStep) ProtoReflect

func (x *SuggestionStep) ProtoReflect() protoreflect.Message

func (*SuggestionStep) Reset

func (x *SuggestionStep) Reset()

func (*SuggestionStep) String

func (x *SuggestionStep) String() string

SuggestionStep_RewriteTarget

type SuggestionStep_RewriteTarget int32

The target to apply the suggestion to.

SuggestionStep_REWRITE_TARGET_UNSPECIFIED, SuggestionStep_SOURCE_SQL, SuggestionStep_TARGET_SQL

const (
	// Rewrite target unspecified.
	SuggestionStep_REWRITE_TARGET_UNSPECIFIED SuggestionStep_RewriteTarget = 0
	// Source SQL.
	SuggestionStep_SOURCE_SQL SuggestionStep_RewriteTarget = 1
	// Target SQL.
	SuggestionStep_TARGET_SQL SuggestionStep_RewriteTarget = 2
)

func (SuggestionStep_RewriteTarget) Descriptor

func (SuggestionStep_RewriteTarget) Descriptor() protoreflect.EnumDescriptor

func (SuggestionStep_RewriteTarget) Enum

func (x SuggestionStep_RewriteTarget) Enum() *SuggestionStep_RewriteTarget

func (SuggestionStep_RewriteTarget) EnumDescriptor

func (SuggestionStep_RewriteTarget) EnumDescriptor() ([]byte, []int)

Deprecated: Use SuggestionStep_RewriteTarget.Descriptor instead.

func (SuggestionStep_RewriteTarget) Number

func (x SuggestionStep_RewriteTarget) Number() protoreflect.EnumNumber

func (SuggestionStep_RewriteTarget) String

func (x SuggestionStep_RewriteTarget) String() string

func (SuggestionStep_RewriteTarget) Type

func (SuggestionStep_RewriteTarget) Type() protoreflect.EnumType

SuggestionStep_SuggestionType

type SuggestionStep_SuggestionType int32

Suggestion type.

SuggestionStep_SUGGESTION_TYPE_UNSPECIFIED, SuggestionStep_QUERY_CUSTOMIZATION, SuggestionStep_TRANSLATION_EXPLANATION

const (
	// Suggestion type unspecified.
	SuggestionStep_SUGGESTION_TYPE_UNSPECIFIED SuggestionStep_SuggestionType = 0
	// Query customization.
	SuggestionStep_QUERY_CUSTOMIZATION SuggestionStep_SuggestionType = 1
	// Translation explanation.
	SuggestionStep_TRANSLATION_EXPLANATION SuggestionStep_SuggestionType = 2
)

func (SuggestionStep_SuggestionType) Descriptor

func (SuggestionStep_SuggestionType) Descriptor() protoreflect.EnumDescriptor

func (SuggestionStep_SuggestionType) Enum

func (x SuggestionStep_SuggestionType) Enum() *SuggestionStep_SuggestionType

func (SuggestionStep_SuggestionType) EnumDescriptor

func (SuggestionStep_SuggestionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SuggestionStep_SuggestionType.Descriptor instead.

func (SuggestionStep_SuggestionType) Number

func (x SuggestionStep_SuggestionType) Number() protoreflect.EnumNumber

func (SuggestionStep_SuggestionType) String

func (x SuggestionStep_SuggestionType) String() string

func (SuggestionStep_SuggestionType) Type

func (SuggestionStep_SuggestionType) Type() protoreflect.EnumType

TargetSpec

type TargetSpec struct {

	// The relative path for the target data. Given source file
	// `base_uri/input/sql`, the output would be
	// `target_base_uri/sql/relative_path/input.sql`.
	RelativePath string `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`
	// contains filtered or unexported fields
}

Represents one path to the location that holds target data.

func (*TargetSpec) Descriptor

func (*TargetSpec) Descriptor() ([]byte, []int)

Deprecated: Use TargetSpec.ProtoReflect.Descriptor instead.

func (*TargetSpec) GetRelativePath

func (x *TargetSpec) GetRelativePath() string

func (*TargetSpec) ProtoMessage

func (*TargetSpec) ProtoMessage()

func (*TargetSpec) ProtoReflect

func (x *TargetSpec) ProtoReflect() protoreflect.Message

func (*TargetSpec) Reset

func (x *TargetSpec) Reset()

func (*TargetSpec) String

func (x *TargetSpec) String() string

TaskOutput

type TaskOutput struct {

	// The detailed output of the task.
	//
	// Types that are valid to be assigned to Output:
	//
	//	*TaskOutput_LineageOutput
	Output isTaskOutput_Output `protobuf_oneof:"output"`
	// Output only. The current state of the task output.
	State TaskOutput_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.TaskOutput_State" json:"state,omitempty"`
	// An explanation that may be populated when the task output is in FAILED
	// state.
	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,2,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
	// contains filtered or unexported fields
}

The task output for a task type including the status and any errors.

func (*TaskOutput) Descriptor

func (*TaskOutput) Descriptor() ([]byte, []int)

Deprecated: Use TaskOutput.ProtoReflect.Descriptor instead.

func (*TaskOutput) GetLineageOutput

func (x *TaskOutput) GetLineageOutput() *LineageOutput

func (*TaskOutput) GetOutput

func (x *TaskOutput) GetOutput() isTaskOutput_Output

func (*TaskOutput) GetProcessingError

func (x *TaskOutput) GetProcessingError() *errdetails.ErrorInfo

func (*TaskOutput) GetState

func (x *TaskOutput) GetState() TaskOutput_State

func (*TaskOutput) ProtoMessage

func (*TaskOutput) ProtoMessage()

func (*TaskOutput) ProtoReflect

func (x *TaskOutput) ProtoReflect() protoreflect.Message

func (*TaskOutput) Reset

func (x *TaskOutput) Reset()

func (*TaskOutput) String

func (x *TaskOutput) String() string

TaskOutput_LineageOutput

type TaskOutput_LineageOutput struct {
	// The output of the task with output type "LINEAGE".
	LineageOutput *LineageOutput `protobuf:"bytes,3,opt,name=lineage_output,json=lineageOutput,proto3,oneof"`
}

TaskOutput_State

type TaskOutput_State int32

Possible task output states.

TaskOutput_STATE_UNSPECIFIED, TaskOutput_PENDING, TaskOutput_SUCCEEDED, TaskOutput_FAILED

const (
	// Task output state is unspecified.
	TaskOutput_STATE_UNSPECIFIED TaskOutput_State = 0
	// Task output is pending.
	TaskOutput_PENDING TaskOutput_State = 1
	// Task output is succeeded.
	TaskOutput_SUCCEEDED TaskOutput_State = 2
	// Task output is failed. This does not mean that there is no useful
	// information in the output; partial outputs or failure details may be
	// available.
	TaskOutput_FAILED TaskOutput_State = 3
)

func (TaskOutput_State) Descriptor

func (TaskOutput_State) Descriptor() protoreflect.EnumDescriptor

func (TaskOutput_State) Enum

func (x TaskOutput_State) Enum() *TaskOutput_State

func (TaskOutput_State) EnumDescriptor

func (TaskOutput_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskOutput_State.Descriptor instead.

func (TaskOutput_State) Number

func (x TaskOutput_State) Number() protoreflect.EnumNumber

func (TaskOutput_State) String

func (x TaskOutput_State) String() string

func (TaskOutput_State) Type

func (TaskOutput_State) Type() protoreflect.EnumType

TeradataDialect

type TeradataDialect struct {

	// Which Teradata sub-dialect mode the user specifies.
	Mode TeradataDialect_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.cloud.bigquery.migration.v2.TeradataDialect_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

The dialect definition for Teradata.

func (*TeradataDialect) Descriptor

func (*TeradataDialect) Descriptor() ([]byte, []int)

Deprecated: Use TeradataDialect.ProtoReflect.Descriptor instead.

func (*TeradataDialect) GetMode

func (x *TeradataDialect) GetMode() TeradataDialect_Mode

func (*TeradataDialect) ProtoMessage

func (*TeradataDialect) ProtoMessage()

func (*TeradataDialect) ProtoReflect

func (x *TeradataDialect) ProtoReflect() protoreflect.Message

func (*TeradataDialect) Reset

func (x *TeradataDialect) Reset()

func (*TeradataDialect) String

func (x *TeradataDialect) String() string

TeradataDialect_Mode

type TeradataDialect_Mode int32

The sub-dialect options for Teradata.

TeradataDialect_MODE_UNSPECIFIED, TeradataDialect_SQL, TeradataDialect_BTEQ

const (
	// Unspecified mode.
	TeradataDialect_MODE_UNSPECIFIED TeradataDialect_Mode = 0
	// Teradata SQL mode.
	TeradataDialect_SQL TeradataDialect_Mode = 1
	// BTEQ mode (which includes SQL).
	TeradataDialect_BTEQ TeradataDialect_Mode = 2
)

func (TeradataDialect_Mode) Descriptor

func (TeradataDialect_Mode) Descriptor() protoreflect.EnumDescriptor

func (TeradataDialect_Mode) Enum

func (x TeradataDialect_Mode) Enum() *TeradataDialect_Mode

func (TeradataDialect_Mode) EnumDescriptor

func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use TeradataDialect_Mode.Descriptor instead.

func (TeradataDialect_Mode) Number

func (x TeradataDialect_Mode) Number() protoreflect.EnumNumber

func (TeradataDialect_Mode) String

func (x TeradataDialect_Mode) String() string

func (TeradataDialect_Mode) Type

func (TeradataDialect_Mode) Type() protoreflect.EnumType

TimeInterval

type TimeInterval struct {

	// Optional. The beginning of the time interval.  The default value
	// for the start time is the end time. The start time must not be
	// later than the end time.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Required. The end of the time interval.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

A time interval extending just after a start time through an end time. If the start time is the same as the end time, then the interval represents a single point in time.

func (*TimeInterval) Descriptor

func (*TimeInterval) Descriptor() ([]byte, []int)

Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.

func (*TimeInterval) GetEndTime

func (x *TimeInterval) GetEndTime() *timestamppb.Timestamp

func (*TimeInterval) GetStartTime

func (x *TimeInterval) GetStartTime() *timestamppb.Timestamp

func (*TimeInterval) ProtoMessage

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) ProtoReflect

func (x *TimeInterval) ProtoReflect() protoreflect.Message

func (*TimeInterval) Reset

func (x *TimeInterval) Reset()

func (*TimeInterval) String

func (x *TimeInterval) String() string

TimeSeries

type TimeSeries struct {

	// Required. The name of the metric.
	//
	// If the metric is not known by the service yet, it will be auto-created.
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// Required. The value type of the time series.
	ValueType metric.MetricDescriptor_ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=google.api.MetricDescriptor_ValueType" json:"value_type,omitempty"`
	// Optional. The metric kind of the time series.
	//
	// If present, it must be the same as the metric kind of the associated
	// metric. If the associated metric's descriptor must be auto-created, then
	// this field specifies the metric kind of the new descriptor and must be
	// either `GAUGE` (the default) or `CUMULATIVE`.
	MetricKind metric.MetricDescriptor_MetricKind `protobuf:"varint,3,opt,name=metric_kind,json=metricKind,proto3,enum=google.api.MetricDescriptor_MetricKind" json:"metric_kind,omitempty"`
	// Required. The data points of this time series. When listing time series,
	// points are returned in reverse time order.
	//
	// When creating a time series, this field must contain exactly one point and
	// the point's type must be the same as the value type of the associated
	// metric. If the associated metric's descriptor must be auto-created, then
	// the value type of the descriptor is determined by the point's type, which
	// must be `BOOL`, `INT64`, `DOUBLE`, or `DISTRIBUTION`.
	Points []*Point `protobuf:"bytes,4,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

The metrics object for a SubTask.

func (*TimeSeries) Descriptor

func (*TimeSeries) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetMetric

func (x *TimeSeries) GetMetric() string

func (*TimeSeries) GetMetricKind

func (x *TimeSeries) GetMetricKind() metric.MetricDescriptor_MetricKind

func (*TimeSeries) GetPoints

func (x *TimeSeries) GetPoints() []*Point

func (*TimeSeries) GetValueType

func (x *TimeSeries) GetValueType() metric.MetricDescriptor_ValueType

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect

func (x *TimeSeries) ProtoReflect() protoreflect.Message

func (*TimeSeries) Reset

func (x *TimeSeries) Reset()

func (*TimeSeries) String

func (x *TimeSeries) String() string

TranslationConfigDetails

type TranslationConfigDetails struct {

	// The chosen path where the source for input files will be found.
	//
	// Types that are valid to be assigned to SourceLocation:
	//
	//	*TranslationConfigDetails_GcsSourcePath
	SourceLocation isTranslationConfigDetails_SourceLocation `protobuf_oneof:"source_location"`
	// The chosen path where the destination for output files will be found.
	//
	// Types that are valid to be assigned to TargetLocation:
	//
	//	*TranslationConfigDetails_GcsTargetPath
	TargetLocation isTranslationConfigDetails_TargetLocation `protobuf_oneof:"target_location"`
	// The mapping of full SQL object names from their current state to the
	// desired output.
	//
	// Types that are valid to be assigned to OutputNameMapping:
	//
	//	*TranslationConfigDetails_NameMappingList
	OutputNameMapping isTranslationConfigDetails_OutputNameMapping `protobuf_oneof:"output_name_mapping"`
	// The dialect of the input files.
	SourceDialect *Dialect `protobuf:"bytes,3,opt,name=source_dialect,json=sourceDialect,proto3" json:"source_dialect,omitempty"`
	// The target dialect for the engine to translate the input to.
	TargetDialect *Dialect `protobuf:"bytes,4,opt,name=target_dialect,json=targetDialect,proto3" json:"target_dialect,omitempty"`
	// The default source environment values for the translation.
	SourceEnv *SourceEnv `protobuf:"bytes,6,opt,name=source_env,json=sourceEnv,proto3" json:"source_env,omitempty"`
	// The indicator to show translation request initiator.
	RequestSource string `protobuf:"bytes,8,opt,name=request_source,json=requestSource,proto3" json:"request_source,omitempty"`
	// The types of output to generate, e.g. sql, metadata etc. If not specified,
	// a default set of targets will be generated. Some additional target types
	// may be slower to generate. See the documentation for the set of available
	// target types.
	TargetTypes []string `protobuf:"bytes,9,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`
	// contains filtered or unexported fields
}

The translation config to capture necessary settings for a translation task and subtask.

func (*TranslationConfigDetails) Descriptor

func (*TranslationConfigDetails) Descriptor() ([]byte, []int)

Deprecated: Use TranslationConfigDetails.ProtoReflect.Descriptor instead.

func (*TranslationConfigDetails) GetGcsSourcePath

func (x *TranslationConfigDetails) GetGcsSourcePath() string

func (*TranslationConfigDetails) GetGcsTargetPath

func (x *TranslationConfigDetails) GetGcsTargetPath() string

func (*TranslationConfigDetails) GetNameMappingList

func (x *TranslationConfigDetails) GetNameMappingList() *ObjectNameMappingList

func (*TranslationConfigDetails) GetOutputNameMapping

func (x *TranslationConfigDetails) GetOutputNameMapping() isTranslationConfigDetails_OutputNameMapping

func (*TranslationConfigDetails) GetRequestSource

func (x *TranslationConfigDetails) GetRequestSource() string

func (*TranslationConfigDetails) GetSourceDialect

func (x *TranslationConfigDetails) GetSourceDialect() *Dialect

func (*TranslationConfigDetails) GetSourceEnv

func (x *TranslationConfigDetails) GetSourceEnv() *SourceEnv

func (*TranslationConfigDetails) GetSourceLocation

func (x *TranslationConfigDetails) GetSourceLocation() isTranslationConfigDetails_SourceLocation

func (*TranslationConfigDetails) GetTargetDialect

func (x *TranslationConfigDetails) GetTargetDialect() *Dialect

func (*TranslationConfigDetails) GetTargetLocation

func (x *TranslationConfigDetails) GetTargetLocation() isTranslationConfigDetails_TargetLocation

func (*TranslationConfigDetails) GetTargetTypes

func (x *TranslationConfigDetails) GetTargetTypes() []string

func (*TranslationConfigDetails) ProtoMessage

func (*TranslationConfigDetails) ProtoMessage()

func (*TranslationConfigDetails) ProtoReflect

func (x *TranslationConfigDetails) ProtoReflect() protoreflect.Message

func (*TranslationConfigDetails) Reset

func (x *TranslationConfigDetails) Reset()

func (*TranslationConfigDetails) String

func (x *TranslationConfigDetails) String() string

TranslationConfigDetails_GcsSourcePath

type TranslationConfigDetails_GcsSourcePath struct {
	// The Cloud Storage path for a directory of files to translate in a task.
	GcsSourcePath string `protobuf:"bytes,1,opt,name=gcs_source_path,json=gcsSourcePath,proto3,oneof"`
}

TranslationConfigDetails_GcsTargetPath

type TranslationConfigDetails_GcsTargetPath struct {
	// The Cloud Storage path to write back the corresponding input files to.
	GcsTargetPath string `protobuf:"bytes,2,opt,name=gcs_target_path,json=gcsTargetPath,proto3,oneof"`
}

TranslationConfigDetails_NameMappingList

type TranslationConfigDetails_NameMappingList struct {
	// The mapping of objects to their desired output names in list form.
	NameMappingList *ObjectNameMappingList `protobuf:"bytes,5,opt,name=name_mapping_list,json=nameMappingList,proto3,oneof"`
}

TranslationDetails

type TranslationDetails struct {

	// The mapping from source to target SQL.
	SourceTargetMapping []*SourceTargetMapping `protobuf:"bytes,1,rep,name=source_target_mapping,json=sourceTargetMapping,proto3" json:"source_target_mapping,omitempty"`
	// The base URI for all writes to persistent storage.
	TargetBaseUri string `protobuf:"bytes,2,opt,name=target_base_uri,json=targetBaseUri,proto3" json:"target_base_uri,omitempty"`
	// The default source environment values for the translation.
	SourceEnvironment *SourceEnvironment `protobuf:"bytes,3,opt,name=source_environment,json=sourceEnvironment,proto3" json:"source_environment,omitempty"`
	// The list of literal targets that will be directly returned to the response.
	// Each entry consists of the constructed path, EXCLUDING the base path. Not
	// providing a target_base_uri will prevent writing to persistent storage.
	TargetReturnLiterals []string `protobuf:"bytes,4,rep,name=target_return_literals,json=targetReturnLiterals,proto3" json:"target_return_literals,omitempty"`
	// The types of output to generate, e.g. sql, metadata,
	// lineage_from_sql_scripts, etc. If not specified, a default set of
	// targets will be generated. Some additional target types may be slower to
	// generate. See the documentation for the set of available target types.
	TargetTypes []string `protobuf:"bytes,5,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`
	// The configuration for the suggestion if requested as a target type.
	SuggestionConfig *SuggestionConfig `protobuf:"bytes,6,opt,name=suggestion_config,json=suggestionConfig,proto3" json:"suggestion_config,omitempty"`
	// contains filtered or unexported fields
}

The translation details to capture the necessary settings for a translation job.

func (*TranslationDetails) Descriptor

func (*TranslationDetails) Descriptor() ([]byte, []int)

Deprecated: Use TranslationDetails.ProtoReflect.Descriptor instead.

func (*TranslationDetails) GetSourceEnvironment

func (x *TranslationDetails) GetSourceEnvironment() *SourceEnvironment

func (*TranslationDetails) GetSourceTargetMapping

func (x *TranslationDetails) GetSourceTargetMapping() []*SourceTargetMapping

func (*TranslationDetails) GetSuggestionConfig

func (x *TranslationDetails) GetSuggestionConfig() *SuggestionConfig

func (*TranslationDetails) GetTargetBaseUri

func (x *TranslationDetails) GetTargetBaseUri() string

func (*TranslationDetails) GetTargetReturnLiterals

func (x *TranslationDetails) GetTargetReturnLiterals() []string

func (*TranslationDetails) GetTargetTypes

func (x *TranslationDetails) GetTargetTypes() []string

func (*TranslationDetails) ProtoMessage

func (*TranslationDetails) ProtoMessage()

func (*TranslationDetails) ProtoReflect

func (x *TranslationDetails) ProtoReflect() protoreflect.Message

func (*TranslationDetails) Reset

func (x *TranslationDetails) Reset()

func (*TranslationDetails) String

func (x *TranslationDetails) String() string

TranslationReportRecord

type TranslationReportRecord struct {

	// Severity of the translation record.
	Severity TranslationReportRecord_Severity `protobuf:"varint,1,opt,name=severity,proto3,enum=google.cloud.bigquery.migration.v2.TranslationReportRecord_Severity" json:"severity,omitempty"`
	// Specifies the row from the source text where the error occurred (0 based).
	// Example: 2
	ScriptLine int32 `protobuf:"varint,2,opt,name=script_line,json=scriptLine,proto3" json:"script_line,omitempty"`
	// Specifies the column from the source texts where the error occurred. (0
	// based) example: 6
	ScriptColumn int32 `protobuf:"varint,3,opt,name=script_column,json=scriptColumn,proto3" json:"script_column,omitempty"`
	// Category of the error/warning. Example: SyntaxError
	Category string `protobuf:"bytes,4,opt,name=category,proto3" json:"category,omitempty"`
	// Detailed message of the record.
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Details about a record.

func (*TranslationReportRecord) Descriptor

func (*TranslationReportRecord) Descriptor() ([]byte, []int)

Deprecated: Use TranslationReportRecord.ProtoReflect.Descriptor instead.

func (*TranslationReportRecord) GetCategory

func (x *TranslationReportRecord) GetCategory() string

func (*TranslationReportRecord) GetMessage

func (x *TranslationReportRecord) GetMessage() string

func (*TranslationReportRecord) GetScriptColumn

func (x *TranslationReportRecord) GetScriptColumn() int32

func (*TranslationReportRecord) GetScriptLine

func (x *TranslationReportRecord) GetScriptLine() int32

func (*TranslationReportRecord) GetSeverity

func (x *TranslationReportRecord) GetSeverity() TranslationReportRecord_Severity

func (*TranslationReportRecord) ProtoMessage

func (*TranslationReportRecord) ProtoMessage()

func (*TranslationReportRecord) ProtoReflect

func (x *TranslationReportRecord) ProtoReflect() protoreflect.Message

func (*TranslationReportRecord) Reset

func (x *TranslationReportRecord) Reset()

func (*TranslationReportRecord) String

func (x *TranslationReportRecord) String() string

TranslationReportRecord_Severity

type TranslationReportRecord_Severity int32

The severity type of the record.

TranslationReportRecord_SEVERITY_UNSPECIFIED, TranslationReportRecord_INFO, TranslationReportRecord_WARNING, TranslationReportRecord_ERROR

const (
	// SeverityType not specified.
	TranslationReportRecord_SEVERITY_UNSPECIFIED TranslationReportRecord_Severity = 0
	// INFO type.
	TranslationReportRecord_INFO TranslationReportRecord_Severity = 1
	// WARNING type. The translated query may still provide useful information
	// if all the report records are WARNING.
	TranslationReportRecord_WARNING TranslationReportRecord_Severity = 2
	// ERROR type. Translation failed.
	TranslationReportRecord_ERROR TranslationReportRecord_Severity = 3
)

func (TranslationReportRecord_Severity) Descriptor

func (TranslationReportRecord_Severity) Descriptor() protoreflect.EnumDescriptor

func (TranslationReportRecord_Severity) Enum

func (x TranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity

func (TranslationReportRecord_Severity) EnumDescriptor

func (TranslationReportRecord_Severity) EnumDescriptor() ([]byte, []int)

Deprecated: Use TranslationReportRecord_Severity.Descriptor instead.

func (TranslationReportRecord_Severity) Number

func (x TranslationReportRecord_Severity) Number() protoreflect.EnumNumber

func (TranslationReportRecord_Severity) String

func (x TranslationReportRecord_Severity) String() string

func (TranslationReportRecord_Severity) Type

func (TranslationReportRecord_Severity) Type() protoreflect.EnumType

TranslationTaskResult

type TranslationTaskResult struct {

	// The list of the translated literals.
	TranslatedLiterals []*Literal `protobuf:"bytes,1,rep,name=translated_literals,json=translatedLiterals,proto3" json:"translated_literals,omitempty"`
	// The records from the aggregate CSV report for a migration workflow.
	ReportLogMessages []*GcsReportLogMessage `protobuf:"bytes,2,rep,name=report_log_messages,json=reportLogMessages,proto3" json:"report_log_messages,omitempty"`
	// The Cloud Console URI for the migration workflow.
	ConsoleUri string `protobuf:"bytes,3,opt,name=console_uri,json=consoleUri,proto3" json:"console_uri,omitempty"`
	// contains filtered or unexported fields
}

Translation specific result details from the migration task.

func (*TranslationTaskResult) Descriptor

func (*TranslationTaskResult) Descriptor() ([]byte, []int)

Deprecated: Use TranslationTaskResult.ProtoReflect.Descriptor instead.

func (*TranslationTaskResult) GetConsoleUri

func (x *TranslationTaskResult) GetConsoleUri() string

func (*TranslationTaskResult) GetReportLogMessages

func (x *TranslationTaskResult) GetReportLogMessages() []*GcsReportLogMessage

func (*TranslationTaskResult) GetTranslatedLiterals

func (x *TranslationTaskResult) GetTranslatedLiterals() []*Literal

func (*TranslationTaskResult) ProtoMessage

func (*TranslationTaskResult) ProtoMessage()

func (*TranslationTaskResult) ProtoReflect

func (x *TranslationTaskResult) ProtoReflect() protoreflect.Message

func (*TranslationTaskResult) Reset

func (x *TranslationTaskResult) Reset()

func (*TranslationTaskResult) String

func (x *TranslationTaskResult) String() string

TypedValue

type TypedValue struct {

	// The typed value field.
	//
	// Types that are valid to be assigned to Value:
	//
	//	*TypedValue_BoolValue
	//	*TypedValue_Int64Value
	//	*TypedValue_DoubleValue
	//	*TypedValue_StringValue
	//	*TypedValue_DistributionValue
	Value isTypedValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

A single strongly-typed value.

func (*TypedValue) Descriptor

func (*TypedValue) Descriptor() ([]byte, []int)

Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.

func (*TypedValue) GetBoolValue

func (x *TypedValue) GetBoolValue() bool

func (*TypedValue) GetDistributionValue

func (x *TypedValue) GetDistributionValue() *distribution.Distribution

func (*TypedValue) GetDoubleValue

func (x *TypedValue) GetDoubleValue() float64

func (*TypedValue) GetInt64Value

func (x *TypedValue) GetInt64Value() int64

func (*TypedValue) GetStringValue

func (x *TypedValue) GetStringValue() string

func (*TypedValue) GetValue

func (x *TypedValue) GetValue() isTypedValue_Value

func (*TypedValue) ProtoMessage

func (*TypedValue) ProtoMessage()

func (*TypedValue) ProtoReflect

func (x *TypedValue) ProtoReflect() protoreflect.Message

func (*TypedValue) Reset

func (x *TypedValue) Reset()

func (*TypedValue) String

func (x *TypedValue) String() string

TypedValue_BoolValue

type TypedValue_BoolValue struct {
	// A Boolean value: `true` or `false`.
	BoolValue bool `protobuf:"varint,1,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

TypedValue_DistributionValue

type TypedValue_DistributionValue struct {
	// A distribution value.
	DistributionValue *distribution.Distribution `protobuf:"bytes,5,opt,name=distribution_value,json=distributionValue,proto3,oneof"`
}

TypedValue_DoubleValue

type TypedValue_DoubleValue struct {
	// A 64-bit double-precision floating-point number. Its magnitude
	// is approximately `+/-10^(+/-300)` and it has 16 significant digits of
	// precision.
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

TypedValue_Int64Value

type TypedValue_Int64Value struct {
	// A 64-bit integer. Its range is approximately `+/-9.2x10^18`.
	Int64Value int64 `protobuf:"varint,2,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

TypedValue_StringValue

type TypedValue_StringValue struct {
	// A variable-length string value.
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}

UnimplementedMigrationServiceServer

type UnimplementedMigrationServiceServer struct {
}

UnimplementedMigrationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedMigrationServiceServer) CreateMigrationWorkflow

func (UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)

func (UnimplementedMigrationServiceServer) DeleteMigrationWorkflow

func (UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)

func (UnimplementedMigrationServiceServer) GetMigrationSubtask

func (UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)

func (UnimplementedMigrationServiceServer) GetMigrationWorkflow

func (UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)

func (UnimplementedMigrationServiceServer) ListMigrationSubtasks

func (UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)

func (UnimplementedMigrationServiceServer) ListMigrationWorkflows

func (UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)

func (UnimplementedMigrationServiceServer) StartMigrationWorkflow

func (UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)

UnsafeMigrationServiceServer

type UnsafeMigrationServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeMigrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MigrationServiceServer will result in compilation errors.

VerticaDialect

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

The dialect definition for Vertica.

func (*VerticaDialect) Descriptor

func (*VerticaDialect) Descriptor() ([]byte, []int)

Deprecated: Use VerticaDialect.ProtoReflect.Descriptor instead.

func (*VerticaDialect) ProtoMessage

func (*VerticaDialect) ProtoMessage()

func (*VerticaDialect) ProtoReflect

func (x *VerticaDialect) ProtoReflect() protoreflect.Message

func (*VerticaDialect) Reset

func (x *VerticaDialect) Reset()

func (*VerticaDialect) String

func (x *VerticaDialect) String() string