migrationpb

package
v1.51.1 Latest Latest
Warning

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

 Go to latest Published: May 4, 2023 License: Apache-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for MigrationWorkflow_State.

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

Enum value maps for MigrationTask_State.

View Source 
var (
	MigrationSubtask_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "RUNNING",
		3: "SUCCEEDED",
		4: "FAILED",
		5: "PAUSED",
	}
	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.

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

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

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

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

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

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

View Source 
var File_google_cloud_bigquery_migration_v2alpha_assessment_task_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2alpha_migration_entities_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2alpha_migration_error_details_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2alpha_migration_metrics_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2alpha_migration_service_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_bigquery_migration_v2alpha_translation_service_proto protoreflect.FileDescriptor
View Source 
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)

Types

type AssessmentOrchestrationResultDetails 

type AssessmentOrchestrationResultDetails struct {

	// Optional. The version used for the output table schemas.
	OutputTablesSchemaVersion string `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

Details for an assessment task orchestration result.

func (*AssessmentOrchestrationResultDetails) Descriptor deprecated 

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

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

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

type 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 `` /* 205-byte string literal not displayed */
	// contains filtered or unexported fields
}

BTEQ translation task related settings.

func (*BteqOptions) Descriptor deprecated 

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

type CreateMigrationWorkflowRequest 

type CreateMigrationWorkflowRequest struct {

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

Request to create a migration workflow resource.

func (*CreateMigrationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateMigrationWorkflowRequest) GetMigrationWorkflow 

func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow

func (*CreateMigrationWorkflowRequest) GetParent 

func (x *CreateMigrationWorkflowRequest) GetParent() string

func (*CreateMigrationWorkflowRequest) ProtoMessage 

func (*CreateMigrationWorkflowRequest) ProtoMessage()

func (*CreateMigrationWorkflowRequest) ProtoReflect 

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

func (*CreateMigrationWorkflowRequest) Reset 

func (x *CreateMigrationWorkflowRequest) Reset()

func (*CreateMigrationWorkflowRequest) String 

func (x *CreateMigrationWorkflowRequest) String() string

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

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

type DeleteMigrationWorkflowRequest 

type DeleteMigrationWorkflowRequest struct {

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

A request to delete a previously created migration workflow.

func (*DeleteMigrationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteMigrationWorkflowRequest) GetName 

func (x *DeleteMigrationWorkflowRequest) GetName() string

func (*DeleteMigrationWorkflowRequest) ProtoMessage 

func (*DeleteMigrationWorkflowRequest) ProtoMessage()

func (*DeleteMigrationWorkflowRequest) ProtoReflect 

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

func (*DeleteMigrationWorkflowRequest) Reset 

func (x *DeleteMigrationWorkflowRequest) Reset()

func (*DeleteMigrationWorkflowRequest) String 

func (x *DeleteMigrationWorkflowRequest) String() string

type ErrorDetail 

type ErrorDetail struct {

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

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

func (*ErrorDetail) Descriptor deprecated 

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

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetErrorInfo 

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

func (*ErrorDetail) GetLocation 

func (x *ErrorDetail) GetLocation() *ErrorLocation

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect 

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

func (*ErrorDetail) Reset 

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String 

func (x *ErrorDetail) String() string

type ErrorLocation 

type ErrorLocation struct {

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

Holds information about where the error is located.

func (*ErrorLocation) Descriptor deprecated 

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

Deprecated: Use ErrorLocation.ProtoReflect.Descriptor instead.

func (*ErrorLocation) GetColumn 

func (x *ErrorLocation) GetColumn() int32

func (*ErrorLocation) GetLine 

func (x *ErrorLocation) GetLine() int32

func (*ErrorLocation) ProtoMessage 

func (*ErrorLocation) ProtoMessage()

func (*ErrorLocation) ProtoReflect 

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

func (*ErrorLocation) Reset 

func (x *ErrorLocation) Reset()

func (*ErrorLocation) String 

func (x *ErrorLocation) String() string

type Filter 

type Filter struct {

	// The list of prefixes used to exclude processing for input files.
	InputFileExclusionPrefixes []string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

The filter applied to fields of translation details.

func (*Filter) Descriptor deprecated 

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

type GetMigrationSubtaskRequest 

type GetMigrationSubtaskRequest struct {

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

A request to get a previously created migration subtasks.

func (*GetMigrationSubtaskRequest) Descriptor deprecated 

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

Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationSubtaskRequest) GetName 

func (x *GetMigrationSubtaskRequest) GetName() string

func (*GetMigrationSubtaskRequest) GetReadMask 

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

func (*GetMigrationSubtaskRequest) ProtoMessage 

func (*GetMigrationSubtaskRequest) ProtoMessage()

func (*GetMigrationSubtaskRequest) ProtoReflect 

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

func (*GetMigrationSubtaskRequest) Reset 

func (x *GetMigrationSubtaskRequest) Reset()

func (*GetMigrationSubtaskRequest) String 

func (x *GetMigrationSubtaskRequest) String() string

type GetMigrationWorkflowRequest 

type GetMigrationWorkflowRequest struct {

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

A request to get a previously created migration workflow.

func (*GetMigrationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationWorkflowRequest) GetName 

func (x *GetMigrationWorkflowRequest) GetName() string

func (*GetMigrationWorkflowRequest) GetReadMask 

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

func (*GetMigrationWorkflowRequest) ProtoMessage 

func (*GetMigrationWorkflowRequest) ProtoMessage()

func (*GetMigrationWorkflowRequest) ProtoReflect 

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

func (*GetMigrationWorkflowRequest) Reset 

func (x *GetMigrationWorkflowRequest) Reset()

func (*GetMigrationWorkflowRequest) String 

func (x *GetMigrationWorkflowRequest) String() string

type IdentifierSettings 

type IdentifierSettings struct {

	// The setting to control output queries' identifier case.
	OutputIdentifierCase IdentifierSettings_IdentifierCase `` /* 203-byte string literal not displayed */
	// Specifies the rewrite mode for SQL identifiers.
	IdentifierRewriteMode IdentifierSettings_IdentifierRewriteMode `` /* 213-byte string literal not displayed */
	// contains filtered or unexported fields
}

Settings related to SQL identifiers.

func (*IdentifierSettings) Descriptor deprecated 

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

type IdentifierSettings_IdentifierCase 

type IdentifierSettings_IdentifierCase int32

The identifier case type. 

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 deprecated 

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

type IdentifierSettings_IdentifierRewriteMode 

type IdentifierSettings_IdentifierRewriteMode int32

The SQL identifier rewrite mode. 

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 deprecated 

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

type ListMigrationSubtasksRequest 

type ListMigrationSubtasksRequest struct {

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

A request to list previously created migration subtasks.

func (*ListMigrationSubtasksRequest) Descriptor deprecated 

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

Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksRequest) GetFilter 

func (x *ListMigrationSubtasksRequest) GetFilter() string

func (*ListMigrationSubtasksRequest) GetPageSize 

func (x *ListMigrationSubtasksRequest) GetPageSize() int32

func (*ListMigrationSubtasksRequest) GetPageToken 

func (x *ListMigrationSubtasksRequest) GetPageToken() string

func (*ListMigrationSubtasksRequest) GetParent 

func (x *ListMigrationSubtasksRequest) GetParent() string

func (*ListMigrationSubtasksRequest) GetReadMask 

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

func (*ListMigrationSubtasksRequest) ProtoMessage 

func (*ListMigrationSubtasksRequest) ProtoMessage()

func (*ListMigrationSubtasksRequest) ProtoReflect 

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

func (*ListMigrationSubtasksRequest) Reset 

func (x *ListMigrationSubtasksRequest) Reset()

func (*ListMigrationSubtasksRequest) String 

func (x *ListMigrationSubtasksRequest) String() string

type ListMigrationSubtasksResponse 

type ListMigrationSubtasksResponse struct {

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

Response object for a `ListMigrationSubtasks` call.

func (*ListMigrationSubtasksResponse) Descriptor deprecated 

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

Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationSubtasksResponse) GetMigrationSubtasks 

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

func (*ListMigrationSubtasksResponse) GetNextPageToken 

func (x *ListMigrationSubtasksResponse) GetNextPageToken() string

func (*ListMigrationSubtasksResponse) ProtoMessage 

func (*ListMigrationSubtasksResponse) ProtoMessage()

func (*ListMigrationSubtasksResponse) ProtoReflect 

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

func (*ListMigrationSubtasksResponse) Reset 

func (x *ListMigrationSubtasksResponse) Reset()

func (*ListMigrationSubtasksResponse) String 

func (x *ListMigrationSubtasksResponse) String() string

type ListMigrationWorkflowsRequest 

type ListMigrationWorkflowsRequest struct {

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

A request to list previously created migration workflows.

func (*ListMigrationWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsRequest) GetPageSize 

func (x *ListMigrationWorkflowsRequest) GetPageSize() int32

func (*ListMigrationWorkflowsRequest) GetPageToken 

func (x *ListMigrationWorkflowsRequest) GetPageToken() string

func (*ListMigrationWorkflowsRequest) GetParent 

func (x *ListMigrationWorkflowsRequest) GetParent() string

func (*ListMigrationWorkflowsRequest) GetReadMask 

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

func (*ListMigrationWorkflowsRequest) ProtoMessage 

func (*ListMigrationWorkflowsRequest) ProtoMessage()

func (*ListMigrationWorkflowsRequest) ProtoReflect 

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

func (*ListMigrationWorkflowsRequest) Reset 

func (x *ListMigrationWorkflowsRequest) Reset()

func (*ListMigrationWorkflowsRequest) String 

func (x *ListMigrationWorkflowsRequest) String() string

type ListMigrationWorkflowsResponse 

type ListMigrationWorkflowsResponse struct {

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

Response object for a `ListMigrationWorkflows` call.

func (*ListMigrationWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListMigrationWorkflowsResponse) GetMigrationWorkflows 

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

func (*ListMigrationWorkflowsResponse) GetNextPageToken 

func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string

func (*ListMigrationWorkflowsResponse) ProtoMessage 

func (*ListMigrationWorkflowsResponse) ProtoMessage()

func (*ListMigrationWorkflowsResponse) ProtoReflect 

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

func (*ListMigrationWorkflowsResponse) Reset 

func (x *ListMigrationWorkflowsResponse) Reset()

func (*ListMigrationWorkflowsResponse) String 

func (x *ListMigrationWorkflowsResponse) String() string

type MigrationServiceClient 

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

MigrationServiceClient is the client API for MigrationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMigrationServiceClient 

func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

type MigrationServiceServer 

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

MigrationServiceServer is the server API for MigrationService service.

type MigrationSubtask 

type MigrationSubtask struct {

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

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

func (*MigrationSubtask) Descriptor deprecated 

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

Deprecated: Use MigrationSubtask.ProtoReflect.Descriptor instead.

func (*MigrationSubtask) GetCreateTime 

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

func (*MigrationSubtask) GetLastUpdateTime 

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

func (*MigrationSubtask) GetMetrics 

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

func (*MigrationSubtask) GetName 

func (x *MigrationSubtask) GetName() string

func (*MigrationSubtask) GetProcessingError 

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

func (*MigrationSubtask) GetResourceErrorCount 

func (x *MigrationSubtask) GetResourceErrorCount() int32

func (*MigrationSubtask) GetResourceErrorDetails 

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

func (*MigrationSubtask) GetState 

func (x *MigrationSubtask) GetState() MigrationSubtask_State

func (*MigrationSubtask) GetTaskId 

func (x *MigrationSubtask) GetTaskId() string

func (*MigrationSubtask) GetType 

func (x *MigrationSubtask) GetType() string

func (*MigrationSubtask) ProtoMessage 

func (*MigrationSubtask) ProtoMessage()

func (*MigrationSubtask) ProtoReflect 

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

func (*MigrationSubtask) Reset 

func (x *MigrationSubtask) Reset()

func (*MigrationSubtask) String 

func (x *MigrationSubtask) String() string

type MigrationSubtask_State 

type MigrationSubtask_State int32

Possible states of a migration subtask. 

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

func (MigrationSubtask_State) Descriptor 

func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationSubtask_State) Enum 

func (x MigrationSubtask_State) Enum() *MigrationSubtask_State

func (MigrationSubtask_State) EnumDescriptor deprecated 

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

Deprecated: Use MigrationSubtask_State.Descriptor instead.

func (MigrationSubtask_State) Number 

func (x MigrationSubtask_State) Number() protoreflect.EnumNumber

func (MigrationSubtask_State) String 

func (x MigrationSubtask_State) String() string

func (MigrationSubtask_State) Type 

func (MigrationSubtask_State) Type() protoreflect.EnumType

type MigrationTask 

type MigrationTask struct {

	// The details of the task.
	//
	// Types that are assignable to TaskDetails:
	//	*MigrationTask_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 `` /* 129-byte string literal not displayed */
	// Output only. An explanation that may be populated when the task is in FAILED state.
	ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,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 deprecated 

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

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

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

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

type MigrationTask_AssessmentTaskDetails 

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

type MigrationTask_State 

type MigrationTask_State int32

Possible states of a migration task. 

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

func (MigrationTask_State) Descriptor 

func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationTask_State) Enum 

func (x MigrationTask_State) Enum() *MigrationTask_State

func (MigrationTask_State) EnumDescriptor deprecated 

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

Deprecated: Use MigrationTask_State.Descriptor instead.

func (MigrationTask_State) Number 

func (x MigrationTask_State) Number() protoreflect.EnumNumber

func (MigrationTask_State) String 

func (x MigrationTask_State) String() string

func (MigrationTask_State) Type 

func (MigrationTask_State) Type() protoreflect.EnumType

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

type 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 `` /* 151-byte string literal not displayed */
	// Output only. That status of the workflow.
	State MigrationWorkflow_State `` /* 133-byte string literal not displayed */
	// Time when the workflow was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Time when the workflow was last updated.
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// contains filtered or unexported fields
}

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

func (*MigrationWorkflow) Descriptor deprecated 

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

Deprecated: Use MigrationWorkflow.ProtoReflect.Descriptor instead.

func (*MigrationWorkflow) GetCreateTime 

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

func (*MigrationWorkflow) GetDisplayName 

func (x *MigrationWorkflow) GetDisplayName() string

func (*MigrationWorkflow) GetLastUpdateTime 

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

func (*MigrationWorkflow) GetName 

func (x *MigrationWorkflow) GetName() string

func (*MigrationWorkflow) GetState 

func (x *MigrationWorkflow) GetState() MigrationWorkflow_State

func (*MigrationWorkflow) GetTasks 

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

func (*MigrationWorkflow) ProtoMessage 

func (*MigrationWorkflow) ProtoMessage()

func (*MigrationWorkflow) ProtoReflect 

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

func (*MigrationWorkflow) Reset 

func (x *MigrationWorkflow) Reset()

func (*MigrationWorkflow) String 

func (x *MigrationWorkflow) String() string

type MigrationWorkflow_State 

type MigrationWorkflow_State int32

Possible migration workflow states. 

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

func (MigrationWorkflow_State) Descriptor 

func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor

func (MigrationWorkflow_State) Enum 

func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State

func (MigrationWorkflow_State) EnumDescriptor deprecated 

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

Deprecated: Use MigrationWorkflow_State.Descriptor instead.

func (MigrationWorkflow_State) Number 

func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber

func (MigrationWorkflow_State) String 

func (x MigrationWorkflow_State) String() string

func (MigrationWorkflow_State) Type 

func (MigrationWorkflow_State) Type() protoreflect.EnumType

type Point 

type Point struct {

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

A single data point in a time series.

func (*Point) Descriptor deprecated 

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

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetInterval 

func (x *Point) GetInterval() *TimeInterval

func (*Point) GetValue 

func (x *Point) GetValue() *TypedValue

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) ProtoReflect 

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

func (*Point) Reset 

func (x *Point) Reset()

func (*Point) String 

func (x *Point) String() string

type ResourceErrorDetail 

type ResourceErrorDetail struct {

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

Provides details for errors and the corresponding resources.

func (*ResourceErrorDetail) Descriptor deprecated 

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

Deprecated: Use ResourceErrorDetail.ProtoReflect.Descriptor instead.

func (*ResourceErrorDetail) GetErrorCount 

func (x *ResourceErrorDetail) GetErrorCount() int32

func (*ResourceErrorDetail) GetErrorDetails 

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

func (*ResourceErrorDetail) GetResourceInfo 

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

func (*ResourceErrorDetail) ProtoMessage 

func (*ResourceErrorDetail) ProtoMessage()

func (*ResourceErrorDetail) ProtoReflect 

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

func (*ResourceErrorDetail) Reset 

func (x *ResourceErrorDetail) Reset()

func (*ResourceErrorDetail) String 

func (x *ResourceErrorDetail) String() string

type SqlTranslationError 

type SqlTranslationError struct {

	// The type of SQL translation error.
	ErrorType SqlTranslationError_SqlTranslationErrorType `` /* 178-byte string literal not displayed */
	// 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 deprecated 

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

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

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

type SqlTranslationError_SqlTranslationErrorType 

type SqlTranslationError_SqlTranslationErrorType int32

The error type of the SQL translation job. 

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 deprecated 

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

type 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

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

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

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

type StartMigrationWorkflowRequest 

type StartMigrationWorkflowRequest struct {

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

A request to start a previously created migration workflow.

func (*StartMigrationWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartMigrationWorkflowRequest) GetName 

func (x *StartMigrationWorkflowRequest) GetName() string

func (*StartMigrationWorkflowRequest) ProtoMessage 

func (*StartMigrationWorkflowRequest) ProtoMessage()

func (*StartMigrationWorkflowRequest) ProtoReflect 

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

func (*StartMigrationWorkflowRequest) Reset 

func (x *StartMigrationWorkflowRequest) Reset()

func (*StartMigrationWorkflowRequest) String 

func (x *StartMigrationWorkflowRequest) String() string

type TeradataOptions 

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

Teradata SQL specific translation task related settings.

func (*TeradataOptions) Descriptor deprecated 

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

type TimeInterval 

type TimeInterval struct {

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

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

func (*TimeInterval) Descriptor deprecated 

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

Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.

func (*TimeInterval) GetEndTime 

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

func (*TimeInterval) GetStartTime 

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

func (*TimeInterval) ProtoMessage 

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) ProtoReflect 

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

func (*TimeInterval) Reset 

func (x *TimeInterval) Reset()

func (*TimeInterval) String 

func (x *TimeInterval) String() string

type TimeSeries 

type TimeSeries struct {

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

The metrics object for a SubTask.

func (*TimeSeries) Descriptor deprecated 

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

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetMetric 

func (x *TimeSeries) GetMetric() string

func (*TimeSeries) GetMetricKind 

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

func (*TimeSeries) GetPoints 

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

func (*TimeSeries) GetValueType 

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

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect 

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

func (*TimeSeries) Reset 

func (x *TimeSeries) Reset()

func (*TimeSeries) String 

func (x *TimeSeries) String() string

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

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

type TranslateQueryRequest_SqlTranslationSourceDialect 

type TranslateQueryRequest_SqlTranslationSourceDialect int32

Supported SQL translation source dialects. 

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 deprecated 

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

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 deprecated 

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

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

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

type 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 `` /* 179-byte string literal not displayed */
	// 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 `` /* 275-byte string literal not displayed */
	// 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 `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*TranslationTaskDetails) Descriptor deprecated 

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

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

type TranslationTaskDetails_FileEncoding 

type TranslationTaskDetails_FileEncoding int32

The file encoding types. 

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 deprecated 

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

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

type TranslationTaskDetails_TokenType 

type TranslationTaskDetails_TokenType int32

The special token data type. 

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 deprecated 

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

type TypedValue 

type TypedValue struct {

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

A single strongly-typed value.

func (*TypedValue) Descriptor deprecated 

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

Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.

func (*TypedValue) GetBoolValue 

func (x *TypedValue) GetBoolValue() bool

func (*TypedValue) GetDistributionValue 

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

func (*TypedValue) GetDoubleValue 

func (x *TypedValue) GetDoubleValue() float64

func (*TypedValue) GetInt64Value 

func (x *TypedValue) GetInt64Value() int64

func (*TypedValue) GetStringValue 

func (x *TypedValue) GetStringValue() string

func (*TypedValue) GetValue 

func (m *TypedValue) GetValue() isTypedValue_Value

func (*TypedValue) ProtoMessage 

func (*TypedValue) ProtoMessage()

func (*TypedValue) ProtoReflect 

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

func (*TypedValue) Reset 

func (x *TypedValue) Reset()

func (*TypedValue) String 

func (x *TypedValue) String() string

type TypedValue_BoolValue 

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

type TypedValue_DistributionValue 

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

type TypedValue_DoubleValue 

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

type TypedValue_Int64Value 

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

type TypedValue_StringValue 

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

type UnimplementedMigrationServiceServer 

type UnimplementedMigrationServiceServer struct {
}

UnimplementedMigrationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow 

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

func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow 

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

func (*UnimplementedMigrationServiceServer) GetMigrationSubtask 

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

func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow 

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

func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks 

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

func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows 

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

func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow 

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

type UnimplementedSqlTranslationServiceServer 

type UnimplementedSqlTranslationServiceServer struct {
}

UnimplementedSqlTranslationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSqlTranslationServiceServer) TranslateQuery 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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