package migrationpb
import "cloud.google.com/go/bigquery/migration/apiv2/migrationpb"
Index ¶
- Variables
- func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)
- type AzureSynapseDialect
- func (*AzureSynapseDialect) Descriptor() ([]byte, []int)
- func (*AzureSynapseDialect) ProtoMessage()
- func (x *AzureSynapseDialect) ProtoReflect() protoreflect.Message
- func (x *AzureSynapseDialect) Reset()
- func (x *AzureSynapseDialect) String() string
- type BigQueryDialect
- func (*BigQueryDialect) Descriptor() ([]byte, []int)
- func (*BigQueryDialect) ProtoMessage()
- func (x *BigQueryDialect) ProtoReflect() protoreflect.Message
- func (x *BigQueryDialect) Reset()
- func (x *BigQueryDialect) String() string
- type CreateMigrationWorkflowRequest
- func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int)
- 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
- func (*DB2Dialect) Descriptor() ([]byte, []int)
- func (*DB2Dialect) ProtoMessage()
- func (x *DB2Dialect) ProtoReflect() protoreflect.Message
- func (x *DB2Dialect) Reset()
- func (x *DB2Dialect) String() string
- type DeleteMigrationWorkflowRequest
- func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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
- func (*GreenplumDialect) Descriptor() ([]byte, []int)
- func (*GreenplumDialect) ProtoMessage()
- func (x *GreenplumDialect) ProtoReflect() protoreflect.Message
- func (x *GreenplumDialect) Reset()
- func (x *GreenplumDialect) String() string
- type HiveQLDialect
- func (*HiveQLDialect) Descriptor() ([]byte, []int)
- func (*HiveQLDialect) ProtoMessage()
- func (x *HiveQLDialect) ProtoReflect() protoreflect.Message
- func (x *HiveQLDialect) Reset()
- func (x *HiveQLDialect) String() string
- type ListMigrationSubtasksRequest
- func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber
- func (x MigrationWorkflow_State) String() string
- func (MigrationWorkflow_State) Type() protoreflect.EnumType
- type MySQLDialect
- func (*MySQLDialect) Descriptor() ([]byte, []int)
- func (*MySQLDialect) ProtoMessage()
- func (x *MySQLDialect) ProtoReflect() protoreflect.Message
- func (x *MySQLDialect) Reset()
- func (x *MySQLDialect) String() string
- type NameMappingKey
- func (*NameMappingKey) Descriptor() ([]byte, []int)
- 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)
- 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)
- 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
- func (*NetezzaDialect) Descriptor() ([]byte, []int)
- func (*NetezzaDialect) ProtoMessage()
- func (x *NetezzaDialect) ProtoReflect() protoreflect.Message
- func (x *NetezzaDialect) Reset()
- func (x *NetezzaDialect) String() string
- type ObjectNameMapping
- func (*ObjectNameMapping) Descriptor() ([]byte, []int)
- 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)
- 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
- func (*OracleDialect) Descriptor() ([]byte, []int)
- func (*OracleDialect) ProtoMessage()
- func (x *OracleDialect) ProtoReflect() protoreflect.Message
- func (x *OracleDialect) Reset()
- func (x *OracleDialect) String() string
- type Point
- func (*Point) Descriptor() ([]byte, []int)
- func (x *Point) GetInterval() *TimeInterval
- func (x *Point) GetValue() *TypedValue
- func (*Point) ProtoMessage()
- func (x *Point) ProtoReflect() protoreflect.Message
- func (x *Point) Reset()
- func (x *Point) String() string
- type PostgresqlDialect
- func (*PostgresqlDialect) Descriptor() ([]byte, []int)
- func (*PostgresqlDialect) ProtoMessage()
- func (x *PostgresqlDialect) ProtoReflect() protoreflect.Message
- func (x *PostgresqlDialect) Reset()
- func (x *PostgresqlDialect) String() string
- type PrestoDialect
- func (*PrestoDialect) Descriptor() ([]byte, []int)
- func (*PrestoDialect) ProtoMessage()
- func (x *PrestoDialect) ProtoReflect() protoreflect.Message
- func (x *PrestoDialect) Reset()
- func (x *PrestoDialect) String() string
- type RedshiftDialect
- func (*RedshiftDialect) Descriptor() ([]byte, []int)
- func (*RedshiftDialect) ProtoMessage()
- func (x *RedshiftDialect) ProtoReflect() protoreflect.Message
- func (x *RedshiftDialect) Reset()
- func (x *RedshiftDialect) String() string
- type ResourceErrorDetail
- func (*ResourceErrorDetail) Descriptor() ([]byte, []int)
- 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
- func (*SQLServerDialect) Descriptor() ([]byte, []int)
- func (*SQLServerDialect) ProtoMessage()
- func (x *SQLServerDialect) ProtoReflect() protoreflect.Message
- func (x *SQLServerDialect) Reset()
- func (x *SQLServerDialect) String() string
- type SQLiteDialect
- func (*SQLiteDialect) Descriptor() ([]byte, []int)
- func (*SQLiteDialect) ProtoMessage()
- func (x *SQLiteDialect) ProtoReflect() protoreflect.Message
- func (x *SQLiteDialect) Reset()
- func (x *SQLiteDialect) String() string
- type SnowflakeDialect
- func (*SnowflakeDialect) Descriptor() ([]byte, []int)
- func (*SnowflakeDialect) ProtoMessage()
- func (x *SnowflakeDialect) ProtoReflect() protoreflect.Message
- func (x *SnowflakeDialect) Reset()
- func (x *SnowflakeDialect) String() string
- type SourceEnv
- func (*SourceEnv) Descriptor() ([]byte, []int)
- 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)
- 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)
- 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)
- 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
- func (*SparkSQLDialect) Descriptor() ([]byte, []int)
- func (*SparkSQLDialect) ProtoMessage()
- func (x *SparkSQLDialect) ProtoReflect() protoreflect.Message
- func (x *SparkSQLDialect) Reset()
- func (x *SparkSQLDialect) String() string
- type StartMigrationWorkflowRequest
- func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int)
- 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
- func (*TargetSpec) Descriptor() ([]byte, []int)
- func (x *TargetSpec) GetRelativePath() string
- func (*TargetSpec) ProtoMessage()
- func (x *TargetSpec) ProtoReflect() protoreflect.Message
- func (x *TargetSpec) Reset()
- func (x *TargetSpec) String() string
- type TeradataDialect
- func (*TeradataDialect) Descriptor() ([]byte, []int)
- func (x *TeradataDialect) GetMode() TeradataDialect_Mode
- func (*TeradataDialect) ProtoMessage()
- func (x *TeradataDialect) ProtoReflect() protoreflect.Message
- func (x *TeradataDialect) Reset()
- func (x *TeradataDialect) String() string
- type TeradataDialect_Mode
- func (TeradataDialect_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x TeradataDialect_Mode) Enum() *TeradataDialect_Mode
- func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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 VerticaDialect
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_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_migration_error_details_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_migration_metrics_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_migration_service_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_translation_config_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_translation_details_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_translation_suggestion_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_migration_v2_translation_usability_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMigrationServiceServer ¶
func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)
Types ¶
type AzureSynapseDialect ¶
type AzureSynapseDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Azure Synapse.
func (*AzureSynapseDialect) Descriptor ¶
func (*AzureSynapseDialect) Descriptor() ([]byte, []int)
Deprecated: Use AzureSynapseDialect.ProtoReflect.Descriptor instead.
func (*AzureSynapseDialect) ProtoMessage ¶
func (*AzureSynapseDialect) ProtoMessage()
func (*AzureSynapseDialect) ProtoReflect ¶
func (x *AzureSynapseDialect) ProtoReflect() protoreflect.Message
func (*AzureSynapseDialect) Reset ¶
func (x *AzureSynapseDialect) Reset()
func (*AzureSynapseDialect) String ¶
func (x *AzureSynapseDialect) String() string
type BigQueryDialect ¶
type BigQueryDialect struct {
// contains filtered or unexported fields
}
The dialect definition for BigQuery.
func (*BigQueryDialect) Descriptor ¶
func (*BigQueryDialect) Descriptor() ([]byte, []int)
Deprecated: Use BigQueryDialect.ProtoReflect.Descriptor instead.
func (*BigQueryDialect) ProtoMessage ¶
func (*BigQueryDialect) ProtoMessage()
func (*BigQueryDialect) ProtoReflect ¶
func (x *BigQueryDialect) ProtoReflect() protoreflect.Message
func (*BigQueryDialect) Reset ¶
func (x *BigQueryDialect) Reset()
func (*BigQueryDialect) String ¶
func (x *BigQueryDialect) String() string
type CreateMigrationWorkflowRequest ¶
type CreateMigrationWorkflowRequest struct {
// Required. The name of the project to which this migration workflow belongs.
// Example: `projects/foo/locations/bar`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The migration workflow to create.
MigrationWorkflow *MigrationWorkflow `protobuf:"bytes,2,opt,name=migration_workflow,json=migrationWorkflow,proto3" json:"migration_workflow,omitempty"`
// contains filtered or unexported fields
}
Request to create a migration workflow resource.
func (*CreateMigrationWorkflowRequest) Descriptor ¶
func (*CreateMigrationWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateMigrationWorkflowRequest.ProtoReflect.Descriptor instead.
func (*CreateMigrationWorkflowRequest) GetMigrationWorkflow ¶
func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow
func (*CreateMigrationWorkflowRequest) GetParent ¶
func (x *CreateMigrationWorkflowRequest) GetParent() string
func (*CreateMigrationWorkflowRequest) ProtoMessage ¶
func (*CreateMigrationWorkflowRequest) ProtoMessage()
func (*CreateMigrationWorkflowRequest) ProtoReflect ¶
func (x *CreateMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
func (*CreateMigrationWorkflowRequest) Reset ¶
func (x *CreateMigrationWorkflowRequest) Reset()
func (*CreateMigrationWorkflowRequest) String ¶
func (x *CreateMigrationWorkflowRequest) String() string
type DB2Dialect ¶
type DB2Dialect struct {
// contains filtered or unexported fields
}
The dialect definition for DB2.
func (*DB2Dialect) Descriptor ¶
func (*DB2Dialect) Descriptor() ([]byte, []int)
Deprecated: Use DB2Dialect.ProtoReflect.Descriptor instead.
func (*DB2Dialect) ProtoMessage ¶
func (*DB2Dialect) ProtoMessage()
func (*DB2Dialect) ProtoReflect ¶
func (x *DB2Dialect) ProtoReflect() protoreflect.Message
func (*DB2Dialect) Reset ¶
func (x *DB2Dialect) Reset()
func (*DB2Dialect) String ¶
func (x *DB2Dialect) String() string
type DeleteMigrationWorkflowRequest ¶
type DeleteMigrationWorkflowRequest struct {
// Required. The unique identifier for the migration workflow.
// Example: `projects/123/locations/us/workflows/1234`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
A request to delete a previously created migration workflow.
func (*DeleteMigrationWorkflowRequest) Descriptor ¶
func (*DeleteMigrationWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMigrationWorkflowRequest.ProtoReflect.Descriptor instead.
func (*DeleteMigrationWorkflowRequest) GetName ¶
func (x *DeleteMigrationWorkflowRequest) GetName() string
func (*DeleteMigrationWorkflowRequest) ProtoMessage ¶
func (*DeleteMigrationWorkflowRequest) ProtoMessage()
func (*DeleteMigrationWorkflowRequest) ProtoReflect ¶
func (x *DeleteMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
func (*DeleteMigrationWorkflowRequest) Reset ¶
func (x *DeleteMigrationWorkflowRequest) Reset()
func (*DeleteMigrationWorkflowRequest) String ¶
func (x *DeleteMigrationWorkflowRequest) String() string
type Dialect ¶
type Dialect struct {
// The possible dialect options that this message represents.
//
// Types that are assignable to DialectValue:
//
// *Dialect_BigqueryDialect
// *Dialect_HiveqlDialect
// *Dialect_RedshiftDialect
// *Dialect_TeradataDialect
// *Dialect_OracleDialect
// *Dialect_SparksqlDialect
// *Dialect_SnowflakeDialect
// *Dialect_NetezzaDialect
// *Dialect_AzureSynapseDialect
// *Dialect_VerticaDialect
// *Dialect_SqlServerDialect
// *Dialect_PostgresqlDialect
// *Dialect_PrestoDialect
// *Dialect_MysqlDialect
// *Dialect_Db2Dialect
// *Dialect_SqliteDialect
// *Dialect_GreenplumDialect
DialectValue isDialect_DialectValue `protobuf_oneof:"dialect_value"`
// contains filtered or unexported fields
}
The possible dialect options for translation.
func (*Dialect) Descriptor ¶
Deprecated: Use Dialect.ProtoReflect.Descriptor instead.
func (*Dialect) GetAzureSynapseDialect ¶
func (x *Dialect) GetAzureSynapseDialect() *AzureSynapseDialect
func (*Dialect) GetBigqueryDialect ¶
func (x *Dialect) GetBigqueryDialect() *BigQueryDialect
func (*Dialect) GetDb2Dialect ¶
func (x *Dialect) GetDb2Dialect() *DB2Dialect
func (*Dialect) GetDialectValue ¶
func (m *Dialect) GetDialectValue() isDialect_DialectValue
func (*Dialect) GetGreenplumDialect ¶
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 ¶
func (x *Dialect) GetSqliteDialect() *SQLiteDialect
func (*Dialect) GetTeradataDialect ¶
func (x *Dialect) GetTeradataDialect() *TeradataDialect
func (*Dialect) GetVerticaDialect ¶
func (x *Dialect) GetVerticaDialect() *VerticaDialect
func (*Dialect) ProtoMessage ¶
func (*Dialect) ProtoMessage()
func (*Dialect) ProtoReflect ¶
func (x *Dialect) ProtoReflect() protoreflect.Message
func (*Dialect) Reset ¶
func (x *Dialect) Reset()
func (*Dialect) String ¶
type Dialect_AzureSynapseDialect ¶
type Dialect_AzureSynapseDialect struct {
// The Azure Synapse dialect
AzureSynapseDialect *AzureSynapseDialect `protobuf:"bytes,9,opt,name=azure_synapse_dialect,json=azureSynapseDialect,proto3,oneof"`
}
type Dialect_BigqueryDialect ¶
type Dialect_BigqueryDialect struct {
// The BigQuery dialect
BigqueryDialect *BigQueryDialect `protobuf:"bytes,1,opt,name=bigquery_dialect,json=bigqueryDialect,proto3,oneof"`
}
type Dialect_Db2Dialect ¶
type Dialect_Db2Dialect struct {
// DB2 dialect
Db2Dialect *DB2Dialect `protobuf:"bytes,15,opt,name=db2_dialect,json=db2Dialect,proto3,oneof"`
}
type Dialect_GreenplumDialect ¶
type Dialect_GreenplumDialect struct {
// Greenplum dialect
GreenplumDialect *GreenplumDialect `protobuf:"bytes,17,opt,name=greenplum_dialect,json=greenplumDialect,proto3,oneof"`
}
type Dialect_HiveqlDialect ¶
type Dialect_HiveqlDialect struct {
// The HiveQL dialect
HiveqlDialect *HiveQLDialect `protobuf:"bytes,2,opt,name=hiveql_dialect,json=hiveqlDialect,proto3,oneof"`
}
type Dialect_MysqlDialect ¶
type Dialect_MysqlDialect struct {
// The MySQL dialect
MysqlDialect *MySQLDialect `protobuf:"bytes,14,opt,name=mysql_dialect,json=mysqlDialect,proto3,oneof"`
}
type Dialect_NetezzaDialect ¶
type Dialect_NetezzaDialect struct {
// The Netezza dialect
NetezzaDialect *NetezzaDialect `protobuf:"bytes,8,opt,name=netezza_dialect,json=netezzaDialect,proto3,oneof"`
}
type Dialect_OracleDialect ¶
type Dialect_OracleDialect struct {
// The Oracle dialect
OracleDialect *OracleDialect `protobuf:"bytes,5,opt,name=oracle_dialect,json=oracleDialect,proto3,oneof"`
}
type Dialect_PostgresqlDialect ¶
type Dialect_PostgresqlDialect struct {
// The Postgresql dialect
PostgresqlDialect *PostgresqlDialect `protobuf:"bytes,12,opt,name=postgresql_dialect,json=postgresqlDialect,proto3,oneof"`
}
type Dialect_PrestoDialect ¶
type Dialect_PrestoDialect struct {
// The Presto dialect
PrestoDialect *PrestoDialect `protobuf:"bytes,13,opt,name=presto_dialect,json=prestoDialect,proto3,oneof"`
}
type Dialect_RedshiftDialect ¶
type Dialect_RedshiftDialect struct {
// The Redshift dialect
RedshiftDialect *RedshiftDialect `protobuf:"bytes,3,opt,name=redshift_dialect,json=redshiftDialect,proto3,oneof"`
}
type Dialect_SnowflakeDialect ¶
type Dialect_SnowflakeDialect struct {
// The Snowflake dialect
SnowflakeDialect *SnowflakeDialect `protobuf:"bytes,7,opt,name=snowflake_dialect,json=snowflakeDialect,proto3,oneof"`
}
type Dialect_SparksqlDialect ¶
type Dialect_SparksqlDialect struct {
// The SparkSQL dialect
SparksqlDialect *SparkSQLDialect `protobuf:"bytes,6,opt,name=sparksql_dialect,json=sparksqlDialect,proto3,oneof"`
}
type Dialect_SqlServerDialect ¶
type Dialect_SqlServerDialect struct {
// The SQL Server dialect
SqlServerDialect *SQLServerDialect `protobuf:"bytes,11,opt,name=sql_server_dialect,json=sqlServerDialect,proto3,oneof"`
}
type Dialect_SqliteDialect ¶
type Dialect_SqliteDialect struct {
// SQLite dialect
SqliteDialect *SQLiteDialect `protobuf:"bytes,16,opt,name=sqlite_dialect,json=sqliteDialect,proto3,oneof"`
}
type Dialect_TeradataDialect ¶
type Dialect_TeradataDialect struct {
// The Teradata dialect
TeradataDialect *TeradataDialect `protobuf:"bytes,4,opt,name=teradata_dialect,json=teradataDialect,proto3,oneof"`
}
type Dialect_VerticaDialect ¶
type Dialect_VerticaDialect struct {
// The Vertica dialect
VerticaDialect *VerticaDialect `protobuf:"bytes,10,opt,name=vertica_dialect,json=verticaDialect,proto3,oneof"`
}
type ErrorDetail ¶
type ErrorDetail struct {
// Optional. The exact location within the resource (if applicable).
Location *ErrorLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
// Required. Describes the cause of the error with structured detail.
ErrorInfo *errdetails.ErrorInfo `protobuf:"bytes,2,opt,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
// contains filtered or unexported fields
}
Provides details for errors, e.g. issues that where encountered when processing a subtask.
func (*ErrorDetail) Descriptor ¶
func (*ErrorDetail) Descriptor() ([]byte, []int)
Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.
func (*ErrorDetail) GetErrorInfo ¶
func (x *ErrorDetail) GetErrorInfo() *errdetails.ErrorInfo
func (*ErrorDetail) GetLocation ¶
func (x *ErrorDetail) GetLocation() *ErrorLocation
func (*ErrorDetail) ProtoMessage ¶
func (*ErrorDetail) ProtoMessage()
func (*ErrorDetail) ProtoReflect ¶
func (x *ErrorDetail) ProtoReflect() protoreflect.Message
func (*ErrorDetail) Reset ¶
func (x *ErrorDetail) Reset()
func (*ErrorDetail) String ¶
func (x *ErrorDetail) String() string
type ErrorLocation ¶
type ErrorLocation struct {
// Optional. If applicable, denotes the line where the error occurred. A zero
// value means that there is no line information.
Line int32 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
// Optional. If applicable, denotes the column where the error occurred. A
// zero value means that there is no columns information.
Column int32 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
// contains filtered or unexported fields
}
Holds information about where the error is located.
func (*ErrorLocation) Descriptor ¶
func (*ErrorLocation) Descriptor() ([]byte, []int)
Deprecated: Use ErrorLocation.ProtoReflect.Descriptor instead.
func (*ErrorLocation) GetColumn ¶
func (x *ErrorLocation) GetColumn() int32
func (*ErrorLocation) GetLine ¶
func (x *ErrorLocation) GetLine() int32
func (*ErrorLocation) ProtoMessage ¶
func (*ErrorLocation) ProtoMessage()
func (*ErrorLocation) ProtoReflect ¶
func (x *ErrorLocation) ProtoReflect() protoreflect.Message
func (*ErrorLocation) Reset ¶
func (x *ErrorLocation) Reset()
func (*ErrorLocation) String ¶
func (x *ErrorLocation) String() string
type GcsReportLogMessage ¶
type GcsReportLogMessage struct {
// Severity of the translation record.
Severity string `protobuf:"bytes,1,opt,name=severity,proto3" json:"severity,omitempty"`
// Category of the error/warning. Example: SyntaxError
Category string `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`
// The file path in which the error occurred
FilePath string `protobuf:"bytes,3,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
// The file name in which the error occurred
Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
// Specifies the row from the source text where the error occurred (0 based,
// -1 for messages without line location). Example: 2
SourceScriptLine int32 `protobuf:"varint,5,opt,name=source_script_line,json=sourceScriptLine,proto3" json:"source_script_line,omitempty"`
// Specifies the column from the source texts where the error occurred. (0
// based, -1 for messages without column location) example: 6
SourceScriptColumn int32 `protobuf:"varint,6,opt,name=source_script_column,json=sourceScriptColumn,proto3" json:"source_script_column,omitempty"`
// Detailed message of the record.
Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
// The script context (obfuscated) in which the error occurred
ScriptContext string `protobuf:"bytes,8,opt,name=script_context,json=scriptContext,proto3" json:"script_context,omitempty"`
// Category of the error/warning. Example: SyntaxError
Action string `protobuf:"bytes,9,opt,name=action,proto3" json:"action,omitempty"`
// Effect of the error/warning. Example: COMPATIBILITY
Effect string `protobuf:"bytes,10,opt,name=effect,proto3" json:"effect,omitempty"`
// Name of the affected object in the log message.
ObjectName string `protobuf:"bytes,11,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
// contains filtered or unexported fields
}
A record in the aggregate CSV report for a migration workflow
func (*GcsReportLogMessage) Descriptor ¶
func (*GcsReportLogMessage) Descriptor() ([]byte, []int)
Deprecated: Use GcsReportLogMessage.ProtoReflect.Descriptor instead.
func (*GcsReportLogMessage) GetAction ¶
func (x *GcsReportLogMessage) GetAction() string
func (*GcsReportLogMessage) GetCategory ¶
func (x *GcsReportLogMessage) GetCategory() string
func (*GcsReportLogMessage) GetEffect ¶
func (x *GcsReportLogMessage) GetEffect() string
func (*GcsReportLogMessage) GetFilePath ¶
func (x *GcsReportLogMessage) GetFilePath() string
func (*GcsReportLogMessage) GetFilename ¶
func (x *GcsReportLogMessage) GetFilename() string
func (*GcsReportLogMessage) GetMessage ¶
func (x *GcsReportLogMessage) GetMessage() string
func (*GcsReportLogMessage) GetObjectName ¶
func (x *GcsReportLogMessage) GetObjectName() string
func (*GcsReportLogMessage) GetScriptContext ¶
func (x *GcsReportLogMessage) GetScriptContext() string
func (*GcsReportLogMessage) GetSeverity ¶
func (x *GcsReportLogMessage) GetSeverity() string
func (*GcsReportLogMessage) GetSourceScriptColumn ¶
func (x *GcsReportLogMessage) GetSourceScriptColumn() int32
func (*GcsReportLogMessage) GetSourceScriptLine ¶
func (x *GcsReportLogMessage) GetSourceScriptLine() int32
func (*GcsReportLogMessage) ProtoMessage ¶
func (*GcsReportLogMessage) ProtoMessage()
func (*GcsReportLogMessage) ProtoReflect ¶
func (x *GcsReportLogMessage) ProtoReflect() protoreflect.Message
func (*GcsReportLogMessage) Reset ¶
func (x *GcsReportLogMessage) Reset()
func (*GcsReportLogMessage) String ¶
func (x *GcsReportLogMessage) String() string
type GetMigrationSubtaskRequest ¶
type GetMigrationSubtaskRequest struct {
// Required. The unique identifier for the migration subtask.
// Example: `projects/123/locations/us/workflows/1234/subtasks/543`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. The list of fields to be retrieved.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// contains filtered or unexported fields
}
A request to get a previously created migration subtasks.
func (*GetMigrationSubtaskRequest) Descriptor ¶
func (*GetMigrationSubtaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMigrationSubtaskRequest.ProtoReflect.Descriptor instead.
func (*GetMigrationSubtaskRequest) GetName ¶
func (x *GetMigrationSubtaskRequest) GetName() string
func (*GetMigrationSubtaskRequest) GetReadMask ¶
func (x *GetMigrationSubtaskRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*GetMigrationSubtaskRequest) ProtoMessage ¶
func (*GetMigrationSubtaskRequest) ProtoMessage()
func (*GetMigrationSubtaskRequest) ProtoReflect ¶
func (x *GetMigrationSubtaskRequest) ProtoReflect() protoreflect.Message
func (*GetMigrationSubtaskRequest) Reset ¶
func (x *GetMigrationSubtaskRequest) Reset()
func (*GetMigrationSubtaskRequest) String ¶
func (x *GetMigrationSubtaskRequest) String() string
type GetMigrationWorkflowRequest ¶
type GetMigrationWorkflowRequest struct {
// Required. The unique identifier for the migration workflow.
// Example: `projects/123/locations/us/workflows/1234`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The list of fields to be retrieved.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// contains filtered or unexported fields
}
A request to get a previously created migration workflow.
func (*GetMigrationWorkflowRequest) Descriptor ¶
func (*GetMigrationWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMigrationWorkflowRequest.ProtoReflect.Descriptor instead.
func (*GetMigrationWorkflowRequest) GetName ¶
func (x *GetMigrationWorkflowRequest) GetName() string
func (*GetMigrationWorkflowRequest) GetReadMask ¶
func (x *GetMigrationWorkflowRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*GetMigrationWorkflowRequest) ProtoMessage ¶
func (*GetMigrationWorkflowRequest) ProtoMessage()
func (*GetMigrationWorkflowRequest) ProtoReflect ¶
func (x *GetMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
func (*GetMigrationWorkflowRequest) Reset ¶
func (x *GetMigrationWorkflowRequest) Reset()
func (*GetMigrationWorkflowRequest) String ¶
func (x *GetMigrationWorkflowRequest) String() string
type GreenplumDialect ¶
type GreenplumDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Greenplum.
func (*GreenplumDialect) Descriptor ¶
func (*GreenplumDialect) Descriptor() ([]byte, []int)
Deprecated: Use GreenplumDialect.ProtoReflect.Descriptor instead.
func (*GreenplumDialect) ProtoMessage ¶
func (*GreenplumDialect) ProtoMessage()
func (*GreenplumDialect) ProtoReflect ¶
func (x *GreenplumDialect) ProtoReflect() protoreflect.Message
func (*GreenplumDialect) Reset ¶
func (x *GreenplumDialect) Reset()
func (*GreenplumDialect) String ¶
func (x *GreenplumDialect) String() string
type HiveQLDialect ¶
type HiveQLDialect struct {
// contains filtered or unexported fields
}
The dialect definition for HiveQL.
func (*HiveQLDialect) Descriptor ¶
func (*HiveQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use HiveQLDialect.ProtoReflect.Descriptor instead.
func (*HiveQLDialect) ProtoMessage ¶
func (*HiveQLDialect) ProtoMessage()
func (*HiveQLDialect) ProtoReflect ¶
func (x *HiveQLDialect) ProtoReflect() protoreflect.Message
func (*HiveQLDialect) Reset ¶
func (x *HiveQLDialect) Reset()
func (*HiveQLDialect) String ¶
func (x *HiveQLDialect) String() string
type ListMigrationSubtasksRequest ¶
type ListMigrationSubtasksRequest struct {
// Required. The migration task of the subtasks to list.
// Example: `projects/123/locations/us/workflows/1234`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Optional. The list of fields to be retrieved.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// Optional. The maximum number of migration tasks to return. The service may
// return fewer than this number.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Optional. A page token, received from previous `ListMigrationSubtasks`
// call. Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListMigrationSubtasks`
// must match the call that provided the page token.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Optional. The filter to apply. This can be used to get the subtasks of a
// specific tasks in a workflow, e.g. `migration_task = "ab012"` where
// `"ab012"` is the task ID (not the name in the named map).
Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
A request to list previously created migration subtasks.
func (*ListMigrationSubtasksRequest) Descriptor ¶
func (*ListMigrationSubtasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationSubtasksRequest.ProtoReflect.Descriptor instead.
func (*ListMigrationSubtasksRequest) GetFilter ¶
func (x *ListMigrationSubtasksRequest) GetFilter() string
func (*ListMigrationSubtasksRequest) GetPageSize ¶
func (x *ListMigrationSubtasksRequest) GetPageSize() int32
func (*ListMigrationSubtasksRequest) GetPageToken ¶
func (x *ListMigrationSubtasksRequest) GetPageToken() string
func (*ListMigrationSubtasksRequest) GetParent ¶
func (x *ListMigrationSubtasksRequest) GetParent() string
func (*ListMigrationSubtasksRequest) GetReadMask ¶
func (x *ListMigrationSubtasksRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*ListMigrationSubtasksRequest) ProtoMessage ¶
func (*ListMigrationSubtasksRequest) ProtoMessage()
func (*ListMigrationSubtasksRequest) ProtoReflect ¶
func (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message
func (*ListMigrationSubtasksRequest) Reset ¶
func (x *ListMigrationSubtasksRequest) Reset()
func (*ListMigrationSubtasksRequest) String ¶
func (x *ListMigrationSubtasksRequest) String() string
type ListMigrationSubtasksResponse ¶
type ListMigrationSubtasksResponse struct {
// The migration subtasks for the specified task.
MigrationSubtasks []*MigrationSubtask `protobuf:"bytes,1,rep,name=migration_subtasks,json=migrationSubtasks,proto3" json:"migration_subtasks,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response object for a `ListMigrationSubtasks` call.
func (*ListMigrationSubtasksResponse) Descriptor ¶
func (*ListMigrationSubtasksResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationSubtasksResponse.ProtoReflect.Descriptor instead.
func (*ListMigrationSubtasksResponse) GetMigrationSubtasks ¶
func (x *ListMigrationSubtasksResponse) GetMigrationSubtasks() []*MigrationSubtask
func (*ListMigrationSubtasksResponse) GetNextPageToken ¶
func (x *ListMigrationSubtasksResponse) GetNextPageToken() string
func (*ListMigrationSubtasksResponse) ProtoMessage ¶
func (*ListMigrationSubtasksResponse) ProtoMessage()
func (*ListMigrationSubtasksResponse) ProtoReflect ¶
func (x *ListMigrationSubtasksResponse) ProtoReflect() protoreflect.Message
func (*ListMigrationSubtasksResponse) Reset ¶
func (x *ListMigrationSubtasksResponse) Reset()
func (*ListMigrationSubtasksResponse) String ¶
func (x *ListMigrationSubtasksResponse) String() string
type ListMigrationWorkflowsRequest ¶
type ListMigrationWorkflowsRequest struct {
// Required. The project and location of the migration workflows to list.
// Example: `projects/123/locations/us`
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The list of fields to be retrieved.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// The maximum number of migration workflows to return. The service may return
// fewer than this number.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from previous `ListMigrationWorkflows` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListMigrationWorkflows`
// must match the call that provided the page token.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
A request to list previously created migration workflows.
func (*ListMigrationWorkflowsRequest) Descriptor ¶
func (*ListMigrationWorkflowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationWorkflowsRequest.ProtoReflect.Descriptor instead.
func (*ListMigrationWorkflowsRequest) GetPageSize ¶
func (x *ListMigrationWorkflowsRequest) GetPageSize() int32
func (*ListMigrationWorkflowsRequest) GetPageToken ¶
func (x *ListMigrationWorkflowsRequest) GetPageToken() string
func (*ListMigrationWorkflowsRequest) GetParent ¶
func (x *ListMigrationWorkflowsRequest) GetParent() string
func (*ListMigrationWorkflowsRequest) GetReadMask ¶
func (x *ListMigrationWorkflowsRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*ListMigrationWorkflowsRequest) ProtoMessage ¶
func (*ListMigrationWorkflowsRequest) ProtoMessage()
func (*ListMigrationWorkflowsRequest) ProtoReflect ¶
func (x *ListMigrationWorkflowsRequest) ProtoReflect() protoreflect.Message
func (*ListMigrationWorkflowsRequest) Reset ¶
func (x *ListMigrationWorkflowsRequest) Reset()
func (*ListMigrationWorkflowsRequest) String ¶
func (x *ListMigrationWorkflowsRequest) String() string
type ListMigrationWorkflowsResponse ¶
type ListMigrationWorkflowsResponse struct {
// The migration workflows for the specified project / location.
MigrationWorkflows []*MigrationWorkflow `protobuf:"bytes,1,rep,name=migration_workflows,json=migrationWorkflows,proto3" json:"migration_workflows,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
Response object for a `ListMigrationWorkflows` call.
func (*ListMigrationWorkflowsResponse) Descriptor ¶
func (*ListMigrationWorkflowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationWorkflowsResponse.ProtoReflect.Descriptor instead.
func (*ListMigrationWorkflowsResponse) GetMigrationWorkflows ¶
func (x *ListMigrationWorkflowsResponse) GetMigrationWorkflows() []*MigrationWorkflow
func (*ListMigrationWorkflowsResponse) GetNextPageToken ¶
func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string
func (*ListMigrationWorkflowsResponse) ProtoMessage ¶
func (*ListMigrationWorkflowsResponse) ProtoMessage()
func (*ListMigrationWorkflowsResponse) ProtoReflect ¶
func (x *ListMigrationWorkflowsResponse) ProtoReflect() protoreflect.Message
func (*ListMigrationWorkflowsResponse) Reset ¶
func (x *ListMigrationWorkflowsResponse) Reset()
func (*ListMigrationWorkflowsResponse) String ¶
func (x *ListMigrationWorkflowsResponse) String() string
type Literal ¶
type Literal struct {
// The literal SQL contents.
//
// Types that are assignable to LiteralData:
//
// *Literal_LiteralString
// *Literal_LiteralBytes
LiteralData isLiteral_LiteralData `protobuf_oneof:"literal_data"`
// Required. The identifier of the literal entry.
RelativePath string `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`
// contains filtered or unexported fields
}
Literal data.
func (*Literal) Descriptor ¶
Deprecated: Use Literal.ProtoReflect.Descriptor instead.
func (*Literal) GetLiteralBytes ¶
func (*Literal) GetLiteralData ¶
func (m *Literal) GetLiteralData() isLiteral_LiteralData
func (*Literal) GetLiteralString ¶
func (*Literal) GetRelativePath ¶
func (*Literal) ProtoMessage ¶
func (*Literal) ProtoMessage()
func (*Literal) ProtoReflect ¶
func (x *Literal) ProtoReflect() protoreflect.Message
func (*Literal) Reset ¶
func (x *Literal) Reset()
func (*Literal) String ¶
type Literal_LiteralBytes ¶
type Literal_LiteralBytes struct {
// Literal byte data.
LiteralBytes []byte `protobuf:"bytes,3,opt,name=literal_bytes,json=literalBytes,proto3,oneof"`
}
type Literal_LiteralString ¶
type Literal_LiteralString struct {
// Literal string data.
LiteralString string `protobuf:"bytes,2,opt,name=literal_string,json=literalString,proto3,oneof"`
}
type MigrationServiceClient ¶
type MigrationServiceClient interface {
// Creates a migration workflow.
CreateMigrationWorkflow(ctx context.Context, in *CreateMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
// Gets a previously created migration workflow.
GetMigrationWorkflow(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)
// Lists previously created migration workflow.
ListMigrationWorkflows(ctx context.Context, in *ListMigrationWorkflowsRequest, opts ...grpc.CallOption) (*ListMigrationWorkflowsResponse, error)
// Deletes a migration workflow by name.
DeleteMigrationWorkflow(ctx context.Context, in *DeleteMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Starts a previously created migration workflow. I.e., the state transitions
// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
// An error will be signaled if the state is anything other than DRAFT or
// RUNNING.
StartMigrationWorkflow(ctx context.Context, in *StartMigrationWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Gets a previously created migration subtask.
GetMigrationSubtask(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error)
// Lists previously created migration subtasks.
ListMigrationSubtasks(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error)
}
MigrationServiceClient is the client API for MigrationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMigrationServiceClient ¶
func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient
type MigrationServiceServer ¶
type MigrationServiceServer interface {
// Creates a migration workflow.
CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
// Gets a previously created migration workflow.
GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
// Lists previously created migration workflow.
ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
// Deletes a migration workflow by name.
DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
// Starts a previously created migration workflow. I.e., the state transitions
// from DRAFT to RUNNING. This is a no-op if the state is already RUNNING.
// An error will be signaled if the state is anything other than DRAFT or
// RUNNING.
StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
// Gets a previously created migration subtask.
GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
// Lists previously created migration subtasks.
ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
}
MigrationServiceServer is the server API for MigrationService service.
type MigrationSubtask ¶
type MigrationSubtask struct {
// Output only. Immutable. The resource name for the migration subtask. The ID
// is server-generated.
//
// Example: `projects/123/locations/us/workflows/345/subtasks/678`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The unique ID of the task to which this subtask belongs.
TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
// The type of the Subtask. The migration service does not check whether this
// is a known type. It is up to the task creator (i.e. orchestrator or worker)
// to ensure it only creates subtasks for which there are compatible workers
// polling for Subtasks.
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
// Output only. The current state of the subtask.
State MigrationSubtask_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationSubtask_State" json:"state,omitempty"`
// Output only. An explanation that may be populated when the task is in
// FAILED state.
ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,6,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
// Output only. Provides details to errors and issues encountered while
// processing the subtask. Presence of error details does not mean that the
// subtask failed.
ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,12,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
// The number or resources with errors. Note: This is not the total
// number of errors as each resource can have more than one error.
// This is used to indicate truncation by having a `resource_error_count`
// that is higher than the size of `resource_error_details`.
ResourceErrorCount int32 `protobuf:"varint,13,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`
// Time when the subtask was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Time when the subtask was last updated.
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
// The metrics for the subtask.
Metrics []*TimeSeries `protobuf:"bytes,11,rep,name=metrics,proto3" json:"metrics,omitempty"`
// contains filtered or unexported fields
}
A subtask for a migration which carries details about the configuration of the subtask. The content of the details should not matter to the end user, but is a contract between the subtask creator and subtask worker.
func (*MigrationSubtask) Descriptor ¶
func (*MigrationSubtask) Descriptor() ([]byte, []int)
Deprecated: Use MigrationSubtask.ProtoReflect.Descriptor instead.
func (*MigrationSubtask) GetCreateTime ¶
func (x *MigrationSubtask) GetCreateTime() *timestamppb.Timestamp
func (*MigrationSubtask) GetLastUpdateTime ¶
func (x *MigrationSubtask) GetLastUpdateTime() *timestamppb.Timestamp
func (*MigrationSubtask) GetMetrics ¶
func (x *MigrationSubtask) GetMetrics() []*TimeSeries
func (*MigrationSubtask) GetName ¶
func (x *MigrationSubtask) GetName() string
func (*MigrationSubtask) GetProcessingError ¶
func (x *MigrationSubtask) GetProcessingError() *errdetails.ErrorInfo
func (*MigrationSubtask) GetResourceErrorCount ¶
func (x *MigrationSubtask) GetResourceErrorCount() int32
func (*MigrationSubtask) GetResourceErrorDetails ¶
func (x *MigrationSubtask) GetResourceErrorDetails() []*ResourceErrorDetail
func (*MigrationSubtask) GetState ¶
func (x *MigrationSubtask) GetState() MigrationSubtask_State
func (*MigrationSubtask) GetTaskId ¶
func (x *MigrationSubtask) GetTaskId() string
func (*MigrationSubtask) GetType ¶
func (x *MigrationSubtask) GetType() string
func (*MigrationSubtask) ProtoMessage ¶
func (*MigrationSubtask) ProtoMessage()
func (*MigrationSubtask) ProtoReflect ¶
func (x *MigrationSubtask) ProtoReflect() protoreflect.Message
func (*MigrationSubtask) Reset ¶
func (x *MigrationSubtask) Reset()
func (*MigrationSubtask) String ¶
func (x *MigrationSubtask) String() string
type MigrationSubtask_State ¶
type MigrationSubtask_State int32
Possible states of a migration subtask.
const ( // The state is unspecified. MigrationSubtask_STATE_UNSPECIFIED MigrationSubtask_State = 0 // The subtask is ready, i.e. it is ready for execution. MigrationSubtask_ACTIVE MigrationSubtask_State = 1 // The subtask is running, i.e. it is assigned to a worker for execution. MigrationSubtask_RUNNING MigrationSubtask_State = 2 // The subtask finished successfully. MigrationSubtask_SUCCEEDED MigrationSubtask_State = 3 // The subtask finished unsuccessfully. MigrationSubtask_FAILED MigrationSubtask_State = 4 // The subtask is paused, i.e., it will not be scheduled. If it was already // assigned,it might still finish but no new lease renewals will be granted. MigrationSubtask_PAUSED MigrationSubtask_State = 5 // The subtask is pending a dependency. It will be scheduled once its // dependencies are done. MigrationSubtask_PENDING_DEPENDENCY MigrationSubtask_State = 6 )
func (MigrationSubtask_State) Descriptor ¶
func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor
func (MigrationSubtask_State) Enum ¶
func (x MigrationSubtask_State) Enum() *MigrationSubtask_State
func (MigrationSubtask_State) EnumDescriptor ¶
func (MigrationSubtask_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationSubtask_State.Descriptor instead.
func (MigrationSubtask_State) Number ¶
func (x MigrationSubtask_State) Number() protoreflect.EnumNumber
func (MigrationSubtask_State) String ¶
func (x MigrationSubtask_State) String() string
func (MigrationSubtask_State) Type ¶
func (MigrationSubtask_State) Type() protoreflect.EnumType
type MigrationTask ¶
type MigrationTask struct {
// The details of the task.
//
// Types that are assignable to TaskDetails:
//
// *MigrationTask_TranslationConfigDetails
// *MigrationTask_TranslationDetails
TaskDetails isMigrationTask_TaskDetails `protobuf_oneof:"task_details"`
// Output only. Immutable. The unique identifier for the migration task. The
// ID is server-generated.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// The type of the task. This must be one of the supported task types:
// Translation_Teradata2BQ, Translation_Redshift2BQ, Translation_Bteq2BQ,
// Translation_Oracle2BQ, Translation_HiveQL2BQ, Translation_SparkSQL2BQ,
// Translation_Snowflake2BQ, Translation_Netezza2BQ,
// Translation_AzureSynapse2BQ, Translation_Vertica2BQ,
// Translation_SQLServer2BQ, Translation_Presto2BQ, Translation_MySQL2BQ,
// Translation_Postgresql2BQ, Translation_SQLite2BQ, Translation_Greenplum2BQ.
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// Output only. The current state of the task.
State MigrationTask_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationTask_State" json:"state,omitempty"`
// Output only. An explanation that may be populated when the task is in
// FAILED state.
ProcessingError *errdetails.ErrorInfo `protobuf:"bytes,5,opt,name=processing_error,json=processingError,proto3" json:"processing_error,omitempty"`
// Time when the task was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Time when the task was last updated.
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
// Output only. Provides details to errors and issues encountered while
// processing the task. Presence of error details does not mean that the task
// failed.
ResourceErrorDetails []*ResourceErrorDetail `protobuf:"bytes,17,rep,name=resource_error_details,json=resourceErrorDetails,proto3" json:"resource_error_details,omitempty"`
// The number or resources with errors. Note: This is not the total
// number of errors as each resource can have more than one error.
// This is used to indicate truncation by having a `resource_error_count`
// that is higher than the size of `resource_error_details`.
ResourceErrorCount int32 `protobuf:"varint,18,opt,name=resource_error_count,json=resourceErrorCount,proto3" json:"resource_error_count,omitempty"`
// The metrics for the task.
Metrics []*TimeSeries `protobuf:"bytes,19,rep,name=metrics,proto3" json:"metrics,omitempty"`
// Output only. The result of the task.
TaskResult *MigrationTaskResult `protobuf:"bytes,20,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
// Count of all the processing errors in this task and its subtasks.
TotalProcessingErrorCount int32 `protobuf:"varint,21,opt,name=total_processing_error_count,json=totalProcessingErrorCount,proto3" json:"total_processing_error_count,omitempty"`
// Count of all the resource errors in this task and its subtasks.
TotalResourceErrorCount int32 `protobuf:"varint,22,opt,name=total_resource_error_count,json=totalResourceErrorCount,proto3" json:"total_resource_error_count,omitempty"`
// contains filtered or unexported fields
}
A single task for a migration which has details about the configuration of the task.
func (*MigrationTask) Descriptor ¶
func (*MigrationTask) Descriptor() ([]byte, []int)
Deprecated: Use MigrationTask.ProtoReflect.Descriptor instead.
func (*MigrationTask) 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 ¶
func (x *MigrationTask) GetMetrics() []*TimeSeries
func (*MigrationTask) GetProcessingError ¶
func (x *MigrationTask) GetProcessingError() *errdetails.ErrorInfo
func (*MigrationTask) GetResourceErrorCount ¶
func (x *MigrationTask) GetResourceErrorCount() int32
func (*MigrationTask) GetResourceErrorDetails ¶
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 ¶
func (x *MigrationTask) GetTaskResult() *MigrationTaskResult
func (*MigrationTask) GetTotalProcessingErrorCount ¶
func (x *MigrationTask) GetTotalProcessingErrorCount() int32
func (*MigrationTask) GetTotalResourceErrorCount ¶
func (x *MigrationTask) GetTotalResourceErrorCount() int32
func (*MigrationTask) GetTranslationConfigDetails ¶
func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails
func (*MigrationTask) GetTranslationDetails ¶
func (x *MigrationTask) GetTranslationDetails() *TranslationDetails
func (*MigrationTask) GetType ¶
func (x *MigrationTask) GetType() string
func (*MigrationTask) ProtoMessage ¶
func (*MigrationTask) ProtoMessage()
func (*MigrationTask) ProtoReflect ¶
func (x *MigrationTask) ProtoReflect() protoreflect.Message
func (*MigrationTask) Reset ¶
func (x *MigrationTask) Reset()
func (*MigrationTask) String ¶
func (x *MigrationTask) String() string
type MigrationTaskResult ¶
type MigrationTaskResult struct {
// Details specific to the task type.
//
// Types that are assignable to Details:
//
// *MigrationTaskResult_TranslationTaskResult
Details isMigrationTaskResult_Details `protobuf_oneof:"details"`
// contains filtered or unexported fields
}
The migration task result.
func (*MigrationTaskResult) Descriptor ¶
func (*MigrationTaskResult) Descriptor() ([]byte, []int)
Deprecated: Use MigrationTaskResult.ProtoReflect.Descriptor instead.
func (*MigrationTaskResult) GetDetails ¶
func (m *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details
func (*MigrationTaskResult) GetTranslationTaskResult ¶
func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult
func (*MigrationTaskResult) ProtoMessage ¶
func (*MigrationTaskResult) ProtoMessage()
func (*MigrationTaskResult) ProtoReflect ¶
func (x *MigrationTaskResult) ProtoReflect() protoreflect.Message
func (*MigrationTaskResult) Reset ¶
func (x *MigrationTaskResult) Reset()
func (*MigrationTaskResult) String ¶
func (x *MigrationTaskResult) String() string
type MigrationTaskResult_TranslationTaskResult ¶
type MigrationTaskResult_TranslationTaskResult struct {
// Details specific to translation task types.
TranslationTaskResult *TranslationTaskResult `protobuf:"bytes,2,opt,name=translation_task_result,json=translationTaskResult,proto3,oneof"`
}
type MigrationTask_State ¶
type MigrationTask_State int32
Possible states of a migration task.
const ( // The state is unspecified. MigrationTask_STATE_UNSPECIFIED MigrationTask_State = 0 // The task is waiting for orchestration. MigrationTask_PENDING MigrationTask_State = 1 // The task is assigned to an orchestrator. MigrationTask_ORCHESTRATING MigrationTask_State = 2 // The task is running, i.e. its subtasks are ready for execution. MigrationTask_RUNNING MigrationTask_State = 3 // Tha task is paused. Assigned subtasks can continue, but no new subtasks // will be scheduled. MigrationTask_PAUSED MigrationTask_State = 4 // The task finished successfully. MigrationTask_SUCCEEDED MigrationTask_State = 5 // The task finished unsuccessfully. MigrationTask_FAILED MigrationTask_State = 6 )
func (MigrationTask_State) Descriptor ¶
func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor
func (MigrationTask_State) Enum ¶
func (x MigrationTask_State) Enum() *MigrationTask_State
func (MigrationTask_State) EnumDescriptor ¶
func (MigrationTask_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationTask_State.Descriptor instead.
func (MigrationTask_State) Number ¶
func (x MigrationTask_State) Number() protoreflect.EnumNumber
func (MigrationTask_State) String ¶
func (x MigrationTask_State) String() string
func (MigrationTask_State) Type ¶
func (MigrationTask_State) Type() protoreflect.EnumType
type MigrationTask_TranslationConfigDetails ¶
type MigrationTask_TranslationConfigDetails struct {
// Task configuration for CW Batch/Offline SQL Translation.
TranslationConfigDetails *TranslationConfigDetails `protobuf:"bytes,14,opt,name=translation_config_details,json=translationConfigDetails,proto3,oneof"`
}
type MigrationTask_TranslationDetails ¶
type MigrationTask_TranslationDetails struct {
// Task details for unified SQL Translation.
TranslationDetails *TranslationDetails `protobuf:"bytes,16,opt,name=translation_details,json=translationDetails,proto3,oneof"`
}
type MigrationWorkflow ¶
type MigrationWorkflow struct {
// Output only. Immutable. Identifier. The unique identifier for the migration
// workflow. The ID is server-generated.
//
// Example: `projects/123/locations/us/workflows/345`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The display name of the workflow. This can be set to give a workflow
// a descriptive name. There is no guarantee or enforcement of uniqueness.
DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// The tasks in a workflow in a named map. The name (i.e. key) has no
// meaning and is merely a convenient way to address a specific task
// in a workflow.
Tasks map[string]*MigrationTask `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Output only. That status of the workflow.
State MigrationWorkflow_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.bigquery.migration.v2.MigrationWorkflow_State" json:"state,omitempty"`
// Time when the workflow was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Time when the workflow was last updated.
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
// contains filtered or unexported fields
}
A migration workflow which specifies what needs to be done for an EDW migration.
func (*MigrationWorkflow) Descriptor ¶
func (*MigrationWorkflow) Descriptor() ([]byte, []int)
Deprecated: Use MigrationWorkflow.ProtoReflect.Descriptor instead.
func (*MigrationWorkflow) GetCreateTime ¶
func (x *MigrationWorkflow) GetCreateTime() *timestamppb.Timestamp
func (*MigrationWorkflow) GetDisplayName ¶
func (x *MigrationWorkflow) GetDisplayName() string
func (*MigrationWorkflow) GetLastUpdateTime ¶
func (x *MigrationWorkflow) GetLastUpdateTime() *timestamppb.Timestamp
func (*MigrationWorkflow) GetName ¶
func (x *MigrationWorkflow) GetName() string
func (*MigrationWorkflow) GetState ¶
func (x *MigrationWorkflow) GetState() MigrationWorkflow_State
func (*MigrationWorkflow) GetTasks ¶
func (x *MigrationWorkflow) GetTasks() map[string]*MigrationTask
func (*MigrationWorkflow) ProtoMessage ¶
func (*MigrationWorkflow) ProtoMessage()
func (*MigrationWorkflow) ProtoReflect ¶
func (x *MigrationWorkflow) ProtoReflect() protoreflect.Message
func (*MigrationWorkflow) Reset ¶
func (x *MigrationWorkflow) Reset()
func (*MigrationWorkflow) String ¶
func (x *MigrationWorkflow) String() string
type MigrationWorkflow_State ¶
type MigrationWorkflow_State int32
Possible migration workflow states.
const ( // Workflow state is unspecified. MigrationWorkflow_STATE_UNSPECIFIED MigrationWorkflow_State = 0 // Workflow is in draft status, i.e. tasks are not yet eligible for // execution. MigrationWorkflow_DRAFT MigrationWorkflow_State = 1 // Workflow is running (i.e. tasks are eligible for execution). MigrationWorkflow_RUNNING MigrationWorkflow_State = 2 // Workflow is paused. Tasks currently in progress may continue, but no // further tasks will be scheduled. MigrationWorkflow_PAUSED MigrationWorkflow_State = 3 // Workflow is complete. There should not be any task in a non-terminal // state, but if they are (e.g. forced termination), they will not be // scheduled. MigrationWorkflow_COMPLETED MigrationWorkflow_State = 4 )
func (MigrationWorkflow_State) Descriptor ¶
func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor
func (MigrationWorkflow_State) Enum ¶
func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State
func (MigrationWorkflow_State) EnumDescriptor ¶
func (MigrationWorkflow_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationWorkflow_State.Descriptor instead.
func (MigrationWorkflow_State) Number ¶
func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber
func (MigrationWorkflow_State) String ¶
func (x MigrationWorkflow_State) String() string
func (MigrationWorkflow_State) Type ¶
func (MigrationWorkflow_State) Type() protoreflect.EnumType
type MySQLDialect ¶
type MySQLDialect struct {
// contains filtered or unexported fields
}
The dialect definition for MySQL.
func (*MySQLDialect) Descriptor ¶
func (*MySQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use MySQLDialect.ProtoReflect.Descriptor instead.
func (*MySQLDialect) ProtoMessage ¶
func (*MySQLDialect) ProtoMessage()
func (*MySQLDialect) ProtoReflect ¶
func (x *MySQLDialect) ProtoReflect() protoreflect.Message
func (*MySQLDialect) Reset ¶
func (x *MySQLDialect) Reset()
func (*MySQLDialect) String ¶
func (x *MySQLDialect) String() string
type NameMappingKey ¶
type NameMappingKey struct {
// The type of object that is being mapped.
Type NameMappingKey_Type `protobuf:"varint,1,opt,name=type,proto3,enum=google.cloud.bigquery.migration.v2.NameMappingKey_Type" json:"type,omitempty"`
// The database name (BigQuery project ID equivalent in the source data
// warehouse).
Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
// The schema name (BigQuery dataset equivalent in the source data warehouse).
Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
// The relation name (BigQuery table or view equivalent in the source data
// warehouse).
Relation string `protobuf:"bytes,4,opt,name=relation,proto3" json:"relation,omitempty"`
// The attribute name (BigQuery column equivalent in the source data
// warehouse).
Attribute string `protobuf:"bytes,5,opt,name=attribute,proto3" json:"attribute,omitempty"`
// contains filtered or unexported fields
}
The potential components of a full name mapping that will be mapped during translation in the source data warehouse.
func (*NameMappingKey) Descriptor ¶
func (*NameMappingKey) Descriptor() ([]byte, []int)
Deprecated: Use NameMappingKey.ProtoReflect.Descriptor instead.
func (*NameMappingKey) GetAttribute ¶
func (x *NameMappingKey) GetAttribute() string
func (*NameMappingKey) GetDatabase ¶
func (x *NameMappingKey) GetDatabase() string
func (*NameMappingKey) GetRelation ¶
func (x *NameMappingKey) GetRelation() string
func (*NameMappingKey) GetSchema ¶
func (x *NameMappingKey) GetSchema() string
func (*NameMappingKey) GetType ¶
func (x *NameMappingKey) GetType() NameMappingKey_Type
func (*NameMappingKey) ProtoMessage ¶
func (*NameMappingKey) ProtoMessage()
func (*NameMappingKey) ProtoReflect ¶
func (x *NameMappingKey) ProtoReflect() protoreflect.Message
func (*NameMappingKey) Reset ¶
func (x *NameMappingKey) Reset()
func (*NameMappingKey) String ¶
func (x *NameMappingKey) String() string
type NameMappingKey_Type ¶
type NameMappingKey_Type int32
The type of the object that is being mapped.
const ( // Unspecified name mapping type. NameMappingKey_TYPE_UNSPECIFIED NameMappingKey_Type = 0 // The object being mapped is a database. NameMappingKey_DATABASE NameMappingKey_Type = 1 // The object being mapped is a schema. NameMappingKey_SCHEMA NameMappingKey_Type = 2 // The object being mapped is a relation. NameMappingKey_RELATION NameMappingKey_Type = 3 // The object being mapped is an attribute. NameMappingKey_ATTRIBUTE NameMappingKey_Type = 4 // The object being mapped is a relation alias. NameMappingKey_RELATION_ALIAS NameMappingKey_Type = 5 // The object being mapped is a an attribute alias. NameMappingKey_ATTRIBUTE_ALIAS NameMappingKey_Type = 6 // The object being mapped is a function. NameMappingKey_FUNCTION NameMappingKey_Type = 7 )
func (NameMappingKey_Type) Descriptor ¶
func (NameMappingKey_Type) Descriptor() protoreflect.EnumDescriptor
func (NameMappingKey_Type) Enum ¶
func (x NameMappingKey_Type) Enum() *NameMappingKey_Type
func (NameMappingKey_Type) EnumDescriptor ¶
func (NameMappingKey_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use NameMappingKey_Type.Descriptor instead.
func (NameMappingKey_Type) Number ¶
func (x NameMappingKey_Type) Number() protoreflect.EnumNumber
func (NameMappingKey_Type) String ¶
func (x NameMappingKey_Type) String() string
func (NameMappingKey_Type) Type ¶
func (NameMappingKey_Type) Type() protoreflect.EnumType
type NameMappingValue ¶
type NameMappingValue struct {
// The database name (BigQuery project ID equivalent in the target data
// warehouse).
Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
// The schema name (BigQuery dataset equivalent in the target data warehouse).
Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
// The relation name (BigQuery table or view equivalent in the target data
// warehouse).
Relation string `protobuf:"bytes,3,opt,name=relation,proto3" json:"relation,omitempty"`
// The attribute name (BigQuery column equivalent in the target data
// warehouse).
Attribute string `protobuf:"bytes,4,opt,name=attribute,proto3" json:"attribute,omitempty"`
// contains filtered or unexported fields
}
The potential components of a full name mapping that will be mapped during translation in the target data warehouse.
func (*NameMappingValue) Descriptor ¶
func (*NameMappingValue) Descriptor() ([]byte, []int)
Deprecated: Use NameMappingValue.ProtoReflect.Descriptor instead.
func (*NameMappingValue) GetAttribute ¶
func (x *NameMappingValue) GetAttribute() string
func (*NameMappingValue) GetDatabase ¶
func (x *NameMappingValue) GetDatabase() string
func (*NameMappingValue) GetRelation ¶
func (x *NameMappingValue) GetRelation() string
func (*NameMappingValue) GetSchema ¶
func (x *NameMappingValue) GetSchema() string
func (*NameMappingValue) ProtoMessage ¶
func (*NameMappingValue) ProtoMessage()
func (*NameMappingValue) ProtoReflect ¶
func (x *NameMappingValue) ProtoReflect() protoreflect.Message
func (*NameMappingValue) Reset ¶
func (x *NameMappingValue) Reset()
func (*NameMappingValue) String ¶
func (x *NameMappingValue) String() string
type NetezzaDialect ¶
type NetezzaDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Netezza.
func (*NetezzaDialect) Descriptor ¶
func (*NetezzaDialect) Descriptor() ([]byte, []int)
Deprecated: Use NetezzaDialect.ProtoReflect.Descriptor instead.
func (*NetezzaDialect) ProtoMessage ¶
func (*NetezzaDialect) ProtoMessage()
func (*NetezzaDialect) ProtoReflect ¶
func (x *NetezzaDialect) ProtoReflect() protoreflect.Message
func (*NetezzaDialect) Reset ¶
func (x *NetezzaDialect) Reset()
func (*NetezzaDialect) String ¶
func (x *NetezzaDialect) String() string
type ObjectNameMapping ¶
type ObjectNameMapping struct {
// The name of the object in source that is being mapped.
Source *NameMappingKey `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
// The desired target name of the object that is being mapped.
Target *NameMappingValue `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
// contains filtered or unexported fields
}
Represents a key-value pair of NameMappingKey to NameMappingValue to represent the mapping of SQL names from the input value to desired output.
func (*ObjectNameMapping) Descriptor ¶
func (*ObjectNameMapping) Descriptor() ([]byte, []int)
Deprecated: Use ObjectNameMapping.ProtoReflect.Descriptor instead.
func (*ObjectNameMapping) GetSource ¶
func (x *ObjectNameMapping) GetSource() *NameMappingKey
func (*ObjectNameMapping) GetTarget ¶
func (x *ObjectNameMapping) GetTarget() *NameMappingValue
func (*ObjectNameMapping) ProtoMessage ¶
func (*ObjectNameMapping) ProtoMessage()
func (*ObjectNameMapping) ProtoReflect ¶
func (x *ObjectNameMapping) ProtoReflect() protoreflect.Message
func (*ObjectNameMapping) Reset ¶
func (x *ObjectNameMapping) Reset()
func (*ObjectNameMapping) String ¶
func (x *ObjectNameMapping) String() string
type ObjectNameMappingList ¶
type ObjectNameMappingList struct {
// The elements of the object name map.
NameMap []*ObjectNameMapping `protobuf:"bytes,1,rep,name=name_map,json=nameMap,proto3" json:"name_map,omitempty"`
// contains filtered or unexported fields
}
Represents a map of name mappings using a list of key:value proto messages of existing name to desired output name.
func (*ObjectNameMappingList) Descriptor ¶
func (*ObjectNameMappingList) Descriptor() ([]byte, []int)
Deprecated: Use ObjectNameMappingList.ProtoReflect.Descriptor instead.
func (*ObjectNameMappingList) GetNameMap ¶
func (x *ObjectNameMappingList) GetNameMap() []*ObjectNameMapping
func (*ObjectNameMappingList) ProtoMessage ¶
func (*ObjectNameMappingList) ProtoMessage()
func (*ObjectNameMappingList) ProtoReflect ¶
func (x *ObjectNameMappingList) ProtoReflect() protoreflect.Message
func (*ObjectNameMappingList) Reset ¶
func (x *ObjectNameMappingList) Reset()
func (*ObjectNameMappingList) String ¶
func (x *ObjectNameMappingList) String() string
type OracleDialect ¶
type OracleDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Oracle.
func (*OracleDialect) Descriptor ¶
func (*OracleDialect) Descriptor() ([]byte, []int)
Deprecated: Use OracleDialect.ProtoReflect.Descriptor instead.
func (*OracleDialect) ProtoMessage ¶
func (*OracleDialect) ProtoMessage()
func (*OracleDialect) ProtoReflect ¶
func (x *OracleDialect) ProtoReflect() protoreflect.Message
func (*OracleDialect) Reset ¶
func (x *OracleDialect) Reset()
func (*OracleDialect) String ¶
func (x *OracleDialect) String() string
type Point ¶
type Point struct {
// The time interval to which the data point applies. For `GAUGE` metrics,
// the start time does not need to be supplied, but if it is supplied, it must
// equal the end time. For `DELTA` metrics, the start and end time should
// specify a non-zero interval, with subsequent points specifying contiguous
// and non-overlapping intervals. For `CUMULATIVE` metrics, the start and end
// time should specify a non-zero interval, with subsequent points specifying
// the same start time and increasing end times, until an event resets the
// cumulative value to zero and sets a new start time for the following
// points.
Interval *TimeInterval `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
// The value of the data point.
Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
A single data point in a time series.
func (*Point) Descriptor ¶
Deprecated: Use Point.ProtoReflect.Descriptor instead.
func (*Point) GetInterval ¶
func (x *Point) GetInterval() *TimeInterval
func (*Point) GetValue ¶
func (x *Point) GetValue() *TypedValue
func (*Point) ProtoMessage ¶
func (*Point) ProtoMessage()
func (*Point) ProtoReflect ¶
func (x *Point) ProtoReflect() protoreflect.Message
func (*Point) Reset ¶
func (x *Point) Reset()
func (*Point) String ¶
type PostgresqlDialect ¶
type PostgresqlDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Postgresql.
func (*PostgresqlDialect) Descriptor ¶
func (*PostgresqlDialect) Descriptor() ([]byte, []int)
Deprecated: Use PostgresqlDialect.ProtoReflect.Descriptor instead.
func (*PostgresqlDialect) ProtoMessage ¶
func (*PostgresqlDialect) ProtoMessage()
func (*PostgresqlDialect) ProtoReflect ¶
func (x *PostgresqlDialect) ProtoReflect() protoreflect.Message
func (*PostgresqlDialect) Reset ¶
func (x *PostgresqlDialect) Reset()
func (*PostgresqlDialect) String ¶
func (x *PostgresqlDialect) String() string
type PrestoDialect ¶
type PrestoDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Presto.
func (*PrestoDialect) Descriptor ¶
func (*PrestoDialect) Descriptor() ([]byte, []int)
Deprecated: Use PrestoDialect.ProtoReflect.Descriptor instead.
func (*PrestoDialect) ProtoMessage ¶
func (*PrestoDialect) ProtoMessage()
func (*PrestoDialect) ProtoReflect ¶
func (x *PrestoDialect) ProtoReflect() protoreflect.Message
func (*PrestoDialect) Reset ¶
func (x *PrestoDialect) Reset()
func (*PrestoDialect) String ¶
func (x *PrestoDialect) String() string
type RedshiftDialect ¶
type RedshiftDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Redshift.
func (*RedshiftDialect) Descriptor ¶
func (*RedshiftDialect) Descriptor() ([]byte, []int)
Deprecated: Use RedshiftDialect.ProtoReflect.Descriptor instead.
func (*RedshiftDialect) ProtoMessage ¶
func (*RedshiftDialect) ProtoMessage()
func (*RedshiftDialect) ProtoReflect ¶
func (x *RedshiftDialect) ProtoReflect() protoreflect.Message
func (*RedshiftDialect) Reset ¶
func (x *RedshiftDialect) Reset()
func (*RedshiftDialect) String ¶
func (x *RedshiftDialect) String() string
type ResourceErrorDetail ¶
type ResourceErrorDetail struct {
// Required. Information about the resource where the error is located.
ResourceInfo *errdetails.ResourceInfo `protobuf:"bytes,1,opt,name=resource_info,json=resourceInfo,proto3" json:"resource_info,omitempty"`
// Required. The error details for the resource.
ErrorDetails []*ErrorDetail `protobuf:"bytes,2,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
// Required. How many errors there are in total for the resource. Truncation
// can be indicated by having an `error_count` that is higher than the size of
// `error_details`.
ErrorCount int32 `protobuf:"varint,3,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
// contains filtered or unexported fields
}
Provides details for errors and the corresponding resources.
func (*ResourceErrorDetail) Descriptor ¶
func (*ResourceErrorDetail) Descriptor() ([]byte, []int)
Deprecated: Use ResourceErrorDetail.ProtoReflect.Descriptor instead.
func (*ResourceErrorDetail) GetErrorCount ¶
func (x *ResourceErrorDetail) GetErrorCount() int32
func (*ResourceErrorDetail) GetErrorDetails ¶
func (x *ResourceErrorDetail) GetErrorDetails() []*ErrorDetail
func (*ResourceErrorDetail) GetResourceInfo ¶
func (x *ResourceErrorDetail) GetResourceInfo() *errdetails.ResourceInfo
func (*ResourceErrorDetail) ProtoMessage ¶
func (*ResourceErrorDetail) ProtoMessage()
func (*ResourceErrorDetail) ProtoReflect ¶
func (x *ResourceErrorDetail) ProtoReflect() protoreflect.Message
func (*ResourceErrorDetail) Reset ¶
func (x *ResourceErrorDetail) Reset()
func (*ResourceErrorDetail) String ¶
func (x *ResourceErrorDetail) String() string
type SQLServerDialect ¶
type SQLServerDialect struct {
// contains filtered or unexported fields
}
The dialect definition for SQL Server.
func (*SQLServerDialect) Descriptor ¶
func (*SQLServerDialect) Descriptor() ([]byte, []int)
Deprecated: Use SQLServerDialect.ProtoReflect.Descriptor instead.
func (*SQLServerDialect) ProtoMessage ¶
func (*SQLServerDialect) ProtoMessage()
func (*SQLServerDialect) ProtoReflect ¶
func (x *SQLServerDialect) ProtoReflect() protoreflect.Message
func (*SQLServerDialect) Reset ¶
func (x *SQLServerDialect) Reset()
func (*SQLServerDialect) String ¶
func (x *SQLServerDialect) String() string
type SQLiteDialect ¶
type SQLiteDialect struct {
// contains filtered or unexported fields
}
The dialect definition for SQLite.
func (*SQLiteDialect) Descriptor ¶
func (*SQLiteDialect) Descriptor() ([]byte, []int)
Deprecated: Use SQLiteDialect.ProtoReflect.Descriptor instead.
func (*SQLiteDialect) ProtoMessage ¶
func (*SQLiteDialect) ProtoMessage()
func (*SQLiteDialect) ProtoReflect ¶
func (x *SQLiteDialect) ProtoReflect() protoreflect.Message
func (*SQLiteDialect) Reset ¶
func (x *SQLiteDialect) Reset()
func (*SQLiteDialect) String ¶
func (x *SQLiteDialect) String() string
type SnowflakeDialect ¶
type SnowflakeDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Snowflake.
func (*SnowflakeDialect) Descriptor ¶
func (*SnowflakeDialect) Descriptor() ([]byte, []int)
Deprecated: Use SnowflakeDialect.ProtoReflect.Descriptor instead.
func (*SnowflakeDialect) ProtoMessage ¶
func (*SnowflakeDialect) ProtoMessage()
func (*SnowflakeDialect) ProtoReflect ¶
func (x *SnowflakeDialect) ProtoReflect() protoreflect.Message
func (*SnowflakeDialect) Reset ¶
func (x *SnowflakeDialect) Reset()
func (*SnowflakeDialect) String ¶
func (x *SnowflakeDialect) String() string
type SourceEnv ¶
type SourceEnv struct {
// The default database name to fully qualify SQL objects when their database
// name is missing.
DefaultDatabase string `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`
// The schema search path. When SQL objects are missing schema name,
// translation engine will search through this list to find the value.
SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`
// Optional. Expects a valid BigQuery dataset ID that exists, e.g.,
// project-123.metadata_store_123. If specified, translation will search and
// read the required schema information from a metadata store in this dataset.
// If metadata store doesn't exist, translation will parse the metadata file
// and upload the schema info to a temp table in the dataset to speed up
// future translation jobs.
MetadataStoreDataset string `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`
// contains filtered or unexported fields
}
Represents the default source environment values for the translation.
func (*SourceEnv) Descriptor ¶
Deprecated: Use SourceEnv.ProtoReflect.Descriptor instead.
func (*SourceEnv) GetDefaultDatabase ¶
func (*SourceEnv) GetMetadataStoreDataset ¶
func (*SourceEnv) GetSchemaSearchPath ¶
func (*SourceEnv) ProtoMessage ¶
func (*SourceEnv) ProtoMessage()
func (*SourceEnv) ProtoReflect ¶
func (x *SourceEnv) ProtoReflect() protoreflect.Message
func (*SourceEnv) Reset ¶
func (x *SourceEnv) Reset()
func (*SourceEnv) String ¶
type SourceEnvironment ¶
type SourceEnvironment struct {
// The default database name to fully qualify SQL objects when their database
// name is missing.
DefaultDatabase string `protobuf:"bytes,1,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`
// The schema search path. When SQL objects are missing schema name,
// translation engine will search through this list to find the value.
SchemaSearchPath []string `protobuf:"bytes,2,rep,name=schema_search_path,json=schemaSearchPath,proto3" json:"schema_search_path,omitempty"`
// Optional. Expects a validQ BigQuery dataset ID that exists, e.g.,
// project-123.metadata_store_123. If specified, translation will search and
// read the required schema information from a metadata store in this dataset.
// If metadata store doesn't exist, translation will parse the metadata file
// and upload the schema info to a temp table in the dataset to speed up
// future translation jobs.
MetadataStoreDataset string `protobuf:"bytes,3,opt,name=metadata_store_dataset,json=metadataStoreDataset,proto3" json:"metadata_store_dataset,omitempty"`
// contains filtered or unexported fields
}
Represents the default source environment values for the translation.
func (*SourceEnvironment) Descriptor ¶
func (*SourceEnvironment) Descriptor() ([]byte, []int)
Deprecated: Use SourceEnvironment.ProtoReflect.Descriptor instead.
func (*SourceEnvironment) GetDefaultDatabase ¶
func (x *SourceEnvironment) GetDefaultDatabase() string
func (*SourceEnvironment) GetMetadataStoreDataset ¶
func (x *SourceEnvironment) GetMetadataStoreDataset() string
func (*SourceEnvironment) GetSchemaSearchPath ¶
func (x *SourceEnvironment) GetSchemaSearchPath() []string
func (*SourceEnvironment) ProtoMessage ¶
func (*SourceEnvironment) ProtoMessage()
func (*SourceEnvironment) ProtoReflect ¶
func (x *SourceEnvironment) ProtoReflect() protoreflect.Message
func (*SourceEnvironment) Reset ¶
func (x *SourceEnvironment) Reset()
func (*SourceEnvironment) String ¶
func (x *SourceEnvironment) String() string
type SourceSpec ¶
type SourceSpec struct {
// The specific source SQL.
//
// Types that are assignable to Source:
//
// *SourceSpec_BaseUri
// *SourceSpec_Literal
Source isSourceSpec_Source `protobuf_oneof:"source"`
// Optional. The optional field to specify the encoding of the sql bytes.
Encoding string `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
// contains filtered or unexported fields
}
Represents one path to the location that holds source data.
func (*SourceSpec) Descriptor ¶
func (*SourceSpec) Descriptor() ([]byte, []int)
Deprecated: Use SourceSpec.ProtoReflect.Descriptor instead.
func (*SourceSpec) GetBaseUri ¶
func (x *SourceSpec) GetBaseUri() string
func (*SourceSpec) GetEncoding ¶
func (x *SourceSpec) GetEncoding() string
func (*SourceSpec) GetLiteral ¶
func (x *SourceSpec) GetLiteral() *Literal
func (*SourceSpec) GetSource ¶
func (m *SourceSpec) GetSource() isSourceSpec_Source
func (*SourceSpec) ProtoMessage ¶
func (*SourceSpec) ProtoMessage()
func (*SourceSpec) ProtoReflect ¶
func (x *SourceSpec) ProtoReflect() protoreflect.Message
func (*SourceSpec) Reset ¶
func (x *SourceSpec) Reset()
func (*SourceSpec) String ¶
func (x *SourceSpec) String() string
type SourceSpec_BaseUri ¶
type SourceSpec_BaseUri struct {
// The base URI for all files to be read in as sources for translation.
BaseUri string `protobuf:"bytes,1,opt,name=base_uri,json=baseUri,proto3,oneof"`
}
type SourceSpec_Literal ¶
type SourceSpec_Literal struct {
// Source literal.
Literal *Literal `protobuf:"bytes,2,opt,name=literal,proto3,oneof"`
}
type SourceTargetMapping ¶
type SourceTargetMapping struct {
// The source SQL or the path to it.
SourceSpec *SourceSpec `protobuf:"bytes,1,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"`
// The target SQL or the path for it.
TargetSpec *TargetSpec `protobuf:"bytes,2,opt,name=target_spec,json=targetSpec,proto3" json:"target_spec,omitempty"`
// contains filtered or unexported fields
}
Represents one mapping from a source SQL to a target SQL.
func (*SourceTargetMapping) Descriptor ¶
func (*SourceTargetMapping) Descriptor() ([]byte, []int)
Deprecated: Use SourceTargetMapping.ProtoReflect.Descriptor instead.
func (*SourceTargetMapping) GetSourceSpec ¶
func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec
func (*SourceTargetMapping) GetTargetSpec ¶
func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec
func (*SourceTargetMapping) ProtoMessage ¶
func (*SourceTargetMapping) ProtoMessage()
func (*SourceTargetMapping) ProtoReflect ¶
func (x *SourceTargetMapping) ProtoReflect() protoreflect.Message
func (*SourceTargetMapping) Reset ¶
func (x *SourceTargetMapping) Reset()
func (*SourceTargetMapping) String ¶
func (x *SourceTargetMapping) String() string
type SparkSQLDialect ¶
type SparkSQLDialect struct {
// contains filtered or unexported fields
}
The dialect definition for SparkSQL.
func (*SparkSQLDialect) Descriptor ¶
func (*SparkSQLDialect) Descriptor() ([]byte, []int)
Deprecated: Use SparkSQLDialect.ProtoReflect.Descriptor instead.
func (*SparkSQLDialect) ProtoMessage ¶
func (*SparkSQLDialect) ProtoMessage()
func (*SparkSQLDialect) ProtoReflect ¶
func (x *SparkSQLDialect) ProtoReflect() protoreflect.Message
func (*SparkSQLDialect) Reset ¶
func (x *SparkSQLDialect) Reset()
func (*SparkSQLDialect) String ¶
func (x *SparkSQLDialect) String() string
type StartMigrationWorkflowRequest ¶
type StartMigrationWorkflowRequest struct {
// Required. The unique identifier for the migration workflow.
// Example: `projects/123/locations/us/workflows/1234`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
A request to start a previously created migration workflow.
func (*StartMigrationWorkflowRequest) Descriptor ¶
func (*StartMigrationWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartMigrationWorkflowRequest.ProtoReflect.Descriptor instead.
func (*StartMigrationWorkflowRequest) GetName ¶
func (x *StartMigrationWorkflowRequest) GetName() string
func (*StartMigrationWorkflowRequest) ProtoMessage ¶
func (*StartMigrationWorkflowRequest) ProtoMessage()
func (*StartMigrationWorkflowRequest) ProtoReflect ¶
func (x *StartMigrationWorkflowRequest) ProtoReflect() protoreflect.Message
func (*StartMigrationWorkflowRequest) Reset ¶
func (x *StartMigrationWorkflowRequest) Reset()
func (*StartMigrationWorkflowRequest) String ¶
func (x *StartMigrationWorkflowRequest) String() string
type TargetSpec ¶
type TargetSpec struct {
// The relative path for the target data. Given source file
// `base_uri/input/sql`, the output would be
// `target_base_uri/sql/relative_path/input.sql`.
RelativePath string `protobuf:"bytes,1,opt,name=relative_path,json=relativePath,proto3" json:"relative_path,omitempty"`
// contains filtered or unexported fields
}
Represents one path to the location that holds target data.
func (*TargetSpec) Descriptor ¶
func (*TargetSpec) Descriptor() ([]byte, []int)
Deprecated: Use TargetSpec.ProtoReflect.Descriptor instead.
func (*TargetSpec) GetRelativePath ¶
func (x *TargetSpec) GetRelativePath() string
func (*TargetSpec) ProtoMessage ¶
func (*TargetSpec) ProtoMessage()
func (*TargetSpec) ProtoReflect ¶
func (x *TargetSpec) ProtoReflect() protoreflect.Message
func (*TargetSpec) Reset ¶
func (x *TargetSpec) Reset()
func (*TargetSpec) String ¶
func (x *TargetSpec) String() string
type TeradataDialect ¶
type TeradataDialect struct {
// Which Teradata sub-dialect mode the user specifies.
Mode TeradataDialect_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.cloud.bigquery.migration.v2.TeradataDialect_Mode" json:"mode,omitempty"`
// contains filtered or unexported fields
}
The dialect definition for Teradata.
func (*TeradataDialect) Descriptor ¶
func (*TeradataDialect) Descriptor() ([]byte, []int)
Deprecated: Use TeradataDialect.ProtoReflect.Descriptor instead.
func (*TeradataDialect) GetMode ¶
func (x *TeradataDialect) GetMode() TeradataDialect_Mode
func (*TeradataDialect) ProtoMessage ¶
func (*TeradataDialect) ProtoMessage()
func (*TeradataDialect) ProtoReflect ¶
func (x *TeradataDialect) ProtoReflect() protoreflect.Message
func (*TeradataDialect) Reset ¶
func (x *TeradataDialect) Reset()
func (*TeradataDialect) String ¶
func (x *TeradataDialect) String() string
type TeradataDialect_Mode ¶
type TeradataDialect_Mode int32
The sub-dialect options for Teradata.
const ( // Unspecified mode. TeradataDialect_MODE_UNSPECIFIED TeradataDialect_Mode = 0 // Teradata SQL mode. TeradataDialect_SQL TeradataDialect_Mode = 1 // BTEQ mode (which includes SQL). TeradataDialect_BTEQ TeradataDialect_Mode = 2 )
func (TeradataDialect_Mode) Descriptor ¶
func (TeradataDialect_Mode) Descriptor() protoreflect.EnumDescriptor
func (TeradataDialect_Mode) Enum ¶
func (x TeradataDialect_Mode) Enum() *TeradataDialect_Mode
func (TeradataDialect_Mode) EnumDescriptor ¶
func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TeradataDialect_Mode.Descriptor instead.
func (TeradataDialect_Mode) Number ¶
func (x TeradataDialect_Mode) Number() protoreflect.EnumNumber
func (TeradataDialect_Mode) String ¶
func (x TeradataDialect_Mode) String() string
func (TeradataDialect_Mode) Type ¶
func (TeradataDialect_Mode) Type() protoreflect.EnumType
type TimeInterval ¶
type TimeInterval struct {
// Optional. The beginning of the time interval. The default value
// for the start time is the end time. The start time must not be
// later than the end time.
StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// Required. The end of the time interval.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// contains filtered or unexported fields
}
A time interval extending just after a start time through an end time. If the start time is the same as the end time, then the interval represents a single point in time.
func (*TimeInterval) Descriptor ¶
func (*TimeInterval) Descriptor() ([]byte, []int)
Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.
func (*TimeInterval) GetEndTime ¶
func (x *TimeInterval) GetEndTime() *timestamppb.Timestamp
func (*TimeInterval) GetStartTime ¶
func (x *TimeInterval) GetStartTime() *timestamppb.Timestamp
func (*TimeInterval) ProtoMessage ¶
func (*TimeInterval) ProtoMessage()
func (*TimeInterval) ProtoReflect ¶
func (x *TimeInterval) ProtoReflect() protoreflect.Message
func (*TimeInterval) Reset ¶
func (x *TimeInterval) Reset()
func (*TimeInterval) String ¶
func (x *TimeInterval) String() string
type TimeSeries ¶
type TimeSeries struct {
// Required. The name of the metric.
//
// If the metric is not known by the service yet, it will be auto-created.
Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
// Required. The value type of the time series.
ValueType metric.MetricDescriptor_ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=google.api.MetricDescriptor_ValueType" json:"value_type,omitempty"`
// Optional. The metric kind of the time series.
//
// If present, it must be the same as the metric kind of the associated
// metric. If the associated metric's descriptor must be auto-created, then
// this field specifies the metric kind of the new descriptor and must be
// either `GAUGE` (the default) or `CUMULATIVE`.
MetricKind metric.MetricDescriptor_MetricKind `protobuf:"varint,3,opt,name=metric_kind,json=metricKind,proto3,enum=google.api.MetricDescriptor_MetricKind" json:"metric_kind,omitempty"`
// Required. The data points of this time series. When listing time series,
// points are returned in reverse time order.
//
// When creating a time series, this field must contain exactly one point and
// the point's type must be the same as the value type of the associated
// metric. If the associated metric's descriptor must be auto-created, then
// the value type of the descriptor is determined by the point's type, which
// must be `BOOL`, `INT64`, `DOUBLE`, or `DISTRIBUTION`.
Points []*Point `protobuf:"bytes,4,rep,name=points,proto3" json:"points,omitempty"`
// contains filtered or unexported fields
}
The metrics object for a SubTask.
func (*TimeSeries) Descriptor ¶
func (*TimeSeries) Descriptor() ([]byte, []int)
Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.
func (*TimeSeries) GetMetric ¶
func (x *TimeSeries) GetMetric() string
func (*TimeSeries) GetMetricKind ¶
func (x *TimeSeries) GetMetricKind() metric.MetricDescriptor_MetricKind
func (*TimeSeries) GetPoints ¶
func (x *TimeSeries) GetPoints() []*Point
func (*TimeSeries) GetValueType ¶
func (x *TimeSeries) GetValueType() metric.MetricDescriptor_ValueType
func (*TimeSeries) ProtoMessage ¶
func (*TimeSeries) ProtoMessage()
func (*TimeSeries) ProtoReflect ¶
func (x *TimeSeries) ProtoReflect() protoreflect.Message
func (*TimeSeries) Reset ¶
func (x *TimeSeries) Reset()
func (*TimeSeries) String ¶
func (x *TimeSeries) String() string
type TranslationConfigDetails ¶
type TranslationConfigDetails struct {
// The chosen path where the source for input files will be found.
//
// Types that are assignable to SourceLocation:
//
// *TranslationConfigDetails_GcsSourcePath
SourceLocation isTranslationConfigDetails_SourceLocation `protobuf_oneof:"source_location"`
// The chosen path where the destination for output files will be found.
//
// Types that are assignable to TargetLocation:
//
// *TranslationConfigDetails_GcsTargetPath
TargetLocation isTranslationConfigDetails_TargetLocation `protobuf_oneof:"target_location"`
// The mapping of full SQL object names from their current state to the
// desired output.
//
// Types that are assignable to OutputNameMapping:
//
// *TranslationConfigDetails_NameMappingList
OutputNameMapping isTranslationConfigDetails_OutputNameMapping `protobuf_oneof:"output_name_mapping"`
// The dialect of the input files.
SourceDialect *Dialect `protobuf:"bytes,3,opt,name=source_dialect,json=sourceDialect,proto3" json:"source_dialect,omitempty"`
// The target dialect for the engine to translate the input to.
TargetDialect *Dialect `protobuf:"bytes,4,opt,name=target_dialect,json=targetDialect,proto3" json:"target_dialect,omitempty"`
// The default source environment values for the translation.
SourceEnv *SourceEnv `protobuf:"bytes,6,opt,name=source_env,json=sourceEnv,proto3" json:"source_env,omitempty"`
// The indicator to show translation request initiator.
RequestSource string `protobuf:"bytes,8,opt,name=request_source,json=requestSource,proto3" json:"request_source,omitempty"`
// The types of output to generate, e.g. sql, metadata etc. If not specified,
// a default set of targets will be generated. Some additional target types
// may be slower to generate. See the documentation for the set of available
// target types.
TargetTypes []string `protobuf:"bytes,9,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`
// contains filtered or unexported fields
}
The translation config to capture necessary settings for a translation task and subtask.
func (*TranslationConfigDetails) Descriptor ¶
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 ¶
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 ¶
func (x *TranslationConfigDetails) GetTargetTypes() []string
func (*TranslationConfigDetails) ProtoMessage ¶
func (*TranslationConfigDetails) ProtoMessage()
func (*TranslationConfigDetails) ProtoReflect ¶
func (x *TranslationConfigDetails) ProtoReflect() protoreflect.Message
func (*TranslationConfigDetails) Reset ¶
func (x *TranslationConfigDetails) Reset()
func (*TranslationConfigDetails) String ¶
func (x *TranslationConfigDetails) String() string
type TranslationConfigDetails_GcsSourcePath ¶
type TranslationConfigDetails_GcsSourcePath struct {
// The Cloud Storage path for a directory of files to translate in a task.
GcsSourcePath string `protobuf:"bytes,1,opt,name=gcs_source_path,json=gcsSourcePath,proto3,oneof"`
}
type TranslationConfigDetails_GcsTargetPath ¶
type TranslationConfigDetails_GcsTargetPath struct {
// The Cloud Storage path to write back the corresponding input files to.
GcsTargetPath string `protobuf:"bytes,2,opt,name=gcs_target_path,json=gcsTargetPath,proto3,oneof"`
}
type TranslationConfigDetails_NameMappingList ¶
type TranslationConfigDetails_NameMappingList struct {
// The mapping of objects to their desired output names in list form.
NameMappingList *ObjectNameMappingList `protobuf:"bytes,5,opt,name=name_mapping_list,json=nameMappingList,proto3,oneof"`
}
type TranslationDetails ¶
type TranslationDetails struct {
// The mapping from source to target SQL.
SourceTargetMapping []*SourceTargetMapping `protobuf:"bytes,1,rep,name=source_target_mapping,json=sourceTargetMapping,proto3" json:"source_target_mapping,omitempty"`
// The base URI for all writes to persistent storage.
TargetBaseUri string `protobuf:"bytes,2,opt,name=target_base_uri,json=targetBaseUri,proto3" json:"target_base_uri,omitempty"`
// The default source environment values for the translation.
SourceEnvironment *SourceEnvironment `protobuf:"bytes,3,opt,name=source_environment,json=sourceEnvironment,proto3" json:"source_environment,omitempty"`
// The list of literal targets that will be directly returned to the response.
// Each entry consists of the constructed path, EXCLUDING the base path. Not
// providing a target_base_uri will prevent writing to persistent storage.
TargetReturnLiterals []string `protobuf:"bytes,4,rep,name=target_return_literals,json=targetReturnLiterals,proto3" json:"target_return_literals,omitempty"`
// The types of output to generate, e.g. sql, metadata,
// lineage_from_sql_scripts, etc. If not specified, a default set of
// targets will be generated. Some additional target types may be slower to
// generate. See the documentation for the set of available target types.
TargetTypes []string `protobuf:"bytes,5,rep,name=target_types,json=targetTypes,proto3" json:"target_types,omitempty"`
// contains filtered or unexported fields
}
The translation details to capture the necessary settings for a translation job.
func (*TranslationDetails) Descriptor ¶
func (*TranslationDetails) Descriptor() ([]byte, []int)
Deprecated: Use TranslationDetails.ProtoReflect.Descriptor instead.
func (*TranslationDetails) GetSourceEnvironment ¶
func (x *TranslationDetails) GetSourceEnvironment() *SourceEnvironment
func (*TranslationDetails) GetSourceTargetMapping ¶
func (x *TranslationDetails) GetSourceTargetMapping() []*SourceTargetMapping
func (*TranslationDetails) GetTargetBaseUri ¶
func (x *TranslationDetails) GetTargetBaseUri() string
func (*TranslationDetails) GetTargetReturnLiterals ¶
func (x *TranslationDetails) GetTargetReturnLiterals() []string
func (*TranslationDetails) GetTargetTypes ¶
func (x *TranslationDetails) GetTargetTypes() []string
func (*TranslationDetails) ProtoMessage ¶
func (*TranslationDetails) ProtoMessage()
func (*TranslationDetails) ProtoReflect ¶
func (x *TranslationDetails) ProtoReflect() protoreflect.Message
func (*TranslationDetails) Reset ¶
func (x *TranslationDetails) Reset()
func (*TranslationDetails) String ¶
func (x *TranslationDetails) String() string
type TranslationReportRecord ¶
type TranslationReportRecord struct {
// Severity of the translation record.
Severity TranslationReportRecord_Severity `protobuf:"varint,1,opt,name=severity,proto3,enum=google.cloud.bigquery.migration.v2.TranslationReportRecord_Severity" json:"severity,omitempty"`
// Specifies the row from the source text where the error occurred (0 based).
// Example: 2
ScriptLine int32 `protobuf:"varint,2,opt,name=script_line,json=scriptLine,proto3" json:"script_line,omitempty"`
// Specifies the column from the source texts where the error occurred. (0
// based) example: 6
ScriptColumn int32 `protobuf:"varint,3,opt,name=script_column,json=scriptColumn,proto3" json:"script_column,omitempty"`
// Category of the error/warning. Example: SyntaxError
Category string `protobuf:"bytes,4,opt,name=category,proto3" json:"category,omitempty"`
// Detailed message of the record.
Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
Details about a record.
func (*TranslationReportRecord) Descriptor ¶
func (*TranslationReportRecord) Descriptor() ([]byte, []int)
Deprecated: Use TranslationReportRecord.ProtoReflect.Descriptor instead.
func (*TranslationReportRecord) GetCategory ¶
func (x *TranslationReportRecord) GetCategory() string
func (*TranslationReportRecord) GetMessage ¶
func (x *TranslationReportRecord) GetMessage() string
func (*TranslationReportRecord) GetScriptColumn ¶
func (x *TranslationReportRecord) GetScriptColumn() int32
func (*TranslationReportRecord) GetScriptLine ¶
func (x *TranslationReportRecord) GetScriptLine() int32
func (*TranslationReportRecord) GetSeverity ¶
func (x *TranslationReportRecord) GetSeverity() TranslationReportRecord_Severity
func (*TranslationReportRecord) ProtoMessage ¶
func (*TranslationReportRecord) ProtoMessage()
func (*TranslationReportRecord) ProtoReflect ¶
func (x *TranslationReportRecord) ProtoReflect() protoreflect.Message
func (*TranslationReportRecord) Reset ¶
func (x *TranslationReportRecord) Reset()
func (*TranslationReportRecord) String ¶
func (x *TranslationReportRecord) String() string
type TranslationReportRecord_Severity ¶
type TranslationReportRecord_Severity int32
The severity type of the record.
const ( // SeverityType not specified. TranslationReportRecord_SEVERITY_UNSPECIFIED TranslationReportRecord_Severity = 0 // INFO type. TranslationReportRecord_INFO TranslationReportRecord_Severity = 1 // WARNING type. The translated query may still provide useful information // if all the report records are WARNING. TranslationReportRecord_WARNING TranslationReportRecord_Severity = 2 // ERROR type. Translation failed. TranslationReportRecord_ERROR TranslationReportRecord_Severity = 3 )
func (TranslationReportRecord_Severity) Descriptor ¶
func (TranslationReportRecord_Severity) Descriptor() protoreflect.EnumDescriptor
func (TranslationReportRecord_Severity) Enum ¶
func (x TranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity
func (TranslationReportRecord_Severity) EnumDescriptor ¶
func (TranslationReportRecord_Severity) EnumDescriptor() ([]byte, []int)
Deprecated: Use TranslationReportRecord_Severity.Descriptor instead.
func (TranslationReportRecord_Severity) Number ¶
func (x TranslationReportRecord_Severity) Number() protoreflect.EnumNumber
func (TranslationReportRecord_Severity) String ¶
func (x TranslationReportRecord_Severity) String() string
func (TranslationReportRecord_Severity) Type ¶
func (TranslationReportRecord_Severity) Type() protoreflect.EnumType
type TranslationTaskResult ¶
type TranslationTaskResult struct {
// The list of the translated literals.
TranslatedLiterals []*Literal `protobuf:"bytes,1,rep,name=translated_literals,json=translatedLiterals,proto3" json:"translated_literals,omitempty"`
// The records from the aggregate CSV report for a migration workflow.
ReportLogMessages []*GcsReportLogMessage `protobuf:"bytes,2,rep,name=report_log_messages,json=reportLogMessages,proto3" json:"report_log_messages,omitempty"`
// contains filtered or unexported fields
}
Translation specific result details from the migration task.
func (*TranslationTaskResult) Descriptor ¶
func (*TranslationTaskResult) Descriptor() ([]byte, []int)
Deprecated: Use TranslationTaskResult.ProtoReflect.Descriptor instead.
func (*TranslationTaskResult) GetReportLogMessages ¶
func (x *TranslationTaskResult) GetReportLogMessages() []*GcsReportLogMessage
func (*TranslationTaskResult) GetTranslatedLiterals ¶
func (x *TranslationTaskResult) GetTranslatedLiterals() []*Literal
func (*TranslationTaskResult) ProtoMessage ¶
func (*TranslationTaskResult) ProtoMessage()
func (*TranslationTaskResult) ProtoReflect ¶
func (x *TranslationTaskResult) ProtoReflect() protoreflect.Message
func (*TranslationTaskResult) Reset ¶
func (x *TranslationTaskResult) Reset()
func (*TranslationTaskResult) String ¶
func (x *TranslationTaskResult) String() string
type TypedValue ¶
type TypedValue struct {
// The typed value field.
//
// Types that are assignable to Value:
//
// *TypedValue_BoolValue
// *TypedValue_Int64Value
// *TypedValue_DoubleValue
// *TypedValue_StringValue
// *TypedValue_DistributionValue
Value isTypedValue_Value `protobuf_oneof:"value"`
// contains filtered or unexported fields
}
A single strongly-typed value.
func (*TypedValue) Descriptor ¶
func (*TypedValue) Descriptor() ([]byte, []int)
Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.
func (*TypedValue) GetBoolValue ¶
func (x *TypedValue) GetBoolValue() bool
func (*TypedValue) GetDistributionValue ¶
func (x *TypedValue) GetDistributionValue() *distribution.Distribution
func (*TypedValue) GetDoubleValue ¶
func (x *TypedValue) GetDoubleValue() float64
func (*TypedValue) GetInt64Value ¶
func (x *TypedValue) GetInt64Value() int64
func (*TypedValue) GetStringValue ¶
func (x *TypedValue) GetStringValue() string
func (*TypedValue) GetValue ¶
func (m *TypedValue) GetValue() isTypedValue_Value
func (*TypedValue) ProtoMessage ¶
func (*TypedValue) ProtoMessage()
func (*TypedValue) ProtoReflect ¶
func (x *TypedValue) ProtoReflect() protoreflect.Message
func (*TypedValue) Reset ¶
func (x *TypedValue) Reset()
func (*TypedValue) String ¶
func (x *TypedValue) String() string
type TypedValue_BoolValue ¶
type TypedValue_BoolValue struct {
// A Boolean value: `true` or `false`.
BoolValue bool `protobuf:"varint,1,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type TypedValue_DistributionValue ¶
type TypedValue_DistributionValue struct {
// A distribution value.
DistributionValue *distribution.Distribution `protobuf:"bytes,5,opt,name=distribution_value,json=distributionValue,proto3,oneof"`
}
type TypedValue_DoubleValue ¶
type TypedValue_DoubleValue struct {
// A 64-bit double-precision floating-point number. Its magnitude
// is approximately `+/-10^(+/-300)` and it has 16 significant digits of
// precision.
DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type TypedValue_Int64Value ¶
type TypedValue_Int64Value struct {
// A 64-bit integer. Its range is approximately `+/-9.2x10^18`.
Int64Value int64 `protobuf:"varint,2,opt,name=int64_value,json=int64Value,proto3,oneof"`
}
type TypedValue_StringValue ¶
type TypedValue_StringValue struct {
// A variable-length string value.
StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type UnimplementedMigrationServiceServer ¶
type UnimplementedMigrationServiceServer struct {
}
UnimplementedMigrationServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow ¶
func (*UnimplementedMigrationServiceServer) CreateMigrationWorkflow(context.Context, *CreateMigrationWorkflowRequest) (*MigrationWorkflow, error)
func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow ¶
func (*UnimplementedMigrationServiceServer) DeleteMigrationWorkflow(context.Context, *DeleteMigrationWorkflowRequest) (*emptypb.Empty, error)
func (*UnimplementedMigrationServiceServer) GetMigrationSubtask ¶
func (*UnimplementedMigrationServiceServer) GetMigrationSubtask(context.Context, *GetMigrationSubtaskRequest) (*MigrationSubtask, error)
func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow ¶
func (*UnimplementedMigrationServiceServer) GetMigrationWorkflow(context.Context, *GetMigrationWorkflowRequest) (*MigrationWorkflow, error)
func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks ¶
func (*UnimplementedMigrationServiceServer) ListMigrationSubtasks(context.Context, *ListMigrationSubtasksRequest) (*ListMigrationSubtasksResponse, error)
func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows ¶
func (*UnimplementedMigrationServiceServer) ListMigrationWorkflows(context.Context, *ListMigrationWorkflowsRequest) (*ListMigrationWorkflowsResponse, error)
func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow ¶
func (*UnimplementedMigrationServiceServer) StartMigrationWorkflow(context.Context, *StartMigrationWorkflowRequest) (*emptypb.Empty, error)
type VerticaDialect ¶
type VerticaDialect struct {
// contains filtered or unexported fields
}
The dialect definition for Vertica.
func (*VerticaDialect) Descriptor ¶
func (*VerticaDialect) Descriptor() ([]byte, []int)
Deprecated: Use VerticaDialect.ProtoReflect.Descriptor instead.
func (*VerticaDialect) ProtoMessage ¶
func (*VerticaDialect) ProtoMessage()
func (*VerticaDialect) ProtoReflect ¶
func (x *VerticaDialect) ProtoReflect() protoreflect.Message
func (*VerticaDialect) Reset ¶
func (x *VerticaDialect) Reset()
func (*VerticaDialect) String ¶
func (x *VerticaDialect) String() string
Source Files ¶
migration_entities.pb.go migration_error_details.pb.go migration_metrics.pb.go migration_service.pb.go translation_config.pb.go translation_details.pb.go translation_suggestion.pb.go translation_usability.pb.go
- Version
- v1.69.0 (latest)
- Published
- May 27, 2025
- Platform
- linux/amd64
- Imports
- 15 packages
- Last checked
- 9 months ago –
Tools for package owners.