clouddms

package
Version: v0.0.0-...-f39f71e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 5, 2022 License: Apache-2.0 Imports: 15 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
var File_google_cloud_clouddms_v1_clouddms_proto protoreflect.FileDescriptor
View Source
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 (*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 (*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) Enum

func (CloudSqlSettings_SqlActivationPolicy) EnumDescriptor deprecated

func (CloudSqlSettings_SqlActivationPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use CloudSqlSettings_SqlActivationPolicy.Descriptor instead.

func (CloudSqlSettings_SqlActivationPolicy) Number

func (CloudSqlSettings_SqlActivationPolicy) String

func (CloudSqlSettings_SqlActivationPolicy) Type

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

func (CloudSqlSettings_SqlDataDiskType) EnumDescriptor deprecated

func (CloudSqlSettings_SqlDataDiskType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CloudSqlSettings_SqlDataDiskType.Descriptor instead.

func (CloudSqlSettings_SqlDataDiskType) Number

func (CloudSqlSettings_SqlDataDiskType) String

func (CloudSqlSettings_SqlDataDiskType) Type

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

func (CloudSqlSettings_SqlDatabaseVersion) EnumDescriptor deprecated

func (CloudSqlSettings_SqlDatabaseVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use CloudSqlSettings_SqlDatabaseVersion.Descriptor instead.

func (CloudSqlSettings_SqlDatabaseVersion) Number

func (CloudSqlSettings_SqlDatabaseVersion) String

func (CloudSqlSettings_SqlDatabaseVersion) Type

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

func (ConnectionProfile_State) EnumDescriptor deprecated

func (ConnectionProfile_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectionProfile_State.Descriptor instead.

func (ConnectionProfile_State) Number

func (ConnectionProfile_State) String

func (x ConnectionProfile_State) String() string

func (ConnectionProfile_State) Type

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 (*CreateConnectionProfileRequest) Reset

func (x *CreateConnectionProfileRequest) Reset()

func (*CreateConnectionProfileRequest) 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/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 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 (*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.

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

func (x DatabaseEngine) Enum() *DatabaseEngine

func (DatabaseEngine) EnumDescriptor deprecated

func (DatabaseEngine) EnumDescriptor() ([]byte, []int)

Deprecated: Use DatabaseEngine.Descriptor instead.

func (DatabaseEngine) Number

func (DatabaseEngine) String

func (x DatabaseEngine) String() string

func (DatabaseEngine) Type

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

func (DatabaseProvider) EnumDescriptor deprecated

func (DatabaseProvider) EnumDescriptor() ([]byte, []int)

Deprecated: Use DatabaseProvider.Descriptor instead.

func (DatabaseProvider) Number

func (DatabaseProvider) String

func (x DatabaseProvider) String() string

func (DatabaseProvider) Type

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 (*DeleteConnectionProfileRequest) GetRequestId

func (x *DeleteConnectionProfileRequest) GetRequestId() string

func (*DeleteConnectionProfileRequest) ProtoMessage

func (*DeleteConnectionProfileRequest) ProtoMessage()

func (*DeleteConnectionProfileRequest) ProtoReflect

func (*DeleteConnectionProfileRequest) Reset

func (x *DeleteConnectionProfileRequest) Reset()

func (*DeleteConnectionProfileRequest) 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 (*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 (*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 (*ListConnectionProfilesRequest) Reset

func (x *ListConnectionProfilesRequest) Reset()

func (*ListConnectionProfilesRequest) 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 (*ListConnectionProfilesResponse) Reset

func (x *ListConnectionProfilesResponse) Reset()

func (*ListConnectionProfilesResponse) 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 (*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 (*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 (*MigrationJobVerificationError) Reset

func (x *MigrationJobVerificationError) Reset()

func (*MigrationJobVerificationError) 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) Enum

func (MigrationJobVerificationError_ErrorCode) EnumDescriptor deprecated

func (MigrationJobVerificationError_ErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationJobVerificationError_ErrorCode.Descriptor instead.

func (MigrationJobVerificationError_ErrorCode) Number

func (MigrationJobVerificationError_ErrorCode) String

func (MigrationJobVerificationError_ErrorCode) Type

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

func (MigrationJob_Phase) EnumDescriptor deprecated

func (MigrationJob_Phase) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationJob_Phase.Descriptor instead.

func (MigrationJob_Phase) Number

func (MigrationJob_Phase) String

func (x MigrationJob_Phase) String() string

func (MigrationJob_Phase) Type

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

func (MigrationJob_State) EnumDescriptor deprecated

func (MigrationJob_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationJob_State.Descriptor instead.

func (MigrationJob_State) Number

func (MigrationJob_State) String

func (x MigrationJob_State) String() string

func (MigrationJob_State) Type

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

func (MigrationJob_Type) EnumDescriptor deprecated

func (MigrationJob_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationJob_Type.Descriptor instead.

func (MigrationJob_Type) Number

func (MigrationJob_Type) String

func (x MigrationJob_Type) String() string

func (MigrationJob_Type) Type

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 (*PostgreSqlConnectionProfile) GetUsername

func (x *PostgreSqlConnectionProfile) GetUsername() string

func (*PostgreSqlConnectionProfile) ProtoMessage

func (*PostgreSqlConnectionProfile) ProtoMessage()

func (*PostgreSqlConnectionProfile) ProtoReflect

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 (*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 (*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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use SshScript.ProtoReflect.Descriptor instead.

func (*SshScript) GetScript

func (x *SshScript) GetScript() string

func (*SshScript) ProtoMessage

func (*SshScript) ProtoMessage()

func (*SshScript) ProtoReflect

func (x *SshScript) ProtoReflect() protoreflect.Message

func (*SshScript) Reset

func (x *SshScript) Reset()

func (*SshScript) String

func (x *SshScript) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use SslConfig.ProtoReflect.Descriptor instead.

func (*SslConfig) GetCaCertificate

func (x *SslConfig) GetCaCertificate() string

func (*SslConfig) GetClientCertificate

func (x *SslConfig) GetClientCertificate() string

func (*SslConfig) GetClientKey

func (x *SslConfig) GetClientKey() string

func (*SslConfig) GetType

func (x *SslConfig) GetType() SslConfig_SslType

func (*SslConfig) ProtoMessage

func (*SslConfig) ProtoMessage()

func (*SslConfig) ProtoReflect

func (x *SslConfig) ProtoReflect() protoreflect.Message

func (*SslConfig) Reset

func (x *SslConfig) Reset()

func (*SslConfig) String

func (x *SslConfig) String() string

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

func (SslConfig_SslType) EnumDescriptor deprecated

func (SslConfig_SslType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SslConfig_SslType.Descriptor instead.

func (SslConfig_SslType) Number

func (SslConfig_SslType) String

func (x SslConfig_SslType) String() string

func (SslConfig_SslType) Type

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

func (*UnimplementedDataMigrationServiceServer) DeleteConnectionProfile

func (*UnimplementedDataMigrationServiceServer) DeleteMigrationJob

func (*UnimplementedDataMigrationServiceServer) GenerateSshScript

func (*UnimplementedDataMigrationServiceServer) GetConnectionProfile

func (*UnimplementedDataMigrationServiceServer) GetMigrationJob

func (*UnimplementedDataMigrationServiceServer) ListConnectionProfiles

func (*UnimplementedDataMigrationServiceServer) ListMigrationJobs

func (*UnimplementedDataMigrationServiceServer) PromoteMigrationJob

func (*UnimplementedDataMigrationServiceServer) RestartMigrationJob

func (*UnimplementedDataMigrationServiceServer) ResumeMigrationJob

func (*UnimplementedDataMigrationServiceServer) StartMigrationJob

func (*UnimplementedDataMigrationServiceServer) StopMigrationJob

func (*UnimplementedDataMigrationServiceServer) UpdateConnectionProfile

func (*UnimplementedDataMigrationServiceServer) UpdateMigrationJob

func (*UnimplementedDataMigrationServiceServer) VerifyMigrationJob

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 (*UpdateConnectionProfileRequest) ProtoMessage

func (*UpdateConnectionProfileRequest) ProtoMessage()

func (*UpdateConnectionProfileRequest) ProtoReflect

func (*UpdateConnectionProfileRequest) Reset

func (x *UpdateConnectionProfileRequest) Reset()

func (*UpdateConnectionProfileRequest) 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 (*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 (*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

Jump to

Keyboard shortcuts

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