Package cloud.google.com/go/clouddms/apiv1/clouddmspb (v1.3.0)

Variables

DatabaseEngine_name, DatabaseEngine_value

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.

DatabaseProvider_name, DatabaseProvider_value

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.

SslConfig_SslType_name, SslConfig_SslType_value

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.

CloudSqlSettings_SqlActivationPolicy_name, CloudSqlSettings_SqlActivationPolicy_value

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.

CloudSqlSettings_SqlDataDiskType_name, CloudSqlSettings_SqlDataDiskType_value

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.

CloudSqlSettings_SqlDatabaseVersion_name, CloudSqlSettings_SqlDatabaseVersion_value

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.

MigrationJob_State_name, MigrationJob_State_value

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.

MigrationJob_Phase_name, MigrationJob_Phase_value

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.

MigrationJob_Type_name, MigrationJob_Type_value

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.

ConnectionProfile_State_name, ConnectionProfile_State_value

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.

MigrationJobVerificationError_ErrorCode_name, MigrationJobVerificationError_ErrorCode_value

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.

File_google_cloud_clouddms_v1_clouddms_proto

var File_google_cloud_clouddms_v1_clouddms_proto protoreflect.FileDescriptor

File_google_cloud_clouddms_v1_clouddms_resources_proto

var File_google_cloud_clouddms_v1_clouddms_resources_proto protoreflect.FileDescriptor

Functions

func RegisterDataMigrationServiceServer

func RegisterDataMigrationServiceServer(s *grpc.Server, srv DataMigrationServiceServer)

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

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

CloudSqlSettings

type CloudSqlSettings struct {
	DatabaseVersion CloudSqlSettings_SqlDatabaseVersion "" /* 173 byte string literal not displayed */

	UserLabels map[string]string "" /* 179 byte string literal not displayed */

	Tier string `protobuf:"bytes,3,opt,name=tier,proto3" json:"tier,omitempty"`

	StorageAutoResizeLimit *wrappers.Int64Value "" /* 131 byte string literal not displayed */

	ActivationPolicy CloudSqlSettings_SqlActivationPolicy "" /* 177 byte string literal not displayed */

	IpConfig *SqlIpConfig `protobuf:"bytes,6,opt,name=ip_config,json=ipConfig,proto3" json:"ip_config,omitempty"`

	AutoStorageIncrease *wrappers.BoolValue `protobuf:"bytes,7,opt,name=auto_storage_increase,json=autoStorageIncrease,proto3" json:"auto_storage_increase,omitempty"`

	DatabaseFlags map[string]string "" /* 188 byte string literal not displayed */

	DataDiskType CloudSqlSettings_SqlDataDiskType "" /* 163 byte string literal not displayed */

	DataDiskSizeGb *wrappers.Int64Value `protobuf:"bytes,10,opt,name=data_disk_size_gb,json=dataDiskSizeGb,proto3" json:"data_disk_size_gb,omitempty"`

	Zone string `protobuf:"bytes,11,opt,name=zone,proto3" json:"zone,omitempty"`

	SourceId string `protobuf:"bytes,12,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`

	RootPassword string `protobuf:"bytes,13,opt,name=root_password,json=rootPassword,proto3" json:"root_password,omitempty"`

	RootPasswordSet bool `protobuf:"varint,14,opt,name=root_password_set,json=rootPasswordSet,proto3" json:"root_password_set,omitempty"`

	Collation string `protobuf:"bytes,15,opt,name=collation,proto3" json:"collation,omitempty"`

}

Settings for creating a Cloud SQL database instance.

func (*CloudSqlSettings) Descriptor

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() *wrappers.BoolValue

func (*CloudSqlSettings) GetCollation

func (x *CloudSqlSettings) GetCollation() string

func (*CloudSqlSettings) GetDataDiskSizeGb

func (x *CloudSqlSettings) GetDataDiskSizeGb() *wrappers.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() *wrappers.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

CloudSqlSettings_SqlActivationPolicy

type CloudSqlSettings_SqlActivationPolicy int32

Specifies when the instance should be activated.

CloudSqlSettings_SQL_ACTIVATION_POLICY_UNSPECIFIED, CloudSqlSettings_ALWAYS, CloudSqlSettings_NEVER

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

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

CloudSqlSettings_SqlDataDiskType

type CloudSqlSettings_SqlDataDiskType int32

The storage options for Cloud SQL databases.

CloudSqlSettings_SQL_DATA_DISK_TYPE_UNSPECIFIED, CloudSqlSettings_PD_SSD, CloudSqlSettings_PD_HDD

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

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

CloudSqlSettings_SqlDatabaseVersion

type CloudSqlSettings_SqlDatabaseVersion int32

The database engine type and version.

CloudSqlSettings_SQL_DATABASE_VERSION_UNSPECIFIED, CloudSqlSettings_MYSQL_5_6, CloudSqlSettings_MYSQL_5_7, CloudSqlSettings_POSTGRES_9_6, CloudSqlSettings_POSTGRES_11, CloudSqlSettings_POSTGRES_10, CloudSqlSettings_MYSQL_8_0, CloudSqlSettings_POSTGRES_12, CloudSqlSettings_POSTGRES_13

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

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

ConnectionProfile

type ConnectionProfile struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	State ConnectionProfile_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.clouddms.v1.ConnectionProfile_State" json:"state,omitempty"`

	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	ConnectionProfile isConnectionProfile_ConnectionProfile `protobuf_oneof:"connection_profile"`

	Error *status.Status `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`

	Provider DatabaseProvider `protobuf:"varint,8,opt,name=provider,proto3,enum=google.cloud.clouddms.v1.DatabaseProvider" json:"provider,omitempty"`

}

A connection profile definition.

func (*ConnectionProfile) Descriptor

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() *timestamp.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() *timestamp.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

ConnectionProfile_Cloudsql

type ConnectionProfile_Cloudsql struct {
	// A CloudSQL database connection profile.
	Cloudsql *CloudSqlConnectionProfile `protobuf:"bytes,102,opt,name=cloudsql,proto3,oneof"`
}

ConnectionProfile_Mysql

type ConnectionProfile_Mysql struct {
	// A MySQL database connection profile.
	Mysql *MySqlConnectionProfile `protobuf:"bytes,100,opt,name=mysql,proto3,oneof"`
}

ConnectionProfile_Postgresql

type ConnectionProfile_Postgresql struct {
	// A PostgreSQL database connection profile.
	Postgresql *PostgreSqlConnectionProfile `protobuf:"bytes,101,opt,name=postgresql,proto3,oneof"`
}

ConnectionProfile_State

type ConnectionProfile_State int32

The current connection profile state (e.g. DRAFT, READY, or FAILED).

ConnectionProfile_STATE_UNSPECIFIED, ConnectionProfile_DRAFT, ConnectionProfile_CREATING, ConnectionProfile_READY, ConnectionProfile_UPDATING, ConnectionProfile_DELETING, ConnectionProfile_DELETED, ConnectionProfile_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

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

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

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

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/docs/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

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

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

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.

DatabaseEngine

type DatabaseEngine int32

The database engine types.

DatabaseEngine_DATABASE_ENGINE_UNSPECIFIED, DatabaseEngine_MYSQL, DatabaseEngine_POSTGRESQL

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

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

DatabaseProvider

type DatabaseProvider int32

The database providers.

DatabaseProvider_DATABASE_PROVIDER_UNSPECIFIED, DatabaseProvider_CLOUDSQL, DatabaseProvider_RDS

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

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

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

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

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

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

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

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

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

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

GenerateSshScriptRequest_VmCreationConfig

type GenerateSshScriptRequest_VmCreationConfig struct {
	// The VM creation configuration
	VmCreationConfig *VmCreationConfig `protobuf:"bytes,100,opt,name=vm_creation_config,json=vmCreationConfig,proto3,oneof"`
}

GenerateSshScriptRequest_VmSelectionConfig

type GenerateSshScriptRequest_VmSelectionConfig struct {
	// The VM selection configuration
	VmSelectionConfig *VmSelectionConfig `protobuf:"bytes,101,opt,name=vm_selection_config,json=vmSelectionConfig,proto3,oneof"`
}

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

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

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

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

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

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

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

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

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

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

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

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

MigrationJob

type MigrationJob struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	State MigrationJob_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.clouddms.v1.MigrationJob_State" json:"state,omitempty"`

	Phase MigrationJob_Phase `protobuf:"varint,7,opt,name=phase,proto3,enum=google.cloud.clouddms.v1.MigrationJob_Phase" json:"phase,omitempty"`

	Type MigrationJob_Type `protobuf:"varint,8,opt,name=type,proto3,enum=google.cloud.clouddms.v1.MigrationJob_Type" json:"type,omitempty"`

	DumpPath string `protobuf:"bytes,9,opt,name=dump_path,json=dumpPath,proto3" json:"dump_path,omitempty"`

	Source string `protobuf:"bytes,10,opt,name=source,proto3" json:"source,omitempty"`

	Destination string `protobuf:"bytes,11,opt,name=destination,proto3" json:"destination,omitempty"`

	Connectivity isMigrationJob_Connectivity `protobuf_oneof:"connectivity"`

	Duration *duration.Duration `protobuf:"bytes,12,opt,name=duration,proto3" json:"duration,omitempty"`

	Error *status.Status `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"`

	SourceDatabase *DatabaseType `protobuf:"bytes,14,opt,name=source_database,json=sourceDatabase,proto3" json:"source_database,omitempty"`

	DestinationDatabase *DatabaseType `protobuf:"bytes,15,opt,name=destination_database,json=destinationDatabase,proto3" json:"destination_database,omitempty"`

	EndTime *timestamp.Timestamp `protobuf:"bytes,16,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`

}

Represents a Database Migration Service migration job object.

func (*MigrationJob) Descriptor

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() *timestamp.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() *duration.Duration

func (*MigrationJob) GetEndTime

func (x *MigrationJob) GetEndTime() *timestamp.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() *timestamp.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

MigrationJobVerificationError

type MigrationJobVerificationError struct {
	ErrorCode MigrationJobVerificationError_ErrorCode "" /* 159 byte string literal not displayed */

	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`

	ErrorDetailMessage string `protobuf:"bytes,3,opt,name=error_detail_message,json=errorDetailMessage,proto3" json:"error_detail_message,omitempty"`

}

Error message of a verification Migration job.

func (*MigrationJobVerificationError) Descriptor

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

MigrationJobVerificationError_ErrorCode

type MigrationJobVerificationError_ErrorCode int32

A general error code describing the type of error that occurred.

MigrationJobVerificationError_ERROR_CODE_UNSPECIFIED, MigrationJobVerificationError_CONNECTION_FAILURE, MigrationJobVerificationError_AUTHENTICATION_FAILURE, MigrationJobVerificationError_INVALID_CONNECTION_PROFILE_CONFIG, MigrationJobVerificationError_VERSION_INCOMPATIBILITY, MigrationJobVerificationError_CONNECTION_PROFILE_TYPES_INCOMPATIBILITY, MigrationJobVerificationError_NO_PGLOGICAL_INSTALLED, MigrationJobVerificationError_PGLOGICAL_NODE_ALREADY_EXISTS, MigrationJobVerificationError_INVALID_WAL_LEVEL, MigrationJobVerificationError_INVALID_SHARED_PRELOAD_LIBRARY, MigrationJobVerificationError_INSUFFICIENT_MAX_REPLICATION_SLOTS, MigrationJobVerificationError_INSUFFICIENT_MAX_WAL_SENDERS, MigrationJobVerificationError_INSUFFICIENT_MAX_WORKER_PROCESSES, MigrationJobVerificationError_UNSUPPORTED_EXTENSIONS, MigrationJobVerificationError_UNSUPPORTED_MIGRATION_TYPE, MigrationJobVerificationError_INVALID_RDS_LOGICAL_REPLICATION, MigrationJobVerificationError_UNSUPPORTED_GTID_MODE, MigrationJobVerificationError_UNSUPPORTED_TABLE_DEFINITION, MigrationJobVerificationError_UNSUPPORTED_DEFINER, MigrationJobVerificationError_CANT_RESTART_RUNNING_MIGRATION

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) Enum

func (x MigrationJobVerificationError_ErrorCode) Enum() *MigrationJobVerificationError_ErrorCode

func (MigrationJobVerificationError_ErrorCode) EnumDescriptor

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

MigrationJob_Phase

type MigrationJob_Phase int32

The current migration job phase.

MigrationJob_PHASE_UNSPECIFIED, MigrationJob_FULL_DUMP, MigrationJob_CDC, MigrationJob_PROMOTE_IN_PROGRESS, MigrationJob_WAITING_FOR_SOURCE_WRITES_TO_STOP, MigrationJob_PREPARING_THE_DUMP

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

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

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

MigrationJob_State

type MigrationJob_State int32

The current migration job states.

MigrationJob_STATE_UNSPECIFIED, MigrationJob_MAINTENANCE, MigrationJob_DRAFT, MigrationJob_CREATING, MigrationJob_NOT_STARTED, MigrationJob_RUNNING, MigrationJob_FAILED, MigrationJob_COMPLETED, MigrationJob_DELETING, MigrationJob_STOPPING, MigrationJob_STOPPED, MigrationJob_DELETED, MigrationJob_UPDATING, MigrationJob_STARTING, MigrationJob_RESTARTING, MigrationJob_RESUMING

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 and not started.
	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

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

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

MigrationJob_Type

type MigrationJob_Type int32

The type of migration job (one-time or continuous).

MigrationJob_TYPE_UNSPECIFIED, MigrationJob_ONE_TIME, MigrationJob_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

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

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

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

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()