clouddmsv1

package
v1.36.10-2024050211440... Latest Latest
Warning

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

Go to latest
Published: unknown License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const ConnectionProfile_Alloydb_case case_ConnectionProfile_ConnectionProfile = 105
View Source
const ConnectionProfile_Cloudsql_case case_ConnectionProfile_ConnectionProfile = 102
View Source
const ConnectionProfile_ConnectionProfile_not_set_case case_ConnectionProfile_ConnectionProfile = 0
View Source
const ConnectionProfile_Mysql_case case_ConnectionProfile_ConnectionProfile = 100
View Source
const ConnectionProfile_Postgresql_case case_ConnectionProfile_ConnectionProfile = 101
View Source
const MigrationJob_Connectivity_not_set_case case_MigrationJob_Connectivity = 0
View Source
const MigrationJob_ReverseSshConnectivity_case case_MigrationJob_Connectivity = 101
View Source
const MigrationJob_StaticIpConnectivity_case case_MigrationJob_Connectivity = 103
View Source
const MigrationJob_VpcPeeringConnectivity_case case_MigrationJob_Connectivity = 102
View Source
const SqlAclEntry_Expiration_not_set_case case_SqlAclEntry_Expiration = 0
View Source
const SqlAclEntry_ExpireTime_case case_SqlAclEntry_Expiration = 10

Variables

View Source
var (
	NetworkArchitecture_name = map[int32]string{
		0: "NETWORK_ARCHITECTURE_UNSPECIFIED",
		1: "NETWORK_ARCHITECTURE_OLD_CSQL_PRODUCER",
		2: "NETWORK_ARCHITECTURE_NEW_CSQL_PRODUCER",
	}
	NetworkArchitecture_value = map[string]int32{
		"NETWORK_ARCHITECTURE_UNSPECIFIED":       0,
		"NETWORK_ARCHITECTURE_OLD_CSQL_PRODUCER": 1,
		"NETWORK_ARCHITECTURE_NEW_CSQL_PRODUCER": 2,
	}
)

Enum value maps for NetworkArchitecture.

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",
		3: "AURORA",
		4: "ALLOYDB",
	}
	DatabaseProvider_value = map[string]int32{
		"DATABASE_PROVIDER_UNSPECIFIED": 0,
		"CLOUDSQL":                      1,
		"RDS":                           2,
		"AURORA":                        3,
		"ALLOYDB":                       4,
	}
)

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",
		17: "POSTGRES_14",
	}
	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,
		"POSTGRES_14":                      17,
	}
)

Enum value maps for CloudSqlSettings_SqlDatabaseVersion.

View Source
var (
	CloudSqlSettings_SqlAvailabilityType_name = map[int32]string{
		0: "SQL_AVAILABILITY_TYPE_UNSPECIFIED",
		1: "ZONAL",
		2: "REGIONAL",
	}
	CloudSqlSettings_SqlAvailabilityType_value = map[string]int32{
		"SQL_AVAILABILITY_TYPE_UNSPECIFIED": 0,
		"ZONAL":                             1,
		"REGIONAL":                          2,
	}
)

Enum value maps for CloudSqlSettings_SqlAvailabilityType.

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 File_google_events_cloud_clouddms_v1_data_proto protoreflect.FileDescriptor
View Source
var File_google_events_cloud_clouddms_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AlloyDbConnectionProfile

type AlloyDbConnectionProfile struct {

	// Required. The AlloyDB cluster ID that this connection profile is associated
	// with.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Immutable. Metadata used to create the destination AlloyDB cluster.
	Settings *AlloyDbSettings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

Specifies required connection parameters, and the parameters required to create an AlloyDB destination cluster.

func (*AlloyDbConnectionProfile) ClearSettings

func (x *AlloyDbConnectionProfile) ClearSettings()

func (*AlloyDbConnectionProfile) GetClusterId

func (x *AlloyDbConnectionProfile) GetClusterId() string

func (*AlloyDbConnectionProfile) GetSettings

func (x *AlloyDbConnectionProfile) GetSettings() *AlloyDbSettings

func (*AlloyDbConnectionProfile) HasSettings

func (x *AlloyDbConnectionProfile) HasSettings() bool

func (*AlloyDbConnectionProfile) ProtoMessage

func (*AlloyDbConnectionProfile) ProtoMessage()

func (*AlloyDbConnectionProfile) ProtoReflect

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

func (*AlloyDbConnectionProfile) Reset

func (x *AlloyDbConnectionProfile) Reset()

func (*AlloyDbConnectionProfile) SetClusterId

func (x *AlloyDbConnectionProfile) SetClusterId(v string)

func (*AlloyDbConnectionProfile) SetSettings

func (x *AlloyDbConnectionProfile) SetSettings(v *AlloyDbSettings)

func (*AlloyDbConnectionProfile) String

func (x *AlloyDbConnectionProfile) String() string

type AlloyDbConnectionProfile_builder

type AlloyDbConnectionProfile_builder struct {

	// Required. The AlloyDB cluster ID that this connection profile is associated
	// with.
	ClusterId string
	// Immutable. Metadata used to create the destination AlloyDB cluster.
	Settings *AlloyDbSettings
	// contains filtered or unexported fields
}

func (AlloyDbConnectionProfile_builder) Build

type AlloyDbSettings

type AlloyDbSettings struct {

	// Required. The resource link for the VPC network in which cluster resources
	// are created and from which they are accessible via Private IP. The network
	// must belong to the same project as the cluster. It is specified in the
	// form: "projects/{project_number}/global/networks/{network_id}". This is
	// required to create a cluster.
	VpcNetwork string `protobuf:"bytes,2,opt,name=vpc_network,json=vpcNetwork,proto3" json:"vpc_network,omitempty"`
	// Labels for the AlloyDB cluster created by DMS. An object containing a list
	// of 'key', 'value' pairs.
	Labels                  map[string]string                        `` /* 139-byte string literal not displayed */
	PrimaryInstanceSettings *AlloyDbSettings_PrimaryInstanceSettings `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Settings for creating an AlloyDB cluster.

func (*AlloyDbSettings) ClearPrimaryInstanceSettings

func (x *AlloyDbSettings) ClearPrimaryInstanceSettings()

func (*AlloyDbSettings) GetLabels

func (x *AlloyDbSettings) GetLabels() map[string]string

func (*AlloyDbSettings) GetPrimaryInstanceSettings

func (x *AlloyDbSettings) GetPrimaryInstanceSettings() *AlloyDbSettings_PrimaryInstanceSettings

func (*AlloyDbSettings) GetVpcNetwork

func (x *AlloyDbSettings) GetVpcNetwork() string

func (*AlloyDbSettings) HasPrimaryInstanceSettings

func (x *AlloyDbSettings) HasPrimaryInstanceSettings() bool

func (*AlloyDbSettings) ProtoMessage

func (*AlloyDbSettings) ProtoMessage()

func (*AlloyDbSettings) ProtoReflect

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

func (*AlloyDbSettings) Reset

func (x *AlloyDbSettings) Reset()

func (*AlloyDbSettings) SetLabels

func (x *AlloyDbSettings) SetLabels(v map[string]string)

func (*AlloyDbSettings) SetPrimaryInstanceSettings

func (x *AlloyDbSettings) SetPrimaryInstanceSettings(v *AlloyDbSettings_PrimaryInstanceSettings)

func (*AlloyDbSettings) SetVpcNetwork

func (x *AlloyDbSettings) SetVpcNetwork(v string)

func (*AlloyDbSettings) String

func (x *AlloyDbSettings) String() string

type AlloyDbSettings_PrimaryInstanceSettings

type AlloyDbSettings_PrimaryInstanceSettings struct {

	// Required. The ID of the AlloyDB primary instance. The ID must satisfy the
	// regex expression "[a-z0-9-]+".
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Configuration for the machines that host the underlying
	// database engine.
	MachineConfig *AlloyDbSettings_PrimaryInstanceSettings_MachineConfig `protobuf:"bytes,2,opt,name=machine_config,json=machineConfig,proto3" json:"machine_config,omitempty"`
	// Database flags to pass to AlloyDB when DMS is creating the AlloyDB
	// cluster and instances. See the AlloyDB documentation for how these can be
	// used.
	DatabaseFlags map[string]string `` /* 174-byte string literal not displayed */
	// Labels for the AlloyDB primary instance created by DMS. An object
	// containing a list of 'key', 'value' pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Output only. The private IP address for the Instance.
	// This is the connection endpoint for an end-user application.
	PrivateIp string `protobuf:"bytes,8,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty"`
	// contains filtered or unexported fields
}

Settings for the cluster's primary instance

func (*AlloyDbSettings_PrimaryInstanceSettings) ClearMachineConfig

func (x *AlloyDbSettings_PrimaryInstanceSettings) ClearMachineConfig()

func (*AlloyDbSettings_PrimaryInstanceSettings) GetDatabaseFlags

func (x *AlloyDbSettings_PrimaryInstanceSettings) GetDatabaseFlags() map[string]string

func (*AlloyDbSettings_PrimaryInstanceSettings) GetId

func (*AlloyDbSettings_PrimaryInstanceSettings) GetLabels

func (*AlloyDbSettings_PrimaryInstanceSettings) GetMachineConfig

func (*AlloyDbSettings_PrimaryInstanceSettings) GetPrivateIp

func (*AlloyDbSettings_PrimaryInstanceSettings) HasMachineConfig

func (x *AlloyDbSettings_PrimaryInstanceSettings) HasMachineConfig() bool

func (*AlloyDbSettings_PrimaryInstanceSettings) ProtoMessage

func (*AlloyDbSettings_PrimaryInstanceSettings) ProtoReflect

func (*AlloyDbSettings_PrimaryInstanceSettings) Reset

func (*AlloyDbSettings_PrimaryInstanceSettings) SetDatabaseFlags

func (x *AlloyDbSettings_PrimaryInstanceSettings) SetDatabaseFlags(v map[string]string)

func (*AlloyDbSettings_PrimaryInstanceSettings) SetId

func (*AlloyDbSettings_PrimaryInstanceSettings) SetLabels

func (*AlloyDbSettings_PrimaryInstanceSettings) SetMachineConfig

func (*AlloyDbSettings_PrimaryInstanceSettings) SetPrivateIp

func (*AlloyDbSettings_PrimaryInstanceSettings) String

type AlloyDbSettings_PrimaryInstanceSettings_MachineConfig

type AlloyDbSettings_PrimaryInstanceSettings_MachineConfig struct {

	// The number of CPU's in the VM instance.
	CpuCount int32 `protobuf:"varint,1,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	// contains filtered or unexported fields
}

MachineConfig describes the configuration of a machine.

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) GetCpuCount

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) ProtoMessage

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) ProtoReflect

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) Reset

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) SetCpuCount

func (*AlloyDbSettings_PrimaryInstanceSettings_MachineConfig) String

type AlloyDbSettings_PrimaryInstanceSettings_MachineConfig_builder

type AlloyDbSettings_PrimaryInstanceSettings_MachineConfig_builder struct {

	// The number of CPU's in the VM instance.
	CpuCount int32
	// contains filtered or unexported fields
}

func (AlloyDbSettings_PrimaryInstanceSettings_MachineConfig_builder) Build

type AlloyDbSettings_PrimaryInstanceSettings_builder

type AlloyDbSettings_PrimaryInstanceSettings_builder struct {

	// Required. The ID of the AlloyDB primary instance. The ID must satisfy the
	// regex expression "[a-z0-9-]+".
	Id string
	// Configuration for the machines that host the underlying
	// database engine.
	MachineConfig *AlloyDbSettings_PrimaryInstanceSettings_MachineConfig
	// Database flags to pass to AlloyDB when DMS is creating the AlloyDB
	// cluster and instances. See the AlloyDB documentation for how these can be
	// used.
	DatabaseFlags map[string]string
	// Labels for the AlloyDB primary instance created by DMS. An object
	// containing a list of 'key', 'value' pairs.
	Labels map[string]string
	// Output only. The private IP address for the Instance.
	// This is the connection endpoint for an end-user application.
	PrivateIp string
	// contains filtered or unexported fields
}

func (AlloyDbSettings_PrimaryInstanceSettings_builder) Build

type AlloyDbSettings_UserPassword

type AlloyDbSettings_UserPassword struct {

	// The database username.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Output only. Indicates if the initial_user.password field has been set.
	PasswordSet bool `protobuf:"varint,3,opt,name=password_set,json=passwordSet,proto3" json:"password_set,omitempty"`
	// contains filtered or unexported fields
}

The username/password for a database user. Used for specifying initial users at cluster creation time.

func (*AlloyDbSettings_UserPassword) GetPasswordSet

func (x *AlloyDbSettings_UserPassword) GetPasswordSet() bool

func (*AlloyDbSettings_UserPassword) GetUser

func (x *AlloyDbSettings_UserPassword) GetUser() string

func (*AlloyDbSettings_UserPassword) ProtoMessage

func (*AlloyDbSettings_UserPassword) ProtoMessage()

func (*AlloyDbSettings_UserPassword) ProtoReflect

func (*AlloyDbSettings_UserPassword) Reset

func (x *AlloyDbSettings_UserPassword) Reset()

func (*AlloyDbSettings_UserPassword) SetPasswordSet

func (x *AlloyDbSettings_UserPassword) SetPasswordSet(v bool)

func (*AlloyDbSettings_UserPassword) SetUser

func (x *AlloyDbSettings_UserPassword) SetUser(v string)

func (*AlloyDbSettings_UserPassword) String

type AlloyDbSettings_UserPassword_builder

type AlloyDbSettings_UserPassword_builder struct {

	// The database username.
	User string
	// Output only. Indicates if the initial_user.password field has been set.
	PasswordSet bool
	// contains filtered or unexported fields
}

func (AlloyDbSettings_UserPassword_builder) Build

type AlloyDbSettings_builder

type AlloyDbSettings_builder struct {

	// Required. The resource link for the VPC network in which cluster resources
	// are created and from which they are accessible via Private IP. The network
	// must belong to the same project as the cluster. It is specified in the
	// form: "projects/{project_number}/global/networks/{network_id}". This is
	// required to create a cluster.
	VpcNetwork string
	// Labels for the AlloyDB cluster created by DMS. An object containing a list
	// of 'key', 'value' pairs.
	Labels                  map[string]string
	PrimaryInstanceSettings *AlloyDbSettings_PrimaryInstanceSettings
	// contains filtered or unexported fields
}

func (AlloyDbSettings_builder) Build

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"`
	// Output only. The Cloud SQL database instance's additional (outgoing) public
	// IP. Used when the Cloud SQL database availability type is REGIONAL (i.e.
	// multiple zones / highly available).
	AdditionalPublicIp string `protobuf:"bytes,5,opt,name=additional_public_ip,json=additionalPublicIp,proto3" json:"additional_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) ClearSettings

func (x *CloudSqlConnectionProfile) ClearSettings()

func (*CloudSqlConnectionProfile) GetAdditionalPublicIp

func (x *CloudSqlConnectionProfile) GetAdditionalPublicIp() string

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

func (x *CloudSqlConnectionProfile) HasSettings() bool

func (*CloudSqlConnectionProfile) ProtoMessage

func (*CloudSqlConnectionProfile) ProtoMessage()

func (*CloudSqlConnectionProfile) ProtoReflect

func (*CloudSqlConnectionProfile) Reset

func (x *CloudSqlConnectionProfile) Reset()

func (*CloudSqlConnectionProfile) SetAdditionalPublicIp

func (x *CloudSqlConnectionProfile) SetAdditionalPublicIp(v string)

func (*CloudSqlConnectionProfile) SetCloudSqlId

func (x *CloudSqlConnectionProfile) SetCloudSqlId(v string)

func (*CloudSqlConnectionProfile) SetPrivateIp

func (x *CloudSqlConnectionProfile) SetPrivateIp(v string)

func (*CloudSqlConnectionProfile) SetPublicIp

func (x *CloudSqlConnectionProfile) SetPublicIp(v string)

func (*CloudSqlConnectionProfile) SetSettings

func (x *CloudSqlConnectionProfile) SetSettings(v *CloudSqlSettings)

func (*CloudSqlConnectionProfile) String

func (x *CloudSqlConnectionProfile) String() string

type CloudSqlConnectionProfile_builder

type CloudSqlConnectionProfile_builder struct {

	// Output only. The Cloud SQL instance ID that this connection profile is
	// associated with.
	CloudSqlId string
	// Immutable. Metadata used to create the destination Cloud SQL database.
	Settings *CloudSqlSettings
	// Output only. The Cloud SQL database instance's private IP.
	PrivateIp string
	// Output only. The Cloud SQL database instance's public IP.
	PublicIp string
	// Output only. The Cloud SQL database instance's additional (outgoing) public
	// IP. Used when the Cloud SQL database availability type is REGIONAL (i.e.
	// multiple zones / highly available).
	AdditionalPublicIp string
	// contains filtered or unexported fields
}

func (CloudSqlConnectionProfile_builder) Build

type CloudSqlSettings

type CloudSqlSettings struct {

	// The database engine type and version.
	DatabaseVersion CloudSqlSettings_SqlDatabaseVersion `` /* 180-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 `` /* 165-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 `` /* 184-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 `` /* 174-byte string literal not displayed */
	// The type of storage: `PD_SSD` (default) or `PD_HDD`.
	DataDiskType CloudSqlSettings_SqlDataDiskType `` /* 170-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 database instance is
	// located.
	Zone string `protobuf:"bytes,11,opt,name=zone,proto3" json:"zone,omitempty"`
	// Optional. The Google Cloud Platform zone where the failover Cloud SQL
	// database instance is located. Used when the Cloud SQL database availability
	// type is REGIONAL (i.e. multiple zones / highly available).
	SecondaryZone string `protobuf:"bytes,18,opt,name=secondary_zone,json=secondaryZone,proto3" json:"secondary_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"`
	// 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"`
	// The KMS key name used for the csql instance.
	CmekKeyName string `protobuf:"bytes,16,opt,name=cmek_key_name,json=cmekKeyName,proto3" json:"cmek_key_name,omitempty"`
	// Optional. Availability type. Potential values:
	// *  `ZONAL`: The instance serves data from only one zone. Outages in that
	// zone affect data availability.
	// *  `REGIONAL`: The instance can serve data from more than one zone in a
	// region (it is highly available).
	AvailabilityType CloudSqlSettings_SqlAvailabilityType `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

Settings for creating a Cloud SQL database instance.

func (*CloudSqlSettings) ClearAutoStorageIncrease

func (x *CloudSqlSettings) ClearAutoStorageIncrease()

func (*CloudSqlSettings) ClearDataDiskSizeGb

func (x *CloudSqlSettings) ClearDataDiskSizeGb()

func (*CloudSqlSettings) ClearIpConfig

func (x *CloudSqlSettings) ClearIpConfig()

func (*CloudSqlSettings) ClearStorageAutoResizeLimit

func (x *CloudSqlSettings) ClearStorageAutoResizeLimit()

func (*CloudSqlSettings) GetActivationPolicy

func (x *CloudSqlSettings) GetActivationPolicy() CloudSqlSettings_SqlActivationPolicy

func (*CloudSqlSettings) GetAutoStorageIncrease

func (x *CloudSqlSettings) GetAutoStorageIncrease() *wrapperspb.BoolValue

func (*CloudSqlSettings) GetAvailabilityType

func (x *CloudSqlSettings) GetAvailabilityType() CloudSqlSettings_SqlAvailabilityType

func (*CloudSqlSettings) GetCmekKeyName

func (x *CloudSqlSettings) GetCmekKeyName() string

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

func (x *CloudSqlSettings) GetRootPasswordSet() bool

func (*CloudSqlSettings) GetSecondaryZone

func (x *CloudSqlSettings) GetSecondaryZone() string

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

func (x *CloudSqlSettings) HasAutoStorageIncrease() bool

func (*CloudSqlSettings) HasDataDiskSizeGb

func (x *CloudSqlSettings) HasDataDiskSizeGb() bool

func (*CloudSqlSettings) HasIpConfig

func (x *CloudSqlSettings) HasIpConfig() bool

func (*CloudSqlSettings) HasStorageAutoResizeLimit

func (x *CloudSqlSettings) HasStorageAutoResizeLimit() bool

func (*CloudSqlSettings) ProtoMessage

func (*CloudSqlSettings) ProtoMessage()

func (*CloudSqlSettings) ProtoReflect

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

func (*CloudSqlSettings) Reset

func (x *CloudSqlSettings) Reset()

func (*CloudSqlSettings) SetActivationPolicy

func (x *CloudSqlSettings) SetActivationPolicy(v CloudSqlSettings_SqlActivationPolicy)

func (*CloudSqlSettings) SetAutoStorageIncrease

func (x *CloudSqlSettings) SetAutoStorageIncrease(v *wrapperspb.BoolValue)

func (*CloudSqlSettings) SetAvailabilityType

func (x *CloudSqlSettings) SetAvailabilityType(v CloudSqlSettings_SqlAvailabilityType)

func (*CloudSqlSettings) SetCmekKeyName

func (x *CloudSqlSettings) SetCmekKeyName(v string)

func (*CloudSqlSettings) SetCollation

func (x *CloudSqlSettings) SetCollation(v string)

func (*CloudSqlSettings) SetDataDiskSizeGb

func (x *CloudSqlSettings) SetDataDiskSizeGb(v *wrapperspb.Int64Value)

func (*CloudSqlSettings) SetDataDiskType

func (x *CloudSqlSettings) SetDataDiskType(v CloudSqlSettings_SqlDataDiskType)

func (*CloudSqlSettings) SetDatabaseFlags

func (x *CloudSqlSettings) SetDatabaseFlags(v map[string]string)

func (*CloudSqlSettings) SetDatabaseVersion

func (x *CloudSqlSettings) SetDatabaseVersion(v CloudSqlSettings_SqlDatabaseVersion)

func (*CloudSqlSettings) SetIpConfig

func (x *CloudSqlSettings) SetIpConfig(v *SqlIpConfig)

func (*CloudSqlSettings) SetRootPasswordSet

func (x *CloudSqlSettings) SetRootPasswordSet(v bool)

func (*CloudSqlSettings) SetSecondaryZone

func (x *CloudSqlSettings) SetSecondaryZone(v string)

func (*CloudSqlSettings) SetSourceId

func (x *CloudSqlSettings) SetSourceId(v string)

func (*CloudSqlSettings) SetStorageAutoResizeLimit

func (x *CloudSqlSettings) SetStorageAutoResizeLimit(v *wrapperspb.Int64Value)

func (*CloudSqlSettings) SetTier

func (x *CloudSqlSettings) SetTier(v string)

func (*CloudSqlSettings) SetUserLabels

func (x *CloudSqlSettings) SetUserLabels(v map[string]string)

func (*CloudSqlSettings) SetZone

func (x *CloudSqlSettings) SetZone(v string)

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

func (CloudSqlSettings_SqlActivationPolicy) String

func (CloudSqlSettings_SqlActivationPolicy) Type

type CloudSqlSettings_SqlAvailabilityType

type CloudSqlSettings_SqlAvailabilityType int32

The availability type of the given Cloud SQL instance.

const (
	// This is an unknown Availability type.
	CloudSqlSettings_SQL_AVAILABILITY_TYPE_UNSPECIFIED CloudSqlSettings_SqlAvailabilityType = 0
	// Zonal availablility instance.
	CloudSqlSettings_ZONAL CloudSqlSettings_SqlAvailabilityType = 1
	// Regional availability instance.
	CloudSqlSettings_REGIONAL CloudSqlSettings_SqlAvailabilityType = 2
)

func (CloudSqlSettings_SqlAvailabilityType) Descriptor

func (CloudSqlSettings_SqlAvailabilityType) Enum

func (CloudSqlSettings_SqlAvailabilityType) Number

func (CloudSqlSettings_SqlAvailabilityType) String

func (CloudSqlSettings_SqlAvailabilityType) 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) 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
	// PostgreSQL 14.
	CloudSqlSettings_POSTGRES_14 CloudSqlSettings_SqlDatabaseVersion = 17
)

func (CloudSqlSettings_SqlDatabaseVersion) Descriptor

func (CloudSqlSettings_SqlDatabaseVersion) Enum

func (CloudSqlSettings_SqlDatabaseVersion) Number

func (CloudSqlSettings_SqlDatabaseVersion) String

func (CloudSqlSettings_SqlDatabaseVersion) Type

type CloudSqlSettings_builder

type CloudSqlSettings_builder struct {

	// The database engine type and version.
	DatabaseVersion CloudSqlSettings_SqlDatabaseVersion
	// 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
	// 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
	// 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
	// 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
	// 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
	// [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
	// 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
	// The type of storage: `PD_SSD` (default) or `PD_HDD`.
	DataDiskType CloudSqlSettings_SqlDataDiskType
	// The storage capacity available to the database, in GB.
	// The minimum (and default) size is 10GB.
	DataDiskSizeGb *wrapperspb.Int64Value
	// The Google Cloud Platform zone where your Cloud SQL database instance is
	// located.
	Zone string
	// Optional. The Google Cloud Platform zone where the failover Cloud SQL
	// database instance is located. Used when the Cloud SQL database availability
	// type is REGIONAL (i.e. multiple zones / highly available).
	SecondaryZone string
	// The Database Migration Service source connection profile ID,
	// in the format:
	// `projects/my_project_name/locations/us-central1/connectionProfiles/connection_profile_ID`
	SourceId string
	// Output only. Indicates If this connection profile root password is stored.
	RootPasswordSet bool
	// The Cloud SQL default instance level collation.
	Collation string
	// The KMS key name used for the csql instance.
	CmekKeyName string
	// Optional. Availability type. Potential values:
	// *  `ZONAL`: The instance serves data from only one zone. Outages in that
	// zone affect data availability.
	// *  `REGIONAL`: The instance can serve data from more than one zone in a
	// region (it is highly available).
	AvailabilityType CloudSqlSettings_SqlAvailabilityType
	// contains filtered or unexported fields
}

func (CloudSqlSettings_builder) Build

type ConnectionProfile

type ConnectionProfile struct {

	// The name of this connection profile resource in the form of
	// projects/{project}/locations/{location}/connectionProfiles/{connectionProfile}.
	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 `` /* 139-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.events.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 valid to be assigned to ConnectionProfile:
	//
	//	*ConnectionProfile_Mysql
	//	*ConnectionProfile_Postgresql
	//	*ConnectionProfile_Cloudsql
	//	*ConnectionProfile_Alloydb
	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.events.cloud.clouddms.v1.DatabaseProvider" json:"provider,omitempty"`
	// contains filtered or unexported fields
}

A connection profile definition.

func (*ConnectionProfile) ClearAlloydb

func (x *ConnectionProfile) ClearAlloydb()

func (*ConnectionProfile) ClearCloudsql

func (x *ConnectionProfile) ClearCloudsql()

func (*ConnectionProfile) ClearConnectionProfile

func (x *ConnectionProfile) ClearConnectionProfile()

func (*ConnectionProfile) ClearCreateTime

func (x *ConnectionProfile) ClearCreateTime()

func (*ConnectionProfile) ClearError

func (x *ConnectionProfile) ClearError()

func (*ConnectionProfile) ClearMysql

func (x *ConnectionProfile) ClearMysql()

func (*ConnectionProfile) ClearPostgresql

func (x *ConnectionProfile) ClearPostgresql()

func (*ConnectionProfile) ClearUpdateTime

func (x *ConnectionProfile) ClearUpdateTime()

func (*ConnectionProfile) GetAlloydb

func (*ConnectionProfile) GetCloudsql

func (x *ConnectionProfile) GetCloudsql() *CloudSqlConnectionProfile

func (*ConnectionProfile) GetConnectionProfile

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

func (x *ConnectionProfile) HasAlloydb() bool

func (*ConnectionProfile) HasCloudsql

func (x *ConnectionProfile) HasCloudsql() bool

func (*ConnectionProfile) HasConnectionProfile

func (x *ConnectionProfile) HasConnectionProfile() bool

func (*ConnectionProfile) HasCreateTime

func (x *ConnectionProfile) HasCreateTime() bool

func (*ConnectionProfile) HasError

func (x *ConnectionProfile) HasError() bool

func (*ConnectionProfile) HasMysql

func (x *ConnectionProfile) HasMysql() bool

func (*ConnectionProfile) HasPostgresql

func (x *ConnectionProfile) HasPostgresql() bool

func (*ConnectionProfile) HasUpdateTime

func (x *ConnectionProfile) HasUpdateTime() bool

func (*ConnectionProfile) ProtoMessage

func (*ConnectionProfile) ProtoMessage()

func (*ConnectionProfile) ProtoReflect

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

func (*ConnectionProfile) Reset

func (x *ConnectionProfile) Reset()

func (*ConnectionProfile) SetAlloydb

func (x *ConnectionProfile) SetAlloydb(v *AlloyDbConnectionProfile)

func (*ConnectionProfile) SetCloudsql

func (x *ConnectionProfile) SetCloudsql(v *CloudSqlConnectionProfile)

func (*ConnectionProfile) SetCreateTime

func (x *ConnectionProfile) SetCreateTime(v *timestamppb.Timestamp)

func (*ConnectionProfile) SetDisplayName

func (x *ConnectionProfile) SetDisplayName(v string)

func (*ConnectionProfile) SetError

func (x *ConnectionProfile) SetError(v *status.Status)

func (*ConnectionProfile) SetLabels

func (x *ConnectionProfile) SetLabels(v map[string]string)

func (*ConnectionProfile) SetMysql

func (x *ConnectionProfile) SetMysql(v *MySqlConnectionProfile)

func (*ConnectionProfile) SetName

func (x *ConnectionProfile) SetName(v string)

func (*ConnectionProfile) SetPostgresql

func (x *ConnectionProfile) SetPostgresql(v *PostgreSqlConnectionProfile)

func (*ConnectionProfile) SetProvider

func (x *ConnectionProfile) SetProvider(v DatabaseProvider)

func (*ConnectionProfile) SetState

func (*ConnectionProfile) SetUpdateTime

func (x *ConnectionProfile) SetUpdateTime(v *timestamppb.Timestamp)

func (*ConnectionProfile) String

func (x *ConnectionProfile) String() string

func (*ConnectionProfile) WhichConnectionProfile

func (x *ConnectionProfile) WhichConnectionProfile() case_ConnectionProfile_ConnectionProfile

type ConnectionProfileCreatedEvent

type ConnectionProfileCreatedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is created.

func (*ConnectionProfileCreatedEvent) ClearData

func (x *ConnectionProfileCreatedEvent) ClearData()

func (*ConnectionProfileCreatedEvent) GetData

func (*ConnectionProfileCreatedEvent) HasData

func (x *ConnectionProfileCreatedEvent) HasData() bool

func (*ConnectionProfileCreatedEvent) ProtoMessage

func (*ConnectionProfileCreatedEvent) ProtoMessage()

func (*ConnectionProfileCreatedEvent) ProtoReflect

func (*ConnectionProfileCreatedEvent) Reset

func (x *ConnectionProfileCreatedEvent) Reset()

func (*ConnectionProfileCreatedEvent) SetData

func (*ConnectionProfileCreatedEvent) String

type ConnectionProfileCreatedEvent_builder

type ConnectionProfileCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileCreatedEvent_builder) Build

type ConnectionProfileDeletedEvent

type ConnectionProfileDeletedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is deleted.

func (*ConnectionProfileDeletedEvent) ClearData

func (x *ConnectionProfileDeletedEvent) ClearData()

func (*ConnectionProfileDeletedEvent) GetData

func (*ConnectionProfileDeletedEvent) HasData

func (x *ConnectionProfileDeletedEvent) HasData() bool

func (*ConnectionProfileDeletedEvent) ProtoMessage

func (*ConnectionProfileDeletedEvent) ProtoMessage()

func (*ConnectionProfileDeletedEvent) ProtoReflect

func (*ConnectionProfileDeletedEvent) Reset

func (x *ConnectionProfileDeletedEvent) Reset()

func (*ConnectionProfileDeletedEvent) SetData

func (*ConnectionProfileDeletedEvent) String

type ConnectionProfileDeletedEvent_builder

type ConnectionProfileDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileDeletedEvent_builder) Build

type ConnectionProfileEventData

type ConnectionProfileEventData struct {

	// Optional. The ConnectionProfile event payload. Unset for deletion events.
	Payload *ConnectionProfile `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all ConnectionProfile events.

func (*ConnectionProfileEventData) ClearPayload

func (x *ConnectionProfileEventData) ClearPayload()

func (*ConnectionProfileEventData) GetPayload

func (*ConnectionProfileEventData) HasPayload

func (x *ConnectionProfileEventData) HasPayload() bool

func (*ConnectionProfileEventData) ProtoMessage

func (*ConnectionProfileEventData) ProtoMessage()

func (*ConnectionProfileEventData) ProtoReflect

func (*ConnectionProfileEventData) Reset

func (x *ConnectionProfileEventData) Reset()

func (*ConnectionProfileEventData) SetPayload

func (*ConnectionProfileEventData) String

func (x *ConnectionProfileEventData) String() string

type ConnectionProfileEventData_builder

type ConnectionProfileEventData_builder struct {

	// Optional. The ConnectionProfile event payload. Unset for deletion events.
	Payload *ConnectionProfile
	// contains filtered or unexported fields
}

func (ConnectionProfileEventData_builder) Build

type ConnectionProfileUpdatedEvent

type ConnectionProfileUpdatedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is updated.

func (*ConnectionProfileUpdatedEvent) ClearData

func (x *ConnectionProfileUpdatedEvent) ClearData()

func (*ConnectionProfileUpdatedEvent) GetData

func (*ConnectionProfileUpdatedEvent) HasData

func (x *ConnectionProfileUpdatedEvent) HasData() bool

func (*ConnectionProfileUpdatedEvent) ProtoMessage

func (*ConnectionProfileUpdatedEvent) ProtoMessage()

func (*ConnectionProfileUpdatedEvent) ProtoReflect

func (*ConnectionProfileUpdatedEvent) Reset

func (x *ConnectionProfileUpdatedEvent) Reset()

func (*ConnectionProfileUpdatedEvent) SetData

func (*ConnectionProfileUpdatedEvent) String

type ConnectionProfileUpdatedEvent_builder

type ConnectionProfileUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileUpdatedEvent_builder) Build

type ConnectionProfile_Alloydb

type ConnectionProfile_Alloydb struct {
	// An AlloyDB cluster connection profile.
	Alloydb *AlloyDbConnectionProfile `protobuf:"bytes,105,opt,name=alloydb,proto3,oneof"`
}

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

func (ConnectionProfile_State) String

func (x ConnectionProfile_State) String() string

func (ConnectionProfile_State) Type

type ConnectionProfile_builder

type ConnectionProfile_builder struct {

	// The name of this connection profile resource in the form of
	// projects/{project}/locations/{location}/connectionProfiles/{connectionProfile}.
	Name string
	// 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
	// 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
	// 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
	// The current connection profile state (e.g. DRAFT, READY, or FAILED).
	State ConnectionProfile_State
	// The connection profile display name.
	DisplayName string

	// Fields of oneof ConnectionProfile:
	// A MySQL database connection profile.
	Mysql *MySqlConnectionProfile
	// A PostgreSQL database connection profile.
	Postgresql *PostgreSqlConnectionProfile
	// A CloudSQL database connection profile.
	Cloudsql *CloudSqlConnectionProfile
	// An AlloyDB cluster connection profile.
	Alloydb *AlloyDbConnectionProfile
	// -- end of ConnectionProfile
	// Output only. The error details in case of state FAILED.
	Error *status.Status
	// The database provider.
	Provider DatabaseProvider
	// contains filtered or unexported fields
}

func (ConnectionProfile_builder) Build

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) 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
	// Amazon Aurora.
	DatabaseProvider_AURORA DatabaseProvider = 3
	// AlloyDB.
	DatabaseProvider_ALLOYDB DatabaseProvider = 4
)

func (DatabaseProvider) Descriptor

func (DatabaseProvider) Enum

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.events.cloud.clouddms.v1.DatabaseProvider" json:"provider,omitempty"`
	// The database engine.
	Engine DatabaseEngine `protobuf:"varint,2,opt,name=engine,proto3,enum=google.events.cloud.clouddms.v1.DatabaseEngine" json:"engine,omitempty"`
	// contains filtered or unexported fields
}

A message defining the database engine and provider.

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

func (x *DatabaseType) SetEngine(v DatabaseEngine)

func (*DatabaseType) SetProvider

func (x *DatabaseType) SetProvider(v DatabaseProvider)

func (*DatabaseType) String

func (x *DatabaseType) String() string

type DatabaseType_builder

type DatabaseType_builder struct {

	// The database provider.
	Provider DatabaseProvider
	// The database engine.
	Engine DatabaseEngine
	// contains filtered or unexported fields
}

func (DatabaseType_builder) Build

func (b0 DatabaseType_builder) Build() *DatabaseType

type MigrationJob

type MigrationJob struct {

	// The name (URI) of this migration job resource, in the form of:
	// projects/{project}/locations/{location}/migrationJobs/{migrationJob}.
	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 `` /* 139-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.events.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.events.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.events.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]).
	// This field and the "dump_flags" field are mutually exclusive.
	DumpPath string `protobuf:"bytes,9,opt,name=dump_path,json=dumpPath,proto3" json:"dump_path,omitempty"`
	// The initial dump flags.
	// This field and the "dump_path" field are mutually exclusive.
	DumpFlags *MigrationJob_DumpFlags `protobuf:"bytes,17,opt,name=dump_flags,json=dumpFlags,proto3" json:"dump_flags,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 valid to be assigned 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) ClearConnectivity

func (x *MigrationJob) ClearConnectivity()

func (*MigrationJob) ClearCreateTime

func (x *MigrationJob) ClearCreateTime()

func (*MigrationJob) ClearDestinationDatabase

func (x *MigrationJob) ClearDestinationDatabase()

func (*MigrationJob) ClearDumpFlags

func (x *MigrationJob) ClearDumpFlags()

func (*MigrationJob) ClearDuration

func (x *MigrationJob) ClearDuration()

func (*MigrationJob) ClearEndTime

func (x *MigrationJob) ClearEndTime()

func (*MigrationJob) ClearError

func (x *MigrationJob) ClearError()

func (*MigrationJob) ClearReverseSshConnectivity

func (x *MigrationJob) ClearReverseSshConnectivity()

func (*MigrationJob) ClearSourceDatabase

func (x *MigrationJob) ClearSourceDatabase()

func (*MigrationJob) ClearStaticIpConnectivity

func (x *MigrationJob) ClearStaticIpConnectivity()

func (*MigrationJob) ClearUpdateTime

func (x *MigrationJob) ClearUpdateTime()

func (*MigrationJob) ClearVpcPeeringConnectivity

func (x *MigrationJob) ClearVpcPeeringConnectivity()

func (*MigrationJob) GetConnectivity

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

func (x *MigrationJob) GetDumpFlags() *MigrationJob_DumpFlags

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

func (x *MigrationJob) HasConnectivity() bool

func (*MigrationJob) HasCreateTime

func (x *MigrationJob) HasCreateTime() bool

func (*MigrationJob) HasDestinationDatabase

func (x *MigrationJob) HasDestinationDatabase() bool

func (*MigrationJob) HasDumpFlags

func (x *MigrationJob) HasDumpFlags() bool

func (*MigrationJob) HasDuration

func (x *MigrationJob) HasDuration() bool

func (*MigrationJob) HasEndTime

func (x *MigrationJob) HasEndTime() bool

func (*MigrationJob) HasError

func (x *MigrationJob) HasError() bool

func (*MigrationJob) HasReverseSshConnectivity

func (x *MigrationJob) HasReverseSshConnectivity() bool

func (*MigrationJob) HasSourceDatabase

func (x *MigrationJob) HasSourceDatabase() bool

func (*MigrationJob) HasStaticIpConnectivity

func (x *MigrationJob) HasStaticIpConnectivity() bool

func (*MigrationJob) HasUpdateTime

func (x *MigrationJob) HasUpdateTime() bool

func (*MigrationJob) HasVpcPeeringConnectivity

func (x *MigrationJob) HasVpcPeeringConnectivity() bool

func (*MigrationJob) ProtoMessage

func (*MigrationJob) ProtoMessage()

func (*MigrationJob) ProtoReflect

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

func (*MigrationJob) Reset

func (x *MigrationJob) Reset()

func (*MigrationJob) SetCreateTime

func (x *MigrationJob) SetCreateTime(v *timestamppb.Timestamp)

func (*MigrationJob) SetDestination

func (x *MigrationJob) SetDestination(v string)

func (*MigrationJob) SetDestinationDatabase

func (x *MigrationJob) SetDestinationDatabase(v *DatabaseType)

func (*MigrationJob) SetDisplayName

func (x *MigrationJob) SetDisplayName(v string)

func (*MigrationJob) SetDumpFlags

func (x *MigrationJob) SetDumpFlags(v *MigrationJob_DumpFlags)

func (*MigrationJob) SetDumpPath

func (x *MigrationJob) SetDumpPath(v string)

func (*MigrationJob) SetDuration

func (x *MigrationJob) SetDuration(v *durationpb.Duration)

func (*MigrationJob) SetEndTime

func (x *MigrationJob) SetEndTime(v *timestamppb.Timestamp)

func (*MigrationJob) SetError

func (x *MigrationJob) SetError(v *status.Status)

func (*MigrationJob) SetLabels

func (x *MigrationJob) SetLabels(v map[string]string)

func (*MigrationJob) SetName

func (x *MigrationJob) SetName(v string)

func (*MigrationJob) SetPhase

func (x *MigrationJob) SetPhase(v MigrationJob_Phase)

func (*MigrationJob) SetReverseSshConnectivity

func (x *MigrationJob) SetReverseSshConnectivity(v *ReverseSshConnectivity)

func (*MigrationJob) SetSource

func (x *MigrationJob) SetSource(v string)

func (*MigrationJob) SetSourceDatabase

func (x *MigrationJob) SetSourceDatabase(v *DatabaseType)

func (*MigrationJob) SetState

func (x *MigrationJob) SetState(v MigrationJob_State)

func (*MigrationJob) SetStaticIpConnectivity

func (x *MigrationJob) SetStaticIpConnectivity(v *StaticIpConnectivity)

func (*MigrationJob) SetType

func (x *MigrationJob) SetType(v MigrationJob_Type)

func (*MigrationJob) SetUpdateTime

func (x *MigrationJob) SetUpdateTime(v *timestamppb.Timestamp)

func (*MigrationJob) SetVpcPeeringConnectivity

func (x *MigrationJob) SetVpcPeeringConnectivity(v *VpcPeeringConnectivity)

func (*MigrationJob) String

func (x *MigrationJob) String() string

func (*MigrationJob) WhichConnectivity

func (x *MigrationJob) WhichConnectivity() case_MigrationJob_Connectivity

type MigrationJobCreatedEvent

type MigrationJobCreatedEvent struct {

	// The data associated with the event.
	Data *MigrationJobEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a MigrationJob is created.

func (*MigrationJobCreatedEvent) ClearData

func (x *MigrationJobCreatedEvent) ClearData()

func (*MigrationJobCreatedEvent) GetData

func (*MigrationJobCreatedEvent) HasData

func (x *MigrationJobCreatedEvent) HasData() bool

func (*MigrationJobCreatedEvent) ProtoMessage

func (*MigrationJobCreatedEvent) ProtoMessage()

func (*MigrationJobCreatedEvent) ProtoReflect

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

func (*MigrationJobCreatedEvent) Reset

func (x *MigrationJobCreatedEvent) Reset()

func (*MigrationJobCreatedEvent) SetData

func (*MigrationJobCreatedEvent) String

func (x *MigrationJobCreatedEvent) String() string

type MigrationJobCreatedEvent_builder

type MigrationJobCreatedEvent_builder struct {

	// The data associated with the event.
	Data *MigrationJobEventData
	// contains filtered or unexported fields
}

func (MigrationJobCreatedEvent_builder) Build

type MigrationJobDeletedEvent

type MigrationJobDeletedEvent struct {

	// The data associated with the event.
	Data *MigrationJobEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a MigrationJob is deleted.

func (*MigrationJobDeletedEvent) ClearData

func (x *MigrationJobDeletedEvent) ClearData()

func (*MigrationJobDeletedEvent) GetData

func (*MigrationJobDeletedEvent) HasData

func (x *MigrationJobDeletedEvent) HasData() bool

func (*MigrationJobDeletedEvent) ProtoMessage

func (*MigrationJobDeletedEvent) ProtoMessage()

func (*MigrationJobDeletedEvent) ProtoReflect

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

func (*MigrationJobDeletedEvent) Reset

func (x *MigrationJobDeletedEvent) Reset()

func (*MigrationJobDeletedEvent) SetData

func (*MigrationJobDeletedEvent) String

func (x *MigrationJobDeletedEvent) String() string

type MigrationJobDeletedEvent_builder

type MigrationJobDeletedEvent_builder struct {

	// The data associated with the event.
	Data *MigrationJobEventData
	// contains filtered or unexported fields
}

func (MigrationJobDeletedEvent_builder) Build

type MigrationJobEventData

type MigrationJobEventData struct {

	// Optional. The MigrationJob event payload. Unset for deletion events.
	Payload *MigrationJob `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all MigrationJob events.

func (*MigrationJobEventData) ClearPayload

func (x *MigrationJobEventData) ClearPayload()

func (*MigrationJobEventData) GetPayload

func (x *MigrationJobEventData) GetPayload() *MigrationJob

func (*MigrationJobEventData) HasPayload

func (x *MigrationJobEventData) HasPayload() bool

func (*MigrationJobEventData) ProtoMessage

func (*MigrationJobEventData) ProtoMessage()

func (*MigrationJobEventData) ProtoReflect

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

func (*MigrationJobEventData) Reset

func (x *MigrationJobEventData) Reset()

func (*MigrationJobEventData) SetPayload

func (x *MigrationJobEventData) SetPayload(v *MigrationJob)

func (*MigrationJobEventData) String

func (x *MigrationJobEventData) String() string

type MigrationJobEventData_builder

type MigrationJobEventData_builder struct {

	// Optional. The MigrationJob event payload. Unset for deletion events.
	Payload *MigrationJob
	// contains filtered or unexported fields
}

func (MigrationJobEventData_builder) Build

type MigrationJobUpdatedEvent

type MigrationJobUpdatedEvent struct {

	// The data associated with the event.
	Data *MigrationJobEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a MigrationJob is updated.

func (*MigrationJobUpdatedEvent) ClearData

func (x *MigrationJobUpdatedEvent) ClearData()

func (*MigrationJobUpdatedEvent) GetData

func (*MigrationJobUpdatedEvent) HasData

func (x *MigrationJobUpdatedEvent) HasData() bool

func (*MigrationJobUpdatedEvent) ProtoMessage

func (*MigrationJobUpdatedEvent) ProtoMessage()

func (*MigrationJobUpdatedEvent) ProtoReflect

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

func (*MigrationJobUpdatedEvent) Reset

func (x *MigrationJobUpdatedEvent) Reset()

func (*MigrationJobUpdatedEvent) SetData

func (*MigrationJobUpdatedEvent) String

func (x *MigrationJobUpdatedEvent) String() string

type MigrationJobUpdatedEvent_builder

type MigrationJobUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *MigrationJobEventData
	// contains filtered or unexported fields
}

func (MigrationJobUpdatedEvent_builder) Build

type MigrationJob_DumpFlag

type MigrationJob_DumpFlag struct {

	// The name of the flag
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The value of the flag.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Dump flag definition.

func (*MigrationJob_DumpFlag) GetName

func (x *MigrationJob_DumpFlag) GetName() string

func (*MigrationJob_DumpFlag) GetValue

func (x *MigrationJob_DumpFlag) GetValue() string

func (*MigrationJob_DumpFlag) ProtoMessage

func (*MigrationJob_DumpFlag) ProtoMessage()

func (*MigrationJob_DumpFlag) ProtoReflect

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

func (*MigrationJob_DumpFlag) Reset

func (x *MigrationJob_DumpFlag) Reset()

func (*MigrationJob_DumpFlag) SetName

func (x *MigrationJob_DumpFlag) SetName(v string)

func (*MigrationJob_DumpFlag) SetValue

func (x *MigrationJob_DumpFlag) SetValue(v string)

func (*MigrationJob_DumpFlag) String

func (x *MigrationJob_DumpFlag) String() string

type MigrationJob_DumpFlag_builder

type MigrationJob_DumpFlag_builder struct {

	// The name of the flag
	Name string
	// The value of the flag.
	Value string
	// contains filtered or unexported fields
}

func (MigrationJob_DumpFlag_builder) Build

type MigrationJob_DumpFlags

type MigrationJob_DumpFlags struct {

	// The flags for the initial dump.
	DumpFlags []*MigrationJob_DumpFlag `protobuf:"bytes,1,rep,name=dump_flags,json=dumpFlags,proto3" json:"dump_flags,omitempty"`
	// contains filtered or unexported fields
}

Dump flags definition.

func (*MigrationJob_DumpFlags) GetDumpFlags

func (x *MigrationJob_DumpFlags) GetDumpFlags() []*MigrationJob_DumpFlag

func (*MigrationJob_DumpFlags) ProtoMessage

func (*MigrationJob_DumpFlags) ProtoMessage()

func (*MigrationJob_DumpFlags) ProtoReflect

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

func (*MigrationJob_DumpFlags) Reset

func (x *MigrationJob_DumpFlags) Reset()

func (*MigrationJob_DumpFlags) SetDumpFlags

func (x *MigrationJob_DumpFlags) SetDumpFlags(v []*MigrationJob_DumpFlag)

func (*MigrationJob_DumpFlags) String

func (x *MigrationJob_DumpFlags) String() string

type MigrationJob_DumpFlags_builder

type MigrationJob_DumpFlags_builder struct {

	// The flags for the initial dump.
	DumpFlags []*MigrationJob_DumpFlag
	// contains filtered or unexported fields
}

func (MigrationJob_DumpFlags_builder) Build

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

type MigrationJob_builder struct {

	// The name (URI) of this migration job resource, in the form of:
	// projects/{project}/locations/{location}/migrationJobs/{migrationJob}.
	Name string
	// 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
	// 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
	// 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
	// The migration job display name.
	DisplayName string
	// The current migration job state.
	State MigrationJob_State
	// Output only. The current migration job phase.
	Phase MigrationJob_Phase
	// Required. The migration job type.
	Type MigrationJob_Type
	// The path to the dump file in Google Cloud Storage,
	// in the format: (gs://[BUCKET_NAME]/[OBJECT_NAME]).
	// This field and the "dump_flags" field are mutually exclusive.
	DumpPath string
	// The initial dump flags.
	// This field and the "dump_path" field are mutually exclusive.
	DumpFlags *MigrationJob_DumpFlags
	// Required. The resource name (URI) of the source connection profile.
	Source string
	// Required. The resource name (URI) of the destination connection profile.
	Destination string

	// Fields of oneof Connectivity:
	// The details needed to communicate to the source over Reverse SSH
	// tunnel connectivity.
	ReverseSshConnectivity *ReverseSshConnectivity
	// The details of the VPC network that the source database is located in.
	VpcPeeringConnectivity *VpcPeeringConnectivity
	// static ip connectivity data (default, no additional details needed).
	StaticIpConnectivity *StaticIpConnectivity
	// -- end of 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
	// Output only. The error details in case of state FAILED.
	Error *status.Status
	// The database engine type and provider of the source.
	SourceDatabase *DatabaseType
	// The database engine type and provider of the destination.
	DestinationDatabase *DatabaseType
	// Output only. If the migration job is completed, the time when it was
	// completed.
	EndTime *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (MigrationJob_builder) Build

func (b0 MigrationJob_builder) Build() *MigrationJob

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"`
	// 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) ClearSsl

func (x *MySqlConnectionProfile) ClearSsl()

func (*MySqlConnectionProfile) GetCloudSqlId

func (x *MySqlConnectionProfile) GetCloudSqlId() string

func (*MySqlConnectionProfile) GetHost

func (x *MySqlConnectionProfile) GetHost() 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) HasSsl

func (x *MySqlConnectionProfile) HasSsl() bool

func (*MySqlConnectionProfile) ProtoMessage

func (*MySqlConnectionProfile) ProtoMessage()

func (*MySqlConnectionProfile) ProtoReflect

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

func (*MySqlConnectionProfile) Reset

func (x *MySqlConnectionProfile) Reset()

func (*MySqlConnectionProfile) SetCloudSqlId

func (x *MySqlConnectionProfile) SetCloudSqlId(v string)

func (*MySqlConnectionProfile) SetHost

func (x *MySqlConnectionProfile) SetHost(v string)

func (*MySqlConnectionProfile) SetPasswordSet

func (x *MySqlConnectionProfile) SetPasswordSet(v bool)

func (*MySqlConnectionProfile) SetPort

func (x *MySqlConnectionProfile) SetPort(v int32)

func (*MySqlConnectionProfile) SetSsl

func (x *MySqlConnectionProfile) SetSsl(v *SslConfig)

func (*MySqlConnectionProfile) SetUsername

func (x *MySqlConnectionProfile) SetUsername(v string)

func (*MySqlConnectionProfile) String

func (x *MySqlConnectionProfile) String() string

type MySqlConnectionProfile_builder

type MySqlConnectionProfile_builder struct {

	// Required. The IP or hostname of the source MySQL database.
	Host string
	// Required. The network port of the source MySQL database.
	Port int32
	// 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
	// Output only. Indicates If this connection profile password is stored.
	PasswordSet bool
	// SSL configuration for the destination to connect to the source database.
	Ssl *SslConfig
	// If the source is a Cloud SQL database, use this field to
	// provide the Cloud SQL instance ID of the source.
	CloudSqlId string
	// contains filtered or unexported fields
}

func (MySqlConnectionProfile_builder) Build

type NetworkArchitecture

type NetworkArchitecture int32
const (
	NetworkArchitecture_NETWORK_ARCHITECTURE_UNSPECIFIED NetworkArchitecture = 0
	// Instance is in Cloud SQL's old producer network architecture.
	NetworkArchitecture_NETWORK_ARCHITECTURE_OLD_CSQL_PRODUCER NetworkArchitecture = 1
	// Instance is in Cloud SQL's new producer network architecture.
	NetworkArchitecture_NETWORK_ARCHITECTURE_NEW_CSQL_PRODUCER NetworkArchitecture = 2
)

func (NetworkArchitecture) Descriptor

func (NetworkArchitecture) Enum

func (NetworkArchitecture) Number

func (NetworkArchitecture) String

func (x NetworkArchitecture) String() string

func (NetworkArchitecture) Type

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"`
	// 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"`
	// Output only. If the source is a Cloud SQL database, this field indicates
	// the network architecture it's associated with.
	NetworkArchitecture NetworkArchitecture `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

Specifies connection parameters required specifically for PostgreSQL databases.

func (*PostgreSqlConnectionProfile) ClearSsl

func (x *PostgreSqlConnectionProfile) ClearSsl()

func (*PostgreSqlConnectionProfile) GetCloudSqlId

func (x *PostgreSqlConnectionProfile) GetCloudSqlId() string

func (*PostgreSqlConnectionProfile) GetHost

func (x *PostgreSqlConnectionProfile) GetHost() string

func (*PostgreSqlConnectionProfile) GetNetworkArchitecture

func (x *PostgreSqlConnectionProfile) GetNetworkArchitecture() NetworkArchitecture

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

func (x *PostgreSqlConnectionProfile) HasSsl() bool

func (*PostgreSqlConnectionProfile) ProtoMessage

func (*PostgreSqlConnectionProfile) ProtoMessage()

func (*PostgreSqlConnectionProfile) ProtoReflect

func (*PostgreSqlConnectionProfile) Reset

func (x *PostgreSqlConnectionProfile) Reset()

func (*PostgreSqlConnectionProfile) SetCloudSqlId

func (x *PostgreSqlConnectionProfile) SetCloudSqlId(v string)

func (*PostgreSqlConnectionProfile) SetHost

func (x *PostgreSqlConnectionProfile) SetHost(v string)

func (*PostgreSqlConnectionProfile) SetNetworkArchitecture

func (x *PostgreSqlConnectionProfile) SetNetworkArchitecture(v NetworkArchitecture)

func (*PostgreSqlConnectionProfile) SetPasswordSet

func (x *PostgreSqlConnectionProfile) SetPasswordSet(v bool)

func (*PostgreSqlConnectionProfile) SetPort

func (x *PostgreSqlConnectionProfile) SetPort(v int32)

func (*PostgreSqlConnectionProfile) SetSsl

func (x *PostgreSqlConnectionProfile) SetSsl(v *SslConfig)

func (*PostgreSqlConnectionProfile) SetUsername

func (x *PostgreSqlConnectionProfile) SetUsername(v string)

func (*PostgreSqlConnectionProfile) String

func (x *PostgreSqlConnectionProfile) String() string

type PostgreSqlConnectionProfile_builder

type PostgreSqlConnectionProfile_builder struct {

	// Required. The IP or hostname of the source PostgreSQL database.
	Host string
	// Required. The network port of the source PostgreSQL database.
	Port int32
	// 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
	// Output only. Indicates If this connection profile password is stored.
	PasswordSet bool
	// SSL configuration for the destination to connect to the source database.
	Ssl *SslConfig
	// If the source is a Cloud SQL database, use this field to
	// provide the Cloud SQL instance ID of the source.
	CloudSqlId string
	// Output only. If the source is a Cloud SQL database, this field indicates
	// the network architecture it's associated with.
	NetworkArchitecture NetworkArchitecture
	// contains filtered or unexported fields
}

func (PostgreSqlConnectionProfile_builder) Build

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

func (x *ReverseSshConnectivity) SetVm(v string)

func (*ReverseSshConnectivity) SetVmIp

func (x *ReverseSshConnectivity) SetVmIp(v string)

func (*ReverseSshConnectivity) SetVmPort

func (x *ReverseSshConnectivity) SetVmPort(v int32)

func (*ReverseSshConnectivity) SetVpc

func (x *ReverseSshConnectivity) SetVpc(v string)

func (*ReverseSshConnectivity) String

func (x *ReverseSshConnectivity) String() string

type ReverseSshConnectivity_builder

type ReverseSshConnectivity_builder struct {

	// Required. The IP of the virtual machine (Compute Engine) used as the
	// bastion server for the SSH tunnel.
	VmIp string
	// Required. The forwarding port of the virtual machine (Compute Engine) used
	// as the bastion server for the SSH tunnel.
	VmPort int32
	// The name of the virtual machine (Compute Engine) used as the bastion server
	// for the SSH tunnel.
	Vm string
	// The name of the VPC to peer with the Cloud SQL private network.
	Vpc string
	// contains filtered or unexported fields
}

func (ReverseSshConnectivity_builder) Build

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 valid to be assigned to Expiration:
	//
	//	*SqlAclEntry_ExpireTime
	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) ClearExpiration

func (x *SqlAclEntry) ClearExpiration()

func (*SqlAclEntry) ClearExpireTime

func (x *SqlAclEntry) ClearExpireTime()

func (*SqlAclEntry) GetExpiration

func (x *SqlAclEntry) GetExpiration() isSqlAclEntry_Expiration

func (*SqlAclEntry) GetExpireTime

func (x *SqlAclEntry) GetExpireTime() *timestamppb.Timestamp

func (*SqlAclEntry) GetLabel

func (x *SqlAclEntry) GetLabel() string

func (*SqlAclEntry) GetValue

func (x *SqlAclEntry) GetValue() string

func (*SqlAclEntry) HasExpiration

func (x *SqlAclEntry) HasExpiration() bool

func (*SqlAclEntry) HasExpireTime

func (x *SqlAclEntry) HasExpireTime() bool

func (*SqlAclEntry) ProtoMessage

func (*SqlAclEntry) ProtoMessage()

func (*SqlAclEntry) ProtoReflect

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

func (*SqlAclEntry) Reset

func (x *SqlAclEntry) Reset()

func (*SqlAclEntry) SetExpireTime

func (x *SqlAclEntry) SetExpireTime(v *timestamppb.Timestamp)

func (*SqlAclEntry) SetLabel

func (x *SqlAclEntry) SetLabel(v string)

func (*SqlAclEntry) SetValue

func (x *SqlAclEntry) SetValue(v string)

func (*SqlAclEntry) String

func (x *SqlAclEntry) String() string

func (*SqlAclEntry) WhichExpiration

func (x *SqlAclEntry) WhichExpiration() case_SqlAclEntry_Expiration

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_builder

type SqlAclEntry_builder struct {

	// The allowlisted value for the access control list.
	Value string

	// Fields of oneof Expiration:
	// 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
	// -- end of Expiration
	// A label to identify this entry.
	Label string
	// contains filtered or unexported fields
}

func (SqlAclEntry_builder) Build

func (b0 SqlAclEntry_builder) Build() *SqlAclEntry

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

func (x *SqlIpConfig) ClearEnableIpv4()

func (*SqlIpConfig) ClearRequireSsl

func (x *SqlIpConfig) ClearRequireSsl()

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

func (x *SqlIpConfig) HasEnableIpv4() bool

func (*SqlIpConfig) HasRequireSsl

func (x *SqlIpConfig) HasRequireSsl() bool

func (*SqlIpConfig) ProtoMessage

func (*SqlIpConfig) ProtoMessage()

func (*SqlIpConfig) ProtoReflect

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

func (*SqlIpConfig) Reset

func (x *SqlIpConfig) Reset()

func (*SqlIpConfig) SetAuthorizedNetworks

func (x *SqlIpConfig) SetAuthorizedNetworks(v []*SqlAclEntry)

func (*SqlIpConfig) SetEnableIpv4

func (x *SqlIpConfig) SetEnableIpv4(v *wrapperspb.BoolValue)

func (*SqlIpConfig) SetPrivateNetwork

func (x *SqlIpConfig) SetPrivateNetwork(v string)

func (*SqlIpConfig) SetRequireSsl

func (x *SqlIpConfig) SetRequireSsl(v *wrapperspb.BoolValue)

func (*SqlIpConfig) String

func (x *SqlIpConfig) String() string

type SqlIpConfig_builder

type SqlIpConfig_builder struct {

	// Whether the instance should be assigned an IPv4 address or not.
	EnableIpv4 *wrapperspb.BoolValue
	// 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
	// Whether SSL connections over IP should be enforced or not.
	RequireSsl *wrapperspb.BoolValue
	// 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
	// contains filtered or unexported fields
}

func (SqlIpConfig_builder) Build

func (b0 SqlIpConfig_builder) Build() *SqlIpConfig

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.events.cloud.clouddms.v1.SslConfig_SslType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

SSL configuration information.

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

func (x *SslConfig) SetType(v SslConfig_SslType)

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

func (SslConfig_SslType) String

func (x SslConfig_SslType) String() string

func (SslConfig_SslType) Type

type SslConfig_builder

type SslConfig_builder struct {

	// Output only. The ssl config type according to 'client_key',
	// 'client_certificate' and 'ca_certificate'.
	Type SslConfig_SslType
	// contains filtered or unexported fields
}

func (SslConfig_builder) Build

func (b0 SslConfig_builder) Build() *SslConfig

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

type StaticIpConnectivity_builder struct {
	// contains filtered or unexported fields
}

func (StaticIpConnectivity_builder) Build

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

func (x *VpcPeeringConnectivity) SetVpc(v string)

func (*VpcPeeringConnectivity) String

func (x *VpcPeeringConnectivity) String() string

type VpcPeeringConnectivity_builder

type VpcPeeringConnectivity_builder struct {

	// The name of the VPC network to peer with the Cloud SQL private network.
	Vpc string
	// contains filtered or unexported fields
}

func (VpcPeeringConnectivity_builder) Build

Source Files

  • data.pb.go
  • events.pb.go

Jump to

Keyboard shortcuts

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