- 1.64.0 (latest)
- 1.63.1
- 1.62.0
- 1.61.0
- 1.60.0
- 1.59.1
- 1.58.0
- 1.57.1
- 1.54.0
- 1.53.0
- 1.52.0
- 1.51.2
- 1.50.0
- 1.49.0
- 1.48.0
- 1.47.0
- 1.46.0
- 1.45.0
- 1.44.0
- 1.43.0
- 1.42.0
- 1.41.0
- 1.40.0
- 1.39.0
- 1.38.0
- 1.37.0
- 1.36.0
- 1.35.0
- 1.34.1
- 1.33.0
- 1.32.0
- 1.31.0
- 1.30.2
- 1.29.0
- 1.28.0
- 1.27.0
- 1.26.0
- 1.25.0
- 1.24.0
- 1.23.0
- 1.22.0
- 1.21.0
- 1.20.1
- 1.19.0
- 1.18.0
- 1.17.0
- 1.16.0
- 1.15.0
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
Functions
func RegisterMigrationServiceServer
func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)
func RegisterSqlTranslationServiceServer
func RegisterSqlTranslationServiceServer(s *grpc.Server, srv SqlTranslationServiceServer)
AssessmentOrchestrationResultDetails
type AssessmentOrchestrationResultDetails struct {
OutputTablesSchemaVersion string "" /* 140 byte string literal not displayed */
}
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 {
ProjectDataset *DatasetReference `protobuf:"bytes,1,opt,name=project_dataset,json=projectDataset,proto3" json:"project_dataset,omitempty"`
DefaultPathUri string `protobuf:"bytes,2,opt,name=default_path_uri,json=defaultPathUri,proto3" json:"default_path_uri,omitempty"`
FileReplacementMap map[string]string "" /* 205 byte string literal not displayed */
}
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 {
InputFileExclusionPrefixes []string "" /* 143 byte string literal not displayed */
}
The filter applied to fields of translation details.
func (*Filter) Descriptor
Deprecated: Use Filter.ProtoReflect.Descriptor instead.
func (*Filter) GetInputFileExclusionPrefixes
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
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 {
OutputIdentifierCase IdentifierSettings_IdentifierCase "" /* 203 byte string literal not displayed */
IdentifierRewriteMode IdentifierSettings_IdentifierRewriteMode "" /* 213 byte string literal not displayed */
}
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 (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://godoc.org/google.golang.org/grpc#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.
MigrationSubtask
type MigrationSubtask struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
State MigrationSubtask_State "" /* 132 byte string literal not displayed */
ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
ResourceErrorCount int32 `protobuf:"varint,13,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
Metrics []*TimeSeries `protobuf:"bytes,11,rep,name=metrics,proto3" json:"metrics,omitempty"`
}
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 {
TaskDetails isMigrationTask_TaskDetails `protobuf_oneof:"task_details"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Details *anypb.Any `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
State MigrationTask_State "" /* 129 byte string literal not displayed */
ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,5,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
OrchestrationResult *MigrationTaskOrchestrationResult `protobuf:"bytes,10,opt,name=orchestration_result,json=orchestrationResult,proto3" json:"orchestration_result,omitempty"`
}
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 {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Tasks map[string]*MigrationTask "" /* 151 byte string literal not displayed */
State MigrationWorkflow_State "" /* 133 byte string literal not displayed */
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
}
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
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
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 {
ErrorType SqlTranslationError_SqlTranslationErrorType "" /* 178 byte string literal not displayed */
ErrorDetail *SqlTranslationErrorDetail `protobuf:"bytes,2,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"`
}
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://godoc.org/google.golang.org/grpc#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.
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 {
Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
ValueType metric.MetricDescriptor_ValueType "" /* 132 byte string literal not displayed */
MetricKind metric.MetricDescriptor_MetricKind "" /* 136 byte string literal not displayed */
Points []*Point `protobuf:"bytes,4,rep,name=points,proto3" json:"points,omitempty"`
}
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 {
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
SourceDialect TranslateQueryRequest_SqlTranslationSourceDialect "" /* 196 byte string literal not displayed */
Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
}
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
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 {
LanguageOptions isTranslationTaskDetails_LanguageOptions `protobuf_oneof:"language_options"`
InputPath string `protobuf:"bytes,1,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
OutputPath string `protobuf:"bytes,2,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
FilePaths []*TranslationFileMapping `protobuf:"bytes,12,rep,name=file_paths,json=filePaths,proto3" json:"file_paths,omitempty"`
SchemaPath string `protobuf:"bytes,3,opt,name=schema_path,json=schemaPath,proto3" json:"schema_path,omitempty"`
FileEncoding TranslationTaskDetails_FileEncoding "" /* 179 byte string literal not displayed */
IdentifierSettings *IdentifierSettings `protobuf:"bytes,5,opt,name=identifier_settings,json=identifierSettings,proto3" json:"identifier_settings,omitempty"`
SpecialTokenMap map[string]TranslationTaskDetails_TokenType "" /* 275 byte string literal not displayed */
Filter *Filter `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
TranslationExceptionTable string "" /* 139 byte string literal not displayed */
}
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 can be embedded to have forward compatible implementations.
func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow
func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow
func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
func (*UnimplementedMigrationServiceServer) GetMigrationSubtask
func (*UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow
func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks
func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows
func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow
func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
UnimplementedSqlTranslationServiceServer
type UnimplementedSqlTranslationServiceServer struct {
}
UnimplementedSqlTranslationServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedSqlTranslationServiceServer) TranslateQuery
func (*UnimplementedSqlTranslationServiceServer) TranslateQuery(context.Context, *TranslateQueryRequest) (*TranslateQueryResponse, error)