migrationpb

package
v1.63.0 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2024 License: Apache-2.0 Imports: 15 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var File_google_cloud_bigquery_migration_v2_migration_entities_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_migration_error_details_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_migration_metrics_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_migration_service_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_translation_config_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_translation_details_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_translation_suggestion_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2_translation_usability_proto protoreflect.FileDescriptor

Functions

func RegisterMigrationServiceServer 

func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)

Types

type AzureSynapseDialect 

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

The dialect definition for Azure Synapse.

func (*AzureSynapseDialect) Descriptor deprecated 

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

type BigQueryDialect 

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

The dialect definition for BigQuery.

func (*BigQueryDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type DB2Dialect added in v1.63.0 

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

The dialect definition for DB2.

func (*DB2Dialect) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use DB2Dialect.ProtoReflect.Descriptor instead.

func (*DB2Dialect) ProtoMessage added in v1.63.0 

func (*DB2Dialect) ProtoMessage()

func (*DB2Dialect) ProtoReflect added in v1.63.0 

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

func (*DB2Dialect) Reset added in v1.63.0 

func (x *DB2Dialect) Reset()

func (*DB2Dialect) String added in v1.63.0 

func (x *DB2Dialect) String() string

type 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 deprecated 

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

type Dialect 

type Dialect struct {

	// The possible dialect options that this message represents.
	//
	// Types that are assignable 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 deprecated 

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 added in v1.63.0 

func (x *Dialect) GetDb2Dialect() *DB2Dialect

func (*Dialect) GetDialectValue 

func (m *Dialect) GetDialectValue() isDialect_DialectValue

func (*Dialect) GetGreenplumDialect added in v1.63.0 

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 added in v1.63.0 

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

type Dialect_AzureSynapseDialect 

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

type Dialect_BigqueryDialect 

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

type Dialect_Db2Dialect added in v1.63.0 

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

type Dialect_GreenplumDialect added in v1.63.0 

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

type Dialect_HiveqlDialect 

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

type Dialect_MysqlDialect 

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

type Dialect_NetezzaDialect 

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

type Dialect_OracleDialect 

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

type Dialect_PostgresqlDialect 

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

type Dialect_PrestoDialect 

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

type Dialect_RedshiftDialect 

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

type Dialect_SnowflakeDialect 

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

type Dialect_SparksqlDialect 

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

type Dialect_SqlServerDialect 

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

type Dialect_SqliteDialect added in v1.63.0 

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

type Dialect_TeradataDialect 

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

type Dialect_VerticaDialect 

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

type 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 deprecated 

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

type 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 deprecated 

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

type GcsReportLogMessage added in v1.63.0 

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 deprecated added in v1.63.0 

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

Deprecated: Use GcsReportLogMessage.ProtoReflect.Descriptor instead.

func (*GcsReportLogMessage) GetAction added in v1.63.0 

func (x *GcsReportLogMessage) GetAction() string

func (*GcsReportLogMessage) GetCategory added in v1.63.0 

func (x *GcsReportLogMessage) GetCategory() string

func (*GcsReportLogMessage) GetEffect added in v1.63.0 

func (x *GcsReportLogMessage) GetEffect() string

func (*GcsReportLogMessage) GetFilePath added in v1.63.0 

func (x *GcsReportLogMessage) GetFilePath() string

func (*GcsReportLogMessage) GetFilename added in v1.63.0 

func (x *GcsReportLogMessage) GetFilename() string

func (*GcsReportLogMessage) GetMessage added in v1.63.0 

func (x *GcsReportLogMessage) GetMessage() string

func (*GcsReportLogMessage) GetObjectName added in v1.63.0 

func (x *GcsReportLogMessage) GetObjectName() string

func (*GcsReportLogMessage) GetScriptContext added in v1.63.0 

func (x *GcsReportLogMessage) GetScriptContext() string

func (*GcsReportLogMessage) GetSeverity added in v1.63.0 

func (x *GcsReportLogMessage) GetSeverity() string

func (*GcsReportLogMessage) GetSourceScriptColumn added in v1.63.0 

func (x *GcsReportLogMessage) GetSourceScriptColumn() int32

func (*GcsReportLogMessage) GetSourceScriptLine added in v1.63.0 

func (x *GcsReportLogMessage) GetSourceScriptLine() int32

func (*GcsReportLogMessage) ProtoMessage added in v1.63.0 

func (*GcsReportLogMessage) ProtoMessage()

func (*GcsReportLogMessage) ProtoReflect added in v1.63.0 

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

func (*GcsReportLogMessage) Reset added in v1.63.0 

func (x *GcsReportLogMessage) Reset()

func (*GcsReportLogMessage) String added in v1.63.0 

func (x *GcsReportLogMessage) String() string

type 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 deprecated 

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

type 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 deprecated 

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

type GreenplumDialect added in v1.63.0 

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

The dialect definition for Greenplum.

func (*GreenplumDialect) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use GreenplumDialect.ProtoReflect.Descriptor instead.

func (*GreenplumDialect) ProtoMessage added in v1.63.0 

func (*GreenplumDialect) ProtoMessage()

func (*GreenplumDialect) ProtoReflect added in v1.63.0 

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

func (*GreenplumDialect) Reset added in v1.63.0 

func (x *GreenplumDialect) Reset()

func (*GreenplumDialect) String added in v1.63.0 

func (x *GreenplumDialect) String() string

type HiveQLDialect 

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

The dialect definition for HiveQL.

func (*HiveQLDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type Literal added in v1.63.0 

type Literal struct {

	// The literal SQL contents.
	//
	// Types that are assignable 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 deprecated added in v1.63.0 

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

Deprecated: Use Literal.ProtoReflect.Descriptor instead.

func (*Literal) GetLiteralBytes added in v1.63.0 

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

func (*Literal) GetLiteralData added in v1.63.0 

func (m *Literal) GetLiteralData() isLiteral_LiteralData

func (*Literal) GetLiteralString added in v1.63.0 

func (x *Literal) GetLiteralString() string

func (*Literal) GetRelativePath added in v1.63.0 

func (x *Literal) GetRelativePath() string

func (*Literal) ProtoMessage added in v1.63.0 

func (*Literal) ProtoMessage()

func (*Literal) ProtoReflect added in v1.63.0 

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

func (*Literal) Reset added in v1.63.0 

func (x *Literal) Reset()

func (*Literal) String added in v1.63.0 

func (x *Literal) String() string

type Literal_LiteralBytes added in v1.63.0 

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

type Literal_LiteralString added in v1.63.0 

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

type 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMigrationServiceClient 

func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

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

type 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 `` /* 127-byte string literal not displayed */
	// 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"`
	// 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"`
	// Time when the subtask was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// 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"`
	// 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 deprecated 

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

type MigrationSubtask_State 

type MigrationSubtask_State int32

Possible states of a migration subtask. 

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 deprecated 

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

type MigrationTask 

type MigrationTask struct {

	// The details of the task.
	//
	// Types that are assignable to TaskDetails:
	//
	//	*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:
	// Translation_Teradata2BQ, Translation_Redshift2BQ, Translation_Bteq2BQ,
	// Translation_Oracle2BQ, Translation_HiveQL2BQ, Translation_SparkSQL2BQ,
	// Translation_Snowflake2BQ, Translation_Netezza2BQ,
	// Translation_AzureSynapse2BQ, Translation_Vertica2BQ,
	// Translation_SQLServer2BQ, Translation_Presto2BQ, Translation_MySQL2BQ,
	// Translation_Postgresql2BQ, Translation_SQLite2BQ, Translation_Greenplum2BQ.
	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"`
	// Time when the task was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// 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"`
	// 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"`
	// 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"`
	// Count of all the processing errors in this task and its subtasks.
	TotalProcessingErrorCount int32 `` /* 142-byte string literal not displayed */
	// Count of all the resource errors in this task and its subtasks.
	TotalResourceErrorCount int32 `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*MigrationTask) Descriptor deprecated 

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

Deprecated: Use MigrationTask.ProtoReflect.Descriptor instead.

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 added in v1.63.0 

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

func (*MigrationTask) GetProcessingError 

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

func (*MigrationTask) GetResourceErrorCount added in v1.63.0 

func (x *MigrationTask) GetResourceErrorCount() int32

func (*MigrationTask) GetResourceErrorDetails added in v1.63.0 

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

func (*MigrationTask) GetState 

func (x *MigrationTask) GetState() MigrationTask_State

func (*MigrationTask) GetTaskDetails 

func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails

func (*MigrationTask) GetTaskResult added in v1.63.0 

func (x *MigrationTask) GetTaskResult() *MigrationTaskResult

func (*MigrationTask) GetTotalProcessingErrorCount added in v1.63.0 

func (x *MigrationTask) GetTotalProcessingErrorCount() int32

func (*MigrationTask) GetTotalResourceErrorCount added in v1.63.0 

func (x *MigrationTask) GetTotalResourceErrorCount() int32

func (*MigrationTask) GetTranslationConfigDetails 

func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails

func (*MigrationTask) GetTranslationDetails added in v1.63.0 

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

type MigrationTaskResult added in v1.63.0 

type MigrationTaskResult struct {

	// Details specific to the task type.
	//
	// Types that are assignable to Details:
	//
	//	*MigrationTaskResult_TranslationTaskResult
	Details isMigrationTaskResult_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

The migration task result.

func (*MigrationTaskResult) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use MigrationTaskResult.ProtoReflect.Descriptor instead.

func (*MigrationTaskResult) GetDetails added in v1.63.0 

func (m *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details

func (*MigrationTaskResult) GetTranslationTaskResult added in v1.63.0 

func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult

func (*MigrationTaskResult) ProtoMessage added in v1.63.0 

func (*MigrationTaskResult) ProtoMessage()

func (*MigrationTaskResult) ProtoReflect added in v1.63.0 

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

func (*MigrationTaskResult) Reset added in v1.63.0 

func (x *MigrationTaskResult) Reset()

func (*MigrationTaskResult) String added in v1.63.0 

func (x *MigrationTaskResult) String() string

type MigrationTaskResult_TranslationTaskResult added in v1.63.0 

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

type MigrationTask_State 

type MigrationTask_State int32

Possible states of a migration task. 

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
	// Tha 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 deprecated 

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

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

type MigrationTask_TranslationDetails added in v1.63.0 

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

type 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 `` /* 151-byte string literal not displayed */
	// Output only. That status of the workflow.
	State MigrationWorkflow_State `` /* 128-byte string literal not displayed */
	// Time when the workflow was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// 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 deprecated 

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

type MigrationWorkflow_State 

type MigrationWorkflow_State int32

Possible migration workflow states. 

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 deprecated 

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

type MySQLDialect 

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

The dialect definition for MySQL.

func (*MySQLDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type NameMappingKey_Type 

type NameMappingKey_Type int32

The type of the object that is being mapped. 

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 deprecated 

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

type 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 deprecated 

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

type NetezzaDialect 

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

The dialect definition for Netezza.

func (*NetezzaDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type 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 deprecated 

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

type OracleDialect 

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

The dialect definition for Oracle.

func (*OracleDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type PostgresqlDialect 

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

The dialect definition for Postgresql.

func (*PostgresqlDialect) Descriptor deprecated 

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

type PrestoDialect 

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

The dialect definition for Presto.

func (*PrestoDialect) Descriptor deprecated 

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

type RedshiftDialect 

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

The dialect definition for Redshift.

func (*RedshiftDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type SQLServerDialect 

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

The dialect definition for SQL Server.

func (*SQLServerDialect) Descriptor deprecated 

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

type SQLiteDialect added in v1.63.0 

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

The dialect definition for SQLite.

func (*SQLiteDialect) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use SQLiteDialect.ProtoReflect.Descriptor instead.

func (*SQLiteDialect) ProtoMessage added in v1.63.0 

func (*SQLiteDialect) ProtoMessage()

func (*SQLiteDialect) ProtoReflect added in v1.63.0 

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

func (*SQLiteDialect) Reset added in v1.63.0 

func (x *SQLiteDialect) Reset()

func (*SQLiteDialect) String added in v1.63.0 

func (x *SQLiteDialect) String() string

type SnowflakeDialect 

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

The dialect definition for Snowflake.

func (*SnowflakeDialect) Descriptor deprecated 

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

type 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 deprecated 

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

Deprecated: Use SourceEnv.ProtoReflect.Descriptor instead.

func (*SourceEnv) GetDefaultDatabase 

func (x *SourceEnv) GetDefaultDatabase() string

func (*SourceEnv) GetMetadataStoreDataset added in v1.63.0 

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

type SourceEnvironment added in v1.63.0 

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 deprecated added in v1.63.0 

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

Deprecated: Use SourceEnvironment.ProtoReflect.Descriptor instead.

func (*SourceEnvironment) GetDefaultDatabase added in v1.63.0 

func (x *SourceEnvironment) GetDefaultDatabase() string

func (*SourceEnvironment) GetMetadataStoreDataset added in v1.63.0 

func (x *SourceEnvironment) GetMetadataStoreDataset() string

func (*SourceEnvironment) GetSchemaSearchPath added in v1.63.0 

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

func (*SourceEnvironment) ProtoMessage added in v1.63.0 

func (*SourceEnvironment) ProtoMessage()

func (*SourceEnvironment) ProtoReflect added in v1.63.0 

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

func (*SourceEnvironment) Reset added in v1.63.0 

func (x *SourceEnvironment) Reset()

func (*SourceEnvironment) String added in v1.63.0 

func (x *SourceEnvironment) String() string

type SourceSpec added in v1.63.0 

type SourceSpec struct {

	// The specific source SQL.
	//
	// Types that are assignable to Source:
	//
	//	*SourceSpec_BaseUri
	//	*SourceSpec_Literal
	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 deprecated added in v1.63.0 

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

Deprecated: Use SourceSpec.ProtoReflect.Descriptor instead.

func (*SourceSpec) GetBaseUri added in v1.63.0 

func (x *SourceSpec) GetBaseUri() string

func (*SourceSpec) GetEncoding added in v1.63.0 

func (x *SourceSpec) GetEncoding() string

func (*SourceSpec) GetLiteral added in v1.63.0 

func (x *SourceSpec) GetLiteral() *Literal

func (*SourceSpec) GetSource added in v1.63.0 

func (m *SourceSpec) GetSource() isSourceSpec_Source

func (*SourceSpec) ProtoMessage added in v1.63.0 

func (*SourceSpec) ProtoMessage()

func (*SourceSpec) ProtoReflect added in v1.63.0 

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

func (*SourceSpec) Reset added in v1.63.0 

func (x *SourceSpec) Reset()

func (*SourceSpec) String added in v1.63.0 

func (x *SourceSpec) String() string

type SourceSpec_BaseUri added in v1.63.0 

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

type SourceSpec_Literal added in v1.63.0 

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

type SourceTargetMapping added in v1.63.0 

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 deprecated added in v1.63.0 

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

Deprecated: Use SourceTargetMapping.ProtoReflect.Descriptor instead.

func (*SourceTargetMapping) GetSourceSpec added in v1.63.0 

func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec

func (*SourceTargetMapping) GetTargetSpec added in v1.63.0 

func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec

func (*SourceTargetMapping) ProtoMessage added in v1.63.0 

func (*SourceTargetMapping) ProtoMessage()

func (*SourceTargetMapping) ProtoReflect added in v1.63.0 

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

func (*SourceTargetMapping) Reset added in v1.63.0 

func (x *SourceTargetMapping) Reset()

func (*SourceTargetMapping) String added in v1.63.0 

func (x *SourceTargetMapping) String() string

type SparkSQLDialect 

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

The dialect definition for SparkSQL.

func (*SparkSQLDialect) Descriptor deprecated 

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

type 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 deprecated 

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

type TargetSpec added in v1.63.0 

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 deprecated added in v1.63.0 

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

Deprecated: Use TargetSpec.ProtoReflect.Descriptor instead.

func (*TargetSpec) GetRelativePath added in v1.63.0 

func (x *TargetSpec) GetRelativePath() string

func (*TargetSpec) ProtoMessage added in v1.63.0 

func (*TargetSpec) ProtoMessage()

func (*TargetSpec) ProtoReflect added in v1.63.0 

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

func (*TargetSpec) Reset added in v1.63.0 

func (x *TargetSpec) Reset()

func (*TargetSpec) String added in v1.63.0 

func (x *TargetSpec) String() string

type 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 deprecated 

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

type TeradataDialect_Mode 

type TeradataDialect_Mode int32

The sub-dialect options for Teradata. 

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 deprecated 

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

type 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 deprecated 

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

type 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 `` /* 132-byte string literal not displayed */
	// 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 `` /* 136-byte string literal not displayed */
	// 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 deprecated 

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

type TranslationConfigDetails 

type TranslationConfigDetails struct {

	// The chosen path where the source for input files will be found.
	//
	// Types that are assignable 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 assignable 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 assignable 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 deprecated 

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 (m *TranslationConfigDetails) GetOutputNameMapping() isTranslationConfigDetails_OutputNameMapping

func (*TranslationConfigDetails) GetRequestSource added in v1.50.0 

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 (m *TranslationConfigDetails) GetSourceLocation() isTranslationConfigDetails_SourceLocation

func (*TranslationConfigDetails) GetTargetDialect 

func (x *TranslationConfigDetails) GetTargetDialect() *Dialect

func (*TranslationConfigDetails) GetTargetLocation 

func (m *TranslationConfigDetails) GetTargetLocation() isTranslationConfigDetails_TargetLocation

func (*TranslationConfigDetails) GetTargetTypes added in v1.63.0 

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

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

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

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

type TranslationDetails added in v1.63.0 

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"`
	// contains filtered or unexported fields
}

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

func (*TranslationDetails) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use TranslationDetails.ProtoReflect.Descriptor instead.

func (*TranslationDetails) GetSourceEnvironment added in v1.63.0 

func (x *TranslationDetails) GetSourceEnvironment() *SourceEnvironment

func (*TranslationDetails) GetSourceTargetMapping added in v1.63.0 

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

func (*TranslationDetails) GetTargetBaseUri added in v1.63.0 

func (x *TranslationDetails) GetTargetBaseUri() string

func (*TranslationDetails) GetTargetReturnLiterals added in v1.63.0 

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

func (*TranslationDetails) GetTargetTypes added in v1.63.0 

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

func (*TranslationDetails) ProtoMessage added in v1.63.0 

func (*TranslationDetails) ProtoMessage()

func (*TranslationDetails) ProtoReflect added in v1.63.0 

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

func (*TranslationDetails) Reset added in v1.63.0 

func (x *TranslationDetails) Reset()

func (*TranslationDetails) String added in v1.63.0 

func (x *TranslationDetails) String() string

type TranslationReportRecord added in v1.63.0 

type TranslationReportRecord struct {

	// Severity of the translation record.
	Severity TranslationReportRecord_Severity `` /* 143-byte string literal not displayed */
	// 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 deprecated added in v1.63.0 

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

Deprecated: Use TranslationReportRecord.ProtoReflect.Descriptor instead.

func (*TranslationReportRecord) GetCategory added in v1.63.0 

func (x *TranslationReportRecord) GetCategory() string

func (*TranslationReportRecord) GetMessage added in v1.63.0 

func (x *TranslationReportRecord) GetMessage() string

func (*TranslationReportRecord) GetScriptColumn added in v1.63.0 

func (x *TranslationReportRecord) GetScriptColumn() int32

func (*TranslationReportRecord) GetScriptLine added in v1.63.0 

func (x *TranslationReportRecord) GetScriptLine() int32

func (*TranslationReportRecord) GetSeverity added in v1.63.0 

func (x *TranslationReportRecord) GetSeverity() TranslationReportRecord_Severity

func (*TranslationReportRecord) ProtoMessage added in v1.63.0 

func (*TranslationReportRecord) ProtoMessage()

func (*TranslationReportRecord) ProtoReflect added in v1.63.0 

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

func (*TranslationReportRecord) Reset added in v1.63.0 

func (x *TranslationReportRecord) Reset()

func (*TranslationReportRecord) String added in v1.63.0 

func (x *TranslationReportRecord) String() string

type TranslationReportRecord_Severity added in v1.63.0 

type TranslationReportRecord_Severity int32

The severity type of the record. 

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 added in v1.63.0 

func (TranslationReportRecord_Severity) Descriptor() protoreflect.EnumDescriptor

func (TranslationReportRecord_Severity) Enum added in v1.63.0 

func (x TranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity

func (TranslationReportRecord_Severity) EnumDescriptor deprecated added in v1.63.0 

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

Deprecated: Use TranslationReportRecord_Severity.Descriptor instead.

func (TranslationReportRecord_Severity) Number added in v1.63.0 

func (x TranslationReportRecord_Severity) Number() protoreflect.EnumNumber

func (TranslationReportRecord_Severity) String added in v1.63.0 

func (x TranslationReportRecord_Severity) String() string

func (TranslationReportRecord_Severity) Type added in v1.63.0 

func (TranslationReportRecord_Severity) Type() protoreflect.EnumType

type TranslationTaskResult added in v1.63.0 

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"`
	// contains filtered or unexported fields
}

Translation specific result details from the migration task.

func (*TranslationTaskResult) Descriptor deprecated added in v1.63.0 

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

Deprecated: Use TranslationTaskResult.ProtoReflect.Descriptor instead.

func (*TranslationTaskResult) GetReportLogMessages added in v1.63.0 

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

func (*TranslationTaskResult) GetTranslatedLiterals added in v1.63.0 

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

func (*TranslationTaskResult) ProtoMessage added in v1.63.0 

func (*TranslationTaskResult) ProtoMessage()

func (*TranslationTaskResult) ProtoReflect added in v1.63.0 

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

func (*TranslationTaskResult) Reset added in v1.63.0 

func (x *TranslationTaskResult) Reset()

func (*TranslationTaskResult) String added in v1.63.0 

func (x *TranslationTaskResult) String() string

type TypedValue 

type TypedValue struct {

	// The typed value field.
	//
	// Types that are assignable 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 deprecated 

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 (m *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

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

type TypedValue_DistributionValue 

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

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

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

type TypedValue_StringValue 

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

type UnimplementedMigrationServiceServer 

type UnimplementedMigrationServiceServer struct {
}

UnimplementedMigrationServiceServer can 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)

type VerticaDialect 

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

The dialect definition for Vertica.

func (*VerticaDialect) Descriptor deprecated 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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