migrationpb
packageThis package is not in the latest version of its module.
Details
Validgo.mod file
The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license
Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version
Modules with tagged versions give importers more predictable builds.
Stable version
When a project reaches major version v1 it is considered stable.
- Learn more about best practices
Repository
Links
Documentation¶
Index¶
- Constants
- Variables
- func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)
- type AzureSynapseDialect
- type BigQueryDialect
- type CreateMigrationWorkflowRequest
- func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow
- func (x *CreateMigrationWorkflowRequest) GetParent() string
- func (*CreateMigrationWorkflowRequest) ProtoMessage()
- func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *CreateMigrationWorkflowRequest) Reset()
- func (x *CreateMigrationWorkflowRequest) String() string
- type DB2Dialect
- type DeleteMigrationWorkflowRequest
- func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMigrationWorkflowRequest) GetName() string
- func (*DeleteMigrationWorkflowRequest) ProtoMessage()
- func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteMigrationWorkflowRequest) Reset()
- func (x *DeleteMigrationWorkflowRequest) String() string
- type Dialect
- func (*Dialect) Descriptor() ([]byte, []int)deprecated
- func (x *Dialect) GetAzureSynapseDialect() *AzureSynapseDialect
- func (x *Dialect) GetBigqueryDialect() *BigQueryDialect
- func (x *Dialect) GetDb2Dialect() *DB2Dialect
- func (m *Dialect) GetDialectValue() isDialect_DialectValue
- func (x *Dialect) GetGreenplumDialect() *GreenplumDialect
- func (x *Dialect) GetHiveqlDialect() *HiveQLDialect
- func (x *Dialect) GetMysqlDialect() *MySQLDialect
- func (x *Dialect) GetNetezzaDialect() *NetezzaDialect
- func (x *Dialect) GetOracleDialect() *OracleDialect
- func (x *Dialect) GetPostgresqlDialect() *PostgresqlDialect
- func (x *Dialect) GetPrestoDialect() *PrestoDialect
- func (x *Dialect) GetRedshiftDialect() *RedshiftDialect
- func (x *Dialect) GetSnowflakeDialect() *SnowflakeDialect
- func (x *Dialect) GetSparksqlDialect() *SparkSQLDialect
- func (x *Dialect) GetSqlServerDialect() *SQLServerDialect
- func (x *Dialect) GetSqliteDialect() *SQLiteDialect
- func (x *Dialect) GetTeradataDialect() *TeradataDialect
- func (x *Dialect) GetVerticaDialect() *VerticaDialect
- func (*Dialect) ProtoMessage()
- func (x *Dialect) ProtoReflect() protoreflect.Message
- func (x *Dialect) Reset()
- func (x *Dialect) String() string
- type Dialect_AzureSynapseDialect
- type Dialect_BigqueryDialect
- type Dialect_Db2Dialect
- type Dialect_GreenplumDialect
- type Dialect_HiveqlDialect
- type Dialect_MysqlDialect
- type Dialect_NetezzaDialect
- type Dialect_OracleDialect
- type Dialect_PostgresqlDialect
- type Dialect_PrestoDialect
- type Dialect_RedshiftDialect
- type Dialect_SnowflakeDialect
- type Dialect_SparksqlDialect
- type Dialect_SqlServerDialect
- type Dialect_SqliteDialect
- type Dialect_TeradataDialect
- type Dialect_VerticaDialect
- type ErrorDetail
- func (*ErrorDetail) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorDetail) GetErrorInfo() *errdetails.ErrorInfo
- func (x *ErrorDetail) GetLocation() *ErrorLocation
- func (*ErrorDetail) ProtoMessage()
- func (x *ErrorDetail) ProtoReflect() protoreflect.Message
- func (x *ErrorDetail) Reset()
- func (x *ErrorDetail) String() string
- type ErrorLocation
- func (*ErrorLocation) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorLocation) GetColumn() int32
- func (x *ErrorLocation) GetLine() int32
- func (*ErrorLocation) ProtoMessage()
- func (x *ErrorLocation) ProtoReflect() protoreflect.Message
- func (x *ErrorLocation) Reset()
- func (x *ErrorLocation) String() string
- type GcsReportLogMessage
- func (*GcsReportLogMessage) Descriptor() ([]byte, []int)deprecated
- func (x *GcsReportLogMessage) GetAction() string
- func (x *GcsReportLogMessage) GetCategory() string
- func (x *GcsReportLogMessage) GetEffect() string
- func (x *GcsReportLogMessage) GetFilePath() string
- func (x *GcsReportLogMessage) GetFilename() string
- func (x *GcsReportLogMessage) GetMessage() string
- func (x *GcsReportLogMessage) GetObjectName() string
- func (x *GcsReportLogMessage) GetScriptContext() string
- func (x *GcsReportLogMessage) GetSeverity() string
- func (x *GcsReportLogMessage) GetSourceScriptColumn() int32
- func (x *GcsReportLogMessage) GetSourceScriptLine() int32
- func (*GcsReportLogMessage) ProtoMessage()
- func (x *GcsReportLogMessage) ProtoReflect() protoreflect.Message
- func (x *GcsReportLogMessage) Reset()
- func (x *GcsReportLogMessage) String() string
- type GetMigrationSubtaskRequest
- func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMigrationSubtaskRequest) GetName() string
- func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (*GetMigrationSubtaskRequest) ProtoMessage()
- func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message
- func (x *GetMigrationSubtaskRequest) Reset()
- func (x *GetMigrationSubtaskRequest) String() string
- type GetMigrationWorkflowRequest
- func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMigrationWorkflowRequest) GetName() string
- func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (*GetMigrationWorkflowRequest) ProtoMessage()
- func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *GetMigrationWorkflowRequest) Reset()
- func (x *GetMigrationWorkflowRequest) String() string
- type GreenplumDialect
- type HiveQLDialect
- type ListMigrationSubtasksRequest
- func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationSubtasksRequest) GetFilter() string
- func (x *ListMigrationSubtasksRequest) GetPageSize() int32
- func (x *ListMigrationSubtasksRequest) GetPageToken() string
- func (x *ListMigrationSubtasksRequest) GetParent() string
- func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (*ListMigrationSubtasksRequest) ProtoMessage()
- func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListMigrationSubtasksRequest) Reset()
- func (x *ListMigrationSubtasksRequest) String() string
- type ListMigrationSubtasksResponse
- func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask
- func (x *ListMigrationSubtasksResponse) GetNextPageToken() string
- func (*ListMigrationSubtasksResponse) ProtoMessage()
- func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message
- func (x *ListMigrationSubtasksResponse) Reset()
- func (x *ListMigrationSubtasksResponse) String() string
- type ListMigrationWorkflowsRequest
- func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationWorkflowsRequest) GetPageSize() int32
- func (x *ListMigrationWorkflowsRequest) GetPageToken() string
- func (x *ListMigrationWorkflowsRequest) GetParent() string
- func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (*ListMigrationWorkflowsRequest) ProtoMessage()
- func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message
- func (x *ListMigrationWorkflowsRequest) Reset()
- func (x *ListMigrationWorkflowsRequest) String() string
- type ListMigrationWorkflowsResponse
- func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow
- func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string
- func (*ListMigrationWorkflowsResponse) ProtoMessage()
- func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMigrationWorkflowsResponse) Reset()
- func (x *ListMigrationWorkflowsResponse) String() string
- type Literal
- func (*Literal) Descriptor() ([]byte, []int)deprecated
- func (x *Literal) GetLiteralBytes() []byte
- func (m *Literal) GetLiteralData() isLiteral_LiteralData
- func (x *Literal) GetLiteralString() string
- func (x *Literal) GetRelativePath() string
- func (*Literal) ProtoMessage()
- func (x *Literal) ProtoReflect() protoreflect.Message
- func (x *Literal) Reset()
- func (x *Literal) String() string
- type Literal_LiteralBytes
- type Literal_LiteralString
- type MigrationServiceClient
- type MigrationServiceServer
- type MigrationSubtask
- func (*MigrationSubtask) Descriptor() ([]byte, []int)deprecated
- func (x *MigrationSubtask) GetCreateTime() *timestamppb.Timestamp
- func (x *MigrationSubtask) GetLastUpdateTime() *timestamppb.Timestamp
- func (x *MigrationSubtask) GetMetrics() []*TimeSeries
- func (x *MigrationSubtask) GetName() string
- func (x *MigrationSubtask) GetProcessingError() *errdetails.ErrorInfo
- func (x *MigrationSubtask) GetResourceErrorCount() int32
- func (x *MigrationSubtask) GetResourceErrorDetails() []*ResourceErrorDetail
- func (x *MigrationSubtask) GetState() MigrationSubtask_State
- func (x *MigrationSubtask) GetTaskId() string
- func (x *MigrationSubtask) GetType() string
- func (*MigrationSubtask) ProtoMessage()
- func (x *MigrationSubtask) ProtoReflect() protoreflect.Message
- func (x *MigrationSubtask) Reset()
- func (x *MigrationSubtask) String() string
- type MigrationSubtask_State
- func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationSubtask_State) Enum() *MigrationSubtask_State
- func (MigrationSubtask_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationSubtask_State) Number() protoreflect.EnumNumber
- func (x MigrationSubtask_State) String() string
- func (MigrationSubtask_State) Type() protoreflect.EnumType
- type MigrationTask
- func (*MigrationTask) Descriptor() ([]byte, []int)deprecated
- func (x *MigrationTask) GetCreateTime() *timestamppb.Timestamp
- func (x *MigrationTask) GetId() string
- func (x *MigrationTask) GetLastUpdateTime() *timestamppb.Timestamp
- func (x *MigrationTask) GetMetrics() []*TimeSeries
- func (x *MigrationTask) GetProcessingError() *errdetails.ErrorInfo
- func (x *MigrationTask) GetResourceErrorCount() int32
- func (x *MigrationTask) GetResourceErrorDetails() []*ResourceErrorDetail
- func (x *MigrationTask) GetState() MigrationTask_State
- func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails
- func (x *MigrationTask) GetTaskResult() *MigrationTaskResult
- func (x *MigrationTask) GetTotalProcessingErrorCount() int32
- func (x *MigrationTask) GetTotalResourceErrorCount() int32
- func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails
- func (x *MigrationTask) GetTranslationDetails() *TranslationDetails
- func (x *MigrationTask) GetType() string
- func (*MigrationTask) ProtoMessage()
- func (x *MigrationTask) ProtoReflect() protoreflect.Message
- func (x *MigrationTask) Reset()
- func (x *MigrationTask) String() string
- type MigrationTaskResult
- func (*MigrationTaskResult) Descriptor() ([]byte, []int)deprecated
- func (m *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details
- func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult
- func (*MigrationTaskResult) ProtoMessage()
- func (x *MigrationTaskResult) ProtoReflect() protoreflect.Message
- func (x *MigrationTaskResult) Reset()
- func (x *MigrationTaskResult) String() string
- type MigrationTaskResult_TranslationTaskResult
- type MigrationTask_State
- func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationTask_State) Enum() *MigrationTask_State
- func (MigrationTask_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationTask_State) Number() protoreflect.EnumNumber
- func (x MigrationTask_State) String() string
- func (MigrationTask_State) Type() protoreflect.EnumType
- type MigrationTask_TranslationConfigDetails
- type MigrationTask_TranslationDetails
- type MigrationWorkflow
- func (*MigrationWorkflow) Descriptor() ([]byte, []int)deprecated
- func (x *MigrationWorkflow) GetCreateTime() *timestamppb.Timestamp
- func (x *MigrationWorkflow) GetDisplayName() string
- func (x *MigrationWorkflow) GetLastUpdateTime() *timestamppb.Timestamp
- func (x *MigrationWorkflow) GetName() string
- func (x *MigrationWorkflow) GetState() MigrationWorkflow_State
- func (x *MigrationWorkflow) GetTasks() map[string]*MigrationTask
- func (*MigrationWorkflow) ProtoMessage()
- func (x *MigrationWorkflow) ProtoReflect() protoreflect.Message
- func (x *MigrationWorkflow) Reset()
- func (x *MigrationWorkflow) String() string
- type MigrationWorkflow_State
- func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State
- func (MigrationWorkflow_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber
- func (x MigrationWorkflow_State) String() string
- func (MigrationWorkflow_State) Type() protoreflect.EnumType
- type MySQLDialect
- type NameMappingKey
- func (*NameMappingKey) Descriptor() ([]byte, []int)deprecated
- func (x *NameMappingKey) GetAttribute() string
- func (x *NameMappingKey) GetDatabase() string
- func (x *NameMappingKey) GetRelation() string
- func (x *NameMappingKey) GetSchema() string
- func (x *NameMappingKey) GetType() NameMappingKey_Type
- func (*NameMappingKey) ProtoMessage()
- func (x *NameMappingKey) ProtoReflect() protoreflect.Message
- func (x *NameMappingKey) Reset()
- func (x *NameMappingKey) String() string
- type NameMappingKey_Type
- func (NameMappingKey_Type) Descriptor() protoreflect.EnumDescriptor
- func (x NameMappingKey_Type) Enum() *NameMappingKey_Type
- func (NameMappingKey_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x NameMappingKey_Type) Number() protoreflect.EnumNumber
- func (x NameMappingKey_Type) String() string
- func (NameMappingKey_Type) Type() protoreflect.EnumType
- type NameMappingValue
- func (*NameMappingValue) Descriptor() ([]byte, []int)deprecated
- func (x *NameMappingValue) GetAttribute() string
- func (x *NameMappingValue) GetDatabase() string
- func (x *NameMappingValue) GetRelation() string
- func (x *NameMappingValue) GetSchema() string
- func (*NameMappingValue) ProtoMessage()
- func (x *NameMappingValue) ProtoReflect() protoreflect.Message
- func (x *NameMappingValue) Reset()
- func (x *NameMappingValue) String() string
- type NetezzaDialect
- type ObjectNameMapping
- func (*ObjectNameMapping) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectNameMapping) GetSource() *NameMappingKey
- func (x *ObjectNameMapping) GetTarget() *NameMappingValue
- func (*ObjectNameMapping) ProtoMessage()
- func (x *ObjectNameMapping) ProtoReflect() protoreflect.Message
- func (x *ObjectNameMapping) Reset()
- func (x *ObjectNameMapping) String() string
- type ObjectNameMappingList
- func (*ObjectNameMappingList) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectNameMappingList) GetNameMap() []*ObjectNameMapping
- func (*ObjectNameMappingList) ProtoMessage()
- func (x *ObjectNameMappingList) ProtoReflect() protoreflect.Message
- func (x *ObjectNameMappingList) Reset()
- func (x *ObjectNameMappingList) String() string
- type OracleDialect
- type Point
- type PostgresqlDialect
- type PrestoDialect
- type RedshiftDialect
- type ResourceErrorDetail
- func (*ResourceErrorDetail) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceErrorDetail) GetErrorCount() int32
- func (x *ResourceErrorDetail) GetErrorDetails() []*ErrorDetail
- func (x *ResourceErrorDetail) GetResourceInfo() *errdetails.ResourceInfo
- func (*ResourceErrorDetail) ProtoMessage()
- func (x *ResourceErrorDetail) ProtoReflect() protoreflect.Message
- func (x *ResourceErrorDetail) Reset()
- func (x *ResourceErrorDetail) String() string
- type SQLServerDialect
- type SQLiteDialect
- type SnowflakeDialect
- type SourceEnv
- func (*SourceEnv) Descriptor() ([]byte, []int)deprecated
- func (x *SourceEnv) GetDefaultDatabase() string
- func (x *SourceEnv) GetMetadataStoreDataset() string
- func (x *SourceEnv) GetSchemaSearchPath() []string
- func (*SourceEnv) ProtoMessage()
- func (x *SourceEnv) ProtoReflect() protoreflect.Message
- func (x *SourceEnv) Reset()
- func (x *SourceEnv) String() string
- type SourceEnvironment
- func (*SourceEnvironment) Descriptor() ([]byte, []int)deprecated
- func (x *SourceEnvironment) GetDefaultDatabase() string
- func (x *SourceEnvironment) GetMetadataStoreDataset() string
- func (x *SourceEnvironment) GetSchemaSearchPath() []string
- func (*SourceEnvironment) ProtoMessage()
- func (x *SourceEnvironment) ProtoReflect() protoreflect.Message
- func (x *SourceEnvironment) Reset()
- func (x *SourceEnvironment) String() string
- type SourceSpec
- func (*SourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *SourceSpec) GetBaseUri() string
- func (x *SourceSpec) GetEncoding() string
- func (x *SourceSpec) GetLiteral() *Literal
- func (m *SourceSpec) GetSource() isSourceSpec_Source
- func (*SourceSpec) ProtoMessage()
- func (x *SourceSpec) ProtoReflect() protoreflect.Message
- func (x *SourceSpec) Reset()
- func (x *SourceSpec) String() string
- type SourceSpec_BaseUri
- type SourceSpec_Literal
- type SourceTargetMapping
- func (*SourceTargetMapping) Descriptor() ([]byte, []int)deprecated
- func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec
- func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec
- func (*SourceTargetMapping) ProtoMessage()
- func (x *SourceTargetMapping) ProtoReflect() protoreflect.Message
- func (x *SourceTargetMapping) Reset()
- func (x *SourceTargetMapping) String() string
- type SparkSQLDialect
- type StartMigrationWorkflowRequest
- func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartMigrationWorkflowRequest) GetName() string
- func (*StartMigrationWorkflowRequest) ProtoMessage()
- func (x *StartMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *StartMigrationWorkflowRequest) Reset()
- func (x *StartMigrationWorkflowRequest) String() string
- type TargetSpec
- type TeradataDialect
- type TeradataDialect_Mode
- func (TeradataDialect_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x TeradataDialect_Mode) Enum() *TeradataDialect_Mode
- func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x TeradataDialect_Mode) Number() protoreflect.EnumNumber
- func (x TeradataDialect_Mode) String() string
- func (TeradataDialect_Mode) Type() protoreflect.EnumType
- type TimeInterval
- func (*TimeInterval) Descriptor() ([]byte, []int)deprecated
- func (x *TimeInterval) GetEndTime() *timestamppb.Timestamp
- func (x *TimeInterval) GetStartTime() *timestamppb.Timestamp
- func (*TimeInterval) ProtoMessage()
- func (x *TimeInterval) ProtoReflect() protoreflect.Message
- func (x *TimeInterval) Reset()
- func (x *TimeInterval) String() string
- type TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)deprecated
- func (x *TimeSeries) GetMetric() string
- func (x *TimeSeries) GetMetricKind() metric.MetricDescriptor_MetricKind
- func (x *TimeSeries) GetPoints() []*Point
- func (x *TimeSeries) GetValueType() metric.MetricDescriptor_ValueType
- func (*TimeSeries) ProtoMessage()
- func (x *TimeSeries) ProtoReflect() protoreflect.Message
- func (x *TimeSeries) Reset()
- func (x *TimeSeries) String() string
- type TranslationConfigDetails
- func (*TranslationConfigDetails) Descriptor() ([]byte, []int)deprecated
- func (x *TranslationConfigDetails) GetGcsSourcePath() string
- func (x *TranslationConfigDetails) GetGcsTargetPath() string
- func (x *TranslationConfigDetails) GetNameMappingList() *ObjectNameMappingList
- func (m *TranslationConfigDetails) GetOutputNameMapping() isTranslationConfigDetails_OutputNameMapping
- func (x *TranslationConfigDetails) GetRequestSource() string
- func (x *TranslationConfigDetails) GetSourceDialect() *Dialect
- func (x *TranslationConfigDetails) GetSourceEnv() *SourceEnv
- func (m *TranslationConfigDetails) GetSourceLocation() isTranslationConfigDetails_SourceLocation
- func (x *TranslationConfigDetails) GetTargetDialect() *Dialect
- func (m *TranslationConfigDetails) GetTargetLocation() isTranslationConfigDetails_TargetLocation
- func (x *TranslationConfigDetails) GetTargetTypes() []string
- func (*TranslationConfigDetails) ProtoMessage()
- func (x *TranslationConfigDetails) ProtoReflect() protoreflect.Message
- func (x *TranslationConfigDetails) Reset()
- func (x *TranslationConfigDetails) String() string
- type TranslationConfigDetails_GcsSourcePath
- type TranslationConfigDetails_GcsTargetPath
- type TranslationConfigDetails_NameMappingList
- type TranslationDetails
- func (*TranslationDetails) Descriptor() ([]byte, []int)deprecated
- func (x *TranslationDetails) GetSourceEnvironment() *SourceEnvironment
- func (x *TranslationDetails) GetSourceTargetMapping() []*SourceTargetMapping
- func (x *TranslationDetails) GetTargetBaseUri() string
- func (x *TranslationDetails) GetTargetReturnLiterals() []string
- func (x *TranslationDetails) GetTargetTypes() []string
- func (*TranslationDetails) ProtoMessage()
- func (x *TranslationDetails) ProtoReflect() protoreflect.Message
- func (x *TranslationDetails) Reset()
- func (x *TranslationDetails) String() string
- type TranslationReportRecord
- func (*TranslationReportRecord) Descriptor() ([]byte, []int)deprecated
- func (x *TranslationReportRecord) GetCategory() string
- func (x *TranslationReportRecord) GetMessage() string
- func (x *TranslationReportRecord) GetScriptColumn() int32
- func (x *TranslationReportRecord) GetScriptLine() int32
- func (x *TranslationReportRecord) GetSeverity() TranslationReportRecord_Severity
- func (*TranslationReportRecord) ProtoMessage()
- func (x *TranslationReportRecord) ProtoReflect() protoreflect.Message
- func (x *TranslationReportRecord) Reset()
- func (x *TranslationReportRecord) String() string
- type TranslationReportRecord_Severity
- func (TranslationReportRecord_Severity) Descriptor() protoreflect.EnumDescriptor
- func (x TranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity
- func (TranslationReportRecord_Severity) EnumDescriptor() ([]byte, []int)deprecated
- func (x TranslationReportRecord_Severity) Number() protoreflect.EnumNumber
- func (x TranslationReportRecord_Severity) String() string
- func (TranslationReportRecord_Severity) Type() protoreflect.EnumType
- type TranslationTaskResult
- func (*TranslationTaskResult) Descriptor() ([]byte, []int)deprecated
- func (x *TranslationTaskResult) GetReportLogMessages() []*GcsReportLogMessage
- func (x *TranslationTaskResult) GetTranslatedLiterals() []*Literal
- func (*TranslationTaskResult) ProtoMessage()
- func (x *TranslationTaskResult) ProtoReflect() protoreflect.Message
- func (x *TranslationTaskResult) Reset()
- func (x *TranslationTaskResult) String() string
- type TypedValue
- func (*TypedValue) Descriptor() ([]byte, []int)deprecated
- func (x *TypedValue) GetBoolValue() bool
- func (x *TypedValue) GetDistributionValue() *distribution.Distribution
- func (x *TypedValue) GetDoubleValue() float64
- func (x *TypedValue) GetInt64Value() int64
- func (x *TypedValue) GetStringValue() string
- func (m *TypedValue) GetValue() isTypedValue_Value
- func (*TypedValue) ProtoMessage()
- func (x *TypedValue) ProtoReflect() protoreflect.Message
- func (x *TypedValue) Reset()
- func (x *TypedValue) String() string
- type TypedValue_BoolValue
- type TypedValue_DistributionValue
- type TypedValue_DoubleValue
- type TypedValue_Int64Value
- type TypedValue_StringValue
- type UnimplementedMigrationServiceServer
- func (UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
- func (UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
- func (UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
- func (UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
- func (UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
- func (UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
- func (UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
- type UnsafeMigrationServiceServer
- type VerticaDialect
Constants¶
const (MigrationService_CreateMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/CreateMigrationWorkflow"MigrationService_GetMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/GetMigrationWorkflow"MigrationService_ListMigrationWorkflows_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/ListMigrationWorkflows"MigrationService_DeleteMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/DeleteMigrationWorkflow"MigrationService_StartMigrationWorkflow_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/StartMigrationWorkflow"MigrationService_GetMigrationSubtask_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/GetMigrationSubtask"MigrationService_ListMigrationSubtasks_FullMethodName = "/google.cloud.bigquery.migration.v2.MigrationService/ListMigrationSubtasks")
Variables¶
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.
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.
var (MigrationSubtask_State_name = map[int32]string{0: "STATE_UNSPECIFIED",1: "ACTIVE",2: "RUNNING",3: "SUCCEEDED",4: "FAILED",5: "PAUSED",6: "PENDING_DEPENDENCY",}MigrationSubtask_State_value = map[string]int32{"STATE_UNSPECIFIED": 0,"ACTIVE": 1,"RUNNING": 2,"SUCCEEDED": 3,"FAILED": 4,"PAUSED": 5,"PENDING_DEPENDENCY": 6,})
Enum value maps for MigrationSubtask_State.
var (TeradataDialect_Mode_name = map[int32]string{0: "MODE_UNSPECIFIED",1: "SQL",2: "BTEQ",}TeradataDialect_Mode_value = map[string]int32{"MODE_UNSPECIFIED": 0,"SQL": 1,"BTEQ": 2,})
Enum value maps for TeradataDialect_Mode.
var (NameMappingKey_Type_name = map[int32]string{0: "TYPE_UNSPECIFIED",1: "DATABASE",2: "SCHEMA",3: "RELATION",4: "ATTRIBUTE",5: "RELATION_ALIAS",6: "ATTRIBUTE_ALIAS",7: "FUNCTION",}NameMappingKey_Type_value = map[string]int32{"TYPE_UNSPECIFIED": 0,"DATABASE": 1,"SCHEMA": 2,"RELATION": 3,"ATTRIBUTE": 4,"RELATION_ALIAS": 5,"ATTRIBUTE_ALIAS": 6,"FUNCTION": 7,})
Enum value maps for NameMappingKey_Type.
var (TranslationReportRecord_Severity_name = map[int32]string{0: "SEVERITY_UNSPECIFIED",1: "INFO",2: "WARNING",3: "ERROR",}TranslationReportRecord_Severity_value = map[string]int32{"SEVERITY_UNSPECIFIED": 0,"INFO": 1,"WARNING": 2,"ERROR": 3,})
Enum value maps for TranslationReportRecord_Severity.
var File_google_cloud_bigquery_migration_v2_migration_entities_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_migration_error_details_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_migration_metrics_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_migration_service_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_translation_config_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_translation_details_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_translation_suggestion_protoprotoreflect.FileDescriptorvar File_google_cloud_bigquery_migration_v2_translation_usability_protoprotoreflect.FileDescriptorvar MigrationService_ServiceDesc =grpc.ServiceDesc{ServiceName: "google.cloud.bigquery.migration.v2.MigrationService",HandlerType: (*MigrationServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "CreateMigrationWorkflow",Handler: _MigrationService_CreateMigrationWorkflow_Handler,},{MethodName: "GetMigrationWorkflow",Handler: _MigrationService_GetMigrationWorkflow_Handler,},{MethodName: "ListMigrationWorkflows",Handler: _MigrationService_ListMigrationWorkflows_Handler,},{MethodName: "DeleteMigrationWorkflow",Handler: _MigrationService_DeleteMigrationWorkflow_Handler,},{MethodName: "StartMigrationWorkflow",Handler: _MigrationService_StartMigrationWorkflow_Handler,},{MethodName: "GetMigrationSubtask",Handler: _MigrationService_GetMigrationSubtask_Handler,},{MethodName: "ListMigrationSubtasks",Handler: _MigrationService_ListMigrationSubtasks_Handler,},},Streams: []grpc.StreamDesc{},Metadata: "google/cloud/bigquery/migration/v2/migration_service.proto",}
MigrationService_ServiceDesc is the grpc.ServiceDesc for MigrationService service.It's only intended for direct use with grpc.RegisterService,and not to be introspected or modified (even as a copy)
Functions¶
funcRegisterMigrationServiceServer¶
func RegisterMigrationServiceServer(sgrpc.ServiceRegistrar, srvMigrationServiceServer)
Types¶
typeAzureSynapseDialect¶
type AzureSynapseDialect struct {// contains filtered or unexported fields}The dialect definition for Azure Synapse.
func (*AzureSynapseDialect)Descriptordeprecated
func (*AzureSynapseDialect) Descriptor() ([]byte, []int)
Deprecated: Use AzureSynapseDialect.ProtoReflect.Descriptor instead.
func (*AzureSynapseDialect)ProtoMessage¶
func (*AzureSynapseDialect) ProtoMessage()
func (*AzureSynapseDialect)ProtoReflect¶
func (x *AzureSynapseDialect) ProtoReflect()protoreflect.Message
func (*AzureSynapseDialect)Reset¶
func (x *AzureSynapseDialect) Reset()
func (*AzureSynapseDialect)String¶
func (x *AzureSynapseDialect) String()string
typeBigQueryDialect¶
type BigQueryDialect struct {// contains filtered or unexported fields}The dialect definition for BigQuery.
func (*BigQueryDialect)Descriptordeprecated
func (*BigQueryDialect) Descriptor() ([]byte, []int)
Deprecated: Use BigQueryDialect.ProtoReflect.Descriptor instead.
func (*BigQueryDialect)ProtoMessage¶
func (*BigQueryDialect) ProtoMessage()
func (*BigQueryDialect)ProtoReflect¶
func (x *BigQueryDialect) ProtoReflect()protoreflect.Message
func (*BigQueryDialect)Reset¶
func (x *BigQueryDialect) Reset()
func (*BigQueryDialect)String¶
func (x *BigQueryDialect) String()string
typeCreateMigrationWorkflowRequest¶
type CreateMigrationWorkflowRequest struct {// Required. The name of the project to which this migration workflow belongs.// Example: `projects/foo/locations/bar`Parentstring `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)Descriptordeprecated
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
typeDB2Dialect¶added inv1.63.0
type DB2Dialect struct {// contains filtered or unexported fields}The dialect definition for DB2.
func (*DB2Dialect)Descriptordeprecatedadded inv1.63.0
func (*DB2Dialect) Descriptor() ([]byte, []int)
Deprecated: Use DB2Dialect.ProtoReflect.Descriptor instead.
func (*DB2Dialect)ProtoMessage¶added inv1.63.0
func (*DB2Dialect) ProtoMessage()
func (*DB2Dialect)ProtoReflect¶added inv1.63.0
func (x *DB2Dialect) ProtoReflect()protoreflect.Message
func (*DB2Dialect)Reset¶added inv1.63.0
func (x *DB2Dialect) Reset()
func (*DB2Dialect)String¶added inv1.63.0
func (x *DB2Dialect) String()string
typeDeleteMigrationWorkflowRequest¶
type DeleteMigrationWorkflowRequest struct {// Required. The unique identifier for the migration workflow.// Example: `projects/123/locations/us/workflows/1234`Namestring `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)Descriptordeprecated
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
typeDialect¶
type Dialect struct {// The possible dialect options that this message represents.//// Types that are assignable to DialectValue:////*Dialect_BigqueryDialect//*Dialect_HiveqlDialect//*Dialect_RedshiftDialect//*Dialect_TeradataDialect//*Dialect_OracleDialect//*Dialect_SparksqlDialect//*Dialect_SnowflakeDialect//*Dialect_NetezzaDialect//*Dialect_AzureSynapseDialect//*Dialect_VerticaDialect//*Dialect_SqlServerDialect//*Dialect_PostgresqlDialect//*Dialect_PrestoDialect//*Dialect_MysqlDialect//*Dialect_Db2Dialect//*Dialect_SqliteDialect//*Dialect_GreenplumDialectDialectValue isDialect_DialectValue `protobuf_oneof:"dialect_value"`// contains filtered or unexported fields}The possible dialect options for translation.
func (*Dialect)Descriptordeprecated
func (*Dialect)GetAzureSynapseDialect¶
func (x *Dialect) GetAzureSynapseDialect() *AzureSynapseDialect
func (*Dialect)GetBigqueryDialect¶
func (x *Dialect) GetBigqueryDialect() *BigQueryDialect
func (*Dialect)GetDb2Dialect¶added inv1.63.0
func (x *Dialect) GetDb2Dialect() *DB2Dialect
func (*Dialect)GetDialectValue¶
func (m *Dialect) GetDialectValue() isDialect_DialectValue
func (*Dialect)GetGreenplumDialect¶added inv1.63.0
func (x *Dialect) GetGreenplumDialect() *GreenplumDialect
func (*Dialect)GetHiveqlDialect¶
func (x *Dialect) GetHiveqlDialect() *HiveQLDialect
func (*Dialect)GetMysqlDialect¶
func (x *Dialect) GetMysqlDialect() *MySQLDialect
func (*Dialect)GetNetezzaDialect¶
func (x *Dialect) GetNetezzaDialect() *NetezzaDialect
func (*Dialect)GetOracleDialect¶
func (x *Dialect) GetOracleDialect() *OracleDialect
func (*Dialect)GetPostgresqlDialect¶
func (x *Dialect) GetPostgresqlDialect() *PostgresqlDialect
func (*Dialect)GetPrestoDialect¶
func (x *Dialect) GetPrestoDialect() *PrestoDialect
func (*Dialect)GetRedshiftDialect¶
func (x *Dialect) GetRedshiftDialect() *RedshiftDialect
func (*Dialect)GetSnowflakeDialect¶
func (x *Dialect) GetSnowflakeDialect() *SnowflakeDialect
func (*Dialect)GetSparksqlDialect¶
func (x *Dialect) GetSparksqlDialect() *SparkSQLDialect
func (*Dialect)GetSqlServerDialect¶
func (x *Dialect) GetSqlServerDialect() *SQLServerDialect
func (*Dialect)GetSqliteDialect¶added inv1.63.0
func (x *Dialect) GetSqliteDialect() *SQLiteDialect
func (*Dialect)GetTeradataDialect¶
func (x *Dialect) GetTeradataDialect() *TeradataDialect
func (*Dialect)GetVerticaDialect¶
func (x *Dialect) GetVerticaDialect() *VerticaDialect
func (*Dialect)ProtoMessage¶
func (*Dialect) ProtoMessage()
func (*Dialect)ProtoReflect¶
func (x *Dialect) ProtoReflect()protoreflect.Message
typeDialect_AzureSynapseDialect¶
type Dialect_AzureSynapseDialect struct {// The Azure Synapse dialectAzureSynapseDialect *AzureSynapseDialect `protobuf:"bytes,9,opt,name=azure_synapse_dialect,json=azureSynapseDialect,proto3,oneof"`}typeDialect_BigqueryDialect¶
type Dialect_BigqueryDialect struct {// The BigQuery dialectBigqueryDialect *BigQueryDialect `protobuf:"bytes,1,opt,name=bigquery_dialect,json=bigqueryDialect,proto3,oneof"`}typeDialect_Db2Dialect¶added inv1.63.0
type Dialect_Db2Dialect struct {// DB2 dialectDb2Dialect *DB2Dialect `protobuf:"bytes,15,opt,name=db2_dialect,json=db2Dialect,proto3,oneof"`}typeDialect_GreenplumDialect¶added inv1.63.0
type Dialect_GreenplumDialect struct {// Greenplum dialectGreenplumDialect *GreenplumDialect `protobuf:"bytes,17,opt,name=greenplum_dialect,json=greenplumDialect,proto3,oneof"`}typeDialect_HiveqlDialect¶
type Dialect_HiveqlDialect struct {// The HiveQL dialectHiveqlDialect *HiveQLDialect `protobuf:"bytes,2,opt,name=hiveql_dialect,json=hiveqlDialect,proto3,oneof"`}typeDialect_MysqlDialect¶
type Dialect_MysqlDialect struct {// The MySQL dialectMysqlDialect *MySQLDialect `protobuf:"bytes,14,opt,name=mysql_dialect,json=mysqlDialect,proto3,oneof"`}typeDialect_NetezzaDialect¶
type Dialect_NetezzaDialect struct {// The Netezza dialectNetezzaDialect *NetezzaDialect `protobuf:"bytes,8,opt,name=netezza_dialect,json=netezzaDialect,proto3,oneof"`}typeDialect_OracleDialect¶
type Dialect_OracleDialect struct {// The Oracle dialectOracleDialect *OracleDialect `protobuf:"bytes,5,opt,name=oracle_dialect,json=oracleDialect,proto3,oneof"`}typeDialect_PostgresqlDialect¶
type Dialect_PostgresqlDialect struct {// The Postgresql dialectPostgresqlDialect *PostgresqlDialect `protobuf:"bytes,12,opt,name=postgresql_dialect,json=postgresqlDialect,proto3,oneof"`}typeDialect_PrestoDialect¶
type Dialect_PrestoDialect struct {// The Presto dialectPrestoDialect *PrestoDialect `protobuf:"bytes,13,opt,name=presto_dialect,json=prestoDialect,proto3,oneof"`}typeDialect_RedshiftDialect¶
type Dialect_RedshiftDialect struct {// The Redshift dialectRedshiftDialect *RedshiftDialect `protobuf:"bytes,3,opt,name=redshift_dialect,json=redshiftDialect,proto3,oneof"`}typeDialect_SnowflakeDialect¶
type Dialect_SnowflakeDialect struct {// The Snowflake dialectSnowflakeDialect *SnowflakeDialect `protobuf:"bytes,7,opt,name=snowflake_dialect,json=snowflakeDialect,proto3,oneof"`}typeDialect_SparksqlDialect¶
type Dialect_SparksqlDialect struct {// The SparkSQL dialectSparksqlDialect *SparkSQLDialect `protobuf:"bytes,6,opt,name=sparksql_dialect,json=sparksqlDialect,proto3,oneof"`}typeDialect_SqlServerDialect¶
type Dialect_SqlServerDialect struct {// The SQL Server dialectSqlServerDialect *SQLServerDialect `protobuf:"bytes,11,opt,name=sql_server_dialect,json=sqlServerDialect,proto3,oneof"`}typeDialect_SqliteDialect¶added inv1.63.0
type Dialect_SqliteDialect struct {// SQLite dialectSqliteDialect *SQLiteDialect `protobuf:"bytes,16,opt,name=sqlite_dialect,json=sqliteDialect,proto3,oneof"`}typeDialect_TeradataDialect¶
type Dialect_TeradataDialect struct {// The Teradata dialectTeradataDialect *TeradataDialect `protobuf:"bytes,4,opt,name=teradata_dialect,json=teradataDialect,proto3,oneof"`}typeDialect_VerticaDialect¶
type Dialect_VerticaDialect struct {// The Vertica dialectVerticaDialect *VerticaDialect `protobuf:"bytes,10,opt,name=vertica_dialect,json=verticaDialect,proto3,oneof"`}typeErrorDetail¶
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 whenprocessing a subtask.
func (*ErrorDetail)Descriptordeprecated
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
typeErrorLocation¶
type ErrorLocation struct {// Optional. If applicable, denotes the line where the error occurred. A zero// value means that there is no line information.Lineint32 `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.Columnint32 `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)Descriptordeprecated
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
typeGcsReportLogMessage¶added inv1.63.0
type GcsReportLogMessage struct {// Severity of the translation record.Severitystring `protobuf:"bytes,1,opt,name=severity,proto3" json:"severity,omitempty"`// Category of the error/warning. Example: SyntaxErrorCategorystring `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`// The file path in which the error occurredFilePathstring `protobuf:"bytes,3,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`// The file name in which the error occurredFilenamestring `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`// Specifies the row from the source text where the error occurred (0 based,// -1 for messages without line location). Example: 2SourceScriptLineint32 `protobuf:"varint,5,opt,name=source_script_line,json=sourceScriptLine,proto3" json:"source_script_line,omitempty"`// Specifies the column from the source texts where the error occurred. (0// based, -1 for messages without column location) example: 6SourceScriptColumnint32 `protobuf:"varint,6,opt,name=source_script_column,json=sourceScriptColumn,proto3" json:"source_script_column,omitempty"`// Detailed message of the record.Messagestring `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`// The script context (obfuscated) in which the error occurredScriptContextstring `protobuf:"bytes,8,opt,name=script_context,json=scriptContext,proto3" json:"script_context,omitempty"`// Category of the error/warning. Example: SyntaxErrorActionstring `protobuf:"bytes,9,opt,name=action,proto3" json:"action,omitempty"`// Effect of the error/warning. Example: COMPATIBILITYEffectstring `protobuf:"bytes,10,opt,name=effect,proto3" json:"effect,omitempty"`// Name of the affected object in the log message.ObjectNamestring `protobuf:"bytes,11,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`// contains filtered or unexported fields}A record in the aggregate CSV report for a migration workflow
func (*GcsReportLogMessage)Descriptordeprecatedadded inv1.63.0
func (*GcsReportLogMessage) Descriptor() ([]byte, []int)
Deprecated: Use GcsReportLogMessage.ProtoReflect.Descriptor instead.
func (*GcsReportLogMessage)GetAction¶added inv1.63.0
func (x *GcsReportLogMessage) GetAction()string
func (*GcsReportLogMessage)GetCategory¶added inv1.63.0
func (x *GcsReportLogMessage) GetCategory()string
func (*GcsReportLogMessage)GetEffect¶added inv1.63.0
func (x *GcsReportLogMessage) GetEffect()string
func (*GcsReportLogMessage)GetFilePath¶added inv1.63.0
func (x *GcsReportLogMessage) GetFilePath()string
func (*GcsReportLogMessage)GetFilename¶added inv1.63.0
func (x *GcsReportLogMessage) GetFilename()string
func (*GcsReportLogMessage)GetMessage¶added inv1.63.0
func (x *GcsReportLogMessage) GetMessage()string
func (*GcsReportLogMessage)GetObjectName¶added inv1.63.0
func (x *GcsReportLogMessage) GetObjectName()string
func (*GcsReportLogMessage)GetScriptContext¶added inv1.63.0
func (x *GcsReportLogMessage) GetScriptContext()string
func (*GcsReportLogMessage)GetSeverity¶added inv1.63.0
func (x *GcsReportLogMessage) GetSeverity()string
func (*GcsReportLogMessage)GetSourceScriptColumn¶added inv1.63.0
func (x *GcsReportLogMessage) GetSourceScriptColumn()int32
func (*GcsReportLogMessage)GetSourceScriptLine¶added inv1.63.0
func (x *GcsReportLogMessage) GetSourceScriptLine()int32
func (*GcsReportLogMessage)ProtoMessage¶added inv1.63.0
func (*GcsReportLogMessage) ProtoMessage()
func (*GcsReportLogMessage)ProtoReflect¶added inv1.63.0
func (x *GcsReportLogMessage) ProtoReflect()protoreflect.Message
func (*GcsReportLogMessage)Reset¶added inv1.63.0
func (x *GcsReportLogMessage) Reset()
func (*GcsReportLogMessage)String¶added inv1.63.0
func (x *GcsReportLogMessage) String()string
typeGetMigrationSubtaskRequest¶
type GetMigrationSubtaskRequest struct {// Required. The unique identifier for the migration subtask.// Example: `projects/123/locations/us/workflows/1234/subtasks/543`Namestring `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)Descriptordeprecated
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
typeGetMigrationWorkflowRequest¶
type GetMigrationWorkflowRequest struct {// Required. The unique identifier for the migration workflow.// Example: `projects/123/locations/us/workflows/1234`Namestring `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)Descriptordeprecated
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
typeGreenplumDialect¶added inv1.63.0
type GreenplumDialect struct {// contains filtered or unexported fields}The dialect definition for Greenplum.
func (*GreenplumDialect)Descriptordeprecatedadded inv1.63.0
func (*GreenplumDialect) Descriptor() ([]byte, []int)
Deprecated: Use GreenplumDialect.ProtoReflect.Descriptor instead.
func (*GreenplumDialect)ProtoMessage¶added inv1.63.0
func (*GreenplumDialect) ProtoMessage()
func (*GreenplumDialect)ProtoReflect¶added inv1.63.0
func (x *GreenplumDialect) ProtoReflect()protoreflect.Message
func (*GreenplumDialect)Reset¶added inv1.63.0
func (x *GreenplumDialect) Reset()
func (*GreenplumDialect)String¶added inv1.63.0
func (x *GreenplumDialect) String()string
typeHiveQLDialect¶
type HiveQLDialect struct {// contains filtered or unexported fields}The dialect definition for HiveQL.
func (*HiveQLDialect)Descriptordeprecated
func (*HiveQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use HiveQLDialect.ProtoReflect.Descriptor instead.
func (*HiveQLDialect)ProtoMessage¶
func (*HiveQLDialect) ProtoMessage()
func (*HiveQLDialect)ProtoReflect¶
func (x *HiveQLDialect) ProtoReflect()protoreflect.Message
func (*HiveQLDialect)Reset¶
func (x *HiveQLDialect) Reset()
func (*HiveQLDialect)String¶
func (x *HiveQLDialect) String()string
typeListMigrationSubtasksRequest¶
type ListMigrationSubtasksRequest struct {// Required. The migration task of the subtasks to list.// Example: `projects/123/locations/us/workflows/1234`Parentstring `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.PageSizeint32 `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.PageTokenstring `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).Filterstring `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)Descriptordeprecated
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
typeListMigrationSubtasksResponse¶
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.NextPageTokenstring `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)Descriptordeprecated
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
typeListMigrationWorkflowsRequest¶
type ListMigrationWorkflowsRequest struct {// Required. The project and location of the migration workflows to list.// Example: `projects/123/locations/us`Parentstring `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.PageSizeint32 `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.PageTokenstring `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)Descriptordeprecated
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
typeListMigrationWorkflowsResponse¶
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.NextPageTokenstring `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)Descriptordeprecated
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
typeLiteral¶added inv1.63.0
type Literal struct {// The literal SQL contents.//// Types that are assignable to LiteralData:////*Literal_LiteralString//*Literal_LiteralBytesLiteralData isLiteral_LiteralData `protobuf_oneof:"literal_data"`// Required. The identifier of the literal entry.RelativePathstring `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`// contains filtered or unexported fields}Literal data.
func (*Literal)Descriptordeprecatedadded inv1.63.0
func (*Literal)GetLiteralBytes¶added inv1.63.0
func (*Literal)GetLiteralData¶added inv1.63.0
func (m *Literal) GetLiteralData() isLiteral_LiteralData
func (*Literal)GetLiteralString¶added inv1.63.0
func (*Literal)GetRelativePath¶added inv1.63.0
func (*Literal)ProtoMessage¶added inv1.63.0
func (*Literal) ProtoMessage()
func (*Literal)ProtoReflect¶added inv1.63.0
func (x *Literal) ProtoReflect()protoreflect.Message
typeLiteral_LiteralBytes¶added inv1.63.0
type Literal_LiteralBytes struct {// Literal byte data.LiteralBytes []byte `protobuf:"bytes,3,opt,name=literal_bytes,json=literalBytes,proto3,oneof"`}typeLiteral_LiteralString¶added inv1.63.0
type Literal_LiteralString struct {// Literal string data.LiteralStringstring `protobuf:"bytes,2,opt,name=literal_string,json=literalString,proto3,oneof"`}typeMigrationServiceClient¶
type MigrationServiceClient interface {// Creates a migration workflow.CreateMigrationWorkflow(ctxcontext.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow,error)// Gets a previously created migration workflow.GetMigrationWorkflow(ctxcontext.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow,error)// Lists previously created migration workflow.ListMigrationWorkflows(ctxcontext.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse,error)// Deletes a migration workflow by name.DeleteMigrationWorkflow(ctxcontext.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(ctxcontext.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty,error)// Gets a previously created migration subtask.GetMigrationSubtask(ctxcontext.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask,error)// Lists previously created migration subtasks.ListMigrationSubtasks(ctxcontext.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 tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
funcNewMigrationServiceClient¶
func NewMigrationServiceClient(ccgrpc.ClientConnInterface)MigrationServiceClient
typeMigrationServiceServer¶
type MigrationServiceServer interface {// Creates a migration workflow.CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow,error)// Gets a previously created migration workflow.GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow,error)// Lists previously created migration workflow.ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse,error)// Deletes a migration workflow by name.DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty,error)// Starts a previously created migration workflow. I.e., the state transitions// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.// An error will be signaled if the state is anything other than DRAFT or// RUNNING.StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty,error)// Gets a previously created migration subtask.GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask,error)// Lists previously created migration subtasks.ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse,error)}MigrationServiceServer is the server API for MigrationService service.All implementations should embed UnimplementedMigrationServiceServerfor forward compatibility
typeMigrationSubtask¶
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`Namestring `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`// The unique ID of the task to which this subtask belongs.TaskIdstring `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.Typestring `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`// Output only. The current state of the subtask.StateMigrationSubtask_State ``/* 127-byte string literal not displayed */// Output only. An explanation that may be populated when the task is in// FAILED state.ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`// Output only. Provides details to errors and issues encountered while// processing the subtask. Presence of error details does not mean that the// subtask failed.ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`// The number or resources with errors. Note: This is not the total// number of errors as each resource can have more than one error.// This is used to indicate truncation by having a `resource_error_count`// that is higher than the size of `resource_error_details`.ResourceErrorCountint32 `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 ofthe 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)Descriptordeprecated
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
typeMigrationSubtask_State¶
type MigrationSubtask_Stateint32
Possible states of a migration subtask.
const (// The state is unspecified.MigrationSubtask_STATE_UNSPECIFIEDMigrationSubtask_State = 0// The subtask is ready, i.e. it is ready for execution.MigrationSubtask_ACTIVEMigrationSubtask_State = 1// The subtask is running, i.e. it is assigned to a worker for execution.MigrationSubtask_RUNNINGMigrationSubtask_State = 2// The subtask finished successfully.MigrationSubtask_SUCCEEDEDMigrationSubtask_State = 3// The subtask finished unsuccessfully.MigrationSubtask_FAILEDMigrationSubtask_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_PAUSEDMigrationSubtask_State = 5// The subtask is pending a dependency. It will be scheduled once its// dependencies are done.MigrationSubtask_PENDING_DEPENDENCYMigrationSubtask_State = 6)
func (MigrationSubtask_State)Descriptor¶
func (MigrationSubtask_State) Descriptor()protoreflect.EnumDescriptor
func (MigrationSubtask_State)Enum¶
func (xMigrationSubtask_State) Enum() *MigrationSubtask_State
func (MigrationSubtask_State)EnumDescriptordeprecated
func (MigrationSubtask_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationSubtask_State.Descriptor instead.
func (MigrationSubtask_State)Number¶
func (xMigrationSubtask_State) Number()protoreflect.EnumNumber
func (MigrationSubtask_State)String¶
func (xMigrationSubtask_State) String()string
func (MigrationSubtask_State)Type¶
func (MigrationSubtask_State) Type()protoreflect.EnumType
typeMigrationTask¶
type MigrationTask struct {// The details of the task.//// Types that are assignable to TaskDetails:////*MigrationTask_TranslationConfigDetails//*MigrationTask_TranslationDetailsTaskDetails isMigrationTask_TaskDetails `protobuf_oneof:"task_details"`// Output only. Immutable. The unique identifier for the migration task. The// ID is server-generated.Idstring `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`// The type of the task. This must be one of the supported task types:// Translation_Teradata2BQ, Translation_Redshift2BQ, Translation_Bteq2BQ,// Translation_Oracle2BQ, Translation_HiveQL2BQ, Translation_SparkSQL2BQ,// Translation_Snowflake2BQ, Translation_Netezza2BQ,// Translation_AzureSynapse2BQ, Translation_Vertica2BQ,// Translation_SQLServer2BQ, Translation_Presto2BQ, Translation_MySQL2BQ,// Translation_Postgresql2BQ, Translation_SQLite2BQ, Translation_Greenplum2BQ.Typestring `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`// Output only. The current state of the task.StateMigrationTask_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationTask_State" json:"state,omitempty"`// Output only. An explanation that may be populated when the task is in// FAILED state.ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,5,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`// Time when the task was created.CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`// Time when the task was last updated.LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`// Output only. Provides details to errors and issues encountered while// processing the task. Presence of error details does not mean that the task// failed.ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,17,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`// The number or resources with errors. Note: This is not the total// number of errors as each resource can have more than one error.// This is used to indicate truncation by having a `resource_error_count`// that is higher than the size of `resource_error_details`.ResourceErrorCountint32 `protobuf:"varint,18,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`// The metrics for the task.Metrics []*TimeSeries `protobuf:"bytes,19,rep,name=metrics,proto3" json:"metrics,omitempty"`// Output only. The result of the task.TaskResult *MigrationTaskResult `protobuf:"bytes,20,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`// Count of all the processing errors in this task and its subtasks.TotalProcessingErrorCountint32 ``/* 142-byte string literal not displayed */// Count of all the resource errors in this task and its subtasks.TotalResourceErrorCountint32 ``/* 136-byte string literal not displayed */// contains filtered or unexported fields}A single task for a migration which has details about the configuration ofthe task.
func (*MigrationTask)Descriptordeprecated
func (*MigrationTask) Descriptor() ([]byte, []int)
Deprecated: Use MigrationTask.ProtoReflect.Descriptor instead.
func (*MigrationTask)GetCreateTime¶
func (x *MigrationTask) GetCreateTime() *timestamppb.Timestamp
func (*MigrationTask)GetId¶
func (x *MigrationTask) GetId()string
func (*MigrationTask)GetLastUpdateTime¶
func (x *MigrationTask) GetLastUpdateTime() *timestamppb.Timestamp
func (*MigrationTask)GetMetrics¶added inv1.63.0
func (x *MigrationTask) GetMetrics() []*TimeSeries
func (*MigrationTask)GetProcessingError¶
func (x *MigrationTask) GetProcessingError() *errdetails.ErrorInfo
func (*MigrationTask)GetResourceErrorCount¶added inv1.63.0
func (x *MigrationTask) GetResourceErrorCount()int32
func (*MigrationTask)GetResourceErrorDetails¶added inv1.63.0
func (x *MigrationTask) GetResourceErrorDetails() []*ResourceErrorDetail
func (*MigrationTask)GetState¶
func (x *MigrationTask) GetState()MigrationTask_State
func (*MigrationTask)GetTaskDetails¶
func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails
func (*MigrationTask)GetTaskResult¶added inv1.63.0
func (x *MigrationTask) GetTaskResult() *MigrationTaskResult
func (*MigrationTask)GetTotalProcessingErrorCount¶added inv1.63.0
func (x *MigrationTask) GetTotalProcessingErrorCount()int32
func (*MigrationTask)GetTotalResourceErrorCount¶added inv1.63.0
func (x *MigrationTask) GetTotalResourceErrorCount()int32
func (*MigrationTask)GetTranslationConfigDetails¶
func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails
func (*MigrationTask)GetTranslationDetails¶added inv1.63.0
func (x *MigrationTask) GetTranslationDetails() *TranslationDetails
func (*MigrationTask)GetType¶
func (x *MigrationTask) GetType()string
func (*MigrationTask)ProtoMessage¶
func (*MigrationTask) ProtoMessage()
func (*MigrationTask)ProtoReflect¶
func (x *MigrationTask) ProtoReflect()protoreflect.Message
func (*MigrationTask)Reset¶
func (x *MigrationTask) Reset()
func (*MigrationTask)String¶
func (x *MigrationTask) String()string
typeMigrationTaskResult¶added inv1.63.0
type MigrationTaskResult struct {// Details specific to the task type.//// Types that are assignable to Details:////*MigrationTaskResult_TranslationTaskResultDetails isMigrationTaskResult_Details `protobuf_oneof:"details"`// contains filtered or unexported fields}The migration task result.
func (*MigrationTaskResult)Descriptordeprecatedadded inv1.63.0
func (*MigrationTaskResult) Descriptor() ([]byte, []int)
Deprecated: Use MigrationTaskResult.ProtoReflect.Descriptor instead.
func (*MigrationTaskResult)GetDetails¶added inv1.63.0
func (m *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details
func (*MigrationTaskResult)GetTranslationTaskResult¶added inv1.63.0
func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult
func (*MigrationTaskResult)ProtoMessage¶added inv1.63.0
func (*MigrationTaskResult) ProtoMessage()
func (*MigrationTaskResult)ProtoReflect¶added inv1.63.0
func (x *MigrationTaskResult) ProtoReflect()protoreflect.Message
func (*MigrationTaskResult)Reset¶added inv1.63.0
func (x *MigrationTaskResult) Reset()
func (*MigrationTaskResult)String¶added inv1.63.0
func (x *MigrationTaskResult) String()string
typeMigrationTaskResult_TranslationTaskResult¶added inv1.63.0
type MigrationTaskResult_TranslationTaskResult struct {// Details specific to translation task types.TranslationTaskResult *TranslationTaskResult `protobuf:"bytes,2,opt,name=translation_task_result,json=translationTaskResult,proto3,oneof"`}typeMigrationTask_State¶
type MigrationTask_Stateint32
Possible states of a migration task.
const (// The state is unspecified.MigrationTask_STATE_UNSPECIFIEDMigrationTask_State = 0// The task is waiting for orchestration.MigrationTask_PENDINGMigrationTask_State = 1// The task is assigned to an orchestrator.MigrationTask_ORCHESTRATINGMigrationTask_State = 2// The task is running, i.e. its subtasks are ready for execution.MigrationTask_RUNNINGMigrationTask_State = 3// Tha task is paused. Assigned subtasks can continue, but no new subtasks// will be scheduled.MigrationTask_PAUSEDMigrationTask_State = 4// The task finished successfully.MigrationTask_SUCCEEDEDMigrationTask_State = 5// The task finished unsuccessfully.MigrationTask_FAILEDMigrationTask_State = 6)
func (MigrationTask_State)Descriptor¶
func (MigrationTask_State) Descriptor()protoreflect.EnumDescriptor
func (MigrationTask_State)Enum¶
func (xMigrationTask_State) Enum() *MigrationTask_State
func (MigrationTask_State)EnumDescriptordeprecated
func (MigrationTask_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationTask_State.Descriptor instead.
func (MigrationTask_State)Number¶
func (xMigrationTask_State) Number()protoreflect.EnumNumber
func (MigrationTask_State)String¶
func (xMigrationTask_State) String()string
func (MigrationTask_State)Type¶
func (MigrationTask_State) Type()protoreflect.EnumType
typeMigrationTask_TranslationConfigDetails¶
type MigrationTask_TranslationConfigDetails struct {// Task configuration for CW Batch/Offline SQL Translation.TranslationConfigDetails *TranslationConfigDetails `protobuf:"bytes,14,opt,name=translation_config_details,json=translationConfigDetails,proto3,oneof"`}typeMigrationTask_TranslationDetails¶added inv1.63.0
type MigrationTask_TranslationDetails struct {// Task details for unified SQL Translation.TranslationDetails *TranslationDetails `protobuf:"bytes,16,opt,name=translation_details,json=translationDetails,proto3,oneof"`}typeMigrationWorkflow¶
type MigrationWorkflow struct {// Output only. Immutable. Identifier. The unique identifier for the migration// workflow. The ID is server-generated.//// Example: `projects/123/locations/us/workflows/345`Namestring `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.DisplayNamestring `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.StateMigrationWorkflow_State ``/* 128-byte string literal not displayed */// Time when the workflow was created.CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`// Time when the workflow was last updated.LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`// contains filtered or unexported fields}A migration workflow which specifies what needs to be done for an EDWmigration.
func (*MigrationWorkflow)Descriptordeprecated
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
typeMigrationWorkflow_State¶
type MigrationWorkflow_Stateint32
Possible migration workflow states.
const (// Workflow state is unspecified.MigrationWorkflow_STATE_UNSPECIFIEDMigrationWorkflow_State = 0// Workflow is in draft status, i.e. tasks are not yet eligible for// execution.MigrationWorkflow_DRAFTMigrationWorkflow_State = 1// Workflow is running (i.e. tasks are eligible for execution).MigrationWorkflow_RUNNINGMigrationWorkflow_State = 2// Workflow is paused. Tasks currently in progress may continue, but no// further tasks will be scheduled.MigrationWorkflow_PAUSEDMigrationWorkflow_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_COMPLETEDMigrationWorkflow_State = 4)
func (MigrationWorkflow_State)Descriptor¶
func (MigrationWorkflow_State) Descriptor()protoreflect.EnumDescriptor
func (MigrationWorkflow_State)Enum¶
func (xMigrationWorkflow_State) Enum() *MigrationWorkflow_State
func (MigrationWorkflow_State)EnumDescriptordeprecated
func (MigrationWorkflow_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationWorkflow_State.Descriptor instead.
func (MigrationWorkflow_State)Number¶
func (xMigrationWorkflow_State) Number()protoreflect.EnumNumber
func (MigrationWorkflow_State)String¶
func (xMigrationWorkflow_State) String()string
func (MigrationWorkflow_State)Type¶
func (MigrationWorkflow_State) Type()protoreflect.EnumType
typeMySQLDialect¶
type MySQLDialect struct {// contains filtered or unexported fields}The dialect definition for MySQL.
func (*MySQLDialect)Descriptordeprecated
func (*MySQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use MySQLDialect.ProtoReflect.Descriptor instead.
func (*MySQLDialect)ProtoMessage¶
func (*MySQLDialect) ProtoMessage()
func (*MySQLDialect)ProtoReflect¶
func (x *MySQLDialect) ProtoReflect()protoreflect.Message
func (*MySQLDialect)Reset¶
func (x *MySQLDialect) Reset()
func (*MySQLDialect)String¶
func (x *MySQLDialect) String()string
typeNameMappingKey¶
type NameMappingKey struct {// The type of object that is being mapped.TypeNameMappingKey_Type `protobuf:"varint,1,opt,name=type,proto3,enum=google.cloud.bigquery.migration.v2.NameMappingKey_Type" json:"type,omitempty"`// The database name (BigQuery project ID equivalent in the source data// warehouse).Databasestring `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`// The schema name (BigQuery dataset equivalent in the source data warehouse).Schemastring `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`// The relation name (BigQuery table or view equivalent in the source data// warehouse).Relationstring `protobuf:"bytes,4,opt,name=relation,proto3" json:"relation,omitempty"`// The attribute name (BigQuery column equivalent in the source data// warehouse).Attributestring `protobuf:"bytes,5,opt,name=attribute,proto3" json:"attribute,omitempty"`// contains filtered or unexported fields}The potential components of a full name mapping that will be mappedduring translation in the source data warehouse.
func (*NameMappingKey)Descriptordeprecated
func (*NameMappingKey) Descriptor() ([]byte, []int)
Deprecated: Use NameMappingKey.ProtoReflect.Descriptor instead.
func (*NameMappingKey)GetAttribute¶
func (x *NameMappingKey) GetAttribute()string
func (*NameMappingKey)GetDatabase¶
func (x *NameMappingKey) GetDatabase()string
func (*NameMappingKey)GetRelation¶
func (x *NameMappingKey) GetRelation()string
func (*NameMappingKey)GetSchema¶
func (x *NameMappingKey) GetSchema()string
func (*NameMappingKey)GetType¶
func (x *NameMappingKey) GetType()NameMappingKey_Type
func (*NameMappingKey)ProtoMessage¶
func (*NameMappingKey) ProtoMessage()
func (*NameMappingKey)ProtoReflect¶
func (x *NameMappingKey) ProtoReflect()protoreflect.Message
func (*NameMappingKey)Reset¶
func (x *NameMappingKey) Reset()
func (*NameMappingKey)String¶
func (x *NameMappingKey) String()string
typeNameMappingKey_Type¶
type NameMappingKey_Typeint32
The type of the object that is being mapped.
const (// Unspecified name mapping type.NameMappingKey_TYPE_UNSPECIFIEDNameMappingKey_Type = 0// The object being mapped is a database.NameMappingKey_DATABASENameMappingKey_Type = 1// The object being mapped is a schema.NameMappingKey_SCHEMANameMappingKey_Type = 2// The object being mapped is a relation.NameMappingKey_RELATIONNameMappingKey_Type = 3// The object being mapped is an attribute.NameMappingKey_ATTRIBUTENameMappingKey_Type = 4// The object being mapped is a relation alias.NameMappingKey_RELATION_ALIASNameMappingKey_Type = 5// The object being mapped is a an attribute alias.NameMappingKey_ATTRIBUTE_ALIASNameMappingKey_Type = 6// The object being mapped is a function.NameMappingKey_FUNCTIONNameMappingKey_Type = 7)
func (NameMappingKey_Type)Descriptor¶
func (NameMappingKey_Type) Descriptor()protoreflect.EnumDescriptor
func (NameMappingKey_Type)Enum¶
func (xNameMappingKey_Type) Enum() *NameMappingKey_Type
func (NameMappingKey_Type)EnumDescriptordeprecated
func (NameMappingKey_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use NameMappingKey_Type.Descriptor instead.
func (NameMappingKey_Type)Number¶
func (xNameMappingKey_Type) Number()protoreflect.EnumNumber
func (NameMappingKey_Type)String¶
func (xNameMappingKey_Type) String()string
func (NameMappingKey_Type)Type¶
func (NameMappingKey_Type) Type()protoreflect.EnumType
typeNameMappingValue¶
type NameMappingValue struct {// The database name (BigQuery project ID equivalent in the target data// warehouse).Databasestring `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`// The schema name (BigQuery dataset equivalent in the target data warehouse).Schemastring `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`// The relation name (BigQuery table or view equivalent in the target data// warehouse).Relationstring `protobuf:"bytes,3,opt,name=relation,proto3" json:"relation,omitempty"`// The attribute name (BigQuery column equivalent in the target data// warehouse).Attributestring `protobuf:"bytes,4,opt,name=attribute,proto3" json:"attribute,omitempty"`// contains filtered or unexported fields}The potential components of a full name mapping that will be mappedduring translation in the target data warehouse.
func (*NameMappingValue)Descriptordeprecated
func (*NameMappingValue) Descriptor() ([]byte, []int)
Deprecated: Use NameMappingValue.ProtoReflect.Descriptor instead.
func (*NameMappingValue)GetAttribute¶
func (x *NameMappingValue) GetAttribute()string
func (*NameMappingValue)GetDatabase¶
func (x *NameMappingValue) GetDatabase()string
func (*NameMappingValue)GetRelation¶
func (x *NameMappingValue) GetRelation()string
func (*NameMappingValue)GetSchema¶
func (x *NameMappingValue) GetSchema()string
func (*NameMappingValue)ProtoMessage¶
func (*NameMappingValue) ProtoMessage()
func (*NameMappingValue)ProtoReflect¶
func (x *NameMappingValue) ProtoReflect()protoreflect.Message
func (*NameMappingValue)Reset¶
func (x *NameMappingValue) Reset()
func (*NameMappingValue)String¶
func (x *NameMappingValue) String()string
typeNetezzaDialect¶
type NetezzaDialect struct {// contains filtered or unexported fields}The dialect definition for Netezza.
func (*NetezzaDialect)Descriptordeprecated
func (*NetezzaDialect) Descriptor() ([]byte, []int)
Deprecated: Use NetezzaDialect.ProtoReflect.Descriptor instead.
func (*NetezzaDialect)ProtoMessage¶
func (*NetezzaDialect) ProtoMessage()
func (*NetezzaDialect)ProtoReflect¶
func (x *NetezzaDialect) ProtoReflect()protoreflect.Message
func (*NetezzaDialect)Reset¶
func (x *NetezzaDialect) Reset()
func (*NetezzaDialect)String¶
func (x *NetezzaDialect) String()string
typeObjectNameMapping¶
type ObjectNameMapping struct {// The name of the object in source that is being mapped.Source *NameMappingKey `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`// The desired target name of the object that is being mapped.Target *NameMappingValue `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`// contains filtered or unexported fields}Represents a key-value pair of NameMappingKey to NameMappingValue torepresent the mapping of SQL names from the input value to desired output.
func (*ObjectNameMapping)Descriptordeprecated
func (*ObjectNameMapping) Descriptor() ([]byte, []int)
Deprecated: Use ObjectNameMapping.ProtoReflect.Descriptor instead.
func (*ObjectNameMapping)GetSource¶
func (x *ObjectNameMapping) GetSource() *NameMappingKey
func (*ObjectNameMapping)GetTarget¶
func (x *ObjectNameMapping) GetTarget() *NameMappingValue
func (*ObjectNameMapping)ProtoMessage¶
func (*ObjectNameMapping) ProtoMessage()
func (*ObjectNameMapping)ProtoReflect¶
func (x *ObjectNameMapping) ProtoReflect()protoreflect.Message
func (*ObjectNameMapping)Reset¶
func (x *ObjectNameMapping) Reset()
func (*ObjectNameMapping)String¶
func (x *ObjectNameMapping) String()string
typeObjectNameMappingList¶
type ObjectNameMappingList struct {// The elements of the object name map.NameMap []*ObjectNameMapping `protobuf:"bytes,1,rep,name=name_map,json=nameMap,proto3" json:"name_map,omitempty"`// contains filtered or unexported fields}Represents a map of name mappings using a list of key:value proto messages ofexisting name to desired output name.
func (*ObjectNameMappingList)Descriptordeprecated
func (*ObjectNameMappingList) Descriptor() ([]byte, []int)
Deprecated: Use ObjectNameMappingList.ProtoReflect.Descriptor instead.
func (*ObjectNameMappingList)GetNameMap¶
func (x *ObjectNameMappingList) GetNameMap() []*ObjectNameMapping
func (*ObjectNameMappingList)ProtoMessage¶
func (*ObjectNameMappingList) ProtoMessage()
func (*ObjectNameMappingList)ProtoReflect¶
func (x *ObjectNameMappingList) ProtoReflect()protoreflect.Message
func (*ObjectNameMappingList)Reset¶
func (x *ObjectNameMappingList) Reset()
func (*ObjectNameMappingList)String¶
func (x *ObjectNameMappingList) String()string
typeOracleDialect¶
type OracleDialect struct {// contains filtered or unexported fields}The dialect definition for Oracle.
func (*OracleDialect)Descriptordeprecated
func (*OracleDialect) Descriptor() ([]byte, []int)
Deprecated: Use OracleDialect.ProtoReflect.Descriptor instead.
func (*OracleDialect)ProtoMessage¶
func (*OracleDialect) ProtoMessage()
func (*OracleDialect)ProtoReflect¶
func (x *OracleDialect) ProtoReflect()protoreflect.Message
func (*OracleDialect)Reset¶
func (x *OracleDialect) Reset()
func (*OracleDialect)String¶
func (x *OracleDialect) String()string
typePoint¶
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)Descriptordeprecated
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
typePostgresqlDialect¶
type PostgresqlDialect struct {// contains filtered or unexported fields}The dialect definition for Postgresql.
func (*PostgresqlDialect)Descriptordeprecated
func (*PostgresqlDialect) Descriptor() ([]byte, []int)
Deprecated: Use PostgresqlDialect.ProtoReflect.Descriptor instead.
func (*PostgresqlDialect)ProtoMessage¶
func (*PostgresqlDialect) ProtoMessage()
func (*PostgresqlDialect)ProtoReflect¶
func (x *PostgresqlDialect) ProtoReflect()protoreflect.Message
func (*PostgresqlDialect)Reset¶
func (x *PostgresqlDialect) Reset()
func (*PostgresqlDialect)String¶
func (x *PostgresqlDialect) String()string
typePrestoDialect¶
type PrestoDialect struct {// contains filtered or unexported fields}The dialect definition for Presto.
func (*PrestoDialect)Descriptordeprecated
func (*PrestoDialect) Descriptor() ([]byte, []int)
Deprecated: Use PrestoDialect.ProtoReflect.Descriptor instead.
func (*PrestoDialect)ProtoMessage¶
func (*PrestoDialect) ProtoMessage()
func (*PrestoDialect)ProtoReflect¶
func (x *PrestoDialect) ProtoReflect()protoreflect.Message
func (*PrestoDialect)Reset¶
func (x *PrestoDialect) Reset()
func (*PrestoDialect)String¶
func (x *PrestoDialect) String()string
typeRedshiftDialect¶
type RedshiftDialect struct {// contains filtered or unexported fields}The dialect definition for Redshift.
func (*RedshiftDialect)Descriptordeprecated
func (*RedshiftDialect) Descriptor() ([]byte, []int)
Deprecated: Use RedshiftDialect.ProtoReflect.Descriptor instead.
func (*RedshiftDialect)ProtoMessage¶
func (*RedshiftDialect) ProtoMessage()
func (*RedshiftDialect)ProtoReflect¶
func (x *RedshiftDialect) ProtoReflect()protoreflect.Message
func (*RedshiftDialect)Reset¶
func (x *RedshiftDialect) Reset()
func (*RedshiftDialect)String¶
func (x *RedshiftDialect) String()string
typeResourceErrorDetail¶
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`.ErrorCountint32 `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)Descriptordeprecated
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
typeSQLServerDialect¶
type SQLServerDialect struct {// contains filtered or unexported fields}The dialect definition for SQL Server.
func (*SQLServerDialect)Descriptordeprecated
func (*SQLServerDialect) Descriptor() ([]byte, []int)
Deprecated: Use SQLServerDialect.ProtoReflect.Descriptor instead.
func (*SQLServerDialect)ProtoMessage¶
func (*SQLServerDialect) ProtoMessage()
func (*SQLServerDialect)ProtoReflect¶
func (x *SQLServerDialect) ProtoReflect()protoreflect.Message
func (*SQLServerDialect)Reset¶
func (x *SQLServerDialect) Reset()
func (*SQLServerDialect)String¶
func (x *SQLServerDialect) String()string
typeSQLiteDialect¶added inv1.63.0
type SQLiteDialect struct {// contains filtered or unexported fields}The dialect definition for SQLite.
func (*SQLiteDialect)Descriptordeprecatedadded inv1.63.0
func (*SQLiteDialect) Descriptor() ([]byte, []int)
Deprecated: Use SQLiteDialect.ProtoReflect.Descriptor instead.
func (*SQLiteDialect)ProtoMessage¶added inv1.63.0
func (*SQLiteDialect) ProtoMessage()
func (*SQLiteDialect)ProtoReflect¶added inv1.63.0
func (x *SQLiteDialect) ProtoReflect()protoreflect.Message
func (*SQLiteDialect)Reset¶added inv1.63.0
func (x *SQLiteDialect) Reset()
func (*SQLiteDialect)String¶added inv1.63.0
func (x *SQLiteDialect) String()string
typeSnowflakeDialect¶
type SnowflakeDialect struct {// contains filtered or unexported fields}The dialect definition for Snowflake.
func (*SnowflakeDialect)Descriptordeprecated
func (*SnowflakeDialect) Descriptor() ([]byte, []int)
Deprecated: Use SnowflakeDialect.ProtoReflect.Descriptor instead.
func (*SnowflakeDialect)ProtoMessage¶
func (*SnowflakeDialect) ProtoMessage()
func (*SnowflakeDialect)ProtoReflect¶
func (x *SnowflakeDialect) ProtoReflect()protoreflect.Message
func (*SnowflakeDialect)Reset¶
func (x *SnowflakeDialect) Reset()
func (*SnowflakeDialect)String¶
func (x *SnowflakeDialect) String()string
typeSourceEnv¶
type SourceEnv struct {// The default database name to fully qualify SQL objects when their database// name is missing.DefaultDatabasestring `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`// The schema search path. When SQL objects are missing schema name,// translation engine will search through this list to find the value.SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`// Optional. Expects a valid BigQuery dataset ID that exists, e.g.,// project-123.metadata_store_123. If specified, translation will search and// read the required schema information from a metadata store in this dataset.// If metadata store doesn't exist, translation will parse the metadata file// and upload the schema info to a temp table in the dataset to speed up// future translation jobs.MetadataStoreDatasetstring `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`// contains filtered or unexported fields}Represents the default source environment values for the translation.
func (*SourceEnv)Descriptordeprecated
func (*SourceEnv)GetDefaultDatabase¶
func (*SourceEnv)GetMetadataStoreDataset¶added inv1.63.0
func (*SourceEnv)GetSchemaSearchPath¶
func (*SourceEnv)ProtoMessage¶
func (*SourceEnv) ProtoMessage()
func (*SourceEnv)ProtoReflect¶
func (x *SourceEnv) ProtoReflect()protoreflect.Message
typeSourceEnvironment¶added inv1.63.0
type SourceEnvironment struct {// The default database name to fully qualify SQL objects when their database// name is missing.DefaultDatabasestring `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`// The schema search path. When SQL objects are missing schema name,// translation engine will search through this list to find the value.SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`// Optional. Expects a validQ BigQuery dataset ID that exists, e.g.,// project-123.metadata_store_123. If specified, translation will search and// read the required schema information from a metadata store in this dataset.// If metadata store doesn't exist, translation will parse the metadata file// and upload the schema info to a temp table in the dataset to speed up// future translation jobs.MetadataStoreDatasetstring `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`// contains filtered or unexported fields}Represents the default source environment values for the translation.
func (*SourceEnvironment)Descriptordeprecatedadded inv1.63.0
func (*SourceEnvironment) Descriptor() ([]byte, []int)
Deprecated: Use SourceEnvironment.ProtoReflect.Descriptor instead.
func (*SourceEnvironment)GetDefaultDatabase¶added inv1.63.0
func (x *SourceEnvironment) GetDefaultDatabase()string
func (*SourceEnvironment)GetMetadataStoreDataset¶added inv1.63.0
func (x *SourceEnvironment) GetMetadataStoreDataset()string
func (*SourceEnvironment)GetSchemaSearchPath¶added inv1.63.0
func (x *SourceEnvironment) GetSchemaSearchPath() []string
func (*SourceEnvironment)ProtoMessage¶added inv1.63.0
func (*SourceEnvironment) ProtoMessage()
func (*SourceEnvironment)ProtoReflect¶added inv1.63.0
func (x *SourceEnvironment) ProtoReflect()protoreflect.Message
func (*SourceEnvironment)Reset¶added inv1.63.0
func (x *SourceEnvironment) Reset()
func (*SourceEnvironment)String¶added inv1.63.0
func (x *SourceEnvironment) String()string
typeSourceSpec¶added inv1.63.0
type SourceSpec struct {// The specific source SQL.//// Types that are assignable to Source:////*SourceSpec_BaseUri//*SourceSpec_LiteralSource isSourceSpec_Source `protobuf_oneof:"source"`// Optional. The optional field to specify the encoding of the sql bytes.Encodingstring `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`// contains filtered or unexported fields}Represents one path to the location that holds source data.
func (*SourceSpec)Descriptordeprecatedadded inv1.63.0
func (*SourceSpec) Descriptor() ([]byte, []int)
Deprecated: Use SourceSpec.ProtoReflect.Descriptor instead.
func (*SourceSpec)GetBaseUri¶added inv1.63.0
func (x *SourceSpec) GetBaseUri()string
func (*SourceSpec)GetEncoding¶added inv1.63.0
func (x *SourceSpec) GetEncoding()string
func (*SourceSpec)GetLiteral¶added inv1.63.0
func (x *SourceSpec) GetLiteral() *Literal
func (*SourceSpec)GetSource¶added inv1.63.0
func (m *SourceSpec) GetSource() isSourceSpec_Source
func (*SourceSpec)ProtoMessage¶added inv1.63.0
func (*SourceSpec) ProtoMessage()
func (*SourceSpec)ProtoReflect¶added inv1.63.0
func (x *SourceSpec) ProtoReflect()protoreflect.Message
func (*SourceSpec)Reset¶added inv1.63.0
func (x *SourceSpec) Reset()
func (*SourceSpec)String¶added inv1.63.0
func (x *SourceSpec) String()string
typeSourceSpec_BaseUri¶added inv1.63.0
type SourceSpec_BaseUri struct {// The base URI for all files to be read in as sources for translation.BaseUristring `protobuf:"bytes,1,opt,name=base_uri,json=baseUri,proto3,oneof"`}typeSourceSpec_Literal¶added inv1.63.0
type SourceSpec_Literal struct {// Source literal.Literal *Literal `protobuf:"bytes,2,opt,name=literal,proto3,oneof"`}typeSourceTargetMapping¶added inv1.63.0
type SourceTargetMapping struct {// The source SQL or the path to it.SourceSpec *SourceSpec `protobuf:"bytes,1,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"`// The target SQL or the path for it.TargetSpec *TargetSpec `protobuf:"bytes,2,opt,name=target_spec,json=targetSpec,proto3" json:"target_spec,omitempty"`// contains filtered or unexported fields}Represents one mapping from a source SQL to a target SQL.
func (*SourceTargetMapping)Descriptordeprecatedadded inv1.63.0
func (*SourceTargetMapping) Descriptor() ([]byte, []int)
Deprecated: Use SourceTargetMapping.ProtoReflect.Descriptor instead.
func (*SourceTargetMapping)GetSourceSpec¶added inv1.63.0
func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec
func (*SourceTargetMapping)GetTargetSpec¶added inv1.63.0
func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec
func (*SourceTargetMapping)ProtoMessage¶added inv1.63.0
func (*SourceTargetMapping) ProtoMessage()
func (*SourceTargetMapping)ProtoReflect¶added inv1.63.0
func (x *SourceTargetMapping) ProtoReflect()protoreflect.Message
func (*SourceTargetMapping)Reset¶added inv1.63.0
func (x *SourceTargetMapping) Reset()
func (*SourceTargetMapping)String¶added inv1.63.0
func (x *SourceTargetMapping) String()string
typeSparkSQLDialect¶
type SparkSQLDialect struct {// contains filtered or unexported fields}The dialect definition for SparkSQL.
func (*SparkSQLDialect)Descriptordeprecated
func (*SparkSQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use SparkSQLDialect.ProtoReflect.Descriptor instead.
func (*SparkSQLDialect)ProtoMessage¶
func (*SparkSQLDialect) ProtoMessage()
func (*SparkSQLDialect)ProtoReflect¶
func (x *SparkSQLDialect) ProtoReflect()protoreflect.Message
func (*SparkSQLDialect)Reset¶
func (x *SparkSQLDialect) Reset()
func (*SparkSQLDialect)String¶
func (x *SparkSQLDialect) String()string
typeStartMigrationWorkflowRequest¶
type StartMigrationWorkflowRequest struct {// Required. The unique identifier for the migration workflow.// Example: `projects/123/locations/us/workflows/1234`Namestring `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)Descriptordeprecated
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
typeTargetSpec¶added inv1.63.0
type TargetSpec struct {// The relative path for the target data. Given source file// `base_uri/input/sql`, the output would be// `target_base_uri/sql/relative_path/input.sql`.RelativePathstring `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`// contains filtered or unexported fields}Represents one path to the location that holds target data.
func (*TargetSpec)Descriptordeprecatedadded inv1.63.0
func (*TargetSpec) Descriptor() ([]byte, []int)
Deprecated: Use TargetSpec.ProtoReflect.Descriptor instead.
func (*TargetSpec)GetRelativePath¶added inv1.63.0
func (x *TargetSpec) GetRelativePath()string
func (*TargetSpec)ProtoMessage¶added inv1.63.0
func (*TargetSpec) ProtoMessage()
func (*TargetSpec)ProtoReflect¶added inv1.63.0
func (x *TargetSpec) ProtoReflect()protoreflect.Message
func (*TargetSpec)Reset¶added inv1.63.0
func (x *TargetSpec) Reset()
func (*TargetSpec)String¶added inv1.63.0
func (x *TargetSpec) String()string
typeTeradataDialect¶
type TeradataDialect struct {// Which Teradata sub-dialect mode the user specifies.ModeTeradataDialect_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.cloud.bigquery.migration.v2.TeradataDialect_Mode" json:"mode,omitempty"`// contains filtered or unexported fields}The dialect definition for Teradata.
func (*TeradataDialect)Descriptordeprecated
func (*TeradataDialect) Descriptor() ([]byte, []int)
Deprecated: Use TeradataDialect.ProtoReflect.Descriptor instead.
func (*TeradataDialect)GetMode¶
func (x *TeradataDialect) GetMode()TeradataDialect_Mode
func (*TeradataDialect)ProtoMessage¶
func (*TeradataDialect) ProtoMessage()
func (*TeradataDialect)ProtoReflect¶
func (x *TeradataDialect) ProtoReflect()protoreflect.Message
func (*TeradataDialect)Reset¶
func (x *TeradataDialect) Reset()
func (*TeradataDialect)String¶
func (x *TeradataDialect) String()string
typeTeradataDialect_Mode¶
type TeradataDialect_Modeint32
The sub-dialect options for Teradata.
const (// Unspecified mode.TeradataDialect_MODE_UNSPECIFIEDTeradataDialect_Mode = 0// Teradata SQL mode.TeradataDialect_SQLTeradataDialect_Mode = 1// BTEQ mode (which includes SQL).TeradataDialect_BTEQTeradataDialect_Mode = 2)
func (TeradataDialect_Mode)Descriptor¶
func (TeradataDialect_Mode) Descriptor()protoreflect.EnumDescriptor
func (TeradataDialect_Mode)Enum¶
func (xTeradataDialect_Mode) Enum() *TeradataDialect_Mode
func (TeradataDialect_Mode)EnumDescriptordeprecated
func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TeradataDialect_Mode.Descriptor instead.
func (TeradataDialect_Mode)Number¶
func (xTeradataDialect_Mode) Number()protoreflect.EnumNumber
func (TeradataDialect_Mode)String¶
func (xTeradataDialect_Mode) String()string
func (TeradataDialect_Mode)Type¶
func (TeradataDialect_Mode) Type()protoreflect.EnumType
typeTimeInterval¶
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 intervalrepresents a single point in time.
func (*TimeInterval)Descriptordeprecated
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
typeTimeSeries¶
type TimeSeries struct {// Required. The name of the metric.//// If the metric is not known by the service yet, it will be auto-created.Metricstring `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`// Required. The value type of the time series.ValueTypemetric.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`.MetricKindmetric.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)Descriptordeprecated
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
typeTranslationConfigDetails¶
type TranslationConfigDetails struct {// The chosen path where the source for input files will be found.//// Types that are assignable to SourceLocation:////*TranslationConfigDetails_GcsSourcePathSourceLocation isTranslationConfigDetails_SourceLocation `protobuf_oneof:"source_location"`// The chosen path where the destination for output files will be found.//// Types that are assignable to TargetLocation:////*TranslationConfigDetails_GcsTargetPathTargetLocation isTranslationConfigDetails_TargetLocation `protobuf_oneof:"target_location"`// The mapping of full SQL object names from their current state to the// desired output.//// Types that are assignable to OutputNameMapping:////*TranslationConfigDetails_NameMappingListOutputNameMapping isTranslationConfigDetails_OutputNameMapping `protobuf_oneof:"output_name_mapping"`// The dialect of the input files.SourceDialect *Dialect `protobuf:"bytes,3,opt,name=source_dialect,json=sourceDialect,proto3" json:"source_dialect,omitempty"`// The target dialect for the engine to translate the input to.TargetDialect *Dialect `protobuf:"bytes,4,opt,name=target_dialect,json=targetDialect,proto3" json:"target_dialect,omitempty"`// The default source environment values for the translation.SourceEnv *SourceEnv `protobuf:"bytes,6,opt,name=source_env,json=sourceEnv,proto3" json:"source_env,omitempty"`// The indicator to show translation request initiator.RequestSourcestring `protobuf:"bytes,8,opt,name=request_source,json=requestSource,proto3" json:"request_source,omitempty"`// The types of output to generate, e.g. sql, metadata etc. If not specified,// a default set of targets will be generated. Some additional target types// may be slower to generate. See the documentation for the set of available// target types.TargetTypes []string `protobuf:"bytes,9,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`// contains filtered or unexported fields}The translation config to capture necessary settings for a translation taskand subtask.
func (*TranslationConfigDetails)Descriptordeprecated
func (*TranslationConfigDetails) Descriptor() ([]byte, []int)
Deprecated: Use TranslationConfigDetails.ProtoReflect.Descriptor instead.
func (*TranslationConfigDetails)GetGcsSourcePath¶
func (x *TranslationConfigDetails) GetGcsSourcePath()string
func (*TranslationConfigDetails)GetGcsTargetPath¶
func (x *TranslationConfigDetails) GetGcsTargetPath()string
func (*TranslationConfigDetails)GetNameMappingList¶
func (x *TranslationConfigDetails) GetNameMappingList() *ObjectNameMappingList
func (*TranslationConfigDetails)GetOutputNameMapping¶
func (m *TranslationConfigDetails) GetOutputNameMapping() isTranslationConfigDetails_OutputNameMapping
func (*TranslationConfigDetails)GetRequestSource¶added inv1.50.0
func (x *TranslationConfigDetails) GetRequestSource()string
func (*TranslationConfigDetails)GetSourceDialect¶
func (x *TranslationConfigDetails) GetSourceDialect() *Dialect
func (*TranslationConfigDetails)GetSourceEnv¶
func (x *TranslationConfigDetails) GetSourceEnv() *SourceEnv
func (*TranslationConfigDetails)GetSourceLocation¶
func (m *TranslationConfigDetails) GetSourceLocation() isTranslationConfigDetails_SourceLocation
func (*TranslationConfigDetails)GetTargetDialect¶
func (x *TranslationConfigDetails) GetTargetDialect() *Dialect
func (*TranslationConfigDetails)GetTargetLocation¶
func (m *TranslationConfigDetails) GetTargetLocation() isTranslationConfigDetails_TargetLocation
func (*TranslationConfigDetails)GetTargetTypes¶added inv1.63.0
func (x *TranslationConfigDetails) GetTargetTypes() []string
func (*TranslationConfigDetails)ProtoMessage¶
func (*TranslationConfigDetails) ProtoMessage()
func (*TranslationConfigDetails)ProtoReflect¶
func (x *TranslationConfigDetails) ProtoReflect()protoreflect.Message
func (*TranslationConfigDetails)Reset¶
func (x *TranslationConfigDetails) Reset()
func (*TranslationConfigDetails)String¶
func (x *TranslationConfigDetails) String()string
typeTranslationConfigDetails_GcsSourcePath¶
type TranslationConfigDetails_GcsSourcePath struct {// The Cloud Storage path for a directory of files to translate in a task.GcsSourcePathstring `protobuf:"bytes,1,opt,name=gcs_source_path,json=gcsSourcePath,proto3,oneof"`}typeTranslationConfigDetails_GcsTargetPath¶
type TranslationConfigDetails_GcsTargetPath struct {// The Cloud Storage path to write back the corresponding input files to.GcsTargetPathstring `protobuf:"bytes,2,opt,name=gcs_target_path,json=gcsTargetPath,proto3,oneof"`}typeTranslationConfigDetails_NameMappingList¶
type TranslationConfigDetails_NameMappingList struct {// The mapping of objects to their desired output names in list form.NameMappingList *ObjectNameMappingList `protobuf:"bytes,5,opt,name=name_mapping_list,json=nameMappingList,proto3,oneof"`}typeTranslationDetails¶added inv1.63.0
type TranslationDetails struct {// The mapping from source to target SQL.SourceTargetMapping []*SourceTargetMapping `protobuf:"bytes,1,rep,name=source_target_mapping,json=sourceTargetMapping,proto3" json:"source_target_mapping,omitempty"`// The base URI for all writes to persistent storage.TargetBaseUristring `protobuf:"bytes,2,opt,name=target_base_uri,json=targetBaseUri,proto3" json:"target_base_uri,omitempty"`// The default source environment values for the translation.SourceEnvironment *SourceEnvironment `protobuf:"bytes,3,opt,name=source_environment,json=sourceEnvironment,proto3" json:"source_environment,omitempty"`// The list of literal targets that will be directly returned to the response.// Each entry consists of the constructed path, EXCLUDING the base path. Not// providing a target_base_uri will prevent writing to persistent storage.TargetReturnLiterals []string `protobuf:"bytes,4,rep,name=target_return_literals,json=targetReturnLiterals,proto3" json:"target_return_literals,omitempty"`// The types of output to generate, e.g. sql, metadata,// lineage_from_sql_scripts, etc. If not specified, a default set of// targets will be generated. Some additional target types may be slower to// generate. See the documentation for the set of available target types.TargetTypes []string `protobuf:"bytes,5,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`// contains filtered or unexported fields}The translation details to capture the necessary settings for a translationjob.
func (*TranslationDetails)Descriptordeprecatedadded inv1.63.0
func (*TranslationDetails) Descriptor() ([]byte, []int)
Deprecated: Use TranslationDetails.ProtoReflect.Descriptor instead.
func (*TranslationDetails)GetSourceEnvironment¶added inv1.63.0
func (x *TranslationDetails) GetSourceEnvironment() *SourceEnvironment
func (*TranslationDetails)GetSourceTargetMapping¶added inv1.63.0
func (x *TranslationDetails) GetSourceTargetMapping() []*SourceTargetMapping
func (*TranslationDetails)GetTargetBaseUri¶added inv1.63.0
func (x *TranslationDetails) GetTargetBaseUri()string
func (*TranslationDetails)GetTargetReturnLiterals¶added inv1.63.0
func (x *TranslationDetails) GetTargetReturnLiterals() []string
func (*TranslationDetails)GetTargetTypes¶added inv1.63.0
func (x *TranslationDetails) GetTargetTypes() []string
func (*TranslationDetails)ProtoMessage¶added inv1.63.0
func (*TranslationDetails) ProtoMessage()
func (*TranslationDetails)ProtoReflect¶added inv1.63.0
func (x *TranslationDetails) ProtoReflect()protoreflect.Message
func (*TranslationDetails)Reset¶added inv1.63.0
func (x *TranslationDetails) Reset()
func (*TranslationDetails)String¶added inv1.63.0
func (x *TranslationDetails) String()string
typeTranslationReportRecord¶added inv1.63.0
type TranslationReportRecord struct {// Severity of the translation record.SeverityTranslationReportRecord_Severity ``/* 143-byte string literal not displayed */// Specifies the row from the source text where the error occurred (0 based).// Example: 2ScriptLineint32 `protobuf:"varint,2,opt,name=script_line,json=scriptLine,proto3" json:"script_line,omitempty"`// Specifies the column from the source texts where the error occurred. (0// based) example: 6ScriptColumnint32 `protobuf:"varint,3,opt,name=script_column,json=scriptColumn,proto3" json:"script_column,omitempty"`// Category of the error/warning. Example: SyntaxErrorCategorystring `protobuf:"bytes,4,opt,name=category,proto3" json:"category,omitempty"`// Detailed message of the record.Messagestring `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`// contains filtered or unexported fields}Details about a record.
func (*TranslationReportRecord)Descriptordeprecatedadded inv1.63.0
func (*TranslationReportRecord) Descriptor() ([]byte, []int)
Deprecated: Use TranslationReportRecord.ProtoReflect.Descriptor instead.
func (*TranslationReportRecord)GetCategory¶added inv1.63.0
func (x *TranslationReportRecord) GetCategory()string
func (*TranslationReportRecord)GetMessage¶added inv1.63.0
func (x *TranslationReportRecord) GetMessage()string
func (*TranslationReportRecord)GetScriptColumn¶added inv1.63.0
func (x *TranslationReportRecord) GetScriptColumn()int32
func (*TranslationReportRecord)GetScriptLine¶added inv1.63.0
func (x *TranslationReportRecord) GetScriptLine()int32
func (*TranslationReportRecord)GetSeverity¶added inv1.63.0
func (x *TranslationReportRecord) GetSeverity()TranslationReportRecord_Severity
func (*TranslationReportRecord)ProtoMessage¶added inv1.63.0
func (*TranslationReportRecord) ProtoMessage()
func (*TranslationReportRecord)ProtoReflect¶added inv1.63.0
func (x *TranslationReportRecord) ProtoReflect()protoreflect.Message
func (*TranslationReportRecord)Reset¶added inv1.63.0
func (x *TranslationReportRecord) Reset()
func (*TranslationReportRecord)String¶added inv1.63.0
func (x *TranslationReportRecord) String()string
typeTranslationReportRecord_Severity¶added inv1.63.0
type TranslationReportRecord_Severityint32
The severity type of the record.
const (// SeverityType not specified.TranslationReportRecord_SEVERITY_UNSPECIFIEDTranslationReportRecord_Severity = 0// INFO type.TranslationReportRecord_INFOTranslationReportRecord_Severity = 1// WARNING type. The translated query may still provide useful information// if all the report records are WARNING.TranslationReportRecord_WARNINGTranslationReportRecord_Severity = 2// ERROR type. Translation failed.TranslationReportRecord_ERRORTranslationReportRecord_Severity = 3)
func (TranslationReportRecord_Severity)Descriptor¶added inv1.63.0
func (TranslationReportRecord_Severity) Descriptor()protoreflect.EnumDescriptor
func (TranslationReportRecord_Severity)Enum¶added inv1.63.0
func (xTranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity
func (TranslationReportRecord_Severity)EnumDescriptordeprecatedadded inv1.63.0
func (TranslationReportRecord_Severity) EnumDescriptor() ([]byte, []int)
Deprecated: Use TranslationReportRecord_Severity.Descriptor instead.
func (TranslationReportRecord_Severity)Number¶added inv1.63.0
func (xTranslationReportRecord_Severity) Number()protoreflect.EnumNumber
func (TranslationReportRecord_Severity)String¶added inv1.63.0
func (xTranslationReportRecord_Severity) String()string
func (TranslationReportRecord_Severity)Type¶added inv1.63.0
func (TranslationReportRecord_Severity) Type()protoreflect.EnumType
typeTranslationTaskResult¶added inv1.63.0
type TranslationTaskResult struct {// The list of the translated literals.TranslatedLiterals []*Literal `protobuf:"bytes,1,rep,name=translated_literals,json=translatedLiterals,proto3" json:"translated_literals,omitempty"`// The records from the aggregate CSV report for a migration workflow.ReportLogMessages []*GcsReportLogMessage `protobuf:"bytes,2,rep,name=report_log_messages,json=reportLogMessages,proto3" json:"report_log_messages,omitempty"`// contains filtered or unexported fields}Translation specific result details from the migration task.
func (*TranslationTaskResult)Descriptordeprecatedadded inv1.63.0
func (*TranslationTaskResult) Descriptor() ([]byte, []int)
Deprecated: Use TranslationTaskResult.ProtoReflect.Descriptor instead.
func (*TranslationTaskResult)GetReportLogMessages¶added inv1.63.0
func (x *TranslationTaskResult) GetReportLogMessages() []*GcsReportLogMessage
func (*TranslationTaskResult)GetTranslatedLiterals¶added inv1.63.0
func (x *TranslationTaskResult) GetTranslatedLiterals() []*Literal
func (*TranslationTaskResult)ProtoMessage¶added inv1.63.0
func (*TranslationTaskResult) ProtoMessage()
func (*TranslationTaskResult)ProtoReflect¶added inv1.63.0
func (x *TranslationTaskResult) ProtoReflect()protoreflect.Message
func (*TranslationTaskResult)Reset¶added inv1.63.0
func (x *TranslationTaskResult) Reset()
func (*TranslationTaskResult)String¶added inv1.63.0
func (x *TranslationTaskResult) String()string
typeTypedValue¶
type TypedValue struct {// The typed value field.//// Types that are assignable to Value:////*TypedValue_BoolValue//*TypedValue_Int64Value//*TypedValue_DoubleValue//*TypedValue_StringValue//*TypedValue_DistributionValueValue isTypedValue_Value `protobuf_oneof:"value"`// contains filtered or unexported fields}A single strongly-typed value.
func (*TypedValue)Descriptordeprecated
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
typeTypedValue_BoolValue¶
type TypedValue_BoolValue struct {// A Boolean value: `true` or `false`.BoolValuebool `protobuf:"varint,1,opt,name=bool_value,json=boolValue,proto3,oneof"`}typeTypedValue_DistributionValue¶
type TypedValue_DistributionValue struct {// A distribution value.DistributionValue *distribution.Distribution `protobuf:"bytes,5,opt,name=distribution_value,json=distributionValue,proto3,oneof"`}typeTypedValue_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.DoubleValuefloat64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`}typeTypedValue_Int64Value¶
type TypedValue_Int64Value struct {// A 64-bit integer. Its range is approximately `+/-9.2x10^18`.Int64Valueint64 `protobuf:"varint,2,opt,name=int64_value,json=int64Value,proto3,oneof"`}typeTypedValue_StringValue¶
type TypedValue_StringValue struct {// A variable-length string value.StringValuestring `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`}typeUnimplementedMigrationServiceServer¶
type UnimplementedMigrationServiceServer struct {}UnimplementedMigrationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedMigrationServiceServer)CreateMigrationWorkflow¶
func (UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow,error)
func (UnimplementedMigrationServiceServer)DeleteMigrationWorkflow¶
func (UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty,error)
func (UnimplementedMigrationServiceServer)GetMigrationSubtask¶
func (UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask,error)
func (UnimplementedMigrationServiceServer)GetMigrationWorkflow¶
func (UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow,error)
func (UnimplementedMigrationServiceServer)ListMigrationSubtasks¶
func (UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse,error)
func (UnimplementedMigrationServiceServer)ListMigrationWorkflows¶
func (UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse,error)
func (UnimplementedMigrationServiceServer)StartMigrationWorkflow¶
func (UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty,error)
typeUnsafeMigrationServiceServer¶added inv1.72.0
type UnsafeMigrationServiceServer interface {// contains filtered or unexported methods}UnsafeMigrationServiceServer may be embedded to opt out of forward compatibility for this service.Use of this interface is not recommended, as added methods to MigrationServiceServer willresult in compilation errors.
typeVerticaDialect¶
type VerticaDialect struct {// contains filtered or unexported fields}The dialect definition for Vertica.
func (*VerticaDialect)Descriptordeprecated
func (*VerticaDialect) Descriptor() ([]byte, []int)
Deprecated: Use VerticaDialect.ProtoReflect.Descriptor instead.
func (*VerticaDialect)ProtoMessage¶
func (*VerticaDialect) ProtoMessage()
func (*VerticaDialect)ProtoReflect¶
func (x *VerticaDialect) ProtoReflect()protoreflect.Message
func (*VerticaDialect)Reset¶
func (x *VerticaDialect) Reset()
func (*VerticaDialect)String¶
func (x *VerticaDialect) String()string