Documentation ¶
Index ¶
- Variables
- func RegisterDataMigrationServiceServer(s *grpc.Server, srv DataMigrationServiceServer)
- type CloudSqlConnectionProfile
- func (*CloudSqlConnectionProfile) Descriptor() ([]byte, []int)deprecated
- func (x *CloudSqlConnectionProfile) GetCloudSqlId() string
- func (x *CloudSqlConnectionProfile) GetPrivateIp() string
- func (x *CloudSqlConnectionProfile) GetPublicIp() string
- func (x *CloudSqlConnectionProfile) GetSettings() *CloudSqlSettings
- func (*CloudSqlConnectionProfile) ProtoMessage()
- func (x *CloudSqlConnectionProfile) ProtoReflect() protoreflect.Message
- func (x *CloudSqlConnectionProfile) Reset()
- func (x *CloudSqlConnectionProfile) String() string
- type CloudSqlSettings
- func (*CloudSqlSettings) Descriptor() ([]byte, []int)deprecated
- func (x *CloudSqlSettings) GetActivationPolicy() CloudSqlSettings_SqlActivationPolicy
- func (x *CloudSqlSettings) GetAutoStorageIncrease() *wrapperspb.BoolValue
- func (x *CloudSqlSettings) GetCollation() string
- func (x *CloudSqlSettings) GetDataDiskSizeGb() *wrapperspb.Int64Value
- func (x *CloudSqlSettings) GetDataDiskType() CloudSqlSettings_SqlDataDiskType
- func (x *CloudSqlSettings) GetDatabaseFlags() map[string]string
- func (x *CloudSqlSettings) GetDatabaseVersion() CloudSqlSettings_SqlDatabaseVersion
- func (x *CloudSqlSettings) GetIpConfig() *SqlIpConfig
- func (x *CloudSqlSettings) GetRootPassword() string
- func (x *CloudSqlSettings) GetRootPasswordSet() bool
- func (x *CloudSqlSettings) GetSourceId() string
- func (x *CloudSqlSettings) GetStorageAutoResizeLimit() *wrapperspb.Int64Value
- func (x *CloudSqlSettings) GetTier() string
- func (x *CloudSqlSettings) GetUserLabels() map[string]string
- func (x *CloudSqlSettings) GetZone() string
- func (*CloudSqlSettings) ProtoMessage()
- func (x *CloudSqlSettings) ProtoReflect() protoreflect.Message
- func (x *CloudSqlSettings) Reset()
- func (x *CloudSqlSettings) String() string
- type CloudSqlSettings_SqlActivationPolicy
- func (CloudSqlSettings_SqlActivationPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x CloudSqlSettings_SqlActivationPolicy) Enum() *CloudSqlSettings_SqlActivationPolicy
- func (CloudSqlSettings_SqlActivationPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloudSqlSettings_SqlActivationPolicy) Number() protoreflect.EnumNumber
- func (x CloudSqlSettings_SqlActivationPolicy) String() string
- func (CloudSqlSettings_SqlActivationPolicy) Type() protoreflect.EnumType
- type CloudSqlSettings_SqlDataDiskType
- func (CloudSqlSettings_SqlDataDiskType) Descriptor() protoreflect.EnumDescriptor
- func (x CloudSqlSettings_SqlDataDiskType) Enum() *CloudSqlSettings_SqlDataDiskType
- func (CloudSqlSettings_SqlDataDiskType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloudSqlSettings_SqlDataDiskType) Number() protoreflect.EnumNumber
- func (x CloudSqlSettings_SqlDataDiskType) String() string
- func (CloudSqlSettings_SqlDataDiskType) Type() protoreflect.EnumType
- type CloudSqlSettings_SqlDatabaseVersion
- func (CloudSqlSettings_SqlDatabaseVersion) Descriptor() protoreflect.EnumDescriptor
- func (x CloudSqlSettings_SqlDatabaseVersion) Enum() *CloudSqlSettings_SqlDatabaseVersion
- func (CloudSqlSettings_SqlDatabaseVersion) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloudSqlSettings_SqlDatabaseVersion) Number() protoreflect.EnumNumber
- func (x CloudSqlSettings_SqlDatabaseVersion) String() string
- func (CloudSqlSettings_SqlDatabaseVersion) Type() protoreflect.EnumType
- type ConnectionProfile
- func (*ConnectionProfile) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionProfile) GetCloudsql() *CloudSqlConnectionProfile
- func (m *ConnectionProfile) GetConnectionProfile() isConnectionProfile_ConnectionProfile
- func (x *ConnectionProfile) GetCreateTime() *timestamppb.Timestamp
- func (x *ConnectionProfile) GetDisplayName() string
- func (x *ConnectionProfile) GetError() *status.Status
- func (x *ConnectionProfile) GetLabels() map[string]string
- func (x *ConnectionProfile) GetMysql() *MySqlConnectionProfile
- func (x *ConnectionProfile) GetName() string
- func (x *ConnectionProfile) GetPostgresql() *PostgreSqlConnectionProfile
- func (x *ConnectionProfile) GetProvider() DatabaseProvider
- func (x *ConnectionProfile) GetState() ConnectionProfile_State
- func (x *ConnectionProfile) GetUpdateTime() *timestamppb.Timestamp
- func (*ConnectionProfile) ProtoMessage()
- func (x *ConnectionProfile) ProtoReflect() protoreflect.Message
- func (x *ConnectionProfile) Reset()
- func (x *ConnectionProfile) String() string
- type ConnectionProfile_Cloudsql
- type ConnectionProfile_Mysql
- type ConnectionProfile_Postgresql
- type ConnectionProfile_State
- func (ConnectionProfile_State) Descriptor() protoreflect.EnumDescriptor
- func (x ConnectionProfile_State) Enum() *ConnectionProfile_State
- func (ConnectionProfile_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConnectionProfile_State) Number() protoreflect.EnumNumber
- func (x ConnectionProfile_State) String() string
- func (ConnectionProfile_State) Type() protoreflect.EnumType
- type CreateConnectionProfileRequest
- func (*CreateConnectionProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile
- func (x *CreateConnectionProfileRequest) GetConnectionProfileId() string
- func (x *CreateConnectionProfileRequest) GetParent() string
- func (x *CreateConnectionProfileRequest) GetRequestId() string
- func (*CreateConnectionProfileRequest) ProtoMessage()
- func (x *CreateConnectionProfileRequest) ProtoReflect() protoreflect.Message
- func (x *CreateConnectionProfileRequest) Reset()
- func (x *CreateConnectionProfileRequest) String() string
- type CreateMigrationJobRequest
- func (*CreateMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateMigrationJobRequest) GetMigrationJob() *MigrationJob
- func (x *CreateMigrationJobRequest) GetMigrationJobId() string
- func (x *CreateMigrationJobRequest) GetParent() string
- func (x *CreateMigrationJobRequest) GetRequestId() string
- func (*CreateMigrationJobRequest) ProtoMessage()
- func (x *CreateMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *CreateMigrationJobRequest) Reset()
- func (x *CreateMigrationJobRequest) String() string
- type DataMigrationServiceClient
- type DataMigrationServiceServer
- type DatabaseEngine
- func (DatabaseEngine) Descriptor() protoreflect.EnumDescriptor
- func (x DatabaseEngine) Enum() *DatabaseEngine
- func (DatabaseEngine) EnumDescriptor() ([]byte, []int)deprecated
- func (x DatabaseEngine) Number() protoreflect.EnumNumber
- func (x DatabaseEngine) String() string
- func (DatabaseEngine) Type() protoreflect.EnumType
- type DatabaseProvider
- func (DatabaseProvider) Descriptor() protoreflect.EnumDescriptor
- func (x DatabaseProvider) Enum() *DatabaseProvider
- func (DatabaseProvider) EnumDescriptor() ([]byte, []int)deprecated
- func (x DatabaseProvider) Number() protoreflect.EnumNumber
- func (x DatabaseProvider) String() string
- func (DatabaseProvider) Type() protoreflect.EnumType
- type DatabaseType
- func (*DatabaseType) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseType) GetEngine() DatabaseEngine
- func (x *DatabaseType) GetProvider() DatabaseProvider
- func (*DatabaseType) ProtoMessage()
- func (x *DatabaseType) ProtoReflect() protoreflect.Message
- func (x *DatabaseType) Reset()
- func (x *DatabaseType) String() string
- type DeleteConnectionProfileRequest
- func (*DeleteConnectionProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteConnectionProfileRequest) GetForce() bool
- func (x *DeleteConnectionProfileRequest) GetName() string
- func (x *DeleteConnectionProfileRequest) GetRequestId() string
- func (*DeleteConnectionProfileRequest) ProtoMessage()
- func (x *DeleteConnectionProfileRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteConnectionProfileRequest) Reset()
- func (x *DeleteConnectionProfileRequest) String() string
- type DeleteMigrationJobRequest
- func (*DeleteMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMigrationJobRequest) GetForce() bool
- func (x *DeleteMigrationJobRequest) GetName() string
- func (x *DeleteMigrationJobRequest) GetRequestId() string
- func (*DeleteMigrationJobRequest) ProtoMessage()
- func (x *DeleteMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteMigrationJobRequest) Reset()
- func (x *DeleteMigrationJobRequest) String() string
- type GenerateSshScriptRequest
- func (*GenerateSshScriptRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateSshScriptRequest) GetMigrationJob() string
- func (x *GenerateSshScriptRequest) GetVm() string
- func (m *GenerateSshScriptRequest) GetVmConfig() isGenerateSshScriptRequest_VmConfig
- func (x *GenerateSshScriptRequest) GetVmCreationConfig() *VmCreationConfig
- func (x *GenerateSshScriptRequest) GetVmPort() int32
- func (x *GenerateSshScriptRequest) GetVmSelectionConfig() *VmSelectionConfig
- func (*GenerateSshScriptRequest) ProtoMessage()
- func (x *GenerateSshScriptRequest) ProtoReflect() protoreflect.Message
- func (x *GenerateSshScriptRequest) Reset()
- func (x *GenerateSshScriptRequest) String() string
- type GenerateSshScriptRequest_VmCreationConfig
- type GenerateSshScriptRequest_VmSelectionConfig
- type GetConnectionProfileRequest
- func (*GetConnectionProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetConnectionProfileRequest) GetName() string
- func (*GetConnectionProfileRequest) ProtoMessage()
- func (x *GetConnectionProfileRequest) ProtoReflect() protoreflect.Message
- func (x *GetConnectionProfileRequest) Reset()
- func (x *GetConnectionProfileRequest) String() string
- type GetMigrationJobRequest
- func (*GetMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMigrationJobRequest) GetName() string
- func (*GetMigrationJobRequest) ProtoMessage()
- func (x *GetMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *GetMigrationJobRequest) Reset()
- func (x *GetMigrationJobRequest) String() string
- type ListConnectionProfilesRequest
- func (*ListConnectionProfilesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListConnectionProfilesRequest) GetFilter() string
- func (x *ListConnectionProfilesRequest) GetOrderBy() string
- func (x *ListConnectionProfilesRequest) GetPageSize() int32
- func (x *ListConnectionProfilesRequest) GetPageToken() string
- func (x *ListConnectionProfilesRequest) GetParent() string
- func (*ListConnectionProfilesRequest) ProtoMessage()
- func (x *ListConnectionProfilesRequest) ProtoReflect() protoreflect.Message
- func (x *ListConnectionProfilesRequest) Reset()
- func (x *ListConnectionProfilesRequest) String() string
- type ListConnectionProfilesResponse
- func (*ListConnectionProfilesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListConnectionProfilesResponse) GetConnectionProfiles() []*ConnectionProfile
- func (x *ListConnectionProfilesResponse) GetNextPageToken() string
- func (x *ListConnectionProfilesResponse) GetUnreachable() []string
- func (*ListConnectionProfilesResponse) ProtoMessage()
- func (x *ListConnectionProfilesResponse) ProtoReflect() protoreflect.Message
- func (x *ListConnectionProfilesResponse) Reset()
- func (x *ListConnectionProfilesResponse) String() string
- type ListMigrationJobsRequest
- func (*ListMigrationJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationJobsRequest) GetFilter() string
- func (x *ListMigrationJobsRequest) GetOrderBy() string
- func (x *ListMigrationJobsRequest) GetPageSize() int32
- func (x *ListMigrationJobsRequest) GetPageToken() string
- func (x *ListMigrationJobsRequest) GetParent() string
- func (*ListMigrationJobsRequest) ProtoMessage()
- func (x *ListMigrationJobsRequest) ProtoReflect() protoreflect.Message
- func (x *ListMigrationJobsRequest) Reset()
- func (x *ListMigrationJobsRequest) String() string
- type ListMigrationJobsResponse
- func (*ListMigrationJobsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMigrationJobsResponse) GetMigrationJobs() []*MigrationJob
- func (x *ListMigrationJobsResponse) GetNextPageToken() string
- func (x *ListMigrationJobsResponse) GetUnreachable() []string
- func (*ListMigrationJobsResponse) ProtoMessage()
- func (x *ListMigrationJobsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMigrationJobsResponse) Reset()
- func (x *ListMigrationJobsResponse) String() string
- type MigrationJob
- func (*MigrationJob) Descriptor() ([]byte, []int)deprecated
- func (m *MigrationJob) GetConnectivity() isMigrationJob_Connectivity
- func (x *MigrationJob) GetCreateTime() *timestamppb.Timestamp
- func (x *MigrationJob) GetDestination() string
- func (x *MigrationJob) GetDestinationDatabase() *DatabaseType
- func (x *MigrationJob) GetDisplayName() string
- func (x *MigrationJob) GetDumpPath() string
- func (x *MigrationJob) GetDuration() *durationpb.Duration
- func (x *MigrationJob) GetEndTime() *timestamppb.Timestamp
- func (x *MigrationJob) GetError() *status.Status
- func (x *MigrationJob) GetLabels() map[string]string
- func (x *MigrationJob) GetName() string
- func (x *MigrationJob) GetPhase() MigrationJob_Phase
- func (x *MigrationJob) GetReverseSshConnectivity() *ReverseSshConnectivity
- func (x *MigrationJob) GetSource() string
- func (x *MigrationJob) GetSourceDatabase() *DatabaseType
- func (x *MigrationJob) GetState() MigrationJob_State
- func (x *MigrationJob) GetStaticIpConnectivity() *StaticIpConnectivity
- func (x *MigrationJob) GetType() MigrationJob_Type
- func (x *MigrationJob) GetUpdateTime() *timestamppb.Timestamp
- func (x *MigrationJob) GetVpcPeeringConnectivity() *VpcPeeringConnectivity
- func (*MigrationJob) ProtoMessage()
- func (x *MigrationJob) ProtoReflect() protoreflect.Message
- func (x *MigrationJob) Reset()
- func (x *MigrationJob) String() string
- type MigrationJobVerificationError
- func (*MigrationJobVerificationError) Descriptor() ([]byte, []int)deprecated
- func (x *MigrationJobVerificationError) GetErrorCode() MigrationJobVerificationError_ErrorCode
- func (x *MigrationJobVerificationError) GetErrorDetailMessage() string
- func (x *MigrationJobVerificationError) GetErrorMessage() string
- func (*MigrationJobVerificationError) ProtoMessage()
- func (x *MigrationJobVerificationError) ProtoReflect() protoreflect.Message
- func (x *MigrationJobVerificationError) Reset()
- func (x *MigrationJobVerificationError) String() string
- type MigrationJobVerificationError_ErrorCode
- func (MigrationJobVerificationError_ErrorCode) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationJobVerificationError_ErrorCode) Enum() *MigrationJobVerificationError_ErrorCode
- func (MigrationJobVerificationError_ErrorCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationJobVerificationError_ErrorCode) Number() protoreflect.EnumNumber
- func (x MigrationJobVerificationError_ErrorCode) String() string
- func (MigrationJobVerificationError_ErrorCode) Type() protoreflect.EnumType
- type MigrationJob_Phase
- func (MigrationJob_Phase) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationJob_Phase) Enum() *MigrationJob_Phase
- func (MigrationJob_Phase) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationJob_Phase) Number() protoreflect.EnumNumber
- func (x MigrationJob_Phase) String() string
- func (MigrationJob_Phase) Type() protoreflect.EnumType
- type MigrationJob_ReverseSshConnectivity
- type MigrationJob_State
- func (MigrationJob_State) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationJob_State) Enum() *MigrationJob_State
- func (MigrationJob_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationJob_State) Number() protoreflect.EnumNumber
- func (x MigrationJob_State) String() string
- func (MigrationJob_State) Type() protoreflect.EnumType
- type MigrationJob_StaticIpConnectivity
- type MigrationJob_Type
- func (MigrationJob_Type) Descriptor() protoreflect.EnumDescriptor
- func (x MigrationJob_Type) Enum() *MigrationJob_Type
- func (MigrationJob_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x MigrationJob_Type) Number() protoreflect.EnumNumber
- func (x MigrationJob_Type) String() string
- func (MigrationJob_Type) Type() protoreflect.EnumType
- type MigrationJob_VpcPeeringConnectivity
- type MySqlConnectionProfile
- func (*MySqlConnectionProfile) Descriptor() ([]byte, []int)deprecated
- func (x *MySqlConnectionProfile) GetCloudSqlId() string
- func (x *MySqlConnectionProfile) GetHost() string
- func (x *MySqlConnectionProfile) GetPassword() string
- func (x *MySqlConnectionProfile) GetPasswordSet() bool
- func (x *MySqlConnectionProfile) GetPort() int32
- func (x *MySqlConnectionProfile) GetSsl() *SslConfig
- func (x *MySqlConnectionProfile) GetUsername() string
- func (*MySqlConnectionProfile) ProtoMessage()
- func (x *MySqlConnectionProfile) ProtoReflect() protoreflect.Message
- func (x *MySqlConnectionProfile) Reset()
- func (x *MySqlConnectionProfile) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type PostgreSqlConnectionProfile
- func (*PostgreSqlConnectionProfile) Descriptor() ([]byte, []int)deprecated
- func (x *PostgreSqlConnectionProfile) GetCloudSqlId() string
- func (x *PostgreSqlConnectionProfile) GetHost() string
- func (x *PostgreSqlConnectionProfile) GetPassword() string
- func (x *PostgreSqlConnectionProfile) GetPasswordSet() bool
- func (x *PostgreSqlConnectionProfile) GetPort() int32
- func (x *PostgreSqlConnectionProfile) GetSsl() *SslConfig
- func (x *PostgreSqlConnectionProfile) GetUsername() string
- func (*PostgreSqlConnectionProfile) ProtoMessage()
- func (x *PostgreSqlConnectionProfile) ProtoReflect() protoreflect.Message
- func (x *PostgreSqlConnectionProfile) Reset()
- func (x *PostgreSqlConnectionProfile) String() string
- type PromoteMigrationJobRequest
- func (*PromoteMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PromoteMigrationJobRequest) GetName() string
- func (*PromoteMigrationJobRequest) ProtoMessage()
- func (x *PromoteMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *PromoteMigrationJobRequest) Reset()
- func (x *PromoteMigrationJobRequest) String() string
- type RestartMigrationJobRequest
- func (*RestartMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestartMigrationJobRequest) GetName() string
- func (*RestartMigrationJobRequest) ProtoMessage()
- func (x *RestartMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *RestartMigrationJobRequest) Reset()
- func (x *RestartMigrationJobRequest) String() string
- type ResumeMigrationJobRequest
- func (*ResumeMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeMigrationJobRequest) GetName() string
- func (*ResumeMigrationJobRequest) ProtoMessage()
- func (x *ResumeMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeMigrationJobRequest) Reset()
- func (x *ResumeMigrationJobRequest) String() string
- type ReverseSshConnectivity
- func (*ReverseSshConnectivity) Descriptor() ([]byte, []int)deprecated
- func (x *ReverseSshConnectivity) GetVm() string
- func (x *ReverseSshConnectivity) GetVmIp() string
- func (x *ReverseSshConnectivity) GetVmPort() int32
- func (x *ReverseSshConnectivity) GetVpc() string
- func (*ReverseSshConnectivity) ProtoMessage()
- func (x *ReverseSshConnectivity) ProtoReflect() protoreflect.Message
- func (x *ReverseSshConnectivity) Reset()
- func (x *ReverseSshConnectivity) String() string
- type SqlAclEntry
- func (*SqlAclEntry) Descriptor() ([]byte, []int)deprecated
- func (m *SqlAclEntry) GetExpiration() isSqlAclEntry_Expiration
- func (x *SqlAclEntry) GetExpireTime() *timestamppb.Timestamp
- func (x *SqlAclEntry) GetLabel() string
- func (x *SqlAclEntry) GetTtl() *durationpb.Duration
- func (x *SqlAclEntry) GetValue() string
- func (*SqlAclEntry) ProtoMessage()
- func (x *SqlAclEntry) ProtoReflect() protoreflect.Message
- func (x *SqlAclEntry) Reset()
- func (x *SqlAclEntry) String() string
- type SqlAclEntry_ExpireTime
- type SqlAclEntry_Ttl
- type SqlIpConfig
- func (*SqlIpConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SqlIpConfig) GetAuthorizedNetworks() []*SqlAclEntry
- func (x *SqlIpConfig) GetEnableIpv4() *wrapperspb.BoolValue
- func (x *SqlIpConfig) GetPrivateNetwork() string
- func (x *SqlIpConfig) GetRequireSsl() *wrapperspb.BoolValue
- func (*SqlIpConfig) ProtoMessage()
- func (x *SqlIpConfig) ProtoReflect() protoreflect.Message
- func (x *SqlIpConfig) Reset()
- func (x *SqlIpConfig) String() string
- type SshScript
- type SslConfig
- func (*SslConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SslConfig) GetCaCertificate() string
- func (x *SslConfig) GetClientCertificate() string
- func (x *SslConfig) GetClientKey() string
- func (x *SslConfig) GetType() SslConfig_SslType
- func (*SslConfig) ProtoMessage()
- func (x *SslConfig) ProtoReflect() protoreflect.Message
- func (x *SslConfig) Reset()
- func (x *SslConfig) String() string
- type SslConfig_SslType
- func (SslConfig_SslType) Descriptor() protoreflect.EnumDescriptor
- func (x SslConfig_SslType) Enum() *SslConfig_SslType
- func (SslConfig_SslType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SslConfig_SslType) Number() protoreflect.EnumNumber
- func (x SslConfig_SslType) String() string
- func (SslConfig_SslType) Type() protoreflect.EnumType
- type StartMigrationJobRequest
- func (*StartMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartMigrationJobRequest) GetName() string
- func (*StartMigrationJobRequest) ProtoMessage()
- func (x *StartMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *StartMigrationJobRequest) Reset()
- func (x *StartMigrationJobRequest) String() string
- type StaticIpConnectivity
- type StopMigrationJobRequest
- func (*StopMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopMigrationJobRequest) GetName() string
- func (*StopMigrationJobRequest) ProtoMessage()
- func (x *StopMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *StopMigrationJobRequest) Reset()
- func (x *StopMigrationJobRequest) String() string
- type UnimplementedDataMigrationServiceServer
- func (*UnimplementedDataMigrationServiceServer) CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) CreateMigrationJob(context.Context, *CreateMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) DeleteMigrationJob(context.Context, *DeleteMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) GenerateSshScript(context.Context, *GenerateSshScriptRequest) (*SshScript, error)
- func (*UnimplementedDataMigrationServiceServer) GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)
- func (*UnimplementedDataMigrationServiceServer) GetMigrationJob(context.Context, *GetMigrationJobRequest) (*MigrationJob, error)
- func (*UnimplementedDataMigrationServiceServer) ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)
- func (*UnimplementedDataMigrationServiceServer) ListMigrationJobs(context.Context, *ListMigrationJobsRequest) (*ListMigrationJobsResponse, error)
- func (*UnimplementedDataMigrationServiceServer) PromoteMigrationJob(context.Context, *PromoteMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) RestartMigrationJob(context.Context, *RestartMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) ResumeMigrationJob(context.Context, *ResumeMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) StartMigrationJob(context.Context, *StartMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) StopMigrationJob(context.Context, *StopMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) UpdateMigrationJob(context.Context, *UpdateMigrationJobRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataMigrationServiceServer) VerifyMigrationJob(context.Context, *VerifyMigrationJobRequest) (*longrunning.Operation, error)
- type UpdateConnectionProfileRequest
- func (*UpdateConnectionProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile
- func (x *UpdateConnectionProfileRequest) GetRequestId() string
- func (x *UpdateConnectionProfileRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateConnectionProfileRequest) ProtoMessage()
- func (x *UpdateConnectionProfileRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateConnectionProfileRequest) Reset()
- func (x *UpdateConnectionProfileRequest) String() string
- type UpdateMigrationJobRequest
- func (*UpdateMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMigrationJobRequest) GetMigrationJob() *MigrationJob
- func (x *UpdateMigrationJobRequest) GetRequestId() string
- func (x *UpdateMigrationJobRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateMigrationJobRequest) ProtoMessage()
- func (x *UpdateMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMigrationJobRequest) Reset()
- func (x *UpdateMigrationJobRequest) String() string
- type VerifyMigrationJobRequest
- func (*VerifyMigrationJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VerifyMigrationJobRequest) GetName() string
- func (*VerifyMigrationJobRequest) ProtoMessage()
- func (x *VerifyMigrationJobRequest) ProtoReflect() protoreflect.Message
- func (x *VerifyMigrationJobRequest) Reset()
- func (x *VerifyMigrationJobRequest) String() string
- type VmCreationConfig
- func (*VmCreationConfig) Descriptor() ([]byte, []int)deprecated
- func (x *VmCreationConfig) GetSubnet() string
- func (x *VmCreationConfig) GetVmMachineType() string
- func (x *VmCreationConfig) GetVmZone() string
- func (*VmCreationConfig) ProtoMessage()
- func (x *VmCreationConfig) ProtoReflect() protoreflect.Message
- func (x *VmCreationConfig) Reset()
- func (x *VmCreationConfig) String() string
- type VmSelectionConfig
- type VpcPeeringConnectivity
- func (*VpcPeeringConnectivity) Descriptor() ([]byte, []int)deprecated
- func (x *VpcPeeringConnectivity) GetVpc() string
- func (*VpcPeeringConnectivity) ProtoMessage()
- func (x *VpcPeeringConnectivity) ProtoReflect() protoreflect.Message
- func (x *VpcPeeringConnectivity) Reset()
- func (x *VpcPeeringConnectivity) String() string
Constants ¶
This section is empty.
Variables ¶
var ( DatabaseEngine_name = map[int32]string{ 0: "DATABASE_ENGINE_UNSPECIFIED", 1: "MYSQL", 2: "POSTGRESQL", } DatabaseEngine_value = map[string]int32{ "DATABASE_ENGINE_UNSPECIFIED": 0, "MYSQL": 1, "POSTGRESQL": 2, } )
Enum value maps for DatabaseEngine.
var ( DatabaseProvider_name = map[int32]string{ 0: "DATABASE_PROVIDER_UNSPECIFIED", 1: "CLOUDSQL", 2: "RDS", } DatabaseProvider_value = map[string]int32{ "DATABASE_PROVIDER_UNSPECIFIED": 0, "CLOUDSQL": 1, "RDS": 2, } )
Enum value maps for DatabaseProvider.
var ( SslConfig_SslType_name = map[int32]string{ 0: "SSL_TYPE_UNSPECIFIED", 1: "SERVER_ONLY", 2: "SERVER_CLIENT", } SslConfig_SslType_value = map[string]int32{ "SSL_TYPE_UNSPECIFIED": 0, "SERVER_ONLY": 1, "SERVER_CLIENT": 2, } )
Enum value maps for SslConfig_SslType.
var ( CloudSqlSettings_SqlActivationPolicy_name = map[int32]string{ 0: "SQL_ACTIVATION_POLICY_UNSPECIFIED", 1: "ALWAYS", 2: "NEVER", } CloudSqlSettings_SqlActivationPolicy_value = map[string]int32{ "SQL_ACTIVATION_POLICY_UNSPECIFIED": 0, "ALWAYS": 1, "NEVER": 2, } )
Enum value maps for CloudSqlSettings_SqlActivationPolicy.
var ( CloudSqlSettings_SqlDataDiskType_name = map[int32]string{ 0: "SQL_DATA_DISK_TYPE_UNSPECIFIED", 1: "PD_SSD", 2: "PD_HDD", } CloudSqlSettings_SqlDataDiskType_value = map[string]int32{ "SQL_DATA_DISK_TYPE_UNSPECIFIED": 0, "PD_SSD": 1, "PD_HDD": 2, } )
Enum value maps for CloudSqlSettings_SqlDataDiskType.
var ( CloudSqlSettings_SqlDatabaseVersion_name = map[int32]string{ 0: "SQL_DATABASE_VERSION_UNSPECIFIED", 1: "MYSQL_5_6", 2: "MYSQL_5_7", 3: "POSTGRES_9_6", 4: "POSTGRES_11", 5: "POSTGRES_10", 6: "MYSQL_8_0", 7: "POSTGRES_12", 8: "POSTGRES_13", } CloudSqlSettings_SqlDatabaseVersion_value = map[string]int32{ "SQL_DATABASE_VERSION_UNSPECIFIED": 0, "MYSQL_5_6": 1, "MYSQL_5_7": 2, "POSTGRES_9_6": 3, "POSTGRES_11": 4, "POSTGRES_10": 5, "MYSQL_8_0": 6, "POSTGRES_12": 7, "POSTGRES_13": 8, } )
Enum value maps for CloudSqlSettings_SqlDatabaseVersion.
var ( MigrationJob_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "MAINTENANCE", 2: "DRAFT", 3: "CREATING", 4: "NOT_STARTED", 5: "RUNNING", 6: "FAILED", 7: "COMPLETED", 8: "DELETING", 9: "STOPPING", 10: "STOPPED", 11: "DELETED", 12: "UPDATING", 13: "STARTING", 14: "RESTARTING", 15: "RESUMING", } MigrationJob_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "MAINTENANCE": 1, "DRAFT": 2, "CREATING": 3, "NOT_STARTED": 4, "RUNNING": 5, "FAILED": 6, "COMPLETED": 7, "DELETING": 8, "STOPPING": 9, "STOPPED": 10, "DELETED": 11, "UPDATING": 12, "STARTING": 13, "RESTARTING": 14, "RESUMING": 15, } )
Enum value maps for MigrationJob_State.
var ( MigrationJob_Phase_name = map[int32]string{ 0: "PHASE_UNSPECIFIED", 1: "FULL_DUMP", 2: "CDC", 3: "PROMOTE_IN_PROGRESS", 4: "WAITING_FOR_SOURCE_WRITES_TO_STOP", 5: "PREPARING_THE_DUMP", } MigrationJob_Phase_value = map[string]int32{ "PHASE_UNSPECIFIED": 0, "FULL_DUMP": 1, "CDC": 2, "PROMOTE_IN_PROGRESS": 3, "WAITING_FOR_SOURCE_WRITES_TO_STOP": 4, "PREPARING_THE_DUMP": 5, } )
Enum value maps for MigrationJob_Phase.
var ( MigrationJob_Type_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "ONE_TIME", 2: "CONTINUOUS", } MigrationJob_Type_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "ONE_TIME": 1, "CONTINUOUS": 2, } )
Enum value maps for MigrationJob_Type.
var ( ConnectionProfile_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "DRAFT", 2: "CREATING", 3: "READY", 4: "UPDATING", 5: "DELETING", 6: "DELETED", 7: "FAILED", } ConnectionProfile_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "DRAFT": 1, "CREATING": 2, "READY": 3, "UPDATING": 4, "DELETING": 5, "DELETED": 6, "FAILED": 7, } )
Enum value maps for ConnectionProfile_State.
var ( MigrationJobVerificationError_ErrorCode_name = map[int32]string{ 0: "ERROR_CODE_UNSPECIFIED", 1: "CONNECTION_FAILURE", 2: "AUTHENTICATION_FAILURE", 3: "INVALID_CONNECTION_PROFILE_CONFIG", 4: "VERSION_INCOMPATIBILITY", 5: "CONNECTION_PROFILE_TYPES_INCOMPATIBILITY", 7: "NO_PGLOGICAL_INSTALLED", 8: "PGLOGICAL_NODE_ALREADY_EXISTS", 9: "INVALID_WAL_LEVEL", 10: "INVALID_SHARED_PRELOAD_LIBRARY", 11: "INSUFFICIENT_MAX_REPLICATION_SLOTS", 12: "INSUFFICIENT_MAX_WAL_SENDERS", 13: "INSUFFICIENT_MAX_WORKER_PROCESSES", 14: "UNSUPPORTED_EXTENSIONS", 15: "UNSUPPORTED_MIGRATION_TYPE", 16: "INVALID_RDS_LOGICAL_REPLICATION", 17: "UNSUPPORTED_GTID_MODE", 18: "UNSUPPORTED_TABLE_DEFINITION", 19: "UNSUPPORTED_DEFINER", 21: "CANT_RESTART_RUNNING_MIGRATION", } MigrationJobVerificationError_ErrorCode_value = map[string]int32{ "ERROR_CODE_UNSPECIFIED": 0, "CONNECTION_FAILURE": 1, "AUTHENTICATION_FAILURE": 2, "INVALID_CONNECTION_PROFILE_CONFIG": 3, "VERSION_INCOMPATIBILITY": 4, "CONNECTION_PROFILE_TYPES_INCOMPATIBILITY": 5, "NO_PGLOGICAL_INSTALLED": 7, "PGLOGICAL_NODE_ALREADY_EXISTS": 8, "INVALID_WAL_LEVEL": 9, "INVALID_SHARED_PRELOAD_LIBRARY": 10, "INSUFFICIENT_MAX_REPLICATION_SLOTS": 11, "INSUFFICIENT_MAX_WAL_SENDERS": 12, "INSUFFICIENT_MAX_WORKER_PROCESSES": 13, "UNSUPPORTED_EXTENSIONS": 14, "UNSUPPORTED_MIGRATION_TYPE": 15, "INVALID_RDS_LOGICAL_REPLICATION": 16, "UNSUPPORTED_GTID_MODE": 17, "UNSUPPORTED_TABLE_DEFINITION": 18, "UNSUPPORTED_DEFINER": 19, "CANT_RESTART_RUNNING_MIGRATION": 21, } )
Enum value maps for MigrationJobVerificationError_ErrorCode.
var File_google_cloud_clouddms_v1_clouddms_proto protoreflect.FileDescriptor
var File_google_cloud_clouddms_v1_clouddms_resources_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataMigrationServiceServer ¶
func RegisterDataMigrationServiceServer(s *grpc.Server, srv DataMigrationServiceServer)
Types ¶
type CloudSqlConnectionProfile ¶
type CloudSqlConnectionProfile struct { // Output only. The Cloud SQL instance ID that this connection profile is associated with. CloudSqlId string `protobuf:"bytes,1,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"` // Immutable. Metadata used to create the destination Cloud SQL database. Settings *CloudSqlSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"` // Output only. The Cloud SQL database instance's private IP. PrivateIp string `protobuf:"bytes,3,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty"` // Output only. The Cloud SQL database instance's public IP. PublicIp string `protobuf:"bytes,4,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"` // contains filtered or unexported fields }
Specifies required connection parameters, and, optionally, the parameters required to create a Cloud SQL destination database instance.
func (*CloudSqlConnectionProfile) Descriptor
deprecated
func (*CloudSqlConnectionProfile) Descriptor() ([]byte, []int)
Deprecated: Use CloudSqlConnectionProfile.ProtoReflect.Descriptor instead.
func (*CloudSqlConnectionProfile) GetCloudSqlId ¶
func (x *CloudSqlConnectionProfile) GetCloudSqlId() string
func (*CloudSqlConnectionProfile) GetPrivateIp ¶
func (x *CloudSqlConnectionProfile) GetPrivateIp() string
func (*CloudSqlConnectionProfile) GetPublicIp ¶
func (x *CloudSqlConnectionProfile) GetPublicIp() string
func (*CloudSqlConnectionProfile) GetSettings ¶
func (x *CloudSqlConnectionProfile) GetSettings() *CloudSqlSettings
func (*CloudSqlConnectionProfile) ProtoMessage ¶
func (*CloudSqlConnectionProfile) ProtoMessage()
func (*CloudSqlConnectionProfile) ProtoReflect ¶
func (x *CloudSqlConnectionProfile) ProtoReflect() protoreflect.Message
func (*CloudSqlConnectionProfile) Reset ¶
func (x *CloudSqlConnectionProfile) Reset()
func (*CloudSqlConnectionProfile) String ¶
func (x *CloudSqlConnectionProfile) String() string
type CloudSqlSettings ¶
type CloudSqlSettings struct { // The database engine type and version. DatabaseVersion CloudSqlSettings_SqlDatabaseVersion `` /* 173-byte string literal not displayed */ // The resource labels for a Cloud SQL instance to use to annotate any related // underlying resources such as Compute Engine VMs. // An object containing a list of "key": "value" pairs. // // Example: `{ "name": "wrench", "mass": "18kg", "count": "3" }`. UserLabels map[string]string `` /* 179-byte string literal not displayed */ // The tier (or machine type) for this instance, for example: // `db-n1-standard-1` (MySQL instances) or // `db-custom-1-3840` (PostgreSQL instances). // For more information, see // [Cloud SQL Instance // Settings](https://cloud.google.com/sql/docs/mysql/instance-settings). Tier string `protobuf:"bytes,3,opt,name=tier,proto3" json:"tier,omitempty"` // The maximum size to which storage capacity can be automatically increased. // The default value is 0, which specifies that there is no limit. StorageAutoResizeLimit *wrapperspb.Int64Value `` /* 131-byte string literal not displayed */ // The activation policy specifies when the instance is activated; it is // applicable only when the instance state is 'RUNNABLE'. Valid values: // // 'ALWAYS': The instance is on, and remains so even in // the absence of connection requests. // // `NEVER`: The instance is off; it is not activated, even if a // connection request arrives. ActivationPolicy CloudSqlSettings_SqlActivationPolicy `` /* 177-byte string literal not displayed */ // The settings for IP Management. This allows to enable or disable the // instance IP and manage which external networks can connect to the instance. // The IPv4 address cannot be disabled. IpConfig *SqlIpConfig `protobuf:"bytes,6,opt,name=ip_config,json=ipConfig,proto3" json:"ip_config,omitempty"` // [default: ON] If you enable this setting, Cloud SQL checks your available // storage every 30 seconds. If the available storage falls below a threshold // size, Cloud SQL automatically adds additional storage capacity. If the // available storage repeatedly falls below the threshold size, Cloud SQL // continues to add storage until it reaches the maximum of 30 TB. AutoStorageIncrease *wrapperspb.BoolValue `protobuf:"bytes,7,opt,name=auto_storage_increase,json=autoStorageIncrease,proto3" json:"auto_storage_increase,omitempty"` // The database flags passed to the Cloud SQL instance at startup. // An object containing a list of "key": value pairs. // Example: { "name": "wrench", "mass": "1.3kg", "count": "3" }. DatabaseFlags map[string]string `` /* 188-byte string literal not displayed */ // The type of storage: `PD_SSD` (default) or `PD_HDD`. DataDiskType CloudSqlSettings_SqlDataDiskType `` /* 163-byte string literal not displayed */ // The storage capacity available to the database, in GB. // The minimum (and default) size is 10GB. DataDiskSizeGb *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=data_disk_size_gb,json=dataDiskSizeGb,proto3" json:"data_disk_size_gb,omitempty"` // The Google Cloud Platform zone where your Cloud SQL datdabse instance is // located. Zone string `protobuf:"bytes,11,opt,name=zone,proto3" json:"zone,omitempty"` // The Database Migration Service source connection profile ID, // in the format: // `projects/my_project_name/locations/us-central1/connectionProfiles/connection_profile_ID` SourceId string `protobuf:"bytes,12,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` // Input only. Initial root password. RootPassword string `protobuf:"bytes,13,opt,name=root_password,json=rootPassword,proto3" json:"root_password,omitempty"` // Output only. Indicates If this connection profile root password is stored. RootPasswordSet bool `protobuf:"varint,14,opt,name=root_password_set,json=rootPasswordSet,proto3" json:"root_password_set,omitempty"` // The Cloud SQL default instance level collation. Collation string `protobuf:"bytes,15,opt,name=collation,proto3" json:"collation,omitempty"` // contains filtered or unexported fields }
Settings for creating a Cloud SQL database instance.
func (*CloudSqlSettings) Descriptor
deprecated
func (*CloudSqlSettings) Descriptor() ([]byte, []int)
Deprecated: Use CloudSqlSettings.ProtoReflect.Descriptor instead.
func (*CloudSqlSettings) GetActivationPolicy ¶
func (x *CloudSqlSettings) GetActivationPolicy() CloudSqlSettings_SqlActivationPolicy
func (*CloudSqlSettings) GetAutoStorageIncrease ¶
func (x *CloudSqlSettings) GetAutoStorageIncrease() *wrapperspb.BoolValue
func (*CloudSqlSettings) GetCollation ¶
func (x *CloudSqlSettings) GetCollation() string
func (*CloudSqlSettings) GetDataDiskSizeGb ¶
func (x *CloudSqlSettings) GetDataDiskSizeGb() *wrapperspb.Int64Value
func (*CloudSqlSettings) GetDataDiskType ¶
func (x *CloudSqlSettings) GetDataDiskType() CloudSqlSettings_SqlDataDiskType
func (*CloudSqlSettings) GetDatabaseFlags ¶
func (x *CloudSqlSettings) GetDatabaseFlags() map[string]string
func (*CloudSqlSettings) GetDatabaseVersion ¶
func (x *CloudSqlSettings) GetDatabaseVersion() CloudSqlSettings_SqlDatabaseVersion
func (*CloudSqlSettings) GetIpConfig ¶
func (x *CloudSqlSettings) GetIpConfig() *SqlIpConfig
func (*CloudSqlSettings) GetRootPassword ¶
func (x *CloudSqlSettings) GetRootPassword() string
func (*CloudSqlSettings) GetRootPasswordSet ¶
func (x *CloudSqlSettings) GetRootPasswordSet() bool
func (*CloudSqlSettings) GetSourceId ¶
func (x *CloudSqlSettings) GetSourceId() string
func (*CloudSqlSettings) GetStorageAutoResizeLimit ¶
func (x *CloudSqlSettings) GetStorageAutoResizeLimit() *wrapperspb.Int64Value
func (*CloudSqlSettings) GetTier ¶
func (x *CloudSqlSettings) GetTier() string
func (*CloudSqlSettings) GetUserLabels ¶
func (x *CloudSqlSettings) GetUserLabels() map[string]string
func (*CloudSqlSettings) GetZone ¶
func (x *CloudSqlSettings) GetZone() string
func (*CloudSqlSettings) ProtoMessage ¶
func (*CloudSqlSettings) ProtoMessage()
func (*CloudSqlSettings) ProtoReflect ¶
func (x *CloudSqlSettings) ProtoReflect() protoreflect.Message
func (*CloudSqlSettings) Reset ¶
func (x *CloudSqlSettings) Reset()
func (*CloudSqlSettings) String ¶
func (x *CloudSqlSettings) String() string
type CloudSqlSettings_SqlActivationPolicy ¶
type CloudSqlSettings_SqlActivationPolicy int32
Specifies when the instance should be activated.
const ( // unspecified policy. CloudSqlSettings_SQL_ACTIVATION_POLICY_UNSPECIFIED CloudSqlSettings_SqlActivationPolicy = 0 // The instance is always up and running. CloudSqlSettings_ALWAYS CloudSqlSettings_SqlActivationPolicy = 1 // The instance should never spin up. CloudSqlSettings_NEVER CloudSqlSettings_SqlActivationPolicy = 2 )
func (CloudSqlSettings_SqlActivationPolicy) Descriptor ¶
func (CloudSqlSettings_SqlActivationPolicy) Descriptor() protoreflect.EnumDescriptor
func (CloudSqlSettings_SqlActivationPolicy) Enum ¶
func (x CloudSqlSettings_SqlActivationPolicy) Enum() *CloudSqlSettings_SqlActivationPolicy
func (CloudSqlSettings_SqlActivationPolicy) EnumDescriptor
deprecated
func (CloudSqlSettings_SqlActivationPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use CloudSqlSettings_SqlActivationPolicy.Descriptor instead.
func (CloudSqlSettings_SqlActivationPolicy) Number ¶
func (x CloudSqlSettings_SqlActivationPolicy) Number() protoreflect.EnumNumber
func (CloudSqlSettings_SqlActivationPolicy) String ¶
func (x CloudSqlSettings_SqlActivationPolicy) String() string
func (CloudSqlSettings_SqlActivationPolicy) Type ¶
func (CloudSqlSettings_SqlActivationPolicy) Type() protoreflect.EnumType
type CloudSqlSettings_SqlDataDiskType ¶
type CloudSqlSettings_SqlDataDiskType int32
The storage options for Cloud SQL databases.
const ( // Unspecified. CloudSqlSettings_SQL_DATA_DISK_TYPE_UNSPECIFIED CloudSqlSettings_SqlDataDiskType = 0 // SSD disk. CloudSqlSettings_PD_SSD CloudSqlSettings_SqlDataDiskType = 1 // HDD disk. CloudSqlSettings_PD_HDD CloudSqlSettings_SqlDataDiskType = 2 )
func (CloudSqlSettings_SqlDataDiskType) Descriptor ¶
func (CloudSqlSettings_SqlDataDiskType) Descriptor() protoreflect.EnumDescriptor
func (CloudSqlSettings_SqlDataDiskType) Enum ¶
func (x CloudSqlSettings_SqlDataDiskType) Enum() *CloudSqlSettings_SqlDataDiskType
func (CloudSqlSettings_SqlDataDiskType) EnumDescriptor
deprecated
func (CloudSqlSettings_SqlDataDiskType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CloudSqlSettings_SqlDataDiskType.Descriptor instead.
func (CloudSqlSettings_SqlDataDiskType) Number ¶
func (x CloudSqlSettings_SqlDataDiskType) Number() protoreflect.EnumNumber
func (CloudSqlSettings_SqlDataDiskType) String ¶
func (x CloudSqlSettings_SqlDataDiskType) String() string
func (CloudSqlSettings_SqlDataDiskType) Type ¶
func (CloudSqlSettings_SqlDataDiskType) Type() protoreflect.EnumType
type CloudSqlSettings_SqlDatabaseVersion ¶
type CloudSqlSettings_SqlDatabaseVersion int32
The database engine type and version.
const ( // Unspecified version. CloudSqlSettings_SQL_DATABASE_VERSION_UNSPECIFIED CloudSqlSettings_SqlDatabaseVersion = 0 // MySQL 5.6. CloudSqlSettings_MYSQL_5_6 CloudSqlSettings_SqlDatabaseVersion = 1 // MySQL 5.7. CloudSqlSettings_MYSQL_5_7 CloudSqlSettings_SqlDatabaseVersion = 2 // PostgreSQL 9.6. CloudSqlSettings_POSTGRES_9_6 CloudSqlSettings_SqlDatabaseVersion = 3 // PostgreSQL 11. CloudSqlSettings_POSTGRES_11 CloudSqlSettings_SqlDatabaseVersion = 4 // PostgreSQL 10. CloudSqlSettings_POSTGRES_10 CloudSqlSettings_SqlDatabaseVersion = 5 // MySQL 8.0. CloudSqlSettings_MYSQL_8_0 CloudSqlSettings_SqlDatabaseVersion = 6 // PostgreSQL 12. CloudSqlSettings_POSTGRES_12 CloudSqlSettings_SqlDatabaseVersion = 7 // PostgreSQL 13. CloudSqlSettings_POSTGRES_13 CloudSqlSettings_SqlDatabaseVersion = 8 )
func (CloudSqlSettings_SqlDatabaseVersion) Descriptor ¶
func (CloudSqlSettings_SqlDatabaseVersion) Descriptor() protoreflect.EnumDescriptor
func (CloudSqlSettings_SqlDatabaseVersion) Enum ¶
func (x CloudSqlSettings_SqlDatabaseVersion) Enum() *CloudSqlSettings_SqlDatabaseVersion
func (CloudSqlSettings_SqlDatabaseVersion) EnumDescriptor
deprecated
func (CloudSqlSettings_SqlDatabaseVersion) EnumDescriptor() ([]byte, []int)
Deprecated: Use CloudSqlSettings_SqlDatabaseVersion.Descriptor instead.
func (CloudSqlSettings_SqlDatabaseVersion) Number ¶
func (x CloudSqlSettings_SqlDatabaseVersion) Number() protoreflect.EnumNumber
func (CloudSqlSettings_SqlDatabaseVersion) String ¶
func (x CloudSqlSettings_SqlDatabaseVersion) String() string
func (CloudSqlSettings_SqlDatabaseVersion) Type ¶
func (CloudSqlSettings_SqlDatabaseVersion) Type() protoreflect.EnumType
type ConnectionProfile ¶
type ConnectionProfile struct { // The name of this connection profile resource in the form of // projects/{project}/locations/{location}/instances/{instance}. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. The timestamp when the resource was created. // A timestamp in RFC3339 UTC "Zulu" format, accurate to nanoseconds. // Example: "2014-10-02T15:01:23.045123456Z". CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The timestamp when the resource was last updated. // A timestamp in RFC3339 UTC "Zulu" format, accurate to nanoseconds. // Example: "2014-10-02T15:01:23.045123456Z". UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // The resource labels for connection profile to use to annotate any related // underlying resources such as Compute Engine VMs. An object containing a // list of "key": "value" pairs. // // Example: `{ "name": "wrench", "mass": "1.3kg", "count": "3" }`. Labels map[string]string `` /* 153-byte string literal not displayed */ // The current connection profile state (e.g. DRAFT, READY, or FAILED). State ConnectionProfile_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.clouddms.v1.ConnectionProfile_State" json:"state,omitempty"` // The connection profile display name. DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` // The connection profile definition. // // Types that are assignable to ConnectionProfile: // *ConnectionProfile_Mysql // *ConnectionProfile_Postgresql // *ConnectionProfile_Cloudsql ConnectionProfile isConnectionProfile_ConnectionProfile `protobuf_oneof:"connection_profile"` // Output only. The error details in case of state FAILED. Error *status.Status `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"` // The database provider. Provider DatabaseProvider `protobuf:"varint,8,opt,name=provider,proto3,enum=google.cloud.clouddms.v1.DatabaseProvider" json:"provider,omitempty"` // contains filtered or unexported fields }
A connection profile definition.
func (*ConnectionProfile) Descriptor
deprecated
func (*ConnectionProfile) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionProfile.ProtoReflect.Descriptor instead.
func (*ConnectionProfile) GetCloudsql ¶
func (x *ConnectionProfile) GetCloudsql() *CloudSqlConnectionProfile
func (*ConnectionProfile) GetConnectionProfile ¶
func (m *ConnectionProfile) GetConnectionProfile() isConnectionProfile_ConnectionProfile
func (*ConnectionProfile) GetCreateTime ¶
func (x *ConnectionProfile) GetCreateTime() *timestamppb.Timestamp
func (*ConnectionProfile) GetDisplayName ¶
func (x *ConnectionProfile) GetDisplayName() string
func (*ConnectionProfile) GetError ¶
func (x *ConnectionProfile) GetError() *status.Status
func (*ConnectionProfile) GetLabels ¶
func (x *ConnectionProfile) GetLabels() map[string]string
func (*ConnectionProfile) GetMysql ¶
func (x *ConnectionProfile) GetMysql() *MySqlConnectionProfile
func (*ConnectionProfile) GetName ¶
func (x *ConnectionProfile) GetName() string
func (*ConnectionProfile) GetPostgresql ¶
func (x *ConnectionProfile) GetPostgresql() *PostgreSqlConnectionProfile
func (*ConnectionProfile) GetProvider ¶
func (x *ConnectionProfile) GetProvider() DatabaseProvider
func (*ConnectionProfile) GetState ¶
func (x *ConnectionProfile) GetState() ConnectionProfile_State
func (*ConnectionProfile) GetUpdateTime ¶
func (x *ConnectionProfile) GetUpdateTime() *timestamppb.Timestamp
func (*ConnectionProfile) ProtoMessage ¶
func (*ConnectionProfile) ProtoMessage()
func (*ConnectionProfile) ProtoReflect ¶
func (x *ConnectionProfile) ProtoReflect() protoreflect.Message
func (*ConnectionProfile) Reset ¶
func (x *ConnectionProfile) Reset()
func (*ConnectionProfile) String ¶
func (x *ConnectionProfile) String() string
type ConnectionProfile_Cloudsql ¶
type ConnectionProfile_Cloudsql struct { // A CloudSQL database connection profile. Cloudsql *CloudSqlConnectionProfile `protobuf:"bytes,102,opt,name=cloudsql,proto3,oneof"` }
type ConnectionProfile_Mysql ¶
type ConnectionProfile_Mysql struct { // A MySQL database connection profile. Mysql *MySqlConnectionProfile `protobuf:"bytes,100,opt,name=mysql,proto3,oneof"` }
type ConnectionProfile_Postgresql ¶
type ConnectionProfile_Postgresql struct { // A PostgreSQL database connection profile. Postgresql *PostgreSqlConnectionProfile `protobuf:"bytes,101,opt,name=postgresql,proto3,oneof"` }
type ConnectionProfile_State ¶
type ConnectionProfile_State int32
The current connection profile state (e.g. DRAFT, READY, or FAILED).
const ( // The state of the connection profile is unknown. ConnectionProfile_STATE_UNSPECIFIED ConnectionProfile_State = 0 // The connection profile is in draft mode and fully editable. ConnectionProfile_DRAFT ConnectionProfile_State = 1 // The connection profile is being created. ConnectionProfile_CREATING ConnectionProfile_State = 2 // The connection profile is ready. ConnectionProfile_READY ConnectionProfile_State = 3 // The connection profile is being updated. ConnectionProfile_UPDATING ConnectionProfile_State = 4 // The connection profile is being deleted. ConnectionProfile_DELETING ConnectionProfile_State = 5 // The connection profile has been deleted. ConnectionProfile_DELETED ConnectionProfile_State = 6 // The last action on the connection profile failed. ConnectionProfile_FAILED ConnectionProfile_State = 7 )
func (ConnectionProfile_State) Descriptor ¶
func (ConnectionProfile_State) Descriptor() protoreflect.EnumDescriptor
func (ConnectionProfile_State) Enum ¶
func (x ConnectionProfile_State) Enum() *ConnectionProfile_State
func (ConnectionProfile_State) EnumDescriptor
deprecated
func (ConnectionProfile_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConnectionProfile_State.Descriptor instead.
func (ConnectionProfile_State) Number ¶
func (x ConnectionProfile_State) Number() protoreflect.EnumNumber
func (ConnectionProfile_State) String ¶
func (x ConnectionProfile_State) String() string
func (ConnectionProfile_State) Type ¶
func (ConnectionProfile_State) Type() protoreflect.EnumType
type CreateConnectionProfileRequest ¶
type CreateConnectionProfileRequest struct { // Required. The parent, which owns this collection of connection profiles. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The connection profile identifier. ConnectionProfileId string `protobuf:"bytes,2,opt,name=connection_profile_id,json=connectionProfileId,proto3" json:"connection_profile_id,omitempty"` // Required. The create request body including the connection profile data ConnectionProfile *ConnectionProfile `protobuf:"bytes,3,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for 'CreateConnectionProfile' request.
func (*CreateConnectionProfileRequest) Descriptor
deprecated
func (*CreateConnectionProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*CreateConnectionProfileRequest) GetConnectionProfile ¶
func (x *CreateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile
func (*CreateConnectionProfileRequest) GetConnectionProfileId ¶
func (x *CreateConnectionProfileRequest) GetConnectionProfileId() string
func (*CreateConnectionProfileRequest) GetParent ¶
func (x *CreateConnectionProfileRequest) GetParent() string
func (*CreateConnectionProfileRequest) GetRequestId ¶
func (x *CreateConnectionProfileRequest) GetRequestId() string
func (*CreateConnectionProfileRequest) ProtoMessage ¶
func (*CreateConnectionProfileRequest) ProtoMessage()
func (*CreateConnectionProfileRequest) ProtoReflect ¶
func (x *CreateConnectionProfileRequest) ProtoReflect() protoreflect.Message
func (*CreateConnectionProfileRequest) Reset ¶
func (x *CreateConnectionProfileRequest) Reset()
func (*CreateConnectionProfileRequest) String ¶
func (x *CreateConnectionProfileRequest) String() string
type CreateMigrationJobRequest ¶
type CreateMigrationJobRequest struct { // Required. The parent, which owns this collection of migration jobs. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The ID of the instance to create. MigrationJobId string `protobuf:"bytes,2,opt,name=migration_job_id,json=migrationJobId,proto3" json:"migration_job_id,omitempty"` // Required. Represents a [migration // job](https://cloud.google.com/database-migration/reference/rest/v1/projects.locations.migrationJobs) // object. MigrationJob *MigrationJob `protobuf:"bytes,3,opt,name=migration_job,json=migrationJob,proto3" json:"migration_job,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message to create a new Database Migration Service migration job in the specified project and region.
func (*CreateMigrationJobRequest) Descriptor
deprecated
func (*CreateMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*CreateMigrationJobRequest) GetMigrationJob ¶
func (x *CreateMigrationJobRequest) GetMigrationJob() *MigrationJob
func (*CreateMigrationJobRequest) GetMigrationJobId ¶
func (x *CreateMigrationJobRequest) GetMigrationJobId() string
func (*CreateMigrationJobRequest) GetParent ¶
func (x *CreateMigrationJobRequest) GetParent() string
func (*CreateMigrationJobRequest) GetRequestId ¶
func (x *CreateMigrationJobRequest) GetRequestId() string
func (*CreateMigrationJobRequest) ProtoMessage ¶
func (*CreateMigrationJobRequest) ProtoMessage()
func (*CreateMigrationJobRequest) ProtoReflect ¶
func (x *CreateMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*CreateMigrationJobRequest) Reset ¶
func (x *CreateMigrationJobRequest) Reset()
func (*CreateMigrationJobRequest) String ¶
func (x *CreateMigrationJobRequest) String() string
type DataMigrationServiceClient ¶
type DataMigrationServiceClient interface { // Lists migration jobs in a given project and location. ListMigrationJobs(ctx context.Context, in *ListMigrationJobsRequest, opts ...grpc.CallOption) (*ListMigrationJobsResponse, error) // Gets details of a single migration job. GetMigrationJob(ctx context.Context, in *GetMigrationJobRequest, opts ...grpc.CallOption) (*MigrationJob, error) // Creates a new migration job in a given project and location. CreateMigrationJob(ctx context.Context, in *CreateMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Updates the parameters of a single migration job. UpdateMigrationJob(ctx context.Context, in *UpdateMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Deletes a single migration job. DeleteMigrationJob(ctx context.Context, in *DeleteMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Start an already created migration job. StartMigrationJob(ctx context.Context, in *StartMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Stops a running migration job. StopMigrationJob(ctx context.Context, in *StopMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Resume a migration job that is currently stopped and is resumable (was // stopped during CDC phase). ResumeMigrationJob(ctx context.Context, in *ResumeMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Promote a migration job, stopping replication to the destination and // promoting the destination to be a standalone database. PromoteMigrationJob(ctx context.Context, in *PromoteMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Verify a migration job, making sure the destination can reach the source // and that all configuration and prerequisites are met. VerifyMigrationJob(ctx context.Context, in *VerifyMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Restart a stopped or failed migration job, resetting the destination // instance to its original state and starting the migration process from // scratch. RestartMigrationJob(ctx context.Context, in *RestartMigrationJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Generate a SSH configuration script to configure the reverse SSH // connectivity. GenerateSshScript(ctx context.Context, in *GenerateSshScriptRequest, opts ...grpc.CallOption) (*SshScript, error) // Retrieve a list of all connection profiles in a given project and location. ListConnectionProfiles(ctx context.Context, in *ListConnectionProfilesRequest, opts ...grpc.CallOption) (*ListConnectionProfilesResponse, error) // Gets details of a single connection profile. GetConnectionProfile(ctx context.Context, in *GetConnectionProfileRequest, opts ...grpc.CallOption) (*ConnectionProfile, error) // Creates a new connection profile in a given project and location. CreateConnectionProfile(ctx context.Context, in *CreateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Update the configuration of a single connection profile. UpdateConnectionProfile(ctx context.Context, in *UpdateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Deletes a single Database Migration Service connection profile. // A connection profile can only be deleted if it is not in use by any // active migration jobs. DeleteConnectionProfile(ctx context.Context, in *DeleteConnectionProfileRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) }
DataMigrationServiceClient is the client API for DataMigrationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataMigrationServiceClient ¶
func NewDataMigrationServiceClient(cc grpc.ClientConnInterface) DataMigrationServiceClient
type DataMigrationServiceServer ¶
type DataMigrationServiceServer interface { // Lists migration jobs in a given project and location. ListMigrationJobs(context.Context, *ListMigrationJobsRequest) (*ListMigrationJobsResponse, error) // Gets details of a single migration job. GetMigrationJob(context.Context, *GetMigrationJobRequest) (*MigrationJob, error) // Creates a new migration job in a given project and location. CreateMigrationJob(context.Context, *CreateMigrationJobRequest) (*longrunning.Operation, error) // Updates the parameters of a single migration job. UpdateMigrationJob(context.Context, *UpdateMigrationJobRequest) (*longrunning.Operation, error) // Deletes a single migration job. DeleteMigrationJob(context.Context, *DeleteMigrationJobRequest) (*longrunning.Operation, error) // Start an already created migration job. StartMigrationJob(context.Context, *StartMigrationJobRequest) (*longrunning.Operation, error) // Stops a running migration job. StopMigrationJob(context.Context, *StopMigrationJobRequest) (*longrunning.Operation, error) // Resume a migration job that is currently stopped and is resumable (was // stopped during CDC phase). ResumeMigrationJob(context.Context, *ResumeMigrationJobRequest) (*longrunning.Operation, error) // Promote a migration job, stopping replication to the destination and // promoting the destination to be a standalone database. PromoteMigrationJob(context.Context, *PromoteMigrationJobRequest) (*longrunning.Operation, error) // Verify a migration job, making sure the destination can reach the source // and that all configuration and prerequisites are met. VerifyMigrationJob(context.Context, *VerifyMigrationJobRequest) (*longrunning.Operation, error) // Restart a stopped or failed migration job, resetting the destination // instance to its original state and starting the migration process from // scratch. RestartMigrationJob(context.Context, *RestartMigrationJobRequest) (*longrunning.Operation, error) // Generate a SSH configuration script to configure the reverse SSH // connectivity. GenerateSshScript(context.Context, *GenerateSshScriptRequest) (*SshScript, error) // Retrieve a list of all connection profiles in a given project and location. ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error) // Gets details of a single connection profile. GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error) // Creates a new connection profile in a given project and location. CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunning.Operation, error) // Update the configuration of a single connection profile. UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunning.Operation, error) // Deletes a single Database Migration Service connection profile. // A connection profile can only be deleted if it is not in use by any // active migration jobs. DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunning.Operation, error) }
DataMigrationServiceServer is the server API for DataMigrationService service.
type DatabaseEngine ¶
type DatabaseEngine int32
The database engine types.
const ( // The source database engine of the migration job is unknown. DatabaseEngine_DATABASE_ENGINE_UNSPECIFIED DatabaseEngine = 0 // The source engine is MySQL. DatabaseEngine_MYSQL DatabaseEngine = 1 // The source engine is PostgreSQL. DatabaseEngine_POSTGRESQL DatabaseEngine = 2 )
func (DatabaseEngine) Descriptor ¶
func (DatabaseEngine) Descriptor() protoreflect.EnumDescriptor
func (DatabaseEngine) Enum ¶
func (x DatabaseEngine) Enum() *DatabaseEngine
func (DatabaseEngine) EnumDescriptor
deprecated
func (DatabaseEngine) EnumDescriptor() ([]byte, []int)
Deprecated: Use DatabaseEngine.Descriptor instead.
func (DatabaseEngine) Number ¶
func (x DatabaseEngine) Number() protoreflect.EnumNumber
func (DatabaseEngine) String ¶
func (x DatabaseEngine) String() string
func (DatabaseEngine) Type ¶
func (DatabaseEngine) Type() protoreflect.EnumType
type DatabaseProvider ¶
type DatabaseProvider int32
The database providers.
const ( // The database provider is unknown. DatabaseProvider_DATABASE_PROVIDER_UNSPECIFIED DatabaseProvider = 0 // CloudSQL runs the database. DatabaseProvider_CLOUDSQL DatabaseProvider = 1 // RDS runs the database. DatabaseProvider_RDS DatabaseProvider = 2 )
func (DatabaseProvider) Descriptor ¶
func (DatabaseProvider) Descriptor() protoreflect.EnumDescriptor
func (DatabaseProvider) Enum ¶
func (x DatabaseProvider) Enum() *DatabaseProvider
func (DatabaseProvider) EnumDescriptor
deprecated
func (DatabaseProvider) EnumDescriptor() ([]byte, []int)
Deprecated: Use DatabaseProvider.Descriptor instead.
func (DatabaseProvider) Number ¶
func (x DatabaseProvider) Number() protoreflect.EnumNumber
func (DatabaseProvider) String ¶
func (x DatabaseProvider) String() string
func (DatabaseProvider) Type ¶
func (DatabaseProvider) Type() protoreflect.EnumType
type DatabaseType ¶
type DatabaseType struct { // The database provider. Provider DatabaseProvider `protobuf:"varint,1,opt,name=provider,proto3,enum=google.cloud.clouddms.v1.DatabaseProvider" json:"provider,omitempty"` // The database engine. Engine DatabaseEngine `protobuf:"varint,2,opt,name=engine,proto3,enum=google.cloud.clouddms.v1.DatabaseEngine" json:"engine,omitempty"` // contains filtered or unexported fields }
A message defining the database engine and provider.
func (*DatabaseType) Descriptor
deprecated
func (*DatabaseType) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseType.ProtoReflect.Descriptor instead.
func (*DatabaseType) GetEngine ¶
func (x *DatabaseType) GetEngine() DatabaseEngine
func (*DatabaseType) GetProvider ¶
func (x *DatabaseType) GetProvider() DatabaseProvider
func (*DatabaseType) ProtoMessage ¶
func (*DatabaseType) ProtoMessage()
func (*DatabaseType) ProtoReflect ¶
func (x *DatabaseType) ProtoReflect() protoreflect.Message
func (*DatabaseType) Reset ¶
func (x *DatabaseType) Reset()
func (*DatabaseType) String ¶
func (x *DatabaseType) String() string
type DeleteConnectionProfileRequest ¶
type DeleteConnectionProfileRequest struct { // Required. Name of the connection profile resource to delete. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // In case of force delete, the CloudSQL replica database is also deleted // (only for CloudSQL connection profile). Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
Request message for 'DeleteConnectionProfile' request.
func (*DeleteConnectionProfileRequest) Descriptor
deprecated
func (*DeleteConnectionProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*DeleteConnectionProfileRequest) GetForce ¶
func (x *DeleteConnectionProfileRequest) GetForce() bool
func (*DeleteConnectionProfileRequest) GetName ¶
func (x *DeleteConnectionProfileRequest) GetName() string
func (*DeleteConnectionProfileRequest) GetRequestId ¶
func (x *DeleteConnectionProfileRequest) GetRequestId() string
func (*DeleteConnectionProfileRequest) ProtoMessage ¶
func (*DeleteConnectionProfileRequest) ProtoMessage()
func (*DeleteConnectionProfileRequest) ProtoReflect ¶
func (x *DeleteConnectionProfileRequest) ProtoReflect() protoreflect.Message
func (*DeleteConnectionProfileRequest) Reset ¶
func (x *DeleteConnectionProfileRequest) Reset()
func (*DeleteConnectionProfileRequest) String ¶
func (x *DeleteConnectionProfileRequest) String() string
type DeleteMigrationJobRequest ¶
type DeleteMigrationJobRequest struct { // Required. Name of the migration job resource to delete. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // The destination CloudSQL connection profile is always deleted with the // migration job. In case of force delete, the destination CloudSQL replica // database is also deleted. Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
Request message for 'DeleteMigrationJob' request.
func (*DeleteMigrationJobRequest) Descriptor
deprecated
func (*DeleteMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*DeleteMigrationJobRequest) GetForce ¶
func (x *DeleteMigrationJobRequest) GetForce() bool
func (*DeleteMigrationJobRequest) GetName ¶
func (x *DeleteMigrationJobRequest) GetName() string
func (*DeleteMigrationJobRequest) GetRequestId ¶
func (x *DeleteMigrationJobRequest) GetRequestId() string
func (*DeleteMigrationJobRequest) ProtoMessage ¶
func (*DeleteMigrationJobRequest) ProtoMessage()
func (*DeleteMigrationJobRequest) ProtoReflect ¶
func (x *DeleteMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*DeleteMigrationJobRequest) Reset ¶
func (x *DeleteMigrationJobRequest) Reset()
func (*DeleteMigrationJobRequest) String ¶
func (x *DeleteMigrationJobRequest) String() string
type GenerateSshScriptRequest ¶
type GenerateSshScriptRequest struct { // Name of the migration job resource to generate the SSH script. MigrationJob string `protobuf:"bytes,1,opt,name=migration_job,json=migrationJob,proto3" json:"migration_job,omitempty"` // Required. Bastion VM Instance name to use or to create. Vm string `protobuf:"bytes,2,opt,name=vm,proto3" json:"vm,omitempty"` // The VM configuration // // Types that are assignable to VmConfig: // *GenerateSshScriptRequest_VmCreationConfig // *GenerateSshScriptRequest_VmSelectionConfig VmConfig isGenerateSshScriptRequest_VmConfig `protobuf_oneof:"vm_config"` // The port that will be open on the bastion host VmPort int32 `protobuf:"varint,3,opt,name=vm_port,json=vmPort,proto3" json:"vm_port,omitempty"` // contains filtered or unexported fields }
Request message for 'GenerateSshScript' request.
func (*GenerateSshScriptRequest) Descriptor
deprecated
func (*GenerateSshScriptRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenerateSshScriptRequest.ProtoReflect.Descriptor instead.
func (*GenerateSshScriptRequest) GetMigrationJob ¶
func (x *GenerateSshScriptRequest) GetMigrationJob() string
func (*GenerateSshScriptRequest) GetVm ¶
func (x *GenerateSshScriptRequest) GetVm() string
func (*GenerateSshScriptRequest) GetVmConfig ¶
func (m *GenerateSshScriptRequest) GetVmConfig() isGenerateSshScriptRequest_VmConfig
func (*GenerateSshScriptRequest) GetVmCreationConfig ¶
func (x *GenerateSshScriptRequest) GetVmCreationConfig() *VmCreationConfig
func (*GenerateSshScriptRequest) GetVmPort ¶
func (x *GenerateSshScriptRequest) GetVmPort() int32
func (*GenerateSshScriptRequest) GetVmSelectionConfig ¶
func (x *GenerateSshScriptRequest) GetVmSelectionConfig() *VmSelectionConfig
func (*GenerateSshScriptRequest) ProtoMessage ¶
func (*GenerateSshScriptRequest) ProtoMessage()
func (*GenerateSshScriptRequest) ProtoReflect ¶
func (x *GenerateSshScriptRequest) ProtoReflect() protoreflect.Message
func (*GenerateSshScriptRequest) Reset ¶
func (x *GenerateSshScriptRequest) Reset()
func (*GenerateSshScriptRequest) String ¶
func (x *GenerateSshScriptRequest) String() string
type GenerateSshScriptRequest_VmCreationConfig ¶
type GenerateSshScriptRequest_VmCreationConfig struct { // The VM creation configuration VmCreationConfig *VmCreationConfig `protobuf:"bytes,100,opt,name=vm_creation_config,json=vmCreationConfig,proto3,oneof"` }
type GenerateSshScriptRequest_VmSelectionConfig ¶
type GenerateSshScriptRequest_VmSelectionConfig struct { // The VM selection configuration VmSelectionConfig *VmSelectionConfig `protobuf:"bytes,101,opt,name=vm_selection_config,json=vmSelectionConfig,proto3,oneof"` }
type GetConnectionProfileRequest ¶
type GetConnectionProfileRequest struct { // Required. Name of the connection profile resource to get. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'GetConnectionProfile' request.
func (*GetConnectionProfileRequest) Descriptor
deprecated
func (*GetConnectionProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*GetConnectionProfileRequest) GetName ¶
func (x *GetConnectionProfileRequest) GetName() string
func (*GetConnectionProfileRequest) ProtoMessage ¶
func (*GetConnectionProfileRequest) ProtoMessage()
func (*GetConnectionProfileRequest) ProtoReflect ¶
func (x *GetConnectionProfileRequest) ProtoReflect() protoreflect.Message
func (*GetConnectionProfileRequest) Reset ¶
func (x *GetConnectionProfileRequest) Reset()
func (*GetConnectionProfileRequest) String ¶
func (x *GetConnectionProfileRequest) String() string
type GetMigrationJobRequest ¶
type GetMigrationJobRequest struct { // Required. Name of the migration job resource to get. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'GetMigrationJob' request.
func (*GetMigrationJobRequest) Descriptor
deprecated
func (*GetMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*GetMigrationJobRequest) GetName ¶
func (x *GetMigrationJobRequest) GetName() string
func (*GetMigrationJobRequest) ProtoMessage ¶
func (*GetMigrationJobRequest) ProtoMessage()
func (*GetMigrationJobRequest) ProtoReflect ¶
func (x *GetMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*GetMigrationJobRequest) Reset ¶
func (x *GetMigrationJobRequest) Reset()
func (*GetMigrationJobRequest) String ¶
func (x *GetMigrationJobRequest) String() string
type ListConnectionProfilesRequest ¶
type ListConnectionProfilesRequest struct { // Required. The parent, which owns this collection of connection profiles. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of connection profiles to return. The service may return // fewer than this value. If unspecified, at most 50 connection profiles will // be returned. The maximum value is 1000; values above 1000 will be coerced // to 1000. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // A page token, received from a previous `ListConnectionProfiles` call. // Provide this to retrieve the subsequent page. // // When paginating, all other parameters provided to `ListConnectionProfiles` // must match the call that provided the page token. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters connection profiles listed in the // response. The expression must specify the field name, a comparison // operator, and the value that you want to use for filtering. The value must // be a string, a number, or a boolean. The comparison operator must be either // =, !=, >, or <. For example, list connection profiles created this year by // specifying **createTime %gt; 2020-01-01T00:00:00.000000000Z**. You can // also filter nested fields. For example, you could specify **mySql.username // = %lt;my_username%gt;** to list all connection profiles configured to // connect with a specific username. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // the order by fields for the result. OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
Request message for 'ListConnectionProfiles' request.
func (*ListConnectionProfilesRequest) Descriptor
deprecated
func (*ListConnectionProfilesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListConnectionProfilesRequest.ProtoReflect.Descriptor instead.
func (*ListConnectionProfilesRequest) GetFilter ¶
func (x *ListConnectionProfilesRequest) GetFilter() string
func (*ListConnectionProfilesRequest) GetOrderBy ¶
func (x *ListConnectionProfilesRequest) GetOrderBy() string
func (*ListConnectionProfilesRequest) GetPageSize ¶
func (x *ListConnectionProfilesRequest) GetPageSize() int32
func (*ListConnectionProfilesRequest) GetPageToken ¶
func (x *ListConnectionProfilesRequest) GetPageToken() string
func (*ListConnectionProfilesRequest) GetParent ¶
func (x *ListConnectionProfilesRequest) GetParent() string
func (*ListConnectionProfilesRequest) ProtoMessage ¶
func (*ListConnectionProfilesRequest) ProtoMessage()
func (*ListConnectionProfilesRequest) ProtoReflect ¶
func (x *ListConnectionProfilesRequest) ProtoReflect() protoreflect.Message
func (*ListConnectionProfilesRequest) Reset ¶
func (x *ListConnectionProfilesRequest) Reset()
func (*ListConnectionProfilesRequest) String ¶
func (x *ListConnectionProfilesRequest) String() string
type ListConnectionProfilesResponse ¶
type ListConnectionProfilesResponse struct { // The response list of connection profiles. ConnectionProfiles []*ConnectionProfile `protobuf:"bytes,1,rep,name=connection_profiles,json=connectionProfiles,proto3" json:"connection_profiles,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"` // Locations that could not be reached. Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"` // contains filtered or unexported fields }
Response message for 'ListConnectionProfiles' request.
func (*ListConnectionProfilesResponse) Descriptor
deprecated
func (*ListConnectionProfilesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListConnectionProfilesResponse.ProtoReflect.Descriptor instead.
func (*ListConnectionProfilesResponse) GetConnectionProfiles ¶
func (x *ListConnectionProfilesResponse) GetConnectionProfiles() []*ConnectionProfile
func (*ListConnectionProfilesResponse) GetNextPageToken ¶
func (x *ListConnectionProfilesResponse) GetNextPageToken() string
func (*ListConnectionProfilesResponse) GetUnreachable ¶
func (x *ListConnectionProfilesResponse) GetUnreachable() []string
func (*ListConnectionProfilesResponse) ProtoMessage ¶
func (*ListConnectionProfilesResponse) ProtoMessage()
func (*ListConnectionProfilesResponse) ProtoReflect ¶
func (x *ListConnectionProfilesResponse) ProtoReflect() protoreflect.Message
func (*ListConnectionProfilesResponse) Reset ¶
func (x *ListConnectionProfilesResponse) Reset()
func (*ListConnectionProfilesResponse) String ¶
func (x *ListConnectionProfilesResponse) String() string
type ListMigrationJobsRequest ¶
type ListMigrationJobsRequest struct { // Required. The parent, which owns this collection of migrationJobs. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of migration jobs to return. The service may return // fewer than this value. If unspecified, at most 50 migration jobs will be // returned. The maximum value is 1000; values above 1000 will be coerced to // 1000. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // The nextPageToken value received in the previous call to // migrationJobs.list, used in the subsequent request to retrieve the next // page of results. On first call this should be left blank. When paginating, // all other parameters provided to migrationJobs.list must match the call // that provided the page token. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A filter expression that filters migration jobs listed in the response. // The expression must specify the field name, a comparison operator, and the // value that you want to use for filtering. The value must be a string, // a number, or a boolean. The comparison operator must be // either =, !=, >, or <. For example, list migration jobs created this year // by specifying **createTime %gt; 2020-01-01T00:00:00.000000000Z.** // You can also filter nested fields. For example, you could specify // **reverseSshConnectivity.vmIp = "1.2.3.4"** to select all migration // jobs connecting through the specific SSH tunnel bastion. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // Sort the results based on the migration job name. // Valid values are: "name", "name asc", and "name desc". OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
Retrieve a list of all migration jobs in a given project and location.
func (*ListMigrationJobsRequest) Descriptor
deprecated
func (*ListMigrationJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationJobsRequest.ProtoReflect.Descriptor instead.
func (*ListMigrationJobsRequest) GetFilter ¶
func (x *ListMigrationJobsRequest) GetFilter() string
func (*ListMigrationJobsRequest) GetOrderBy ¶
func (x *ListMigrationJobsRequest) GetOrderBy() string
func (*ListMigrationJobsRequest) GetPageSize ¶
func (x *ListMigrationJobsRequest) GetPageSize() int32
func (*ListMigrationJobsRequest) GetPageToken ¶
func (x *ListMigrationJobsRequest) GetPageToken() string
func (*ListMigrationJobsRequest) GetParent ¶
func (x *ListMigrationJobsRequest) GetParent() string
func (*ListMigrationJobsRequest) ProtoMessage ¶
func (*ListMigrationJobsRequest) ProtoMessage()
func (*ListMigrationJobsRequest) ProtoReflect ¶
func (x *ListMigrationJobsRequest) ProtoReflect() protoreflect.Message
func (*ListMigrationJobsRequest) Reset ¶
func (x *ListMigrationJobsRequest) Reset()
func (*ListMigrationJobsRequest) String ¶
func (x *ListMigrationJobsRequest) String() string
type ListMigrationJobsResponse ¶
type ListMigrationJobsResponse struct { // The list of migration jobs objects. MigrationJobs []*MigrationJob `protobuf:"bytes,1,rep,name=migration_jobs,json=migrationJobs,proto3" json:"migration_jobs,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"` // Locations that could not be reached. Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"` // contains filtered or unexported fields }
Response message for 'ListMigrationJobs' request.
func (*ListMigrationJobsResponse) Descriptor
deprecated
func (*ListMigrationJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMigrationJobsResponse.ProtoReflect.Descriptor instead.
func (*ListMigrationJobsResponse) GetMigrationJobs ¶
func (x *ListMigrationJobsResponse) GetMigrationJobs() []*MigrationJob
func (*ListMigrationJobsResponse) GetNextPageToken ¶
func (x *ListMigrationJobsResponse) GetNextPageToken() string
func (*ListMigrationJobsResponse) GetUnreachable ¶
func (x *ListMigrationJobsResponse) GetUnreachable() []string
func (*ListMigrationJobsResponse) ProtoMessage ¶
func (*ListMigrationJobsResponse) ProtoMessage()
func (*ListMigrationJobsResponse) ProtoReflect ¶
func (x *ListMigrationJobsResponse) ProtoReflect() protoreflect.Message
func (*ListMigrationJobsResponse) Reset ¶
func (x *ListMigrationJobsResponse) Reset()
func (*ListMigrationJobsResponse) String ¶
func (x *ListMigrationJobsResponse) String() string
type MigrationJob ¶
type MigrationJob struct { // The name (URI) of this migration job resource, in the form of: // projects/{project}/locations/{location}/instances/{instance}. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. The timestamp when the migration job resource was created. // A timestamp in RFC3339 UTC "Zulu" format, accurate to nanoseconds. // Example: "2014-10-02T15:01:23.045123456Z". CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The timestamp when the migration job resource was last updated. // A timestamp in RFC3339 UTC "Zulu" format, accurate to nanoseconds. // Example: "2014-10-02T15:01:23.045123456Z". UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // The resource labels for migration job to use to annotate any related // underlying resources such as Compute Engine VMs. An object containing a // list of "key": "value" pairs. // // Example: `{ "name": "wrench", "mass": "1.3kg", "count": "3" }`. Labels map[string]string `` /* 153-byte string literal not displayed */ // The migration job display name. DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` // The current migration job state. State MigrationJob_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.clouddms.v1.MigrationJob_State" json:"state,omitempty"` // Output only. The current migration job phase. Phase MigrationJob_Phase `protobuf:"varint,7,opt,name=phase,proto3,enum=google.cloud.clouddms.v1.MigrationJob_Phase" json:"phase,omitempty"` // Required. The migration job type. Type MigrationJob_Type `protobuf:"varint,8,opt,name=type,proto3,enum=google.cloud.clouddms.v1.MigrationJob_Type" json:"type,omitempty"` // The path to the dump file in Google Cloud Storage, // in the format: (gs://[BUCKET_NAME]/[OBJECT_NAME]). DumpPath string `protobuf:"bytes,9,opt,name=dump_path,json=dumpPath,proto3" json:"dump_path,omitempty"` // Required. The resource name (URI) of the source connection profile. Source string `protobuf:"bytes,10,opt,name=source,proto3" json:"source,omitempty"` // Required. The resource name (URI) of the destination connection profile. Destination string `protobuf:"bytes,11,opt,name=destination,proto3" json:"destination,omitempty"` // The connectivity method. // // Types that are assignable to Connectivity: // *MigrationJob_ReverseSshConnectivity // *MigrationJob_VpcPeeringConnectivity // *MigrationJob_StaticIpConnectivity Connectivity isMigrationJob_Connectivity `protobuf_oneof:"connectivity"` // Output only. The duration of the migration job (in seconds). A duration in seconds // with up to nine fractional digits, terminated by 's'. Example: "3.5s". Duration *durationpb.Duration `protobuf:"bytes,12,opt,name=duration,proto3" json:"duration,omitempty"` // Output only. The error details in case of state FAILED. Error *status.Status `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"` // The database engine type and provider of the source. SourceDatabase *DatabaseType `protobuf:"bytes,14,opt,name=source_database,json=sourceDatabase,proto3" json:"source_database,omitempty"` // The database engine type and provider of the destination. DestinationDatabase *DatabaseType `protobuf:"bytes,15,opt,name=destination_database,json=destinationDatabase,proto3" json:"destination_database,omitempty"` // Output only. If the migration job is completed, the time when it was completed. EndTime *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // contains filtered or unexported fields }
Represents a Database Migration Service migration job object.
func (*MigrationJob) Descriptor
deprecated
func (*MigrationJob) Descriptor() ([]byte, []int)
Deprecated: Use MigrationJob.ProtoReflect.Descriptor instead.
func (*MigrationJob) GetConnectivity ¶
func (m *MigrationJob) GetConnectivity() isMigrationJob_Connectivity
func (*MigrationJob) GetCreateTime ¶
func (x *MigrationJob) GetCreateTime() *timestamppb.Timestamp
func (*MigrationJob) GetDestination ¶
func (x *MigrationJob) GetDestination() string
func (*MigrationJob) GetDestinationDatabase ¶
func (x *MigrationJob) GetDestinationDatabase() *DatabaseType
func (*MigrationJob) GetDisplayName ¶
func (x *MigrationJob) GetDisplayName() string
func (*MigrationJob) GetDumpPath ¶
func (x *MigrationJob) GetDumpPath() string
func (*MigrationJob) GetDuration ¶
func (x *MigrationJob) GetDuration() *durationpb.Duration
func (*MigrationJob) GetEndTime ¶
func (x *MigrationJob) GetEndTime() *timestamppb.Timestamp
func (*MigrationJob) GetError ¶
func (x *MigrationJob) GetError() *status.Status
func (*MigrationJob) GetLabels ¶
func (x *MigrationJob) GetLabels() map[string]string
func (*MigrationJob) GetName ¶
func (x *MigrationJob) GetName() string
func (*MigrationJob) GetPhase ¶
func (x *MigrationJob) GetPhase() MigrationJob_Phase
func (*MigrationJob) GetReverseSshConnectivity ¶
func (x *MigrationJob) GetReverseSshConnectivity() *ReverseSshConnectivity
func (*MigrationJob) GetSource ¶
func (x *MigrationJob) GetSource() string
func (*MigrationJob) GetSourceDatabase ¶
func (x *MigrationJob) GetSourceDatabase() *DatabaseType
func (*MigrationJob) GetState ¶
func (x *MigrationJob) GetState() MigrationJob_State
func (*MigrationJob) GetStaticIpConnectivity ¶
func (x *MigrationJob) GetStaticIpConnectivity() *StaticIpConnectivity
func (*MigrationJob) GetType ¶
func (x *MigrationJob) GetType() MigrationJob_Type
func (*MigrationJob) GetUpdateTime ¶
func (x *MigrationJob) GetUpdateTime() *timestamppb.Timestamp
func (*MigrationJob) GetVpcPeeringConnectivity ¶
func (x *MigrationJob) GetVpcPeeringConnectivity() *VpcPeeringConnectivity
func (*MigrationJob) ProtoMessage ¶
func (*MigrationJob) ProtoMessage()
func (*MigrationJob) ProtoReflect ¶
func (x *MigrationJob) ProtoReflect() protoreflect.Message
func (*MigrationJob) Reset ¶
func (x *MigrationJob) Reset()
func (*MigrationJob) String ¶
func (x *MigrationJob) String() string
type MigrationJobVerificationError ¶
type MigrationJobVerificationError struct { // Output only. An instance of ErrorCode specifying the error that occurred. ErrorCode MigrationJobVerificationError_ErrorCode `` /* 159-byte string literal not displayed */ // Output only. A formatted message with further details about the error and a CTA. ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // Output only. A specific detailed error message, if supplied by the engine. ErrorDetailMessage string `protobuf:"bytes,3,opt,name=error_detail_message,json=errorDetailMessage,proto3" json:"error_detail_message,omitempty"` // contains filtered or unexported fields }
Error message of a verification Migration job.
func (*MigrationJobVerificationError) Descriptor
deprecated
func (*MigrationJobVerificationError) Descriptor() ([]byte, []int)
Deprecated: Use MigrationJobVerificationError.ProtoReflect.Descriptor instead.
func (*MigrationJobVerificationError) GetErrorCode ¶
func (x *MigrationJobVerificationError) GetErrorCode() MigrationJobVerificationError_ErrorCode
func (*MigrationJobVerificationError) GetErrorDetailMessage ¶
func (x *MigrationJobVerificationError) GetErrorDetailMessage() string
func (*MigrationJobVerificationError) GetErrorMessage ¶
func (x *MigrationJobVerificationError) GetErrorMessage() string
func (*MigrationJobVerificationError) ProtoMessage ¶
func (*MigrationJobVerificationError) ProtoMessage()
func (*MigrationJobVerificationError) ProtoReflect ¶
func (x *MigrationJobVerificationError) ProtoReflect() protoreflect.Message
func (*MigrationJobVerificationError) Reset ¶
func (x *MigrationJobVerificationError) Reset()
func (*MigrationJobVerificationError) String ¶
func (x *MigrationJobVerificationError) String() string
type MigrationJobVerificationError_ErrorCode ¶
type MigrationJobVerificationError_ErrorCode int32
A general error code describing the type of error that occurred.
const ( // An unknown error occurred MigrationJobVerificationError_ERROR_CODE_UNSPECIFIED MigrationJobVerificationError_ErrorCode = 0 // We failed to connect to one of the connection profile. MigrationJobVerificationError_CONNECTION_FAILURE MigrationJobVerificationError_ErrorCode = 1 // We failed to authenticate to one of the connection profile. MigrationJobVerificationError_AUTHENTICATION_FAILURE MigrationJobVerificationError_ErrorCode = 2 // One of the involved connection profiles has an invalid configuration. MigrationJobVerificationError_INVALID_CONNECTION_PROFILE_CONFIG MigrationJobVerificationError_ErrorCode = 3 // The versions of the source and the destination are incompatible. MigrationJobVerificationError_VERSION_INCOMPATIBILITY MigrationJobVerificationError_ErrorCode = 4 // The types of the source and the destination are incompatible. MigrationJobVerificationError_CONNECTION_PROFILE_TYPES_INCOMPATIBILITY MigrationJobVerificationError_ErrorCode = 5 // No pglogical extension installed on databases, applicable for postgres. MigrationJobVerificationError_NO_PGLOGICAL_INSTALLED MigrationJobVerificationError_ErrorCode = 7 // pglogical node already exists on databases, applicable for postgres. MigrationJobVerificationError_PGLOGICAL_NODE_ALREADY_EXISTS MigrationJobVerificationError_ErrorCode = 8 // The value of parameter wal_level is not set to logical. MigrationJobVerificationError_INVALID_WAL_LEVEL MigrationJobVerificationError_ErrorCode = 9 // The value of parameter shared_preload_libraries does not include // pglogical. MigrationJobVerificationError_INVALID_SHARED_PRELOAD_LIBRARY MigrationJobVerificationError_ErrorCode = 10 // The value of parameter max_replication_slots is not sufficient. MigrationJobVerificationError_INSUFFICIENT_MAX_REPLICATION_SLOTS MigrationJobVerificationError_ErrorCode = 11 // The value of parameter max_wal_senders is not sufficient. MigrationJobVerificationError_INSUFFICIENT_MAX_WAL_SENDERS MigrationJobVerificationError_ErrorCode = 12 // The value of parameter max_worker_processes is not sufficient. MigrationJobVerificationError_INSUFFICIENT_MAX_WORKER_PROCESSES MigrationJobVerificationError_ErrorCode = 13 // Extensions installed are either not supported or having unsupported // versions. MigrationJobVerificationError_UNSUPPORTED_EXTENSIONS MigrationJobVerificationError_ErrorCode = 14 // Unsupported migration type. MigrationJobVerificationError_UNSUPPORTED_MIGRATION_TYPE MigrationJobVerificationError_ErrorCode = 15 // Invalid RDS logical replication. MigrationJobVerificationError_INVALID_RDS_LOGICAL_REPLICATION MigrationJobVerificationError_ErrorCode = 16 // The gtid_mode is not supported, applicable for MySQL. MigrationJobVerificationError_UNSUPPORTED_GTID_MODE MigrationJobVerificationError_ErrorCode = 17 // The table definition is not support due to missing primary key or replica // identity. MigrationJobVerificationError_UNSUPPORTED_TABLE_DEFINITION MigrationJobVerificationError_ErrorCode = 18 // The definer is not supported. MigrationJobVerificationError_UNSUPPORTED_DEFINER MigrationJobVerificationError_ErrorCode = 19 // Migration is already running at the time of restart request. MigrationJobVerificationError_CANT_RESTART_RUNNING_MIGRATION MigrationJobVerificationError_ErrorCode = 21 )
func (MigrationJobVerificationError_ErrorCode) Descriptor ¶
func (MigrationJobVerificationError_ErrorCode) Descriptor() protoreflect.EnumDescriptor
func (MigrationJobVerificationError_ErrorCode) EnumDescriptor
deprecated
func (MigrationJobVerificationError_ErrorCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationJobVerificationError_ErrorCode.Descriptor instead.
func (MigrationJobVerificationError_ErrorCode) Number ¶
func (x MigrationJobVerificationError_ErrorCode) Number() protoreflect.EnumNumber
func (MigrationJobVerificationError_ErrorCode) String ¶
func (x MigrationJobVerificationError_ErrorCode) String() string
func (MigrationJobVerificationError_ErrorCode) Type ¶
func (MigrationJobVerificationError_ErrorCode) Type() protoreflect.EnumType
type MigrationJob_Phase ¶
type MigrationJob_Phase int32
The current migration job phase.
const ( // The phase of the migration job is unknown. MigrationJob_PHASE_UNSPECIFIED MigrationJob_Phase = 0 // The migration job is in the full dump phase. MigrationJob_FULL_DUMP MigrationJob_Phase = 1 // The migration job is CDC phase. MigrationJob_CDC MigrationJob_Phase = 2 // The migration job is running the promote phase. MigrationJob_PROMOTE_IN_PROGRESS MigrationJob_Phase = 3 // Only RDS flow - waiting for source writes to stop MigrationJob_WAITING_FOR_SOURCE_WRITES_TO_STOP MigrationJob_Phase = 4 // Only RDS flow - the sources writes stopped, waiting for dump to begin MigrationJob_PREPARING_THE_DUMP MigrationJob_Phase = 5 )
func (MigrationJob_Phase) Descriptor ¶
func (MigrationJob_Phase) Descriptor() protoreflect.EnumDescriptor
func (MigrationJob_Phase) Enum ¶
func (x MigrationJob_Phase) Enum() *MigrationJob_Phase
func (MigrationJob_Phase) EnumDescriptor
deprecated
func (MigrationJob_Phase) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationJob_Phase.Descriptor instead.
func (MigrationJob_Phase) Number ¶
func (x MigrationJob_Phase) Number() protoreflect.EnumNumber
func (MigrationJob_Phase) String ¶
func (x MigrationJob_Phase) String() string
func (MigrationJob_Phase) Type ¶
func (MigrationJob_Phase) Type() protoreflect.EnumType
type MigrationJob_ReverseSshConnectivity ¶
type MigrationJob_ReverseSshConnectivity struct { // The details needed to communicate to the source over Reverse SSH // tunnel connectivity. ReverseSshConnectivity *ReverseSshConnectivity `protobuf:"bytes,101,opt,name=reverse_ssh_connectivity,json=reverseSshConnectivity,proto3,oneof"` }
type MigrationJob_State ¶
type MigrationJob_State int32
The current migration job states.
const ( // The state of the migration job is unknown. MigrationJob_STATE_UNSPECIFIED MigrationJob_State = 0 // The migration job is down for maintenance. MigrationJob_MAINTENANCE MigrationJob_State = 1 // The migration job is in draft mode and no resources are created. MigrationJob_DRAFT MigrationJob_State = 2 // The migration job is being created. MigrationJob_CREATING MigrationJob_State = 3 // The migration job is created, not started and is fully editable. MigrationJob_NOT_STARTED MigrationJob_State = 4 // The migration job is running. MigrationJob_RUNNING MigrationJob_State = 5 // The migration job failed. MigrationJob_FAILED MigrationJob_State = 6 // The migration job has been completed. MigrationJob_COMPLETED MigrationJob_State = 7 // The migration job is being deleted. MigrationJob_DELETING MigrationJob_State = 8 // The migration job is being stopped. MigrationJob_STOPPING MigrationJob_State = 9 // The migration job is currently stopped. MigrationJob_STOPPED MigrationJob_State = 10 // The migration job has been deleted. MigrationJob_DELETED MigrationJob_State = 11 // The migration job is being updated. MigrationJob_UPDATING MigrationJob_State = 12 // The migration job is starting. MigrationJob_STARTING MigrationJob_State = 13 // The migration job is restarting. MigrationJob_RESTARTING MigrationJob_State = 14 // The migration job is resuming. MigrationJob_RESUMING MigrationJob_State = 15 )
func (MigrationJob_State) Descriptor ¶
func (MigrationJob_State) Descriptor() protoreflect.EnumDescriptor
func (MigrationJob_State) Enum ¶
func (x MigrationJob_State) Enum() *MigrationJob_State
func (MigrationJob_State) EnumDescriptor
deprecated
func (MigrationJob_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationJob_State.Descriptor instead.
func (MigrationJob_State) Number ¶
func (x MigrationJob_State) Number() protoreflect.EnumNumber
func (MigrationJob_State) String ¶
func (x MigrationJob_State) String() string
func (MigrationJob_State) Type ¶
func (MigrationJob_State) Type() protoreflect.EnumType
type MigrationJob_StaticIpConnectivity ¶
type MigrationJob_StaticIpConnectivity struct { // static ip connectivity data (default, no additional details needed). StaticIpConnectivity *StaticIpConnectivity `protobuf:"bytes,103,opt,name=static_ip_connectivity,json=staticIpConnectivity,proto3,oneof"` }
type MigrationJob_Type ¶
type MigrationJob_Type int32
The type of migration job (one-time or continuous).
const ( // The type of the migration job is unknown. MigrationJob_TYPE_UNSPECIFIED MigrationJob_Type = 0 // The migration job is a one time migration. MigrationJob_ONE_TIME MigrationJob_Type = 1 // The migration job is a continuous migration. MigrationJob_CONTINUOUS MigrationJob_Type = 2 )
func (MigrationJob_Type) Descriptor ¶
func (MigrationJob_Type) Descriptor() protoreflect.EnumDescriptor
func (MigrationJob_Type) Enum ¶
func (x MigrationJob_Type) Enum() *MigrationJob_Type
func (MigrationJob_Type) EnumDescriptor
deprecated
func (MigrationJob_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use MigrationJob_Type.Descriptor instead.
func (MigrationJob_Type) Number ¶
func (x MigrationJob_Type) Number() protoreflect.EnumNumber
func (MigrationJob_Type) String ¶
func (x MigrationJob_Type) String() string
func (MigrationJob_Type) Type ¶
func (MigrationJob_Type) Type() protoreflect.EnumType
type MigrationJob_VpcPeeringConnectivity ¶
type MigrationJob_VpcPeeringConnectivity struct { // The details of the VPC network that the source database is located in. VpcPeeringConnectivity *VpcPeeringConnectivity `protobuf:"bytes,102,opt,name=vpc_peering_connectivity,json=vpcPeeringConnectivity,proto3,oneof"` }
type MySqlConnectionProfile ¶
type MySqlConnectionProfile struct { // Required. The IP or hostname of the source MySQL database. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Required. The network port of the source MySQL database. Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Required. The username that Database Migration Service will use to connect to the // database. The value is encrypted when stored in Database Migration Service. Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"` // Required. Input only. The password for the user that Database Migration Service will be using to // connect to the database. This field is not returned on request, and the // value is encrypted when stored in Database Migration Service. Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` // Output only. Indicates If this connection profile password is stored. PasswordSet bool `protobuf:"varint,5,opt,name=password_set,json=passwordSet,proto3" json:"password_set,omitempty"` // SSL configuration for the destination to connect to the source database. Ssl *SslConfig `protobuf:"bytes,6,opt,name=ssl,proto3" json:"ssl,omitempty"` // If the source is a Cloud SQL database, use this field to // provide the Cloud SQL instance ID of the source. CloudSqlId string `protobuf:"bytes,7,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"` // contains filtered or unexported fields }
Specifies connection parameters required specifically for MySQL databases.
func (*MySqlConnectionProfile) Descriptor
deprecated
func (*MySqlConnectionProfile) Descriptor() ([]byte, []int)
Deprecated: Use MySqlConnectionProfile.ProtoReflect.Descriptor instead.
func (*MySqlConnectionProfile) GetCloudSqlId ¶
func (x *MySqlConnectionProfile) GetCloudSqlId() string
func (*MySqlConnectionProfile) GetHost ¶
func (x *MySqlConnectionProfile) GetHost() string
func (*MySqlConnectionProfile) GetPassword ¶
func (x *MySqlConnectionProfile) GetPassword() string
func (*MySqlConnectionProfile) GetPasswordSet ¶
func (x *MySqlConnectionProfile) GetPasswordSet() bool
func (*MySqlConnectionProfile) GetPort ¶
func (x *MySqlConnectionProfile) GetPort() int32
func (*MySqlConnectionProfile) GetSsl ¶
func (x *MySqlConnectionProfile) GetSsl() *SslConfig
func (*MySqlConnectionProfile) GetUsername ¶
func (x *MySqlConnectionProfile) GetUsername() string
func (*MySqlConnectionProfile) ProtoMessage ¶
func (*MySqlConnectionProfile) ProtoMessage()
func (*MySqlConnectionProfile) ProtoReflect ¶
func (x *MySqlConnectionProfile) ProtoReflect() protoreflect.Message
func (*MySqlConnectionProfile) Reset ¶
func (x *MySqlConnectionProfile) Reset()
func (*MySqlConnectionProfile) String ¶
func (x *MySqlConnectionProfile) String() string
type OperationMetadata ¶
type OperationMetadata struct { // Output only. The time the operation was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time the operation finished running. EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Output only. Server-defined resource path for the target of the operation. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Output only. Name of the verb executed by the operation. Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"` // Output only. Human-readable status of the operation, if any. StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"` // Output only. Identifies whether the user has requested cancellation // of the operation. Operations that have successfully been cancelled // have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, // corresponding to `Code.CANCELLED`. RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"` // Output only. API version used to start the operation. ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` // contains filtered or unexported fields }
Represents the metadata of the long-running operation.
func (*OperationMetadata) Descriptor
deprecated
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion ¶
func (x *OperationMetadata) GetApiVersion() string
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetRequestedCancellation ¶
func (x *OperationMetadata) GetRequestedCancellation() bool
func (*OperationMetadata) GetStatusMessage ¶
func (x *OperationMetadata) GetStatusMessage() string
func (*OperationMetadata) GetTarget ¶
func (x *OperationMetadata) GetTarget() string
func (*OperationMetadata) GetVerb ¶
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type PostgreSqlConnectionProfile ¶
type PostgreSqlConnectionProfile struct { // Required. The IP or hostname of the source PostgreSQL database. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Required. The network port of the source PostgreSQL database. Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Required. The username that Database Migration Service will use to connect to the // database. The value is encrypted when stored in Database Migration Service. Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"` // Required. Input only. The password for the user that Database Migration Service will be using to // connect to the database. This field is not returned on request, and the // value is encrypted when stored in Database Migration Service. Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` // Output only. Indicates If this connection profile password is stored. PasswordSet bool `protobuf:"varint,5,opt,name=password_set,json=passwordSet,proto3" json:"password_set,omitempty"` // SSL configuration for the destination to connect to the source database. Ssl *SslConfig `protobuf:"bytes,6,opt,name=ssl,proto3" json:"ssl,omitempty"` // If the source is a Cloud SQL database, use this field to // provide the Cloud SQL instance ID of the source. CloudSqlId string `protobuf:"bytes,7,opt,name=cloud_sql_id,json=cloudSqlId,proto3" json:"cloud_sql_id,omitempty"` // contains filtered or unexported fields }
Specifies connection parameters required specifically for PostgreSQL databases.
func (*PostgreSqlConnectionProfile) Descriptor
deprecated
func (*PostgreSqlConnectionProfile) Descriptor() ([]byte, []int)
Deprecated: Use PostgreSqlConnectionProfile.ProtoReflect.Descriptor instead.
func (*PostgreSqlConnectionProfile) GetCloudSqlId ¶
func (x *PostgreSqlConnectionProfile) GetCloudSqlId() string
func (*PostgreSqlConnectionProfile) GetHost ¶
func (x *PostgreSqlConnectionProfile) GetHost() string
func (*PostgreSqlConnectionProfile) GetPassword ¶
func (x *PostgreSqlConnectionProfile) GetPassword() string
func (*PostgreSqlConnectionProfile) GetPasswordSet ¶
func (x *PostgreSqlConnectionProfile) GetPasswordSet() bool
func (*PostgreSqlConnectionProfile) GetPort ¶
func (x *PostgreSqlConnectionProfile) GetPort() int32
func (*PostgreSqlConnectionProfile) GetSsl ¶
func (x *PostgreSqlConnectionProfile) GetSsl() *SslConfig
func (*PostgreSqlConnectionProfile) GetUsername ¶
func (x *PostgreSqlConnectionProfile) GetUsername() string
func (*PostgreSqlConnectionProfile) ProtoMessage ¶
func (*PostgreSqlConnectionProfile) ProtoMessage()
func (*PostgreSqlConnectionProfile) ProtoReflect ¶
func (x *PostgreSqlConnectionProfile) ProtoReflect() protoreflect.Message
func (*PostgreSqlConnectionProfile) Reset ¶
func (x *PostgreSqlConnectionProfile) Reset()
func (*PostgreSqlConnectionProfile) String ¶
func (x *PostgreSqlConnectionProfile) String() string
type PromoteMigrationJobRequest ¶
type PromoteMigrationJobRequest struct { // Name of the migration job resource to promote. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'PromoteMigrationJob' request.
func (*PromoteMigrationJobRequest) Descriptor
deprecated
func (*PromoteMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use PromoteMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*PromoteMigrationJobRequest) GetName ¶
func (x *PromoteMigrationJobRequest) GetName() string
func (*PromoteMigrationJobRequest) ProtoMessage ¶
func (*PromoteMigrationJobRequest) ProtoMessage()
func (*PromoteMigrationJobRequest) ProtoReflect ¶
func (x *PromoteMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*PromoteMigrationJobRequest) Reset ¶
func (x *PromoteMigrationJobRequest) Reset()
func (*PromoteMigrationJobRequest) String ¶
func (x *PromoteMigrationJobRequest) String() string
type RestartMigrationJobRequest ¶
type RestartMigrationJobRequest struct { // Name of the migration job resource to restart. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'RestartMigrationJob' request.
func (*RestartMigrationJobRequest) Descriptor
deprecated
func (*RestartMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*RestartMigrationJobRequest) GetName ¶
func (x *RestartMigrationJobRequest) GetName() string
func (*RestartMigrationJobRequest) ProtoMessage ¶
func (*RestartMigrationJobRequest) ProtoMessage()
func (*RestartMigrationJobRequest) ProtoReflect ¶
func (x *RestartMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*RestartMigrationJobRequest) Reset ¶
func (x *RestartMigrationJobRequest) Reset()
func (*RestartMigrationJobRequest) String ¶
func (x *RestartMigrationJobRequest) String() string
type ResumeMigrationJobRequest ¶
type ResumeMigrationJobRequest struct { // Name of the migration job resource to resume. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'ResumeMigrationJob' request.
func (*ResumeMigrationJobRequest) Descriptor
deprecated
func (*ResumeMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*ResumeMigrationJobRequest) GetName ¶
func (x *ResumeMigrationJobRequest) GetName() string
func (*ResumeMigrationJobRequest) ProtoMessage ¶
func (*ResumeMigrationJobRequest) ProtoMessage()
func (*ResumeMigrationJobRequest) ProtoReflect ¶
func (x *ResumeMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*ResumeMigrationJobRequest) Reset ¶
func (x *ResumeMigrationJobRequest) Reset()
func (*ResumeMigrationJobRequest) String ¶
func (x *ResumeMigrationJobRequest) String() string
type ReverseSshConnectivity ¶
type ReverseSshConnectivity struct { // Required. The IP of the virtual machine (Compute Engine) used as the bastion server // for the SSH tunnel. VmIp string `protobuf:"bytes,1,opt,name=vm_ip,json=vmIp,proto3" json:"vm_ip,omitempty"` // Required. The forwarding port of the virtual machine (Compute Engine) used as the // bastion server for the SSH tunnel. VmPort int32 `protobuf:"varint,2,opt,name=vm_port,json=vmPort,proto3" json:"vm_port,omitempty"` // The name of the virtual machine (Compute Engine) used as the bastion server // for the SSH tunnel. Vm string `protobuf:"bytes,3,opt,name=vm,proto3" json:"vm,omitempty"` // The name of the VPC to peer with the Cloud SQL private network. Vpc string `protobuf:"bytes,4,opt,name=vpc,proto3" json:"vpc,omitempty"` // contains filtered or unexported fields }
The details needed to configure a reverse SSH tunnel between the source and destination databases. These details will be used when calling the generateSshScript method (see https://cloud.google.com/database-migration/docs/reference/rest/v1/projects.locations.migrationJobs/generateSshScript) to produce the script that will help set up the reverse SSH tunnel, and to set up the VPC peering between the Cloud SQL private network and the VPC.
func (*ReverseSshConnectivity) Descriptor
deprecated
func (*ReverseSshConnectivity) Descriptor() ([]byte, []int)
Deprecated: Use ReverseSshConnectivity.ProtoReflect.Descriptor instead.
func (*ReverseSshConnectivity) GetVm ¶
func (x *ReverseSshConnectivity) GetVm() string
func (*ReverseSshConnectivity) GetVmIp ¶
func (x *ReverseSshConnectivity) GetVmIp() string
func (*ReverseSshConnectivity) GetVmPort ¶
func (x *ReverseSshConnectivity) GetVmPort() int32
func (*ReverseSshConnectivity) GetVpc ¶
func (x *ReverseSshConnectivity) GetVpc() string
func (*ReverseSshConnectivity) ProtoMessage ¶
func (*ReverseSshConnectivity) ProtoMessage()
func (*ReverseSshConnectivity) ProtoReflect ¶
func (x *ReverseSshConnectivity) ProtoReflect() protoreflect.Message
func (*ReverseSshConnectivity) Reset ¶
func (x *ReverseSshConnectivity) Reset()
func (*ReverseSshConnectivity) String ¶
func (x *ReverseSshConnectivity) String() string
type SqlAclEntry ¶
type SqlAclEntry struct { // The allowlisted value for the access control list. Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // The access control entry entry expiration. // // Types that are assignable to Expiration: // *SqlAclEntry_ExpireTime // *SqlAclEntry_Ttl Expiration isSqlAclEntry_Expiration `protobuf_oneof:"expiration"` // A label to identify this entry. Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"` // contains filtered or unexported fields }
An entry for an Access Control list.
func (*SqlAclEntry) Descriptor
deprecated
func (*SqlAclEntry) Descriptor() ([]byte, []int)
Deprecated: Use SqlAclEntry.ProtoReflect.Descriptor instead.
func (*SqlAclEntry) GetExpiration ¶
func (m *SqlAclEntry) GetExpiration() isSqlAclEntry_Expiration
func (*SqlAclEntry) GetExpireTime ¶
func (x *SqlAclEntry) GetExpireTime() *timestamppb.Timestamp
func (*SqlAclEntry) GetLabel ¶
func (x *SqlAclEntry) GetLabel() string
func (*SqlAclEntry) GetTtl ¶
func (x *SqlAclEntry) GetTtl() *durationpb.Duration
func (*SqlAclEntry) GetValue ¶
func (x *SqlAclEntry) GetValue() string
func (*SqlAclEntry) ProtoMessage ¶
func (*SqlAclEntry) ProtoMessage()
func (*SqlAclEntry) ProtoReflect ¶
func (x *SqlAclEntry) ProtoReflect() protoreflect.Message
func (*SqlAclEntry) Reset ¶
func (x *SqlAclEntry) Reset()
func (*SqlAclEntry) String ¶
func (x *SqlAclEntry) String() string
type SqlAclEntry_ExpireTime ¶
type SqlAclEntry_ExpireTime struct { // The time when this access control entry expires in // [RFC 3339](https://tools.ietf.org/html/rfc3339) format, for example: // `2012-11-15T16:19:00.094Z`. ExpireTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=expire_time,json=expireTime,proto3,oneof"` }
type SqlAclEntry_Ttl ¶
type SqlAclEntry_Ttl struct { // Input only. The time-to-leave of this access control entry. Ttl *durationpb.Duration `protobuf:"bytes,11,opt,name=ttl,proto3,oneof"` }
type SqlIpConfig ¶
type SqlIpConfig struct { // Whether the instance should be assigned an IPv4 address or not. EnableIpv4 *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=enable_ipv4,json=enableIpv4,proto3" json:"enable_ipv4,omitempty"` // The resource link for the VPC network from which the Cloud SQL instance is // accessible for private IP. For example, // `projects/myProject/global/networks/default`. This setting can // be updated, but it cannot be removed after it is set. PrivateNetwork string `protobuf:"bytes,2,opt,name=private_network,json=privateNetwork,proto3" json:"private_network,omitempty"` // Whether SSL connections over IP should be enforced or not. RequireSsl *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=require_ssl,json=requireSsl,proto3" json:"require_ssl,omitempty"` // The list of external networks that are allowed to connect to the instance // using the IP. See // https://en.wikipedia.org/wiki/CIDR_notation#CIDR_notation, also known as // 'slash' notation (e.g. `192.168.100.0/24`). AuthorizedNetworks []*SqlAclEntry `protobuf:"bytes,4,rep,name=authorized_networks,json=authorizedNetworks,proto3" json:"authorized_networks,omitempty"` // contains filtered or unexported fields }
IP Management configuration.
func (*SqlIpConfig) Descriptor
deprecated
func (*SqlIpConfig) Descriptor() ([]byte, []int)
Deprecated: Use SqlIpConfig.ProtoReflect.Descriptor instead.
func (*SqlIpConfig) GetAuthorizedNetworks ¶
func (x *SqlIpConfig) GetAuthorizedNetworks() []*SqlAclEntry
func (*SqlIpConfig) GetEnableIpv4 ¶
func (x *SqlIpConfig) GetEnableIpv4() *wrapperspb.BoolValue
func (*SqlIpConfig) GetPrivateNetwork ¶
func (x *SqlIpConfig) GetPrivateNetwork() string
func (*SqlIpConfig) GetRequireSsl ¶
func (x *SqlIpConfig) GetRequireSsl() *wrapperspb.BoolValue
func (*SqlIpConfig) ProtoMessage ¶
func (*SqlIpConfig) ProtoMessage()
func (*SqlIpConfig) ProtoReflect ¶
func (x *SqlIpConfig) ProtoReflect() protoreflect.Message
func (*SqlIpConfig) Reset ¶
func (x *SqlIpConfig) Reset()
func (*SqlIpConfig) String ¶
func (x *SqlIpConfig) String() string
type SshScript ¶
type SshScript struct { // The ssh configuration script. Script string `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"` // contains filtered or unexported fields }
Response message for 'GenerateSshScript' request.
func (*SshScript) Descriptor
deprecated
func (*SshScript) ProtoMessage ¶
func (*SshScript) ProtoMessage()
func (*SshScript) ProtoReflect ¶
func (x *SshScript) ProtoReflect() protoreflect.Message
type SslConfig ¶
type SslConfig struct { // Output only. The ssl config type according to 'client_key', 'client_certificate' and // 'ca_certificate'. Type SslConfig_SslType `protobuf:"varint,1,opt,name=type,proto3,enum=google.cloud.clouddms.v1.SslConfig_SslType" json:"type,omitempty"` // Input only. The unencrypted PKCS#1 or PKCS#8 PEM-encoded private key associated with // the Client Certificate. If this field is used then the 'client_certificate' // field is mandatory. ClientKey string `protobuf:"bytes,2,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"` // Input only. The x509 PEM-encoded certificate that will be used by the replica to // authenticate against the source database server.If this field is used then // the 'client_key' field is mandatory. ClientCertificate string `protobuf:"bytes,3,opt,name=client_certificate,json=clientCertificate,proto3" json:"client_certificate,omitempty"` // Required. Input only. The x509 PEM-encoded certificate of the CA that signed the source database // server's certificate. The replica will use this certificate to verify // it's connecting to the right host. CaCertificate string `protobuf:"bytes,4,opt,name=ca_certificate,json=caCertificate,proto3" json:"ca_certificate,omitempty"` // contains filtered or unexported fields }
SSL configuration information.
func (*SslConfig) Descriptor
deprecated
func (*SslConfig) GetCaCertificate ¶
func (*SslConfig) GetClientCertificate ¶
func (*SslConfig) GetClientKey ¶
func (*SslConfig) GetType ¶
func (x *SslConfig) GetType() SslConfig_SslType
func (*SslConfig) ProtoMessage ¶
func (*SslConfig) ProtoMessage()
func (*SslConfig) ProtoReflect ¶
func (x *SslConfig) ProtoReflect() protoreflect.Message
type SslConfig_SslType ¶
type SslConfig_SslType int32
Specifies The kind of ssl configuration used.
const ( // Unspecified. SslConfig_SSL_TYPE_UNSPECIFIED SslConfig_SslType = 0 // Only 'ca_certificate' specified. SslConfig_SERVER_ONLY SslConfig_SslType = 1 // Both server ('ca_certificate'), and client ('client_key', // 'client_certificate') specified. SslConfig_SERVER_CLIENT SslConfig_SslType = 2 )
func (SslConfig_SslType) Descriptor ¶
func (SslConfig_SslType) Descriptor() protoreflect.EnumDescriptor
func (SslConfig_SslType) Enum ¶
func (x SslConfig_SslType) Enum() *SslConfig_SslType
func (SslConfig_SslType) EnumDescriptor
deprecated
func (SslConfig_SslType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SslConfig_SslType.Descriptor instead.
func (SslConfig_SslType) Number ¶
func (x SslConfig_SslType) Number() protoreflect.EnumNumber
func (SslConfig_SslType) String ¶
func (x SslConfig_SslType) String() string
func (SslConfig_SslType) Type ¶
func (SslConfig_SslType) Type() protoreflect.EnumType
type StartMigrationJobRequest ¶
type StartMigrationJobRequest struct { // Name of the migration job resource to start. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'StartMigrationJob' request.
func (*StartMigrationJobRequest) Descriptor
deprecated
func (*StartMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*StartMigrationJobRequest) GetName ¶
func (x *StartMigrationJobRequest) GetName() string
func (*StartMigrationJobRequest) ProtoMessage ¶
func (*StartMigrationJobRequest) ProtoMessage()
func (*StartMigrationJobRequest) ProtoReflect ¶
func (x *StartMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*StartMigrationJobRequest) Reset ¶
func (x *StartMigrationJobRequest) Reset()
func (*StartMigrationJobRequest) String ¶
func (x *StartMigrationJobRequest) String() string
type StaticIpConnectivity ¶
type StaticIpConnectivity struct {
// contains filtered or unexported fields
}
The source database will allow incoming connections from the destination database's public IP. You can retrieve the Cloud SQL instance's public IP from the Cloud SQL console or using Cloud SQL APIs. No additional configuration is required.
func (*StaticIpConnectivity) Descriptor
deprecated
func (*StaticIpConnectivity) Descriptor() ([]byte, []int)
Deprecated: Use StaticIpConnectivity.ProtoReflect.Descriptor instead.
func (*StaticIpConnectivity) ProtoMessage ¶
func (*StaticIpConnectivity) ProtoMessage()
func (*StaticIpConnectivity) ProtoReflect ¶
func (x *StaticIpConnectivity) ProtoReflect() protoreflect.Message
func (*StaticIpConnectivity) Reset ¶
func (x *StaticIpConnectivity) Reset()
func (*StaticIpConnectivity) String ¶
func (x *StaticIpConnectivity) String() string
type StopMigrationJobRequest ¶
type StopMigrationJobRequest struct { // Name of the migration job resource to stop. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'StopMigrationJob' request.
func (*StopMigrationJobRequest) Descriptor
deprecated
func (*StopMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*StopMigrationJobRequest) GetName ¶
func (x *StopMigrationJobRequest) GetName() string
func (*StopMigrationJobRequest) ProtoMessage ¶
func (*StopMigrationJobRequest) ProtoMessage()
func (*StopMigrationJobRequest) ProtoReflect ¶
func (x *StopMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*StopMigrationJobRequest) Reset ¶
func (x *StopMigrationJobRequest) Reset()
func (*StopMigrationJobRequest) String ¶
func (x *StopMigrationJobRequest) String() string
type UnimplementedDataMigrationServiceServer ¶
type UnimplementedDataMigrationServiceServer struct { }
UnimplementedDataMigrationServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataMigrationServiceServer) CreateConnectionProfile ¶
func (*UnimplementedDataMigrationServiceServer) CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) CreateMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) CreateMigrationJob(context.Context, *CreateMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) DeleteConnectionProfile ¶
func (*UnimplementedDataMigrationServiceServer) DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) DeleteMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) DeleteMigrationJob(context.Context, *DeleteMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) GenerateSshScript ¶
func (*UnimplementedDataMigrationServiceServer) GenerateSshScript(context.Context, *GenerateSshScriptRequest) (*SshScript, error)
func (*UnimplementedDataMigrationServiceServer) GetConnectionProfile ¶
func (*UnimplementedDataMigrationServiceServer) GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)
func (*UnimplementedDataMigrationServiceServer) GetMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) GetMigrationJob(context.Context, *GetMigrationJobRequest) (*MigrationJob, error)
func (*UnimplementedDataMigrationServiceServer) ListConnectionProfiles ¶
func (*UnimplementedDataMigrationServiceServer) ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)
func (*UnimplementedDataMigrationServiceServer) ListMigrationJobs ¶
func (*UnimplementedDataMigrationServiceServer) ListMigrationJobs(context.Context, *ListMigrationJobsRequest) (*ListMigrationJobsResponse, error)
func (*UnimplementedDataMigrationServiceServer) PromoteMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) PromoteMigrationJob(context.Context, *PromoteMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) RestartMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) RestartMigrationJob(context.Context, *RestartMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) ResumeMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) ResumeMigrationJob(context.Context, *ResumeMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) StartMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) StartMigrationJob(context.Context, *StartMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) StopMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) StopMigrationJob(context.Context, *StopMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) UpdateConnectionProfile ¶
func (*UnimplementedDataMigrationServiceServer) UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) UpdateMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) UpdateMigrationJob(context.Context, *UpdateMigrationJobRequest) (*longrunning.Operation, error)
func (*UnimplementedDataMigrationServiceServer) VerifyMigrationJob ¶
func (*UnimplementedDataMigrationServiceServer) VerifyMigrationJob(context.Context, *VerifyMigrationJobRequest) (*longrunning.Operation, error)
type UpdateConnectionProfileRequest ¶
type UpdateConnectionProfileRequest struct { // Required. Field mask is used to specify the fields to be overwritten in the // connection profile resource by the update. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The connection profile parameters to update. ConnectionProfile *ConnectionProfile `protobuf:"bytes,2,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for 'UpdateConnectionProfile' request.
func (*UpdateConnectionProfileRequest) Descriptor
deprecated
func (*UpdateConnectionProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*UpdateConnectionProfileRequest) GetConnectionProfile ¶
func (x *UpdateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile
func (*UpdateConnectionProfileRequest) GetRequestId ¶
func (x *UpdateConnectionProfileRequest) GetRequestId() string
func (*UpdateConnectionProfileRequest) GetUpdateMask ¶
func (x *UpdateConnectionProfileRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateConnectionProfileRequest) ProtoMessage ¶
func (*UpdateConnectionProfileRequest) ProtoMessage()
func (*UpdateConnectionProfileRequest) ProtoReflect ¶
func (x *UpdateConnectionProfileRequest) ProtoReflect() protoreflect.Message
func (*UpdateConnectionProfileRequest) Reset ¶
func (x *UpdateConnectionProfileRequest) Reset()
func (*UpdateConnectionProfileRequest) String ¶
func (x *UpdateConnectionProfileRequest) String() string
type UpdateMigrationJobRequest ¶
type UpdateMigrationJobRequest struct { // Required. Field mask is used to specify the fields to be overwritten in the // migration job resource by the update. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The migration job parameters to update. MigrationJob *MigrationJob `protobuf:"bytes,2,opt,name=migration_job,json=migrationJob,proto3" json:"migration_job,omitempty"` // A unique id used to identify the request. If the server receives two // requests with the same id, then the second request will be ignored. // // It is recommended to always set this value to a UUID. // // The id must contain only letters (a-z, A-Z), numbers (0-9), underscores // (_), and hyphens (-). The maximum length is 40 characters. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for 'UpdateMigrationJob' request.
func (*UpdateMigrationJobRequest) Descriptor
deprecated
func (*UpdateMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*UpdateMigrationJobRequest) GetMigrationJob ¶
func (x *UpdateMigrationJobRequest) GetMigrationJob() *MigrationJob
func (*UpdateMigrationJobRequest) GetRequestId ¶
func (x *UpdateMigrationJobRequest) GetRequestId() string
func (*UpdateMigrationJobRequest) GetUpdateMask ¶
func (x *UpdateMigrationJobRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateMigrationJobRequest) ProtoMessage ¶
func (*UpdateMigrationJobRequest) ProtoMessage()
func (*UpdateMigrationJobRequest) ProtoReflect ¶
func (x *UpdateMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*UpdateMigrationJobRequest) Reset ¶
func (x *UpdateMigrationJobRequest) Reset()
func (*UpdateMigrationJobRequest) String ¶
func (x *UpdateMigrationJobRequest) String() string
type VerifyMigrationJobRequest ¶
type VerifyMigrationJobRequest struct { // Name of the migration job resource to verify. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for 'VerifyMigrationJob' request.
func (*VerifyMigrationJobRequest) Descriptor
deprecated
func (*VerifyMigrationJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use VerifyMigrationJobRequest.ProtoReflect.Descriptor instead.
func (*VerifyMigrationJobRequest) GetName ¶
func (x *VerifyMigrationJobRequest) GetName() string
func (*VerifyMigrationJobRequest) ProtoMessage ¶
func (*VerifyMigrationJobRequest) ProtoMessage()
func (*VerifyMigrationJobRequest) ProtoReflect ¶
func (x *VerifyMigrationJobRequest) ProtoReflect() protoreflect.Message
func (*VerifyMigrationJobRequest) Reset ¶
func (x *VerifyMigrationJobRequest) Reset()
func (*VerifyMigrationJobRequest) String ¶
func (x *VerifyMigrationJobRequest) String() string
type VmCreationConfig ¶
type VmCreationConfig struct { // Required. VM instance machine type to create. VmMachineType string `protobuf:"bytes,1,opt,name=vm_machine_type,json=vmMachineType,proto3" json:"vm_machine_type,omitempty"` // The Google Cloud Platform zone to create the VM in. VmZone string `protobuf:"bytes,2,opt,name=vm_zone,json=vmZone,proto3" json:"vm_zone,omitempty"` // The subnet name the vm needs to be created in. Subnet string `protobuf:"bytes,3,opt,name=subnet,proto3" json:"subnet,omitempty"` // contains filtered or unexported fields }
VM creation configuration message
func (*VmCreationConfig) Descriptor
deprecated
func (*VmCreationConfig) Descriptor() ([]byte, []int)
Deprecated: Use VmCreationConfig.ProtoReflect.Descriptor instead.
func (*VmCreationConfig) GetSubnet ¶
func (x *VmCreationConfig) GetSubnet() string
func (*VmCreationConfig) GetVmMachineType ¶
func (x *VmCreationConfig) GetVmMachineType() string
func (*VmCreationConfig) GetVmZone ¶
func (x *VmCreationConfig) GetVmZone() string
func (*VmCreationConfig) ProtoMessage ¶
func (*VmCreationConfig) ProtoMessage()
func (*VmCreationConfig) ProtoReflect ¶
func (x *VmCreationConfig) ProtoReflect() protoreflect.Message
func (*VmCreationConfig) Reset ¶
func (x *VmCreationConfig) Reset()
func (*VmCreationConfig) String ¶
func (x *VmCreationConfig) String() string
type VmSelectionConfig ¶
type VmSelectionConfig struct { // Required. The Google Cloud Platform zone the VM is located. VmZone string `protobuf:"bytes,1,opt,name=vm_zone,json=vmZone,proto3" json:"vm_zone,omitempty"` // contains filtered or unexported fields }
VM selection configuration message
func (*VmSelectionConfig) Descriptor
deprecated
func (*VmSelectionConfig) Descriptor() ([]byte, []int)
Deprecated: Use VmSelectionConfig.ProtoReflect.Descriptor instead.
func (*VmSelectionConfig) GetVmZone ¶
func (x *VmSelectionConfig) GetVmZone() string
func (*VmSelectionConfig) ProtoMessage ¶
func (*VmSelectionConfig) ProtoMessage()
func (*VmSelectionConfig) ProtoReflect ¶
func (x *VmSelectionConfig) ProtoReflect() protoreflect.Message
func (*VmSelectionConfig) Reset ¶
func (x *VmSelectionConfig) Reset()
func (*VmSelectionConfig) String ¶
func (x *VmSelectionConfig) String() string
type VpcPeeringConnectivity ¶
type VpcPeeringConnectivity struct { // The name of the VPC network to peer with the Cloud SQL private network. Vpc string `protobuf:"bytes,1,opt,name=vpc,proto3" json:"vpc,omitempty"` // contains filtered or unexported fields }
The details of the VPC where the source database is located in Google Cloud. We will use this information to set up the VPC peering connection between Cloud SQL and this VPC.
func (*VpcPeeringConnectivity) Descriptor
deprecated
func (*VpcPeeringConnectivity) Descriptor() ([]byte, []int)
Deprecated: Use VpcPeeringConnectivity.ProtoReflect.Descriptor instead.
func (*VpcPeeringConnectivity) GetVpc ¶
func (x *VpcPeeringConnectivity) GetVpc() string
func (*VpcPeeringConnectivity) ProtoMessage ¶
func (*VpcPeeringConnectivity) ProtoMessage()
func (*VpcPeeringConnectivity) ProtoReflect ¶
func (x *VpcPeeringConnectivity) ProtoReflect() protoreflect.Message
func (*VpcPeeringConnectivity) Reset ¶
func (x *VpcPeeringConnectivity) Reset()
func (*VpcPeeringConnectivity) String ¶
func (x *VpcPeeringConnectivity) String() string