migrationpb

package

Go to main page

Versions in this module

v1

v1.65.0

Dec 5, 2024

v1.64.0

Oct 30, 2024

v1.63.1

Oct 2, 2024

v1.63.0

Sep 18, 2024

Changes in this version

+ 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

+ var TranslationReportRecord_Severity_name = map[int32]string

+ var TranslationReportRecord_Severity_value = map[string]int32

+ type DB2Dialect struct

+ func (*DB2Dialect) Descriptor() ([]byte, []int)

+ func (*DB2Dialect) ProtoMessage()

+ func (x *DB2Dialect) ProtoReflect() protoreflect.Message

+ func (x *DB2Dialect) Reset()

+ func (x *DB2Dialect) String() string

type Dialect

+ func (x *Dialect) GetDb2Dialect() *DB2Dialect

+ func (x *Dialect) GetGreenplumDialect() *GreenplumDialect

+ func (x *Dialect) GetSqliteDialect() *SQLiteDialect

+ type Dialect_Db2Dialect struct

+ Db2Dialect *DB2Dialect

+ type Dialect_GreenplumDialect struct

+ GreenplumDialect *GreenplumDialect

+ type Dialect_SqliteDialect struct

+ SqliteDialect *SQLiteDialect

+ type GcsReportLogMessage struct

+ Action string

+ Category string

+ Effect string

+ FilePath string

+ Filename string

+ Message string

+ ObjectName string

+ ScriptContext string

+ Severity string

+ SourceScriptColumn int32

+ SourceScriptLine int32

+ func (*GcsReportLogMessage) Descriptor() ([]byte, []int)

+ func (*GcsReportLogMessage) ProtoMessage()

+ 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 (x *GcsReportLogMessage) ProtoReflect() protoreflect.Message

+ func (x *GcsReportLogMessage) Reset()

+ func (x *GcsReportLogMessage) String() string

+ type GreenplumDialect struct

+ func (*GreenplumDialect) Descriptor() ([]byte, []int)

+ func (*GreenplumDialect) ProtoMessage()

+ func (x *GreenplumDialect) ProtoReflect() protoreflect.Message

+ func (x *GreenplumDialect) Reset()

+ func (x *GreenplumDialect) String() string

+ type Literal struct

+ LiteralData isLiteral_LiteralData

+ RelativePath string

+ func (*Literal) Descriptor() ([]byte, []int)

+ func (*Literal) ProtoMessage()

+ func (m *Literal) GetLiteralData() isLiteral_LiteralData

+ func (x *Literal) GetLiteralBytes() []byte

+ func (x *Literal) GetLiteralString() string

+ func (x *Literal) GetRelativePath() string

+ func (x *Literal) ProtoReflect() protoreflect.Message

+ func (x *Literal) Reset()

+ func (x *Literal) String() string

+ type Literal_LiteralBytes struct

+ LiteralBytes []byte

+ type Literal_LiteralString struct

+ LiteralString string

type MigrationTask

+ Metrics []*TimeSeries

+ ResourceErrorCount int32

+ ResourceErrorDetails []*ResourceErrorDetail

+ TaskResult *MigrationTaskResult

+ TotalProcessingErrorCount int32

+ TotalResourceErrorCount int32

+ func (x *MigrationTask) GetMetrics() []*TimeSeries

+ func (x *MigrationTask) GetResourceErrorCount() int32

+ func (x *MigrationTask) GetResourceErrorDetails() []*ResourceErrorDetail

+ func (x *MigrationTask) GetTaskResult() *MigrationTaskResult

+ func (x *MigrationTask) GetTotalProcessingErrorCount() int32

+ func (x *MigrationTask) GetTotalResourceErrorCount() int32

+ func (x *MigrationTask) GetTranslationDetails() *TranslationDetails

+ type MigrationTaskResult struct

+ Details isMigrationTaskResult_Details

+ func (*MigrationTaskResult) Descriptor() ([]byte, []int)

+ func (*MigrationTaskResult) ProtoMessage()

+ func (m *MigrationTaskResult) GetDetails() isMigrationTaskResult_Details

+ func (x *MigrationTaskResult) GetTranslationTaskResult() *TranslationTaskResult

+ func (x *MigrationTaskResult) ProtoReflect() protoreflect.Message

+ func (x *MigrationTaskResult) Reset()

+ func (x *MigrationTaskResult) String() string

+ type MigrationTaskResult_TranslationTaskResult struct

+ TranslationTaskResult *TranslationTaskResult

+ type MigrationTask_TranslationDetails struct

+ TranslationDetails *TranslationDetails

+ type SQLiteDialect struct

+ func (*SQLiteDialect) Descriptor() ([]byte, []int)

+ func (*SQLiteDialect) ProtoMessage()

+ func (x *SQLiteDialect) ProtoReflect() protoreflect.Message

+ func (x *SQLiteDialect) Reset()

+ func (x *SQLiteDialect) String() string

type SourceEnv

+ MetadataStoreDataset string

+ func (x *SourceEnv) GetMetadataStoreDataset() string

+ type SourceEnvironment struct

+ DefaultDatabase string

+ MetadataStoreDataset string

+ SchemaSearchPath []string

+ func (*SourceEnvironment) Descriptor() ([]byte, []int)

+ func (*SourceEnvironment) ProtoMessage()

+ func (x *SourceEnvironment) GetDefaultDatabase() string

+ func (x *SourceEnvironment) GetMetadataStoreDataset() string

+ func (x *SourceEnvironment) GetSchemaSearchPath() []string

+ func (x *SourceEnvironment) ProtoReflect() protoreflect.Message

+ func (x *SourceEnvironment) Reset()

+ func (x *SourceEnvironment) String() string

+ type SourceSpec struct

+ Encoding string

+ Source isSourceSpec_Source

+ func (*SourceSpec) Descriptor() ([]byte, []int)

+ func (*SourceSpec) ProtoMessage()

+ func (m *SourceSpec) GetSource() isSourceSpec_Source

+ func (x *SourceSpec) GetBaseUri() string

+ func (x *SourceSpec) GetEncoding() string

+ func (x *SourceSpec) GetLiteral() *Literal

+ func (x *SourceSpec) ProtoReflect() protoreflect.Message

+ func (x *SourceSpec) Reset()

+ func (x *SourceSpec) String() string

+ type SourceSpec_BaseUri struct

+ BaseUri string

+ type SourceSpec_Literal struct

+ Literal *Literal

+ type SourceTargetMapping struct

+ SourceSpec *SourceSpec

+ TargetSpec *TargetSpec

+ func (*SourceTargetMapping) Descriptor() ([]byte, []int)

+ func (*SourceTargetMapping) ProtoMessage()

+ func (x *SourceTargetMapping) GetSourceSpec() *SourceSpec

+ func (x *SourceTargetMapping) GetTargetSpec() *TargetSpec

+ func (x *SourceTargetMapping) ProtoReflect() protoreflect.Message

+ func (x *SourceTargetMapping) Reset()

+ func (x *SourceTargetMapping) String() string

+ type TargetSpec struct

+ RelativePath string

+ func (*TargetSpec) Descriptor() ([]byte, []int)

+ func (*TargetSpec) ProtoMessage()

+ func (x *TargetSpec) GetRelativePath() string

+ func (x *TargetSpec) ProtoReflect() protoreflect.Message

+ func (x *TargetSpec) Reset()

+ func (x *TargetSpec) String() string

type TranslationConfigDetails

+ TargetTypes []string

+ func (x *TranslationConfigDetails) GetTargetTypes() []string

+ type TranslationDetails struct

+ SourceEnvironment *SourceEnvironment

+ SourceTargetMapping []*SourceTargetMapping

+ TargetBaseUri string

+ TargetReturnLiterals []string

+ TargetTypes []string

+ func (*TranslationDetails) Descriptor() ([]byte, []int)

+ func (*TranslationDetails) ProtoMessage()

+ 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 (x *TranslationDetails) ProtoReflect() protoreflect.Message

+ func (x *TranslationDetails) Reset()

+ func (x *TranslationDetails) String() string

+ type TranslationReportRecord struct

+ Category string

+ Message string

+ ScriptColumn int32

+ ScriptLine int32

+ Severity TranslationReportRecord_Severity

+ func (*TranslationReportRecord) Descriptor() ([]byte, []int)

+ func (*TranslationReportRecord) ProtoMessage()

+ 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 (x *TranslationReportRecord) ProtoReflect() protoreflect.Message

+ func (x *TranslationReportRecord) Reset()

+ func (x *TranslationReportRecord) String() string

+ type TranslationReportRecord_Severity int32

+ const TranslationReportRecord_ERROR

+ const TranslationReportRecord_INFO

+ const TranslationReportRecord_SEVERITY_UNSPECIFIED

+ const TranslationReportRecord_WARNING

+ func (TranslationReportRecord_Severity) Descriptor() protoreflect.EnumDescriptor

+ func (TranslationReportRecord_Severity) EnumDescriptor() ([]byte, []int)

+ func (TranslationReportRecord_Severity) Type() protoreflect.EnumType

+ func (x TranslationReportRecord_Severity) Enum() *TranslationReportRecord_Severity

+ func (x TranslationReportRecord_Severity) Number() protoreflect.EnumNumber

+ func (x TranslationReportRecord_Severity) String() string

+ type TranslationTaskResult struct

+ ReportLogMessages []*GcsReportLogMessage

+ TranslatedLiterals []*Literal

+ func (*TranslationTaskResult) Descriptor() ([]byte, []int)

+ func (*TranslationTaskResult) ProtoMessage()

+ func (x *TranslationTaskResult) GetReportLogMessages() []*GcsReportLogMessage

+ func (x *TranslationTaskResult) GetTranslatedLiterals() []*Literal

+ func (x *TranslationTaskResult) ProtoReflect() protoreflect.Message

+ func (x *TranslationTaskResult) Reset()

+ func (x *TranslationTaskResult) String() string

v1.62.0

Jul 22, 2024

v1.61.0

Apr 24, 2024

v1.60.0

Mar 27, 2024

v1.59.1

Feb 12, 2024

v1.59.0

Feb 6, 2024

v1.58.0

Jan 18, 2024

v1.57.1

Nov 1, 2023

v1.57.0

Oct 30, 2023

v1.56.0

Oct 5, 2023

v1.55.0

Sep 11, 2023

v1.54.0

Aug 17, 2023

v1.53.0

Jul 24, 2023

v1.52.0

Jun 26, 2023

v1.51.2

May 9, 2023

v1.51.1

May 4, 2023

v1.51.0

Apr 17, 2023

v1.50.0

Apr 3, 2023

Changes in this version

type MigrationSubtask_State

+ const MigrationSubtask_PENDING_DEPENDENCY

type TranslationConfigDetails

+ RequestSource string

+ func (x *TranslationConfigDetails) GetRequestSource() string

v1.49.0

Mar 16, 2023

v1.48.0

Mar 1, 2023

v1.47.0

Feb 22, 2023

v1.46.0

Feb 7, 2023

v1.45.0

Jan 5, 2023

v1.44.0

Nov 30, 2022

Changes in this version

+ 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 MigrationSubtask_State_name = map[int32]string

+ var MigrationSubtask_State_value = map[string]int32

+ var MigrationTask_State_name = map[int32]string

+ var MigrationTask_State_value = map[string]int32

+ var MigrationWorkflow_State_name = map[int32]string

+ var MigrationWorkflow_State_value = map[string]int32

+ var NameMappingKey_Type_name = map[int32]string

+ var NameMappingKey_Type_value = map[string]int32

+ var TeradataDialect_Mode_name = map[int32]string

+ var TeradataDialect_Mode_value = map[string]int32

+ func RegisterMigrationServiceServer(s *grpc.Server, srv MigrationServiceServer)

+ type AzureSynapseDialect struct

+ 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 struct

+ 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 struct

+ MigrationWorkflow *MigrationWorkflow

+ Parent string

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

+ func (*CreateMigrationWorkflowRequest) ProtoMessage()

+ func (x *CreateMigrationWorkflowRequest) GetMigrationWorkflow() *MigrationWorkflow

+ func (x *CreateMigrationWorkflowRequest) GetParent() string

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

+ func (x *CreateMigrationWorkflowRequest) Reset()

+ func (x *CreateMigrationWorkflowRequest) String() string

+ type DeleteMigrationWorkflowRequest struct

+ Name string

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

+ func (*DeleteMigrationWorkflowRequest) ProtoMessage()

+ func (x *DeleteMigrationWorkflowRequest) GetName() string

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

+ func (x *DeleteMigrationWorkflowRequest) Reset()

+ func (x *DeleteMigrationWorkflowRequest) String() string

+ type Dialect struct

+ DialectValue isDialect_DialectValue

+ func (*Dialect) Descriptor() ([]byte, []int)

+ func (*Dialect) ProtoMessage()

+ func (m *Dialect) GetDialectValue() isDialect_DialectValue

+ func (x *Dialect) GetAzureSynapseDialect() *AzureSynapseDialect

+ func (x *Dialect) GetBigqueryDialect() *BigQueryDialect

+ 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) GetTeradataDialect() *TeradataDialect

+ func (x *Dialect) GetVerticaDialect() *VerticaDialect

+ func (x *Dialect) ProtoReflect() protoreflect.Message

+ func (x *Dialect) Reset()

+ func (x *Dialect) String() string

+ type Dialect_AzureSynapseDialect struct

+ AzureSynapseDialect *AzureSynapseDialect

+ type Dialect_BigqueryDialect struct

+ BigqueryDialect *BigQueryDialect

+ type Dialect_HiveqlDialect struct

+ HiveqlDialect *HiveQLDialect

+ type Dialect_MysqlDialect struct

+ MysqlDialect *MySQLDialect

+ type Dialect_NetezzaDialect struct

+ NetezzaDialect *NetezzaDialect

+ type Dialect_OracleDialect struct

+ OracleDialect *OracleDialect

+ type Dialect_PostgresqlDialect struct

+ PostgresqlDialect *PostgresqlDialect

+ type Dialect_PrestoDialect struct

+ PrestoDialect *PrestoDialect

+ type Dialect_RedshiftDialect struct

+ RedshiftDialect *RedshiftDialect

+ type Dialect_SnowflakeDialect struct

+ SnowflakeDialect *SnowflakeDialect

+ type Dialect_SparksqlDialect struct

+ SparksqlDialect *SparkSQLDialect

+ type Dialect_SqlServerDialect struct

+ SqlServerDialect *SQLServerDialect

+ type Dialect_TeradataDialect struct

+ TeradataDialect *TeradataDialect

+ type Dialect_VerticaDialect struct

+ VerticaDialect *VerticaDialect

+ type ErrorDetail struct

+ ErrorInfo *errdetails.ErrorInfo

+ Location *ErrorLocation

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

+ func (*ErrorDetail) ProtoMessage()

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

+ func (x *ErrorDetail) GetLocation() *ErrorLocation

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

+ func (x *ErrorDetail) Reset()

+ func (x *ErrorDetail) String() string

+ type ErrorLocation struct

+ Column int32

+ Line int32

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

+ func (*ErrorLocation) ProtoMessage()

+ func (x *ErrorLocation) GetColumn() int32

+ func (x *ErrorLocation) GetLine() int32

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

+ func (x *ErrorLocation) Reset()

+ func (x *ErrorLocation) String() string

+ type GetMigrationSubtaskRequest struct

+ Name string

+ ReadMask *fieldmaskpb.FieldMask

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

+ func (*GetMigrationSubtaskRequest) ProtoMessage()

+ func (x *GetMigrationSubtaskRequest) GetName() string

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

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

+ func (x *GetMigrationSubtaskRequest) Reset()

+ func (x *GetMigrationSubtaskRequest) String() string

+ type GetMigrationWorkflowRequest struct

+ Name string

+ ReadMask *fieldmaskpb.FieldMask

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

+ func (*GetMigrationWorkflowRequest) ProtoMessage()

+ func (x *GetMigrationWorkflowRequest) GetName() string

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

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

+ func (x *GetMigrationWorkflowRequest) Reset()

+ func (x *GetMigrationWorkflowRequest) String() string

+ type HiveQLDialect struct

+ 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 struct

+ Filter string

+ PageSize int32

+ PageToken string

+ Parent string

+ ReadMask *fieldmaskpb.FieldMask

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

+ func (*ListMigrationSubtasksRequest) ProtoMessage()

+ 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 (x *ListMigrationSubtasksRequest) ProtoReflect() protoreflect.Message

+ func (x *ListMigrationSubtasksRequest) Reset()

+ func (x *ListMigrationSubtasksRequest) String() string

+ type ListMigrationSubtasksResponse struct

+ MigrationSubtasks []*MigrationSubtask

+ NextPageToken string

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

+ func (*ListMigrationSubtasksResponse) ProtoMessage()

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

+ func (x *ListMigrationSubtasksResponse) GetNextPageToken() string

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

+ func (x *ListMigrationSubtasksResponse) Reset()

+ func (x *ListMigrationSubtasksResponse) String() string

+ type ListMigrationWorkflowsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ ReadMask *fieldmaskpb.FieldMask

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

+ func (*ListMigrationWorkflowsRequest) ProtoMessage()

+ func (x *ListMigrationWorkflowsRequest) GetPageSize() int32

+ func (x *ListMigrationWorkflowsRequest) GetPageToken() string

+ func (x *ListMigrationWorkflowsRequest) GetParent() string

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

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

+ func (x *ListMigrationWorkflowsRequest) Reset()

+ func (x *ListMigrationWorkflowsRequest) String() string

+ type ListMigrationWorkflowsResponse struct

+ MigrationWorkflows []*MigrationWorkflow

+ NextPageToken string

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

+ func (*ListMigrationWorkflowsResponse) ProtoMessage()

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

+ func (x *ListMigrationWorkflowsResponse) GetNextPageToken() string

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

+ func (x *ListMigrationWorkflowsResponse) Reset()

+ func (x *ListMigrationWorkflowsResponse) String() string

+ type MigrationServiceClient interface

+ CreateMigrationWorkflow func(ctx context.Context, in *CreateMigrationWorkflowRequest, ...) (*MigrationWorkflow, error)

+ DeleteMigrationWorkflow func(ctx context.Context, in *DeleteMigrationWorkflowRequest, ...) (*emptypb.Empty, error)

+ GetMigrationSubtask func(ctx context.Context, in *GetMigrationSubtaskRequest, opts ...grpc.CallOption) (*MigrationSubtask, error)

+ GetMigrationWorkflow func(ctx context.Context, in *GetMigrationWorkflowRequest, opts ...grpc.CallOption) (*MigrationWorkflow, error)

+ ListMigrationSubtasks func(ctx context.Context, in *ListMigrationSubtasksRequest, opts ...grpc.CallOption) (*ListMigrationSubtasksResponse, error)

+ ListMigrationWorkflows func(ctx context.Context, in *ListMigrationWorkflowsRequest, ...) (*ListMigrationWorkflowsResponse, error)

+ StartMigrationWorkflow func(ctx context.Context, in *StartMigrationWorkflowRequest, ...) (*emptypb.Empty, error)

+ func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient

+ type MigrationServiceServer interface

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

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

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

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

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

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

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

+ type MigrationSubtask struct

+ CreateTime *timestamppb.Timestamp

+ LastUpdateTime *timestamppb.Timestamp

+ Metrics []*TimeSeries

+ Name string

+ ProcessingError *errdetails.ErrorInfo

+ ResourceErrorCount int32

+ ResourceErrorDetails []*ResourceErrorDetail

+ State MigrationSubtask_State

+ TaskId string

+ Type string

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

+ func (*MigrationSubtask) ProtoMessage()

+ 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 (x *MigrationSubtask) ProtoReflect() protoreflect.Message

+ func (x *MigrationSubtask) Reset()

+ func (x *MigrationSubtask) String() string

+ type MigrationSubtask_State int32

+ const MigrationSubtask_ACTIVE

+ const MigrationSubtask_FAILED

+ const MigrationSubtask_PAUSED

+ const MigrationSubtask_RUNNING

+ const MigrationSubtask_STATE_UNSPECIFIED

+ const MigrationSubtask_SUCCEEDED

+ func (MigrationSubtask_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (MigrationSubtask_State) Type() protoreflect.EnumType

+ func (x MigrationSubtask_State) Enum() *MigrationSubtask_State

+ func (x MigrationSubtask_State) Number() protoreflect.EnumNumber

+ func (x MigrationSubtask_State) String() string

+ type MigrationTask struct

+ CreateTime *timestamppb.Timestamp

+ Id string

+ LastUpdateTime *timestamppb.Timestamp

+ ProcessingError *errdetails.ErrorInfo

+ State MigrationTask_State

+ TaskDetails isMigrationTask_TaskDetails

+ Type string

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

+ func (*MigrationTask) ProtoMessage()

+ func (m *MigrationTask) GetTaskDetails() isMigrationTask_TaskDetails

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

+ func (x *MigrationTask) GetId() string

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

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

+ func (x *MigrationTask) GetState() MigrationTask_State

+ func (x *MigrationTask) GetTranslationConfigDetails() *TranslationConfigDetails

+ func (x *MigrationTask) GetType() string

+ func (x *MigrationTask) ProtoReflect() protoreflect.Message

+ func (x *MigrationTask) Reset()

+ func (x *MigrationTask) String() string

+ type MigrationTask_State int32

+ const MigrationTask_FAILED

+ const MigrationTask_ORCHESTRATING

+ const MigrationTask_PAUSED

+ const MigrationTask_PENDING

+ const MigrationTask_RUNNING

+ const MigrationTask_STATE_UNSPECIFIED

+ const MigrationTask_SUCCEEDED

+ func (MigrationTask_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (MigrationTask_State) Type() protoreflect.EnumType

+ func (x MigrationTask_State) Enum() *MigrationTask_State

+ func (x MigrationTask_State) Number() protoreflect.EnumNumber

+ func (x MigrationTask_State) String() string

+ type MigrationTask_TranslationConfigDetails struct

+ TranslationConfigDetails *TranslationConfigDetails

+ type MigrationWorkflow struct

+ CreateTime *timestamppb.Timestamp

+ DisplayName string

+ LastUpdateTime *timestamppb.Timestamp

+ Name string

+ State MigrationWorkflow_State

+ Tasks map[string]*MigrationTask

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

+ func (*MigrationWorkflow) ProtoMessage()

+ 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 (x *MigrationWorkflow) ProtoReflect() protoreflect.Message

+ func (x *MigrationWorkflow) Reset()

+ func (x *MigrationWorkflow) String() string

+ type MigrationWorkflow_State int32

+ const MigrationWorkflow_COMPLETED

+ const MigrationWorkflow_DRAFT

+ const MigrationWorkflow_PAUSED

+ const MigrationWorkflow_RUNNING

+ const MigrationWorkflow_STATE_UNSPECIFIED

+ func (MigrationWorkflow_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (MigrationWorkflow_State) Type() protoreflect.EnumType

+ func (x MigrationWorkflow_State) Enum() *MigrationWorkflow_State

+ func (x MigrationWorkflow_State) Number() protoreflect.EnumNumber

+ func (x MigrationWorkflow_State) String() string

+ type MySQLDialect struct

+ 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 struct

+ Attribute string

+ Database string

+ Relation string

+ Schema string

+ Type NameMappingKey_Type

+ func (*NameMappingKey) Descriptor() ([]byte, []int)

+ func (*NameMappingKey) ProtoMessage()

+ 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 (x *NameMappingKey) ProtoReflect() protoreflect.Message

+ func (x *NameMappingKey) Reset()

+ func (x *NameMappingKey) String() string

+ type NameMappingKey_Type int32

+ const NameMappingKey_ATTRIBUTE

+ const NameMappingKey_ATTRIBUTE_ALIAS

+ const NameMappingKey_DATABASE

+ const NameMappingKey_FUNCTION

+ const NameMappingKey_RELATION

+ const NameMappingKey_RELATION_ALIAS

+ const NameMappingKey_SCHEMA

+ const NameMappingKey_TYPE_UNSPECIFIED

+ func (NameMappingKey_Type) Descriptor() protoreflect.EnumDescriptor

+ func (NameMappingKey_Type) EnumDescriptor() ([]byte, []int)

+ func (NameMappingKey_Type) Type() protoreflect.EnumType

+ func (x NameMappingKey_Type) Enum() *NameMappingKey_Type

+ func (x NameMappingKey_Type) Number() protoreflect.EnumNumber

+ func (x NameMappingKey_Type) String() string

+ type NameMappingValue struct

+ Attribute string

+ Database string

+ Relation string

+ Schema string

+ func (*NameMappingValue) Descriptor() ([]byte, []int)

+ func (*NameMappingValue) ProtoMessage()

+ func (x *NameMappingValue) GetAttribute() string

+ func (x *NameMappingValue) GetDatabase() string

+ func (x *NameMappingValue) GetRelation() string

+ func (x *NameMappingValue) GetSchema() string

+ func (x *NameMappingValue) ProtoReflect() protoreflect.Message

+ func (x *NameMappingValue) Reset()

+ func (x *NameMappingValue) String() string

+ type NetezzaDialect struct

+ 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 struct

+ Source *NameMappingKey

+ Target *NameMappingValue

+ func (*ObjectNameMapping) Descriptor() ([]byte, []int)

+ func (*ObjectNameMapping) ProtoMessage()

+ func (x *ObjectNameMapping) GetSource() *NameMappingKey

+ func (x *ObjectNameMapping) GetTarget() *NameMappingValue

+ func (x *ObjectNameMapping) ProtoReflect() protoreflect.Message

+ func (x *ObjectNameMapping) Reset()

+ func (x *ObjectNameMapping) String() string

+ type ObjectNameMappingList struct

+ NameMap []*ObjectNameMapping

+ func (*ObjectNameMappingList) Descriptor() ([]byte, []int)

+ func (*ObjectNameMappingList) ProtoMessage()

+ func (x *ObjectNameMappingList) GetNameMap() []*ObjectNameMapping

+ func (x *ObjectNameMappingList) ProtoReflect() protoreflect.Message

+ func (x *ObjectNameMappingList) Reset()

+ func (x *ObjectNameMappingList) String() string

+ type OracleDialect struct

+ 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 struct

+ Interval *TimeInterval

+ Value *TypedValue

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

+ func (*Point) ProtoMessage()

+ func (x *Point) GetInterval() *TimeInterval

+ func (x *Point) GetValue() *TypedValue

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

+ func (x *Point) Reset()

+ func (x *Point) String() string

+ type PostgresqlDialect struct

+ 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 struct

+ 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 struct

+ 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 struct

+ ErrorCount int32

+ ErrorDetails []*ErrorDetail

+ ResourceInfo *errdetails.ResourceInfo

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

+ func (*ResourceErrorDetail) ProtoMessage()

+ func (x *ResourceErrorDetail) GetErrorCount() int32

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

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

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

+ func (x *ResourceErrorDetail) Reset()

+ func (x *ResourceErrorDetail) String() string

+ type SQLServerDialect struct

+ func (*SQLServerDialect) Descriptor() ([]byte, []int)

+ func (*SQLServerDialect) ProtoMessage()

+ func (x *SQLServerDialect) ProtoReflect() protoreflect.Message

+ func (x *SQLServerDialect) Reset()

+ func (x *SQLServerDialect) String() string

+ type SnowflakeDialect struct

+ 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 struct

+ DefaultDatabase string

+ SchemaSearchPath []string

+ func (*SourceEnv) Descriptor() ([]byte, []int)

+ func (*SourceEnv) ProtoMessage()

+ func (x *SourceEnv) GetDefaultDatabase() string

+ func (x *SourceEnv) GetSchemaSearchPath() []string

+ func (x *SourceEnv) ProtoReflect() protoreflect.Message

+ func (x *SourceEnv) Reset()

+ func (x *SourceEnv) String() string

+ type SparkSQLDialect struct

+ 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 struct

+ Name string

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

+ func (*StartMigrationWorkflowRequest) ProtoMessage()

+ func (x *StartMigrationWorkflowRequest) GetName() string

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

+ func (x *StartMigrationWorkflowRequest) Reset()

+ func (x *StartMigrationWorkflowRequest) String() string

+ type TeradataDialect struct

+ Mode TeradataDialect_Mode

+ func (*TeradataDialect) Descriptor() ([]byte, []int)

+ func (*TeradataDialect) ProtoMessage()

+ func (x *TeradataDialect) GetMode() TeradataDialect_Mode

+ func (x *TeradataDialect) ProtoReflect() protoreflect.Message

+ func (x *TeradataDialect) Reset()

+ func (x *TeradataDialect) String() string

+ type TeradataDialect_Mode int32

+ const TeradataDialect_BTEQ

+ const TeradataDialect_MODE_UNSPECIFIED

+ const TeradataDialect_SQL

+ func (TeradataDialect_Mode) Descriptor() protoreflect.EnumDescriptor

+ func (TeradataDialect_Mode) EnumDescriptor() ([]byte, []int)

+ func (TeradataDialect_Mode) Type() protoreflect.EnumType

+ func (x TeradataDialect_Mode) Enum() *TeradataDialect_Mode

+ func (x TeradataDialect_Mode) Number() protoreflect.EnumNumber

+ func (x TeradataDialect_Mode) String() string

+ type TimeInterval struct

+ EndTime *timestamppb.Timestamp

+ StartTime *timestamppb.Timestamp

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

+ func (*TimeInterval) ProtoMessage()

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

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

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

+ func (x *TimeInterval) Reset()

+ func (x *TimeInterval) String() string

+ type TimeSeries struct

+ Metric string

+ MetricKind metric.MetricDescriptor_MetricKind

+ Points []*Point

+ ValueType metric.MetricDescriptor_ValueType

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

+ func (*TimeSeries) ProtoMessage()

+ 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 (x *TimeSeries) ProtoReflect() protoreflect.Message

+ func (x *TimeSeries) Reset()

+ func (x *TimeSeries) String() string

+ type TranslationConfigDetails struct

+ OutputNameMapping isTranslationConfigDetails_OutputNameMapping

+ SourceDialect *Dialect

+ SourceEnv *SourceEnv

+ SourceLocation isTranslationConfigDetails_SourceLocation

+ TargetDialect *Dialect

+ TargetLocation isTranslationConfigDetails_TargetLocation

+ func (*TranslationConfigDetails) Descriptor() ([]byte, []int)

+ func (*TranslationConfigDetails) ProtoMessage()

+ func (m *TranslationConfigDetails) GetOutputNameMapping() isTranslationConfigDetails_OutputNameMapping

+ func (m *TranslationConfigDetails) GetSourceLocation() isTranslationConfigDetails_SourceLocation

+ func (m *TranslationConfigDetails) GetTargetLocation() isTranslationConfigDetails_TargetLocation

+ func (x *TranslationConfigDetails) GetGcsSourcePath() string

+ func (x *TranslationConfigDetails) GetGcsTargetPath() string

+ func (x *TranslationConfigDetails) GetNameMappingList() *ObjectNameMappingList

+ func (x *TranslationConfigDetails) GetSourceDialect() *Dialect

+ func (x *TranslationConfigDetails) GetSourceEnv() *SourceEnv

+ func (x *TranslationConfigDetails) GetTargetDialect() *Dialect

+ func (x *TranslationConfigDetails) ProtoReflect() protoreflect.Message

+ func (x *TranslationConfigDetails) Reset()

+ func (x *TranslationConfigDetails) String() string

+ type TranslationConfigDetails_GcsSourcePath struct

+ GcsSourcePath string

+ type TranslationConfigDetails_GcsTargetPath struct

+ GcsTargetPath string

+ type TranslationConfigDetails_NameMappingList struct

+ NameMappingList *ObjectNameMappingList

+ type TypedValue struct

+ Value isTypedValue_Value

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

+ func (*TypedValue) ProtoMessage()

+ func (m *TypedValue) GetValue() isTypedValue_Value

+ 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 (x *TypedValue) ProtoReflect() protoreflect.Message

+ func (x *TypedValue) Reset()

+ func (x *TypedValue) String() string

+ type TypedValue_BoolValue struct

+ BoolValue bool

+ type TypedValue_DistributionValue struct

+ DistributionValue *distribution.Distribution

+ type TypedValue_DoubleValue struct

+ DoubleValue float64

+ type TypedValue_Int64Value struct

+ Int64Value int64

+ type TypedValue_StringValue struct

+ StringValue string

+ type UnimplementedMigrationServiceServer struct

+ 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 struct

+ func (*VerticaDialect) Descriptor() ([]byte, []int)

+ func (*VerticaDialect) ProtoMessage()

+ func (x *VerticaDialect) ProtoReflect() protoreflect.Message

+ func (x *VerticaDialect) Reset()

+ func (x *VerticaDialect) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL