Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Package cloud.google.com/go/bigquery/migration/apiv2alpha/migrationpb (v1.72.0)

Constants

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

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

SqlTranslationService_TranslateQuery_FullMethodName

const (
	SqlTranslationService_TranslateQuery_FullMethodName = "/google.cloud.bigquery.migration.v2alpha.SqlTranslationService/TranslateQuery"
)

Variables

MigrationWorkflow_State_name, MigrationWorkflow_State_value

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

Enum value maps for MigrationWorkflow_State.

MigrationTask_State_name, MigrationTask_State_value

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

Enum value maps for MigrationTask_State.

MigrationSubtask_State_name, MigrationSubtask_State_value

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

Enum value maps for MigrationSubtask_State.

TranslateQueryRequest_SqlTranslationSourceDialect_name, TranslateQueryRequest_SqlTranslationSourceDialect_value

var (
	TranslateQueryRequest_SqlTranslationSourceDialect_name = map[int32]string{
		0: "SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED",
		1: "TERADATA",
	}
	TranslateQueryRequest_SqlTranslationSourceDialect_value = map[string]int32{
		"SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED": 0,
		"TERADATA": 1,
	}
)

Enum value maps for TranslateQueryRequest_SqlTranslationSourceDialect.

SqlTranslationError_SqlTranslationErrorType_name, SqlTranslationError_SqlTranslationErrorType_value

var (
	SqlTranslationError_SqlTranslationErrorType_name = map[int32]string{
		0: "SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED",
		1: "SQL_PARSE_ERROR",
		2: "UNSUPPORTED_SQL_FUNCTION",
	}
	SqlTranslationError_SqlTranslationErrorType_value = map[string]int32{
		"SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED": 0,
		"SQL_PARSE_ERROR":                        1,
		"UNSUPPORTED_SQL_FUNCTION":               2,
	}
)

Enum value maps for SqlTranslationError_SqlTranslationErrorType.

TranslationTaskDetails_FileEncoding_name, TranslationTaskDetails_FileEncoding_value

var (
	TranslationTaskDetails_FileEncoding_name = map[int32]string{
		0: "FILE_ENCODING_UNSPECIFIED",
		1: "UTF_8",
		2: "ISO_8859_1",
		3: "US_ASCII",
		4: "UTF_16",
		5: "UTF_16LE",
		6: "UTF_16BE",
	}
	TranslationTaskDetails_FileEncoding_value = map[string]int32{
		"FILE_ENCODING_UNSPECIFIED": 0,
		"UTF_8":                     1,
		"ISO_8859_1":                2,
		"US_ASCII":                  3,
		"UTF_16":                    4,
		"UTF_16LE":                  5,
		"UTF_16BE":                  6,
	}
)

Enum value maps for TranslationTaskDetails_FileEncoding.

TranslationTaskDetails_TokenType_name, TranslationTaskDetails_TokenType_value

var (
	TranslationTaskDetails_TokenType_name = map[int32]string{
		0: "TOKEN_TYPE_UNSPECIFIED",
		1: "STRING",
		2: "INT64",
		3: "NUMERIC",
		4: "BOOL",
		5: "FLOAT64",
		6: "DATE",
		7: "TIMESTAMP",
	}
	TranslationTaskDetails_TokenType_value = map[string]int32{
		"TOKEN_TYPE_UNSPECIFIED": 0,
		"STRING":                 1,
		"INT64":                  2,
		"NUMERIC":                3,
		"BOOL":                   4,
		"FLOAT64":                5,
		"DATE":                   6,
		"TIMESTAMP":              7,
	}
)

Enum value maps for TranslationTaskDetails_TokenType.

IdentifierSettings_IdentifierCase_name, IdentifierSettings_IdentifierCase_value

var (
	IdentifierSettings_IdentifierCase_name = map[int32]string{
		0: "IDENTIFIER_CASE_UNSPECIFIED",
		1: "ORIGINAL",
		2: "UPPER",
		3: "LOWER",
	}
	IdentifierSettings_IdentifierCase_value = map[string]int32{
		"IDENTIFIER_CASE_UNSPECIFIED": 0,
		"ORIGINAL":                    1,
		"UPPER":                       2,
		"LOWER":                       3,
	}
)

Enum value maps for IdentifierSettings_IdentifierCase.

IdentifierSettings_IdentifierRewriteMode_name, IdentifierSettings_IdentifierRewriteMode_value

var (
	IdentifierSettings_IdentifierRewriteMode_name = map[int32]string{
		0: "IDENTIFIER_REWRITE_MODE_UNSPECIFIED",
		1: "NONE",
		2: "REWRITE_ALL",
	}
	IdentifierSettings_IdentifierRewriteMode_value = map[string]int32{
		"IDENTIFIER_REWRITE_MODE_UNSPECIFIED": 0,
		"NONE":                                1,
		"REWRITE_ALL":                         2,
	}
)

Enum value maps for IdentifierSettings_IdentifierRewriteMode.

File_google_cloud_bigquery_migration_v2alpha_assessment_task_proto

var File_google_cloud_bigquery_migration_v2alpha_assessment_task_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_migration_entities_proto

var File_google_cloud_bigquery_migration_v2alpha_migration_entities_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto

var File_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto

var File_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_migration_service_proto

var File_google_cloud_bigquery_migration_v2alpha_migration_service_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_translation_service_proto

var File_google_cloud_bigquery_migration_v2alpha_translation_service_proto protoreflect.FileDescriptor

File_google_cloud_bigquery_migration_v2alpha_translation_task_proto

var File_google_cloud_bigquery_migration_v2alpha_translation_task_proto protoreflect.FileDescriptor

MigrationService_ServiceDesc

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

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

SqlTranslationService_ServiceDesc

var SqlTranslationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.bigquery.migration.v2alpha.SqlTranslationService",
	HandlerType: (*SqlTranslationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TranslateQuery",
			Handler:    _SqlTranslationService_TranslateQuery_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/bigquery/migration/v2alpha/translation_service.proto",
}

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

Functions

func RegisterMigrationServiceServer

func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)

func RegisterSqlTranslationServiceServer

func RegisterSqlTranslationServiceServer(s grpc.ServiceRegistrar, srv SqlTranslationServiceServer)

AssessmentOrchestrationResultDetails

type AssessmentOrchestrationResultDetails struct {

	// Optional. The version used for the output table schemas.
	OutputTablesSchemaVersion string `protobuf:"bytes,1,opt,name=output_tables_schema_version,json=outputTablesSchemaVersion,proto3" json:"output_tables_schema_version,omitempty"`
	// contains filtered or unexported fields
}

Details for an assessment task orchestration result.

func (*AssessmentOrchestrationResultDetails) Descriptor

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

Deprecated: Use AssessmentOrchestrationResultDetails.ProtoReflect.Descriptor instead.

func (*AssessmentOrchestrationResultDetails) GetOutputTablesSchemaVersion

func (x *AssessmentOrchestrationResultDetails) GetOutputTablesSchemaVersion() string

func (*AssessmentOrchestrationResultDetails) ProtoMessage

func (*AssessmentOrchestrationResultDetails) ProtoMessage()

func (*AssessmentOrchestrationResultDetails) ProtoReflect

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

func (*AssessmentOrchestrationResultDetails) Reset

func (x *AssessmentOrchestrationResultDetails) Reset()

func (*AssessmentOrchestrationResultDetails) String

func (x *AssessmentOrchestrationResultDetails) String() string

AssessmentTaskDetails

type AssessmentTaskDetails struct {

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

Assessment task config.

func (*AssessmentTaskDetails) Descriptor

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

Deprecated: Use AssessmentTaskDetails.ProtoReflect.Descriptor instead.

func (*AssessmentTaskDetails) GetDataSource

func (x *AssessmentTaskDetails) GetDataSource() string

func (*AssessmentTaskDetails) GetInputPath

func (x *AssessmentTaskDetails) GetInputPath() string

func (*AssessmentTaskDetails) GetOutputDataset

func (x *AssessmentTaskDetails) GetOutputDataset() string

func (*AssessmentTaskDetails) GetQuerylogsPath

func (x *AssessmentTaskDetails) GetQuerylogsPath() string

func (*AssessmentTaskDetails) ProtoMessage

func (*AssessmentTaskDetails) ProtoMessage()

func (*AssessmentTaskDetails) ProtoReflect

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

func (*AssessmentTaskDetails) Reset

func (x *AssessmentTaskDetails) Reset()

func (*AssessmentTaskDetails) String

func (x *AssessmentTaskDetails) String() string

BteqOptions

type BteqOptions struct {

	// Specifies the project and dataset in BigQuery that will be used for
	// external table creation during the translation.
	ProjectDataset *DatasetReference `protobuf:"bytes,1,opt,name=project_dataset,json=projectDataset,proto3" json:"project_dataset,omitempty"`
	// The Cloud Storage location to be used as the default path for files that
	// are not otherwise specified in the file replacement map.
	DefaultPathUri string `protobuf:"bytes,2,opt,name=default_path_uri,json=defaultPathUri,proto3" json:"default_path_uri,omitempty"`
	// Maps the local paths that are used in BTEQ scripts (the keys) to the paths
	// in Cloud Storage that should be used in their stead in the translation (the
	// value).
	FileReplacementMap map[string]string `protobuf:"bytes,3,rep,name=file_replacement_map,json=fileReplacementMap,proto3" json:"file_replacement_map,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

BTEQ translation task related settings.

func (*BteqOptions) Descriptor

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

Deprecated: Use BteqOptions.ProtoReflect.Descriptor instead.

func (*BteqOptions) GetDefaultPathUri

func (x *BteqOptions) GetDefaultPathUri() string

func (*BteqOptions) GetFileReplacementMap

func (x *BteqOptions) GetFileReplacementMap() map[string]string

func (*BteqOptions) GetProjectDataset

func (x *BteqOptions) GetProjectDataset() *DatasetReference

func (*BteqOptions) ProtoMessage

func (*BteqOptions) ProtoMessage()

func (*BteqOptions) ProtoReflect

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

func (*BteqOptions) Reset

func (x *BteqOptions) Reset()

func (*BteqOptions) String

func (x *BteqOptions) String() string

CreateMigrationWorkflowRequest

type CreateMigrationWorkflowRequest struct {

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

Request to create a migration workflow resource.

func (*CreateMigrationWorkflowRequest) Descriptor

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

Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateMigrationWorkflowRequest) GetMigrationWorkflow

func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow

func (*CreateMigrationWorkflowRequest) GetParent

func (x *CreateMigrationWorkflowRequest) GetParent() string

func (*CreateMigrationWorkflowRequest) ProtoMessage

func (*CreateMigrationWorkflowRequest) ProtoMessage()

func (*CreateMigrationWorkflowRequest) ProtoReflect

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

func (*CreateMigrationWorkflowRequest) Reset

func (x *CreateMigrationWorkflowRequest) Reset()

func (*CreateMigrationWorkflowRequest) String

func (x *CreateMigrationWorkflowRequest) String() string

DatasetReference

type DatasetReference struct {

	// A unique ID for this dataset, without the project name. The ID
	// must contain only letters (a-z, A-Z), numbers (0-9), or underscores (_).
	// The maximum length is 1,024 characters.
	DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// The ID of the project containing this dataset.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Reference to a BigQuery dataset.

func (*DatasetReference) Descriptor

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

Deprecated: Use DatasetReference.ProtoReflect.Descriptor instead.

func (*DatasetReference) GetDatasetId

func (x *DatasetReference) GetDatasetId() string

func (*DatasetReference) GetProjectId

func (x *DatasetReference) GetProjectId() string

func (*DatasetReference) ProtoMessage

func (*DatasetReference) ProtoMessage()

func (*DatasetReference) ProtoReflect

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

func (*DatasetReference) Reset

func (x *DatasetReference) Reset()

func (*DatasetReference) String

func (x *DatasetReference) String() string

DeleteMigrationWorkflowRequest

type DeleteMigrationWorkflowRequest struct {

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

A request to delete a previously created migration workflow.

func (*DeleteMigrationWorkflowRequest) Descriptor

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

Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteMigrationWorkflowRequest) GetName

func (x *DeleteMigrationWorkflowRequest) GetName() string

func (*DeleteMigrationWorkflowRequest) ProtoMessage

func (*DeleteMigrationWorkflowRequest) ProtoMessage()

func (*DeleteMigrationWorkflowRequest) ProtoReflect

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

func (*DeleteMigrationWorkflowRequest) Reset

func (x *DeleteMigrationWorkflowRequest) Reset()

func (*DeleteMigrationWorkflowRequest) String

func (x *DeleteMigrationWorkflowRequest) String() string

ErrorDetail

type ErrorDetail struct {

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

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

func (*ErrorDetail) Descriptor

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

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetErrorInfo

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

func (*ErrorDetail) GetLocation

func (x *ErrorDetail) GetLocation() *ErrorLocation

func (*ErrorDetail) ProtoMessage

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect

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

func (*ErrorDetail) Reset

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String

func (x *ErrorDetail) String() string

ErrorLocation

type ErrorLocation struct {

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

Holds information about where the error is located.

func (*ErrorLocation) Descriptor

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

Deprecated: Use ErrorLocation.ProtoReflect.Descriptor instead.

func (*ErrorLocation) GetColumn

func (x *ErrorLocation) GetColumn() int32

func (*ErrorLocation) GetLine

func (x *ErrorLocation) GetLine() int32

func (*ErrorLocation) ProtoMessage

func (*ErrorLocation) ProtoMessage()

func (*ErrorLocation) ProtoReflect

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

func (*ErrorLocation) Reset

func (x *ErrorLocation) Reset()

func (*ErrorLocation) String

func (x *ErrorLocation) String() string

Filter

type Filter struct {

	// The list of prefixes used to exclude processing for input files.
	InputFileExclusionPrefixes []string `protobuf:"bytes,1,rep,name=input_file_exclusion_prefixes,json=inputFileExclusionPrefixes,proto3" json:"input_file_exclusion_prefixes,omitempty"`
	// contains filtered or unexported fields
}

The filter applied to fields of translation details.

func (*Filter) Descriptor

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetInputFileExclusionPrefixes

func (x *Filter) GetInputFileExclusionPrefixes() []string

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect

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

func (*Filter) Reset

func (x *Filter) Reset()

func (*Filter) String

func (x *Filter) String() string

GetMigrationSubtaskRequest

type GetMigrationSubtaskRequest struct {

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

A request to get a previously created migration subtasks.

func (*GetMigrationSubtaskRequest) Descriptor

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

Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationSubtaskRequest) GetName

func (x *GetMigrationSubtaskRequest) GetName() string

func (*GetMigrationSubtaskRequest) GetReadMask

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

func (*GetMigrationSubtaskRequest) ProtoMessage

func (*GetMigrationSubtaskRequest) ProtoMessage()

func (*GetMigrationSubtaskRequest) ProtoReflect

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

func (*GetMigrationSubtaskRequest) Reset

func (x *GetMigrationSubtaskRequest) Reset()

func (*GetMigrationSubtaskRequest) String

func (x *GetMigrationSubtaskRequest) String() string

GetMigrationWorkflowRequest

type GetMigrationWorkflowRequest struct {

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

A request to get a previously created migration workflow.

func (*GetMigrationWorkflowRequest) Descriptor

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

Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationWorkflowRequest) GetName

func (x *GetMigrationWorkflowRequest) GetName() string

func (*GetMigrationWorkflowRequest) GetReadMask

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

func (*GetMigrationWorkflowRequest) ProtoMessage

func (*GetMigrationWorkflowRequest) ProtoMessage()

func (*GetMigrationWorkflowRequest) ProtoReflect

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

func (*GetMigrationWorkflowRequest) Reset

func (x *GetMigrationWorkflowRequest) Reset()

func (*GetMigrationWorkflowRequest) String

func (x *GetMigrationWorkflowRequest) String() string

IdentifierSettings

type IdentifierSettings struct {

	// The setting to control output queries' identifier case.
	OutputIdentifierCase IdentifierSettings_IdentifierCase `protobuf:"varint,1,opt,name=output_identifier_case,json=outputIdentifierCase,proto3,enum=google.cloud.bigquery.migration.v2alpha.IdentifierSettings_IdentifierCase" json:"output_identifier_case,omitempty"`
	// Specifies the rewrite mode for SQL identifiers.
	IdentifierRewriteMode IdentifierSettings_IdentifierRewriteMode `protobuf:"varint,2,opt,name=identifier_rewrite_mode,json=identifierRewriteMode,proto3,enum=google.cloud.bigquery.migration.v2alpha.IdentifierSettings_IdentifierRewriteMode" json:"identifier_rewrite_mode,omitempty"`
	// contains filtered or unexported fields
}

Settings related to SQL identifiers.

func (*IdentifierSettings) Descriptor

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

Deprecated: Use IdentifierSettings.ProtoReflect.Descriptor instead.

func (*IdentifierSettings) GetIdentifierRewriteMode

func (x *IdentifierSettings) GetIdentifierRewriteMode() IdentifierSettings_IdentifierRewriteMode

func (*IdentifierSettings) GetOutputIdentifierCase

func (x *IdentifierSettings) GetOutputIdentifierCase() IdentifierSettings_IdentifierCase

func (*IdentifierSettings) ProtoMessage

func (*IdentifierSettings) ProtoMessage()

func (*IdentifierSettings) ProtoReflect

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

func (*IdentifierSettings) Reset

func (x *IdentifierSettings) Reset()

func (*IdentifierSettings) String

func (x *IdentifierSettings) String() string

IdentifierSettings_IdentifierCase

type IdentifierSettings_IdentifierCase int32

The identifier case type.

IdentifierSettings_IDENTIFIER_CASE_UNSPECIFIED, IdentifierSettings_ORIGINAL, IdentifierSettings_UPPER, IdentifierSettings_LOWER

const (
	// The identifier case is not specified.
	IdentifierSettings_IDENTIFIER_CASE_UNSPECIFIED IdentifierSettings_IdentifierCase = 0
	// Identifiers' cases will be kept as the original cases.
	IdentifierSettings_ORIGINAL IdentifierSettings_IdentifierCase = 1
	// Identifiers will be in upper cases.
	IdentifierSettings_UPPER IdentifierSettings_IdentifierCase = 2
	// Identifiers will be in lower cases.
	IdentifierSettings_LOWER IdentifierSettings_IdentifierCase = 3
)

func (IdentifierSettings_IdentifierCase) Descriptor

func (IdentifierSettings_IdentifierCase) Descriptor() protoreflect.EnumDescriptor

func (IdentifierSettings_IdentifierCase) Enum

func (x IdentifierSettings_IdentifierCase) Enum() *IdentifierSettings_IdentifierCase

func (IdentifierSettings_IdentifierCase) EnumDescriptor

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

Deprecated: Use IdentifierSettings_IdentifierCase.Descriptor instead.

func (IdentifierSettings_IdentifierCase) Number

func (x IdentifierSettings_IdentifierCase) Number() protoreflect.EnumNumber

func (IdentifierSettings_IdentifierCase) String

func (x IdentifierSettings_IdentifierCase) String() string

func (IdentifierSettings_IdentifierCase) Type

func (IdentifierSettings_IdentifierCase) Type() protoreflect.EnumType

IdentifierSettings_IdentifierRewriteMode

type IdentifierSettings_IdentifierRewriteMode int32

The SQL identifier rewrite mode.

IdentifierSettings_IDENTIFIER_REWRITE_MODE_UNSPECIFIED, IdentifierSettings_NONE, IdentifierSettings_REWRITE_ALL

const (
	// SQL Identifier rewrite mode is unspecified.
	IdentifierSettings_IDENTIFIER_REWRITE_MODE_UNSPECIFIED IdentifierSettings_IdentifierRewriteMode = 0
	// SQL identifiers won't be rewrite.
	IdentifierSettings_NONE IdentifierSettings_IdentifierRewriteMode = 1
	// All SQL identifiers will be rewrite.
	IdentifierSettings_REWRITE_ALL IdentifierSettings_IdentifierRewriteMode = 2
)

func (IdentifierSettings_IdentifierRewriteMode) Descriptor

func (IdentifierSettings_IdentifierRewriteMode) Descriptor() protoreflect.EnumDescriptor

func (IdentifierSettings_IdentifierRewriteMode) Enum

func (x IdentifierSettings_IdentifierRewriteMode) Enum() *IdentifierSettings_IdentifierRewriteMode

func (IdentifierSettings_IdentifierRewriteMode) EnumDescriptor

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

Deprecated: Use IdentifierSettings_IdentifierRewriteMode.Descriptor instead.

func (IdentifierSettings_IdentifierRewriteMode) Number

func (x IdentifierSettings_IdentifierRewriteMode) Number() protoreflect.EnumNumber

func (IdentifierSettings_IdentifierRewriteMode) String

func (x IdentifierSettings_IdentifierRewriteMode) String() string

func (IdentifierSettings_IdentifierRewriteMode) Type

func (IdentifierSettings_IdentifierRewriteMode) Type() protoreflect.EnumType

ListMigrationSubtasksRequest

type ListMigrationSubtasksRequest struct {

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

A request to list previously created migration subtasks.

func (*ListMigrationSubtasksRequest) Descriptor

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

Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksRequest) GetFilter

func (x *ListMigrationSubtasksRequest) GetFilter() string

func (*ListMigrationSubtasksRequest) GetPageSize

func (x *ListMigrationSubtasksRequest) GetPageSize() int32

func (*ListMigrationSubtasksRequest) GetPageToken

func (x *ListMigrationSubtasksRequest) GetPageToken() string

func (*ListMigrationSubtasksRequest) GetParent

func (x *ListMigrationSubtasksRequest) GetParent() string

func (*ListMigrationSubtasksRequest) GetReadMask

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

func (*ListMigrationSubtasksRequest) ProtoMessage

func (*ListMigrationSubtasksRequest) ProtoMessage()

func (*ListMigrationSubtasksRequest) ProtoReflect

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

func (*ListMigrationSubtasksRequest) Reset

func (x *ListMigrationSubtasksRequest) Reset()

func (*ListMigrationSubtasksRequest) String

func (x *ListMigrationSubtasksRequest) String() string

ListMigrationSubtasksResponse

type ListMigrationSubtasksResponse struct {

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

Response object for a ListMigrationSubtasks call.

func (*ListMigrationSubtasksResponse) Descriptor

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

Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksResponse) GetMigrationSubtasks

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

func (*ListMigrationSubtasksResponse) GetNextPageToken

func (x *ListMigrationSubtasksResponse) GetNextPageToken() string

func (*ListMigrationSubtasksResponse) ProtoMessage

func (*ListMigrationSubtasksResponse) ProtoMessage()

func (*ListMigrationSubtasksResponse) ProtoReflect

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

func (*ListMigrationSubtasksResponse) Reset

func (x *ListMigrationSubtasksResponse) Reset()

func (*ListMigrationSubtasksResponse) String

func (x *ListMigrationSubtasksResponse) String() string

ListMigrationWorkflowsRequest

type ListMigrationWorkflowsRequest struct {

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

A request to list previously created migration workflows.

func (*ListMigrationWorkflowsRequest) Descriptor

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

Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsRequest) GetPageSize

func (x *ListMigrationWorkflowsRequest) GetPageSize() int32

func (*ListMigrationWorkflowsRequest) GetPageToken

func (x *ListMigrationWorkflowsRequest) GetPageToken() string

func (*ListMigrationWorkflowsRequest) GetParent

func (x *ListMigrationWorkflowsRequest) GetParent() string

func (*ListMigrationWorkflowsRequest) GetReadMask

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

func (*ListMigrationWorkflowsRequest) ProtoMessage

func (*ListMigrationWorkflowsRequest) ProtoMessage()

func (*ListMigrationWorkflowsRequest) ProtoReflect

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

func (*ListMigrationWorkflowsRequest) Reset

func (x *ListMigrationWorkflowsRequest) Reset()

func (*ListMigrationWorkflowsRequest) String

func (x *ListMigrationWorkflowsRequest) String() string

ListMigrationWorkflowsResponse

type ListMigrationWorkflowsResponse struct {

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

Response object for a ListMigrationWorkflows call.

func (*ListMigrationWorkflowsResponse) Descriptor

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

Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsResponse) GetMigrationWorkflows

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

func (*ListMigrationWorkflowsResponse) GetNextPageToken

func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string

func (*ListMigrationWorkflowsResponse) ProtoMessage

func (*ListMigrationWorkflowsResponse) ProtoMessage()

func (*ListMigrationWorkflowsResponse) ProtoReflect

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

func (*ListMigrationWorkflowsResponse) Reset

func (x *ListMigrationWorkflowsResponse) Reset()

func (*ListMigrationWorkflowsResponse) String

func (x *ListMigrationWorkflowsResponse) String() string

MigrationServiceClient

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

MigrationServiceClient is the client API for MigrationService service.

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

func NewMigrationServiceClient

func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

MigrationServiceServer

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

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

MigrationSubtask

type MigrationSubtask struct {

	// Output only. Immutable. The resource name for the migration subtask. The ID is
	// server-generated.
	//
	// Example: `projects/123/locations/us/workflows/345/subtasks/678`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The unique ID of the task to which this subtask belongs.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The type of the Subtask. The migration service does not check whether this
	// is a known type. It is up to the task creator (i.e. orchestrator or worker)
	// to ensure it only creates subtasks for which there are compatible workers
	// polling for Subtasks.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Output only. The current state of the subtask.
	State MigrationSubtask_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2alpha.MigrationSubtask_State" json:"state,omitempty"`
	// Output only. An explanation that may be populated when the task is in FAILED state.
	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
	// Output only. Provides details to errors and issues encountered while processing the
	// subtask. Presence of error details does not mean that the subtask failed.
	ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
	// 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

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

Deprecated: Use MigrationSubtask.ProtoReflect.Descriptor instead.

func (*MigrationSubtask) GetCreateTime

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

func (*MigrationSubtask) GetLastUpdateTime

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

func (*MigrationSubtask) GetMetrics

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

func (*MigrationSubtask) GetName

func (x *MigrationSubtask) GetName() string

func (*MigrationSubtask) GetProcessingError

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

func (*MigrationSubtask) GetResourceErrorCount

func (x *MigrationSubtask) GetResourceErrorCount() int32

func (*MigrationSubtask) GetResourceErrorDetails

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

func (*MigrationSubtask) GetState

func (x *MigrationSubtask) GetState() MigrationSubtask_State

func (*MigrationSubtask) GetTaskId

func (x *MigrationSubtask) GetTaskId() string

func (*MigrationSubtask) GetType

func (x *MigrationSubtask) GetType() string

func (*MigrationSubtask) ProtoMessage

func (*MigrationSubtask) ProtoMessage()

func (*MigrationSubtask) ProtoReflect

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

func (*MigrationSubtask) Reset

func (x *MigrationSubtask) Reset()

func (*MigrationSubtask) String

func (x *MigrationSubtask) String() string

MigrationSubtask_State

type MigrationSubtask_State int32

Possible states of a migration subtask.

MigrationSubtask_STATE_UNSPECIFIED, MigrationSubtask_ACTIVE, MigrationSubtask_RUNNING, MigrationSubtask_SUCCEEDED, MigrationSubtask_FAILED, MigrationSubtask_PAUSED

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
)

func (MigrationSubtask_State) Descriptor

func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationSubtask_State) Enum

func (x MigrationSubtask_State) Enum() *MigrationSubtask_State

func (MigrationSubtask_State) EnumDescriptor

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

Deprecated: Use MigrationSubtask_State.Descriptor instead.

func (MigrationSubtask_State) Number

func (x MigrationSubtask_State) Number() protoreflect.EnumNumber

func (MigrationSubtask_State) String

func (x MigrationSubtask_State) String() string

func (MigrationSubtask_State) Type

func (MigrationSubtask_State) Type() protoreflect.EnumType

MigrationTask

type MigrationTask struct {

	// The details of the task.
	//
	// Types that are assignable to TaskDetails:
	//
	//	*MigrationTask_AssessmentTaskDetails
	//	*MigrationTask_TranslationTaskDetails
	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 a supported task type.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// DEPRECATED! Use one of the task_details below.
	// The details of the task. The type URL must be one of the supported task
	// details messages and correspond to the Task's type.
	Details *anypb.Any `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// Output only. The current state of the task.
	State MigrationTask_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2alpha.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. Additional information about the orchestration.
	OrchestrationResult *MigrationTaskOrchestrationResult `protobuf:"bytes,10,opt,name=orchestration_result,json=orchestrationResult,proto3" json:"orchestration_result,omitempty"`
	// contains filtered or unexported fields
}

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

func (*MigrationTask) Descriptor

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

Deprecated: Use MigrationTask.ProtoReflect.Descriptor instead.

func (*MigrationTask) GetAssessmentTaskDetails

func (x *MigrationTask) GetAssessmentTaskDetails() *AssessmentTaskDetails

func (*MigrationTask) GetCreateTime

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

func (*MigrationTask) GetDetails

func (x *MigrationTask) GetDetails() *anypb.Any

func (*MigrationTask) GetId

func (x *MigrationTask) GetId() string

func (*MigrationTask) GetLastUpdateTime

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

func (*MigrationTask) GetOrchestrationResult

func (x *MigrationTask) GetOrchestrationResult() *MigrationTaskOrchestrationResult

func (*MigrationTask) GetProcessingError

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

func (*MigrationTask) GetState

func (x *MigrationTask) GetState() MigrationTask_State

func (*MigrationTask) GetTaskDetails

func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails

func (*MigrationTask) GetTranslationTaskDetails

func (x *MigrationTask) GetTranslationTaskDetails() *TranslationTaskDetails

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

MigrationTaskOrchestrationResult

type MigrationTaskOrchestrationResult struct {

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

Additional information from the orchestrator when it is done with the task orchestration.

func (*MigrationTaskOrchestrationResult) Descriptor

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

Deprecated: Use MigrationTaskOrchestrationResult.ProtoReflect.Descriptor instead.

func (*MigrationTaskOrchestrationResult) GetAssessmentDetails

func (x *MigrationTaskOrchestrationResult) GetAssessmentDetails() *AssessmentOrchestrationResultDetails

func (*MigrationTaskOrchestrationResult) GetDetails

func (m *MigrationTaskOrchestrationResult) GetDetails() isMigrationTaskOrchestrationResult_Details

func (*MigrationTaskOrchestrationResult) ProtoMessage

func (*MigrationTaskOrchestrationResult) ProtoMessage()

func (*MigrationTaskOrchestrationResult) ProtoReflect

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

func (*MigrationTaskOrchestrationResult) Reset

func (x *MigrationTaskOrchestrationResult) Reset()

func (*MigrationTaskOrchestrationResult) String

func (x *MigrationTaskOrchestrationResult) String() string

MigrationTaskOrchestrationResult_AssessmentDetails

type MigrationTaskOrchestrationResult_AssessmentDetails struct {
	// Details specific to assessment task types.
	AssessmentDetails *AssessmentOrchestrationResultDetails `protobuf:"bytes,1,opt,name=assessment_details,json=assessmentDetails,proto3,oneof"`
}

MigrationTask_AssessmentTaskDetails

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

MigrationTask_State

type MigrationTask_State int32

Possible states of a migration task.

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

const (
	// The state is unspecified.
	MigrationTask_STATE_UNSPECIFIED MigrationTask_State = 0
	// The task is waiting for orchestration.
	MigrationTask_PENDING MigrationTask_State = 1
	// The task is assigned to an orchestrator.
	MigrationTask_ORCHESTRATING MigrationTask_State = 2
	// The task is running, i.e. its subtasks are ready for execution.
	MigrationTask_RUNNING MigrationTask_State = 3
	// 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

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

Deprecated: Use MigrationTask_State.Descriptor instead.

func (MigrationTask_State) Number

func (x MigrationTask_State) Number() protoreflect.EnumNumber

func (MigrationTask_State) String

func (x MigrationTask_State) String() string

func (MigrationTask_State) Type

func (MigrationTask_State) Type() protoreflect.EnumType

MigrationTask_TranslationTaskDetails

type MigrationTask_TranslationTaskDetails struct {
	// Task configuration for Batch/Offline SQL Translation.
	TranslationTaskDetails *TranslationTaskDetails `protobuf:"bytes,13,opt,name=translation_task_details,json=translationTaskDetails,proto3,oneof"`
}

MigrationWorkflow

type MigrationWorkflow struct {

	// Output only. Immutable. The unique identifier for the migration workflow. The ID is
	// server-generated.
	//
	// Example: `projects/123/locations/us/workflows/345`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The display name of the workflow. This can be set to give a workflow
	// a descriptive name. There is no guarantee or enforcement of uniqueness.
	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// The tasks in a workflow in a named map. The name (i.e. key) has no
	// meaning and is merely a convenient way to address a specific task
	// in a workflow.
	Tasks map[string]*MigrationTask `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Output only. That status of the workflow.
	State MigrationWorkflow_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2alpha.MigrationWorkflow_State" json:"state,omitempty"`
	// 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

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

Deprecated: Use MigrationWorkflow.ProtoReflect.Descriptor instead.

func (*MigrationWorkflow) GetCreateTime

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

func (*MigrationWorkflow) GetDisplayName

func (x *MigrationWorkflow) GetDisplayName() string

func (*MigrationWorkflow) GetLastUpdateTime

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

func (*MigrationWorkflow) GetName

func (x *MigrationWorkflow) GetName() string

func (*MigrationWorkflow) GetState

func (x *MigrationWorkflow) GetState() MigrationWorkflow_State

func (*MigrationWorkflow) GetTasks

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

func (*MigrationWorkflow) ProtoMessage

func (*MigrationWorkflow) ProtoMessage()

func (*MigrationWorkflow) ProtoReflect

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

func (*MigrationWorkflow) Reset

func (x *MigrationWorkflow) Reset()

func (*MigrationWorkflow) String

func (x *MigrationWorkflow) String() string

MigrationWorkflow_State

type MigrationWorkflow_State int32

Possible migration workflow states.

MigrationWorkflow_STATE_UNSPECIFIED, MigrationWorkflow_DRAFT, MigrationWorkflow_RUNNING, MigrationWorkflow_PAUSED, MigrationWorkflow_COMPLETED

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

func (MigrationWorkflow_State) Descriptor

func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationWorkflow_State) Enum

func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State

func (MigrationWorkflow_State) EnumDescriptor

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

Deprecated: Use MigrationWorkflow_State.Descriptor instead.

func (MigrationWorkflow_State) Number

func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber

func (MigrationWorkflow_State) String

func (x MigrationWorkflow_State) String() string

func (MigrationWorkflow_State) Type

func (MigrationWorkflow_State) Type() protoreflect.EnumType

Point

type Point struct {

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

A single data point in a time series.

func (*Point) Descriptor

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

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetInterval

func (x *Point) GetInterval() *TimeInterval

func (*Point) GetValue

func (x *Point) GetValue() *TypedValue

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) ProtoReflect

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

func (*Point) Reset

func (x *Point) Reset()

func (*Point) String

func (x *Point) String() string

ResourceErrorDetail

type ResourceErrorDetail struct {

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

Provides details for errors and the corresponding resources.

func (*ResourceErrorDetail) Descriptor

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

Deprecated: Use ResourceErrorDetail.ProtoReflect.Descriptor instead.

func (*ResourceErrorDetail) GetErrorCount

func (x *ResourceErrorDetail) GetErrorCount() int32

func (*ResourceErrorDetail) GetErrorDetails

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

func (*ResourceErrorDetail) GetResourceInfo

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

func (*ResourceErrorDetail) ProtoMessage

func (*ResourceErrorDetail) ProtoMessage()

func (*ResourceErrorDetail) ProtoReflect

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

func (*ResourceErrorDetail) Reset

func (x *ResourceErrorDetail) Reset()

func (*ResourceErrorDetail) String

func (x *ResourceErrorDetail) String() string

SqlTranslationError

type SqlTranslationError struct {

	// The type of SQL translation error.
	ErrorType SqlTranslationError_SqlTranslationErrorType `protobuf:"varint,1,opt,name=error_type,json=errorType,proto3,enum=google.cloud.bigquery.migration.v2alpha.SqlTranslationError_SqlTranslationErrorType" json:"error_type,omitempty"`
	// Specifies the details of the error, including the error message and
	// location from the source text.
	ErrorDetail *SqlTranslationErrorDetail `protobuf:"bytes,2,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"`
	// contains filtered or unexported fields
}

The detailed error object if the SQL translation job fails.

func (*SqlTranslationError) Descriptor

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

Deprecated: Use SqlTranslationError.ProtoReflect.Descriptor instead.

func (*SqlTranslationError) GetErrorDetail

func (x *SqlTranslationError) GetErrorDetail() *SqlTranslationErrorDetail

func (*SqlTranslationError) GetErrorType

func (x *SqlTranslationError) GetErrorType() SqlTranslationError_SqlTranslationErrorType

func (*SqlTranslationError) ProtoMessage

func (*SqlTranslationError) ProtoMessage()

func (*SqlTranslationError) ProtoReflect

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

func (*SqlTranslationError) Reset

func (x *SqlTranslationError) Reset()

func (*SqlTranslationError) String

func (x *SqlTranslationError) String() string

SqlTranslationErrorDetail

type SqlTranslationErrorDetail struct {

	// Specifies the row from the source text where the error occurred.
	Row int64 `protobuf:"varint,1,opt,name=row,proto3" json:"row,omitempty"`
	// Specifie the column from the source texts where the error occurred.
	Column int64 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	// A human-readable description of the error.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Structured error object capturing the error message and the location in the source text where the error occurs.

func (*SqlTranslationErrorDetail) Descriptor

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

Deprecated: Use SqlTranslationErrorDetail.ProtoReflect.Descriptor instead.

func (*SqlTranslationErrorDetail) GetColumn

func (x *SqlTranslationErrorDetail) GetColumn() int64

func (*SqlTranslationErrorDetail) GetMessage

func (x *SqlTranslationErrorDetail) GetMessage() string

func (*SqlTranslationErrorDetail) GetRow

func (x *SqlTranslationErrorDetail) GetRow() int64

func (*SqlTranslationErrorDetail) ProtoMessage

func (*SqlTranslationErrorDetail) ProtoMessage()

func (*SqlTranslationErrorDetail) ProtoReflect

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

func (*SqlTranslationErrorDetail) Reset

func (x *SqlTranslationErrorDetail) Reset()

func (*SqlTranslationErrorDetail) String

func (x *SqlTranslationErrorDetail) String() string

SqlTranslationError_SqlTranslationErrorType

type SqlTranslationError_SqlTranslationErrorType int32

The error type of the SQL translation job.

SqlTranslationError_SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED, SqlTranslationError_SQL_PARSE_ERROR, SqlTranslationError_UNSUPPORTED_SQL_FUNCTION

const (
	// SqlTranslationErrorType not specified.
	SqlTranslationError_SQL_TRANSLATION_ERROR_TYPE_UNSPECIFIED SqlTranslationError_SqlTranslationErrorType = 0
	// Failed to parse the input text as a SQL query.
	SqlTranslationError_SQL_PARSE_ERROR SqlTranslationError_SqlTranslationErrorType = 1
	// Found unsupported functions in the input SQL query that are not able to
	// translate.
	SqlTranslationError_UNSUPPORTED_SQL_FUNCTION SqlTranslationError_SqlTranslationErrorType = 2
)

func (SqlTranslationError_SqlTranslationErrorType) Descriptor

func (SqlTranslationError_SqlTranslationErrorType) Descriptor() protoreflect.EnumDescriptor

func (SqlTranslationError_SqlTranslationErrorType) Enum

func (x SqlTranslationError_SqlTranslationErrorType) Enum() *SqlTranslationError_SqlTranslationErrorType

func (SqlTranslationError_SqlTranslationErrorType) EnumDescriptor

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

Deprecated: Use SqlTranslationError_SqlTranslationErrorType.Descriptor instead.

func (SqlTranslationError_SqlTranslationErrorType) Number

func (x SqlTranslationError_SqlTranslationErrorType) Number() protoreflect.EnumNumber

func (SqlTranslationError_SqlTranslationErrorType) String

func (x SqlTranslationError_SqlTranslationErrorType) String() string

func (SqlTranslationError_SqlTranslationErrorType) Type

func (SqlTranslationError_SqlTranslationErrorType) Type() protoreflect.EnumType

SqlTranslationServiceClient

type SqlTranslationServiceClient interface {
	// Translates input queries from source dialects to GoogleSQL.
	TranslateQuery(ctx context.Context, in *TranslateQueryRequest, opts ...grpc.CallOption) (*TranslateQueryResponse, error)
}

SqlTranslationServiceClient is the client API for SqlTranslationService service.

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

func NewSqlTranslationServiceClient

func NewSqlTranslationServiceClient(cc grpc.ClientConnInterface) SqlTranslationServiceClient

SqlTranslationServiceServer

type SqlTranslationServiceServer interface {
	// Translates input queries from source dialects to GoogleSQL.
	TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)
}

SqlTranslationServiceServer is the server API for SqlTranslationService service. All implementations should embed UnimplementedSqlTranslationServiceServer for forward compatibility

SqlTranslationWarning

type SqlTranslationWarning struct {

	// Specifies the details of the warning, including the warning message and
	// location from the source text.
	WarningDetail *SqlTranslationErrorDetail `protobuf:"bytes,1,opt,name=warning_detail,json=warningDetail,proto3" json:"warning_detail,omitempty"`
	// contains filtered or unexported fields
}

The detailed warning object if the SQL translation job is completed but not semantically correct.

func (*SqlTranslationWarning) Descriptor

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

Deprecated: Use SqlTranslationWarning.ProtoReflect.Descriptor instead.

func (*SqlTranslationWarning) GetWarningDetail

func (x *SqlTranslationWarning) GetWarningDetail() *SqlTranslationErrorDetail

func (*SqlTranslationWarning) ProtoMessage

func (*SqlTranslationWarning) ProtoMessage()

func (*SqlTranslationWarning) ProtoReflect

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

func (*SqlTranslationWarning) Reset

func (x *SqlTranslationWarning) Reset()

func (*SqlTranslationWarning) String

func (x *SqlTranslationWarning) String() string

StartMigrationWorkflowRequest

type StartMigrationWorkflowRequest struct {

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

A request to start a previously created migration workflow.

func (*StartMigrationWorkflowRequest) Descriptor

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

Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartMigrationWorkflowRequest) GetName

func (x *StartMigrationWorkflowRequest) GetName() string

func (*StartMigrationWorkflowRequest) ProtoMessage

func (*StartMigrationWorkflowRequest) ProtoMessage()

func (*StartMigrationWorkflowRequest) ProtoReflect

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

func (*StartMigrationWorkflowRequest) Reset

func (x *StartMigrationWorkflowRequest) Reset()

func (*StartMigrationWorkflowRequest) String

func (x *StartMigrationWorkflowRequest) String() string

TeradataOptions

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

Teradata SQL specific translation task related settings.

func (*TeradataOptions) Descriptor

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

Deprecated: Use TeradataOptions.ProtoReflect.Descriptor instead.

func (*TeradataOptions) ProtoMessage

func (*TeradataOptions) ProtoMessage()

func (*TeradataOptions) ProtoReflect

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

func (*TeradataOptions) Reset

func (x *TeradataOptions) Reset()

func (*TeradataOptions) String

func (x *TeradataOptions) String() string

TimeInterval

type TimeInterval struct {

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

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

func (*TimeInterval) Descriptor

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

Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.

func (*TimeInterval) GetEndTime

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

func (*TimeInterval) GetStartTime

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

func (*TimeInterval) ProtoMessage

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) ProtoReflect

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

func (*TimeInterval) Reset

func (x *TimeInterval) Reset()

func (*TimeInterval) String

func (x *TimeInterval) String() string

TimeSeries

type TimeSeries struct {

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

The metrics object for a SubTask.

func (*TimeSeries) Descriptor

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

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetMetric

func (x *TimeSeries) GetMetric() string

func (*TimeSeries) GetMetricKind

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

func (*TimeSeries) GetPoints

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

func (*TimeSeries) GetValueType

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

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect

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

func (*TimeSeries) Reset

func (x *TimeSeries) Reset()

func (*TimeSeries) String

func (x *TimeSeries) String() string

TranslateQueryRequest

type TranslateQueryRequest struct {

	// Required. The name of the project to which this translation request belongs.
	// Example: `projects/foo/locations/bar`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The source SQL dialect of `queries`.
	SourceDialect TranslateQueryRequest_SqlTranslationSourceDialect `protobuf:"varint,2,opt,name=source_dialect,json=sourceDialect,proto3,enum=google.cloud.bigquery.migration.v2alpha.TranslateQueryRequest_SqlTranslationSourceDialect" json:"source_dialect,omitempty"`
	// Required. The query to be translated.
	Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

The request of translating a SQL query to Standard SQL.

func (*TranslateQueryRequest) Descriptor

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

Deprecated: Use TranslateQueryRequest.ProtoReflect.Descriptor instead.

func (*TranslateQueryRequest) GetParent

func (x *TranslateQueryRequest) GetParent() string

func (*TranslateQueryRequest) GetQuery

func (x *TranslateQueryRequest) GetQuery() string

func (*TranslateQueryRequest) GetSourceDialect

func (x *TranslateQueryRequest) GetSourceDialect() TranslateQueryRequest_SqlTranslationSourceDialect

func (*TranslateQueryRequest) ProtoMessage

func (*TranslateQueryRequest) ProtoMessage()

func (*TranslateQueryRequest) ProtoReflect

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

func (*TranslateQueryRequest) Reset

func (x *TranslateQueryRequest) Reset()

func (*TranslateQueryRequest) String

func (x *TranslateQueryRequest) String() string

TranslateQueryRequest_SqlTranslationSourceDialect

type TranslateQueryRequest_SqlTranslationSourceDialect int32

Supported SQL translation source dialects.

TranslateQueryRequest_SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED, TranslateQueryRequest_TERADATA

const (
	// SqlTranslationSourceDialect not specified.
	TranslateQueryRequest_SQL_TRANSLATION_SOURCE_DIALECT_UNSPECIFIED TranslateQueryRequest_SqlTranslationSourceDialect = 0
	// Teradata SQL.
	TranslateQueryRequest_TERADATA TranslateQueryRequest_SqlTranslationSourceDialect = 1
)

func (TranslateQueryRequest_SqlTranslationSourceDialect) Descriptor

func (TranslateQueryRequest_SqlTranslationSourceDialect) Descriptor() protoreflect.EnumDescriptor

func (TranslateQueryRequest_SqlTranslationSourceDialect) Enum

func (x TranslateQueryRequest_SqlTranslationSourceDialect) Enum() *TranslateQueryRequest_SqlTranslationSourceDialect

func (TranslateQueryRequest_SqlTranslationSourceDialect) EnumDescriptor

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

Deprecated: Use TranslateQueryRequest_SqlTranslationSourceDialect.Descriptor instead.

func (TranslateQueryRequest_SqlTranslationSourceDialect) Number

func (x TranslateQueryRequest_SqlTranslationSourceDialect) Number() protoreflect.EnumNumber

func (TranslateQueryRequest_SqlTranslationSourceDialect) String

func (x TranslateQueryRequest_SqlTranslationSourceDialect) String() string

func (TranslateQueryRequest_SqlTranslationSourceDialect) Type

func (TranslateQueryRequest_SqlTranslationSourceDialect) Type() protoreflect.EnumType

TranslateQueryResponse

type TranslateQueryResponse struct {

	// Output only. Immutable. The unique identifier for the SQL translation job.
	// Example: `projects/123/locations/us/translation/1234`
	TranslationJob string `protobuf:"bytes,4,opt,name=translation_job,json=translationJob,proto3" json:"translation_job,omitempty"`
	// The translated result. This will be empty if the translation fails.
	TranslatedQuery string `protobuf:"bytes,1,opt,name=translated_query,json=translatedQuery,proto3" json:"translated_query,omitempty"`
	// The list of errors encountered during the translation, if present.
	Errors []*SqlTranslationError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// The list of warnings encountered during the translation, if present,
	// indicates non-semantically correct translation.
	Warnings []*SqlTranslationWarning `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

The response of translating a SQL query to Standard SQL.

func (*TranslateQueryResponse) Descriptor

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

Deprecated: Use TranslateQueryResponse.ProtoReflect.Descriptor instead.

func (*TranslateQueryResponse) GetErrors

func (x *TranslateQueryResponse) GetErrors() []*SqlTranslationError

func (*TranslateQueryResponse) GetTranslatedQuery

func (x *TranslateQueryResponse) GetTranslatedQuery() string

func (*TranslateQueryResponse) GetTranslationJob

func (x *TranslateQueryResponse) GetTranslationJob() string

func (*TranslateQueryResponse) GetWarnings

func (x *TranslateQueryResponse) GetWarnings() []*SqlTranslationWarning

func (*TranslateQueryResponse) ProtoMessage

func (*TranslateQueryResponse) ProtoMessage()

func (*TranslateQueryResponse) ProtoReflect

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

func (*TranslateQueryResponse) Reset

func (x *TranslateQueryResponse) Reset()

func (*TranslateQueryResponse) String

func (x *TranslateQueryResponse) String() string

TranslationFileMapping

type TranslationFileMapping struct {

	// The Cloud Storage path for a file to translation in a subtask.
	InputPath string `protobuf:"bytes,1,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// The Cloud Storage path to write back the corresponding input file to.
	OutputPath string `protobuf:"bytes,2,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// contains filtered or unexported fields
}

Mapping between an input and output file to be translated in a subtask.

func (*TranslationFileMapping) Descriptor

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

Deprecated: Use TranslationFileMapping.ProtoReflect.Descriptor instead.

func (*TranslationFileMapping) GetInputPath

func (x *TranslationFileMapping) GetInputPath() string

func (*TranslationFileMapping) GetOutputPath

func (x *TranslationFileMapping) GetOutputPath() string

func (*TranslationFileMapping) ProtoMessage

func (*TranslationFileMapping) ProtoMessage()

func (*TranslationFileMapping) ProtoReflect

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

func (*TranslationFileMapping) Reset

func (x *TranslationFileMapping) Reset()

func (*TranslationFileMapping) String

func (x *TranslationFileMapping) String() string

TranslationTaskDetails

type TranslationTaskDetails struct {

	// The language specific settings for the translation task.
	//
	// Types that are assignable to LanguageOptions:
	//
	//	*TranslationTaskDetails_TeradataOptions
	//	*TranslationTaskDetails_BteqOptions
	LanguageOptions isTranslationTaskDetails_LanguageOptions `protobuf_oneof:"language_options"`
	// The Cloud Storage path for translation input files.
	InputPath string `protobuf:"bytes,1,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// The Cloud Storage path for translation output files.
	OutputPath string `protobuf:"bytes,2,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// Cloud Storage files to be processed for translation.
	FilePaths []*TranslationFileMapping `protobuf:"bytes,12,rep,name=file_paths,json=filePaths,proto3" json:"file_paths,omitempty"`
	// The Cloud Storage path to DDL files as table schema to assist semantic
	// translation.
	SchemaPath string `protobuf:"bytes,3,opt,name=schema_path,json=schemaPath,proto3" json:"schema_path,omitempty"`
	// The file encoding type.
	FileEncoding TranslationTaskDetails_FileEncoding `protobuf:"varint,4,opt,name=file_encoding,json=fileEncoding,proto3,enum=google.cloud.bigquery.migration.v2alpha.TranslationTaskDetails_FileEncoding" json:"file_encoding,omitempty"`
	// The settings for SQL identifiers.
	IdentifierSettings *IdentifierSettings `protobuf:"bytes,5,opt,name=identifier_settings,json=identifierSettings,proto3" json:"identifier_settings,omitempty"`
	// The map capturing special tokens to be replaced during translation. The key
	// is special token in string. The value is the token data type. This is used
	// to translate SQL query template which contains special token as place
	// holder. The special token makes a query invalid to parse. This map will be
	// applied to annotate those special token with types to let parser understand
	// how to parse them into proper structure with type information.
	SpecialTokenMap map[string]TranslationTaskDetails_TokenType `protobuf:"bytes,6,rep,name=special_token_map,json=specialTokenMap,proto3" json:"special_token_map,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3,enum=google.cloud.bigquery.migration.v2alpha.TranslationTaskDetails_TokenType"`
	// The filter applied to translation details.
	Filter *Filter `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// Specifies the exact name of the bigquery table ("dataset.table") to be used
	// for surfacing raw translation errors. If the table does not exist, we will
	// create it. If it already exists and the schema is the same, we will re-use.
	// If the table exists and the schema is different, we will throw an error.
	TranslationExceptionTable string `protobuf:"bytes,13,opt,name=translation_exception_table,json=translationExceptionTable,proto3" json:"translation_exception_table,omitempty"`
	// contains filtered or unexported fields
}

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

func (*TranslationTaskDetails) Descriptor

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

Deprecated: Use TranslationTaskDetails.ProtoReflect.Descriptor instead.

func (*TranslationTaskDetails) GetBteqOptions

func (x *TranslationTaskDetails) GetBteqOptions() *BteqOptions

func (*TranslationTaskDetails) GetFileEncoding

func (x *TranslationTaskDetails) GetFileEncoding() TranslationTaskDetails_FileEncoding

func (*TranslationTaskDetails) GetFilePaths

func (x *TranslationTaskDetails) GetFilePaths() []*TranslationFileMapping

func (*TranslationTaskDetails) GetFilter

func (x *TranslationTaskDetails) GetFilter() *Filter

func (*TranslationTaskDetails) GetIdentifierSettings

func (x *TranslationTaskDetails) GetIdentifierSettings() *IdentifierSettings

func (*TranslationTaskDetails) GetInputPath

func (x *TranslationTaskDetails) GetInputPath() string

func (*TranslationTaskDetails) GetLanguageOptions

func (m *TranslationTaskDetails) GetLanguageOptions() isTranslationTaskDetails_LanguageOptions

func (*TranslationTaskDetails) GetOutputPath

func (x *TranslationTaskDetails) GetOutputPath() string

func (*TranslationTaskDetails) GetSchemaPath

func (x *TranslationTaskDetails) GetSchemaPath() string

func (*TranslationTaskDetails) GetSpecialTokenMap

func (x *TranslationTaskDetails) GetSpecialTokenMap() map[string]TranslationTaskDetails_TokenType

func (*TranslationTaskDetails) GetTeradataOptions

func (x *TranslationTaskDetails) GetTeradataOptions() *TeradataOptions

func (*TranslationTaskDetails) GetTranslationExceptionTable

func (x *TranslationTaskDetails) GetTranslationExceptionTable() string

func (*TranslationTaskDetails) ProtoMessage

func (*TranslationTaskDetails) ProtoMessage()

func (*TranslationTaskDetails) ProtoReflect

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

func (*TranslationTaskDetails) Reset

func (x *TranslationTaskDetails) Reset()

func (*TranslationTaskDetails) String

func (x *TranslationTaskDetails) String() string

TranslationTaskDetails_BteqOptions

type TranslationTaskDetails_BteqOptions struct {
	// The BTEQ specific settings for the translation task.
	BteqOptions *BteqOptions `protobuf:"bytes,11,opt,name=bteq_options,json=bteqOptions,proto3,oneof"`
}

TranslationTaskDetails_FileEncoding

type TranslationTaskDetails_FileEncoding int32

The file encoding types.

TranslationTaskDetails_FILE_ENCODING_UNSPECIFIED, TranslationTaskDetails_UTF_8, TranslationTaskDetails_ISO_8859_1, TranslationTaskDetails_US_ASCII, TranslationTaskDetails_UTF_16, TranslationTaskDetails_UTF_16LE, TranslationTaskDetails_UTF_16BE

const (
	// File encoding setting is not specified.
	TranslationTaskDetails_FILE_ENCODING_UNSPECIFIED TranslationTaskDetails_FileEncoding = 0
	// File encoding is UTF_8.
	TranslationTaskDetails_UTF_8 TranslationTaskDetails_FileEncoding = 1
	// File encoding is ISO_8859_1.
	TranslationTaskDetails_ISO_8859_1 TranslationTaskDetails_FileEncoding = 2
	// File encoding is US_ASCII.
	TranslationTaskDetails_US_ASCII TranslationTaskDetails_FileEncoding = 3
	// File encoding is UTF_16.
	TranslationTaskDetails_UTF_16 TranslationTaskDetails_FileEncoding = 4
	// File encoding is UTF_16LE.
	TranslationTaskDetails_UTF_16LE TranslationTaskDetails_FileEncoding = 5
	// File encoding is UTF_16BE.
	TranslationTaskDetails_UTF_16BE TranslationTaskDetails_FileEncoding = 6
)

func (TranslationTaskDetails_FileEncoding) Descriptor

func (TranslationTaskDetails_FileEncoding) Descriptor() protoreflect.EnumDescriptor

func (TranslationTaskDetails_FileEncoding) Enum

func (x TranslationTaskDetails_FileEncoding) Enum() *TranslationTaskDetails_FileEncoding

func (TranslationTaskDetails_FileEncoding) EnumDescriptor

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

Deprecated: Use TranslationTaskDetails_FileEncoding.Descriptor instead.

func (TranslationTaskDetails_FileEncoding) Number

func (x TranslationTaskDetails_FileEncoding) Number() protoreflect.EnumNumber

func (TranslationTaskDetails_FileEncoding) String

func (x TranslationTaskDetails_FileEncoding) String() string

func (TranslationTaskDetails_FileEncoding) Type

func (TranslationTaskDetails_FileEncoding) Type() protoreflect.EnumType

TranslationTaskDetails_TeradataOptions

type TranslationTaskDetails_TeradataOptions struct {
	// The Teradata SQL specific settings for the translation task.
	TeradataOptions *TeradataOptions `protobuf:"bytes,10,opt,name=teradata_options,json=teradataOptions,proto3,oneof"`
}

TranslationTaskDetails_TokenType

type TranslationTaskDetails_TokenType int32

The special token data type.

TranslationTaskDetails_TOKEN_TYPE_UNSPECIFIED, TranslationTaskDetails_STRING, TranslationTaskDetails_INT64, TranslationTaskDetails_NUMERIC, TranslationTaskDetails_BOOL, TranslationTaskDetails_FLOAT64, TranslationTaskDetails_DATE, TranslationTaskDetails_TIMESTAMP

const (
	// Token type is not specified.
	TranslationTaskDetails_TOKEN_TYPE_UNSPECIFIED TranslationTaskDetails_TokenType = 0
	// Token type as string.
	TranslationTaskDetails_STRING TranslationTaskDetails_TokenType = 1
	// Token type as integer.
	TranslationTaskDetails_INT64 TranslationTaskDetails_TokenType = 2
	// Token type as numeric.
	TranslationTaskDetails_NUMERIC TranslationTaskDetails_TokenType = 3
	// Token type as boolean.
	TranslationTaskDetails_BOOL TranslationTaskDetails_TokenType = 4
	// Token type as float.
	TranslationTaskDetails_FLOAT64 TranslationTaskDetails_TokenType = 5
	// Token type as date.
	TranslationTaskDetails_DATE TranslationTaskDetails_TokenType = 6
	// Token type as timestamp.
	TranslationTaskDetails_TIMESTAMP TranslationTaskDetails_TokenType = 7
)

func (TranslationTaskDetails_TokenType) Descriptor

func (TranslationTaskDetails_TokenType) Descriptor() protoreflect.EnumDescriptor

func (TranslationTaskDetails_TokenType) Enum

func (x TranslationTaskDetails_TokenType) Enum() *TranslationTaskDetails_TokenType

func (TranslationTaskDetails_TokenType) EnumDescriptor

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

Deprecated: Use TranslationTaskDetails_TokenType.Descriptor instead.

func (TranslationTaskDetails_TokenType) Number

func (x TranslationTaskDetails_TokenType) Number() protoreflect.EnumNumber

func (TranslationTaskDetails_TokenType) String

func (x TranslationTaskDetails_TokenType) String() string

func (TranslationTaskDetails_TokenType) Type

func (TranslationTaskDetails_TokenType) Type() protoreflect.EnumType

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

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

TypedValue_BoolValue

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

TypedValue_DistributionValue

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

TypedValue_DoubleValue

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

TypedValue_Int64Value

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

TypedValue_StringValue

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

UnimplementedMigrationServiceServer

type UnimplementedMigrationServiceServer struct {
}

UnimplementedMigrationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedMigrationServiceServer) CreateMigrationWorkflow

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

func (UnimplementedMigrationServiceServer) DeleteMigrationWorkflow

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

func (UnimplementedMigrationServiceServer) GetMigrationSubtask

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

func (UnimplementedMigrationServiceServer) GetMigrationWorkflow

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

func (UnimplementedMigrationServiceServer) ListMigrationSubtasks

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

func (UnimplementedMigrationServiceServer) ListMigrationWorkflows

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

func (UnimplementedMigrationServiceServer) StartMigrationWorkflow

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

UnimplementedSqlTranslationServiceServer

type UnimplementedSqlTranslationServiceServer struct {
}

UnimplementedSqlTranslationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSqlTranslationServiceServer) TranslateQuery

func (UnimplementedSqlTranslationServiceServer) TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)

UnsafeMigrationServiceServer

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

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

UnsafeSqlTranslationServiceServer

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

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