diff --git a/api_names_out.yaml b/api_names_out.yaml index 6553f3a397b..a23946b08e5 100644 --- a/api_names_out.yaml +++ b/api_names_out.yaml @@ -244359,6 +244359,10 @@ "/metastore:v1/AuditLogConfig/exemptedMembers": exempted_members "/metastore:v1/AuditLogConfig/exemptedMembers/exempted_member": exempted_member "/metastore:v1/AuditLogConfig/logType": log_type +"/metastore:v1/AutoscalingConfig": autoscaling_config +"/metastore:v1/AutoscalingConfig/autoscalingEnabled": autoscaling_enabled +"/metastore:v1/AutoscalingConfig/autoscalingFactor": autoscaling_factor +"/metastore:v1/AutoscalingConfig/limitConfig": limit_config "/metastore:v1/AuxiliaryVersionConfig": auxiliary_version_config "/metastore:v1/AuxiliaryVersionConfig/configOverrides": config_overrides "/metastore:v1/AuxiliaryVersionConfig/configOverrides/config_override": config_override @@ -244381,7 +244385,29 @@ "/metastore:v1/Binding/members": members "/metastore:v1/Binding/members/member": member "/metastore:v1/Binding/role": role +"/metastore:v1/CancelMigrationRequest": cancel_migration_request "/metastore:v1/CancelOperationRequest": cancel_operation_request +"/metastore:v1/CdcConfig": cdc_config +"/metastore:v1/CdcConfig/bucket": bucket +"/metastore:v1/CdcConfig/password": password +"/metastore:v1/CdcConfig/reverseProxySubnet": reverse_proxy_subnet +"/metastore:v1/CdcConfig/rootPath": root_path +"/metastore:v1/CdcConfig/subnetIpRange": subnet_ip_range +"/metastore:v1/CdcConfig/username": username +"/metastore:v1/CdcConfig/vpcNetwork": vpc_network +"/metastore:v1/CloudSQLConnectionConfig": cloud_sql_connection_config +"/metastore:v1/CloudSQLConnectionConfig/hiveDatabaseName": hive_database_name +"/metastore:v1/CloudSQLConnectionConfig/instanceConnectionName": instance_connection_name +"/metastore:v1/CloudSQLConnectionConfig/ipAddress": ip_address +"/metastore:v1/CloudSQLConnectionConfig/natSubnet": nat_subnet +"/metastore:v1/CloudSQLConnectionConfig/password": password +"/metastore:v1/CloudSQLConnectionConfig/port": port +"/metastore:v1/CloudSQLConnectionConfig/proxySubnet": proxy_subnet +"/metastore:v1/CloudSQLConnectionConfig/username": username +"/metastore:v1/CloudSQLMigrationConfig": cloud_sql_migration_config +"/metastore:v1/CloudSQLMigrationConfig/cdcConfig": cdc_config +"/metastore:v1/CloudSQLMigrationConfig/cloudSqlConnectionConfig": cloud_sql_connection_config +"/metastore:v1/CompleteMigrationRequest": complete_migration_request "/metastore:v1/Consumer": consumer "/metastore:v1/Consumer/endpointLocation": endpoint_location "/metastore:v1/Consumer/endpointUri": endpoint_uri @@ -244447,6 +244473,9 @@ "/metastore:v1/LatestBackup/duration": duration "/metastore:v1/LatestBackup/startTime": start_time "/metastore:v1/LatestBackup/state": state +"/metastore:v1/LimitConfig": limit_config +"/metastore:v1/LimitConfig/maxScalingFactor": max_scaling_factor +"/metastore:v1/LimitConfig/minScalingFactor": min_scaling_factor "/metastore:v1/ListBackupsResponse": list_backups_response "/metastore:v1/ListBackupsResponse/backups": backups "/metastore:v1/ListBackupsResponse/backups/backup": backup @@ -244469,6 +244498,12 @@ "/metastore:v1/ListMetadataImportsResponse/nextPageToken": next_page_token "/metastore:v1/ListMetadataImportsResponse/unreachable": unreachable "/metastore:v1/ListMetadataImportsResponse/unreachable/unreachable": unreachable +"/metastore:v1/ListMigrationExecutionsResponse": list_migration_executions_response +"/metastore:v1/ListMigrationExecutionsResponse/migrationExecutions": migration_executions +"/metastore:v1/ListMigrationExecutionsResponse/migrationExecutions/migration_execution": migration_execution +"/metastore:v1/ListMigrationExecutionsResponse/nextPageToken": next_page_token +"/metastore:v1/ListMigrationExecutionsResponse/unreachable": unreachable +"/metastore:v1/ListMigrationExecutionsResponse/unreachable/unreachable": unreachable "/metastore:v1/ListOperationsResponse": list_operations_response "/metastore:v1/ListOperationsResponse/nextPageToken": next_page_token "/metastore:v1/ListOperationsResponse/operations": operations @@ -244517,6 +244552,14 @@ "/metastore:v1/MetadataManagementActivity/metadataExports/metadata_export": metadata_export "/metastore:v1/MetadataManagementActivity/restores": restores "/metastore:v1/MetadataManagementActivity/restores/restore": restore +"/metastore:v1/MigrationExecution": migration_execution +"/metastore:v1/MigrationExecution/cloudSqlMigrationConfig": cloud_sql_migration_config +"/metastore:v1/MigrationExecution/createTime": create_time +"/metastore:v1/MigrationExecution/endTime": end_time +"/metastore:v1/MigrationExecution/name": name +"/metastore:v1/MigrationExecution/phase": phase +"/metastore:v1/MigrationExecution/state": state +"/metastore:v1/MigrationExecution/stateMessage": state_message "/metastore:v1/MoveTableToDatabaseRequest": move_table_to_database_request "/metastore:v1/MoveTableToDatabaseRequest/dbName": db_name "/metastore:v1/MoveTableToDatabaseRequest/destinationDbName": destination_db_name @@ -244569,6 +244612,7 @@ "/metastore:v1/RestoreServiceRequest/requestId": request_id "/metastore:v1/RestoreServiceRequest/restoreType": restore_type "/metastore:v1/ScalingConfig": scaling_config +"/metastore:v1/ScalingConfig/autoscalingConfig": autoscaling_config "/metastore:v1/ScalingConfig/instanceSize": instance_size "/metastore:v1/ScalingConfig/scalingFactor": scaling_factor "/metastore:v1/ScheduledBackup": scheduled_backup @@ -244609,6 +244653,9 @@ "/metastore:v1/SetIamPolicyRequest": set_iam_policy_request "/metastore:v1/SetIamPolicyRequest/policy": policy "/metastore:v1/SetIamPolicyRequest/updateMask": update_mask +"/metastore:v1/StartMigrationRequest": start_migration_request +"/metastore:v1/StartMigrationRequest/migrationExecution": migration_execution +"/metastore:v1/StartMigrationRequest/requestId": request_id "/metastore:v1/Status": status "/metastore:v1/Status/code": code "/metastore:v1/Status/details": details @@ -244695,6 +244742,10 @@ "/metastore:v1/metastore.projects.locations.services.backups.list/parent": parent "/metastore:v1/metastore.projects.locations.services.backups.setIamPolicy": set_backup_iam_policy "/metastore:v1/metastore.projects.locations.services.backups.setIamPolicy/resource": resource +"/metastore:v1/metastore.projects.locations.services.cancelMigration": cancel_service_migration +"/metastore:v1/metastore.projects.locations.services.cancelMigration/service": service +"/metastore:v1/metastore.projects.locations.services.completeMigration": complete_service_migration +"/metastore:v1/metastore.projects.locations.services.completeMigration/service": service "/metastore:v1/metastore.projects.locations.services.create": create_project_location_service "/metastore:v1/metastore.projects.locations.services.create/parent": parent "/metastore:v1/metastore.projects.locations.services.create/requestId": request_id @@ -244744,6 +244795,14 @@ "/metastore:v1/metastore.projects.locations.services.migrationExecutions.delete": delete_project_location_service_migration_execution "/metastore:v1/metastore.projects.locations.services.migrationExecutions.delete/name": name "/metastore:v1/metastore.projects.locations.services.migrationExecutions.delete/requestId": request_id +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.get": get_project_location_service_migration_execution +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.get/name": name +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list": list_project_location_service_migration_executions +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list/filter": filter +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list/orderBy": order_by +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list/pageSize": page_size +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list/pageToken": page_token +"/metastore:v1/metastore.projects.locations.services.migrationExecutions.list/parent": parent "/metastore:v1/metastore.projects.locations.services.moveTableToDatabase": move_service_table_to_database "/metastore:v1/metastore.projects.locations.services.moveTableToDatabase/service": service "/metastore:v1/metastore.projects.locations.services.patch": patch_project_location_service @@ -244756,6 +244815,8 @@ "/metastore:v1/metastore.projects.locations.services.restore/service": service "/metastore:v1/metastore.projects.locations.services.setIamPolicy": set_service_iam_policy "/metastore:v1/metastore.projects.locations.services.setIamPolicy/resource": resource +"/metastore:v1/metastore.projects.locations.services.startMigration": start_service_migration +"/metastore:v1/metastore.projects.locations.services.startMigration/service": service "/metastore:v1/metastore.projects.locations.services.testIamPermissions": test_service_iam_permissions "/metastore:v1/metastore.projects.locations.services.testIamPermissions/resource": resource "/metastore:v1/quotaUser": quota_user diff --git a/generated/google-apis-metastore_v1/CHANGELOG.md b/generated/google-apis-metastore_v1/CHANGELOG.md index 5575320e5c6..3108bc757ce 100644 --- a/generated/google-apis-metastore_v1/CHANGELOG.md +++ b/generated/google-apis-metastore_v1/CHANGELOG.md @@ -1,5 +1,9 @@ # Release history for google-apis-metastore_v1 +### v0.28.0 (2024-07-07) + +* Regenerated from discovery document revision 20240627 + ### v0.27.0 (2024-06-16) * Regenerated from discovery document revision 20240611 diff --git a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/classes.rb b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/classes.rb index cb0d1b32d1e..b886c88886e 100644 --- a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/classes.rb +++ b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/classes.rb @@ -173,6 +173,38 @@ def update!(**args) end end + # Represents the autoscaling configuration of a metastore service. + class AutoscalingConfig + include Google::Apis::Core::Hashable + + # Optional. Whether or not autoscaling is enabled for this service. + # Corresponds to the JSON property `autoscalingEnabled` + # @return [Boolean] + attr_accessor :autoscaling_enabled + alias_method :autoscaling_enabled?, :autoscaling_enabled + + # Output only. The scaling factor of a service with autoscaling enabled. + # Corresponds to the JSON property `autoscalingFactor` + # @return [Float] + attr_accessor :autoscaling_factor + + # Represents the autoscaling limit configuration of a metastore service. + # Corresponds to the JSON property `limitConfig` + # @return [Google::Apis::MetastoreV1::LimitConfig] + attr_accessor :limit_config + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @autoscaling_enabled = args[:autoscaling_enabled] if args.key?(:autoscaling_enabled) + @autoscaling_factor = args[:autoscaling_factor] if args.key?(:autoscaling_factor) + @limit_config = args[:limit_config] if args.key?(:limit_config) + end + end + # Configuration information for the auxiliary service versions. class AuxiliaryVersionConfig include Google::Apis::Core::Hashable @@ -394,6 +426,19 @@ def update!(**args) end end + # Request message for DataprocMetastore.CancelMigration. + class CancelMigrationRequest + include Google::Apis::Core::Hashable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + end + end + # The request message for Operations.CancelOperation. class CancelOperationRequest include Google::Apis::Core::Hashable @@ -407,6 +452,192 @@ def update!(**args) end end + # Configuration information to start the Change Data Capture (CDC) streams from + # customer database to backend database of Dataproc Metastore. + class CdcConfig + include Google::Apis::Core::Hashable + + # Optional. The bucket to write the intermediate stream event data in. The + # bucket name must be without any prefix like "gs://". See the bucket naming + # requirements (https://cloud.google.com/storage/docs/buckets#naming). This + # field is optional. If not set, the Artifacts Cloud Storage bucket will be used. + # Corresponds to the JSON property `bucket` + # @return [String] + attr_accessor :bucket + + # Required. Input only. The password for the user that Datastream service should + # use for the MySQL connection. This field is not returned on request. + # Corresponds to the JSON property `password` + # @return [String] + attr_accessor :password + + # Required. The URL of the subnetwork resource to create the VM instance hosting + # the reverse proxy in. More context in https://cloud.google.com/datastream/docs/ + # private-connectivity#reverse-csql-proxy The subnetwork should reside in the + # network provided in the request that Datastream will peer to and should be in + # the same region as Datastream, in the following format. projects/`project_id`/ + # regions/`region_id`/subnetworks/`subnetwork_id` + # Corresponds to the JSON property `reverseProxySubnet` + # @return [String] + attr_accessor :reverse_proxy_subnet + + # Optional. The root path inside the Cloud Storage bucket. The stream event data + # will be written to this path. The default value is /migration. + # Corresponds to the JSON property `rootPath` + # @return [String] + attr_accessor :root_path + + # Required. A /29 CIDR IP range for peering with datastream. + # Corresponds to the JSON property `subnetIpRange` + # @return [String] + attr_accessor :subnet_ip_range + + # Required. The username that the Datastream service should use for the MySQL + # connection. + # Corresponds to the JSON property `username` + # @return [String] + attr_accessor :username + + # Required. Fully qualified name of the Cloud SQL instance's VPC network or the + # shared VPC network that Datastream will peer to, in the following format: + # projects/`project_id`/locations/global/networks/`network_id`. More context in + # https://cloud.google.com/datastream/docs/network-connectivity-options# + # privateconnectivity + # Corresponds to the JSON property `vpcNetwork` + # @return [String] + attr_accessor :vpc_network + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @bucket = args[:bucket] if args.key?(:bucket) + @password = args[:password] if args.key?(:password) + @reverse_proxy_subnet = args[:reverse_proxy_subnet] if args.key?(:reverse_proxy_subnet) + @root_path = args[:root_path] if args.key?(:root_path) + @subnet_ip_range = args[:subnet_ip_range] if args.key?(:subnet_ip_range) + @username = args[:username] if args.key?(:username) + @vpc_network = args[:vpc_network] if args.key?(:vpc_network) + end + end + + # Configuration information to establish customer database connection before the + # cutover phase of migration + class CloudSqlConnectionConfig + include Google::Apis::Core::Hashable + + # Required. The hive database name. + # Corresponds to the JSON property `hiveDatabaseName` + # @return [String] + attr_accessor :hive_database_name + + # Required. Cloud SQL database connection name (project_id:region:instance_name) + # Corresponds to the JSON property `instanceConnectionName` + # @return [String] + attr_accessor :instance_connection_name + + # Required. The private IP address of the Cloud SQL instance. + # Corresponds to the JSON property `ipAddress` + # @return [String] + attr_accessor :ip_address + + # Required. The relative resource name of the subnetwork to be used for Private + # Service Connect. Note that this cannot be a regular subnet and is used only + # for NAT. (https://cloud.google.com/vpc/docs/about-vpc-hosted-services#psc- + # subnets) This subnet is used to publish the SOCKS5 proxy service. The subnet + # size must be at least /29 and it should reside in a network through which the + # Cloud SQL instance is accessible. The resource name should be in the format, + # projects/`project_id`/regions/`region_id`/subnetworks/`subnetwork_id` + # Corresponds to the JSON property `natSubnet` + # @return [String] + attr_accessor :nat_subnet + + # Required. Input only. The password for the user that Dataproc Metastore + # service will be using to connect to the database. This field is not returned + # on request. + # Corresponds to the JSON property `password` + # @return [String] + attr_accessor :password + + # Required. The network port of the database. + # Corresponds to the JSON property `port` + # @return [Fixnum] + attr_accessor :port + + # Required. The relative resource name of the subnetwork to deploy the SOCKS5 + # proxy service in. The subnetwork should reside in a network through which the + # Cloud SQL instance is accessible. The resource name should be in the format, + # projects/`project_id`/regions/`region_id`/subnetworks/`subnetwork_id` + # Corresponds to the JSON property `proxySubnet` + # @return [String] + attr_accessor :proxy_subnet + + # Required. The username that Dataproc Metastore service will use to connect to + # the database. + # Corresponds to the JSON property `username` + # @return [String] + attr_accessor :username + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @hive_database_name = args[:hive_database_name] if args.key?(:hive_database_name) + @instance_connection_name = args[:instance_connection_name] if args.key?(:instance_connection_name) + @ip_address = args[:ip_address] if args.key?(:ip_address) + @nat_subnet = args[:nat_subnet] if args.key?(:nat_subnet) + @password = args[:password] if args.key?(:password) + @port = args[:port] if args.key?(:port) + @proxy_subnet = args[:proxy_subnet] if args.key?(:proxy_subnet) + @username = args[:username] if args.key?(:username) + end + end + + # Configuration information for migrating from self-managed hive metastore on + # Google Cloud using Cloud SQL as the backend database to Dataproc Metastore. + class CloudSqlMigrationConfig + include Google::Apis::Core::Hashable + + # Configuration information to start the Change Data Capture (CDC) streams from + # customer database to backend database of Dataproc Metastore. + # Corresponds to the JSON property `cdcConfig` + # @return [Google::Apis::MetastoreV1::CdcConfig] + attr_accessor :cdc_config + + # Configuration information to establish customer database connection before the + # cutover phase of migration + # Corresponds to the JSON property `cloudSqlConnectionConfig` + # @return [Google::Apis::MetastoreV1::CloudSqlConnectionConfig] + attr_accessor :cloud_sql_connection_config + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cdc_config = args[:cdc_config] if args.key?(:cdc_config) + @cloud_sql_connection_config = args[:cloud_sql_connection_config] if args.key?(:cloud_sql_connection_config) + end + end + + # Request message for DataprocMetastore.CompleteMigration. + class CompleteMigrationRequest + include Google::Apis::Core::Hashable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + end + end + # Contains information of the customer's network configurations. class Consumer include Google::Apis::Core::Hashable @@ -893,6 +1124,31 @@ def update!(**args) end end + # Represents the autoscaling limit configuration of a metastore service. + class LimitConfig + include Google::Apis::Core::Hashable + + # Optional. The highest scaling factor that the service should be autoscaled to. + # Corresponds to the JSON property `maxScalingFactor` + # @return [Float] + attr_accessor :max_scaling_factor + + # Optional. The lowest scaling factor that the service should be autoscaled to. + # Corresponds to the JSON property `minScalingFactor` + # @return [Float] + attr_accessor :min_scaling_factor + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @max_scaling_factor = args[:max_scaling_factor] if args.key?(:max_scaling_factor) + @min_scaling_factor = args[:min_scaling_factor] if args.key?(:min_scaling_factor) + end + end + # Response message for DataprocMetastore.ListBackups. class ListBackupsResponse include Google::Apis::Core::Hashable @@ -1014,6 +1270,38 @@ def update!(**args) end end + # Response message for DataprocMetastore.ListMigrationExecutions. + class ListMigrationExecutionsResponse + include Google::Apis::Core::Hashable + + # The migration executions on the specified service. + # Corresponds to the JSON property `migrationExecutions` + # @return [Array] + attr_accessor :migration_executions + + # A token that can be sent as page_token to retrieve the next page. If this + # field is omitted, there are no subsequent pages. + # Corresponds to the JSON property `nextPageToken` + # @return [String] + attr_accessor :next_page_token + + # Locations that could not be reached. + # Corresponds to the JSON property `unreachable` + # @return [Array] + attr_accessor :unreachable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @migration_executions = args[:migration_executions] if args.key?(:migration_executions) + @next_page_token = args[:next_page_token] if args.key?(:next_page_token) + @unreachable = args[:unreachable] if args.key?(:unreachable) + end + end + # The response message for Operations.ListOperations. class ListOperationsResponse include Google::Apis::Core::Hashable @@ -1320,6 +1608,65 @@ def update!(**args) end end + # The details of a migration execution resource. + class MigrationExecution + include Google::Apis::Core::Hashable + + # Configuration information for migrating from self-managed hive metastore on + # Google Cloud using Cloud SQL as the backend database to Dataproc Metastore. + # Corresponds to the JSON property `cloudSqlMigrationConfig` + # @return [Google::Apis::MetastoreV1::CloudSqlMigrationConfig] + attr_accessor :cloud_sql_migration_config + + # Output only. The time when the migration execution was started. + # Corresponds to the JSON property `createTime` + # @return [String] + attr_accessor :create_time + + # Output only. The time when the migration execution finished. + # Corresponds to the JSON property `endTime` + # @return [String] + attr_accessor :end_time + + # Output only. The relative resource name of the migration execution, in the + # following form: projects/`project_number`/locations/`location_id`/services/` + # service_id`/migrationExecutions/`migration_execution_id` + # Corresponds to the JSON property `name` + # @return [String] + attr_accessor :name + + # Output only. The current phase of the migration execution. + # Corresponds to the JSON property `phase` + # @return [String] + attr_accessor :phase + + # Output only. The current state of the migration execution. + # Corresponds to the JSON property `state` + # @return [String] + attr_accessor :state + + # Output only. Additional information about the current state of the migration + # execution. + # Corresponds to the JSON property `stateMessage` + # @return [String] + attr_accessor :state_message + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cloud_sql_migration_config = args[:cloud_sql_migration_config] if args.key?(:cloud_sql_migration_config) + @create_time = args[:create_time] if args.key?(:create_time) + @end_time = args[:end_time] if args.key?(:end_time) + @name = args[:name] if args.key?(:name) + @phase = args[:phase] if args.key?(:phase) + @state = args[:state] if args.key?(:state) + @state_message = args[:state_message] if args.key?(:state_message) + end + end + # Request message for DataprocMetastore.MoveTableToDatabase. class MoveTableToDatabaseRequest include Google::Apis::Core::Hashable @@ -1774,6 +2121,11 @@ def update!(**args) class ScalingConfig include Google::Apis::Core::Hashable + # Represents the autoscaling configuration of a metastore service. + # Corresponds to the JSON property `autoscalingConfig` + # @return [Google::Apis::MetastoreV1::AutoscalingConfig] + attr_accessor :autoscaling_config + # An enum of readable instance sizes, with each instance size mapping to a float # value (e.g. InstanceSize.EXTRA_SMALL = scaling_factor(0.1)) # Corresponds to the JSON property `instanceSize` @@ -1792,6 +2144,7 @@ def initialize(**args) # Update properties of this object def update!(**args) + @autoscaling_config = args[:autoscaling_config] if args.key?(:autoscaling_config) @instance_size = args[:instance_size] if args.key?(:instance_size) @scaling_factor = args[:scaling_factor] if args.key?(:scaling_factor) end @@ -2096,6 +2449,38 @@ def update!(**args) end end + # Request message for DataprocMetastore.StartMigration. + class StartMigrationRequest + include Google::Apis::Core::Hashable + + # The details of a migration execution resource. + # Corresponds to the JSON property `migrationExecution` + # @return [Google::Apis::MetastoreV1::MigrationExecution] + attr_accessor :migration_execution + + # Optional. A request ID. Specify a unique request ID to allow the server to + # ignore the request if it has completed. The server will ignore subsequent + # requests that provide a duplicate request ID for at least 60 minutes after the + # first request.For example, if an initial request times out, followed by + # another request with the same request ID, the server ignores the second + # request to prevent the creation of duplicate commitments.The request ID must + # be a valid UUID (https://en.wikipedia.org/wiki/Universally_unique_identifier# + # Format) A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. + # Corresponds to the JSON property `requestId` + # @return [String] + attr_accessor :request_id + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @migration_execution = args[:migration_execution] if args.key?(:migration_execution) + @request_id = args[:request_id] if args.key?(:request_id) + end + end + # The Status type defines a logical error model that is suitable for different # programming environments, including REST APIs and RPC APIs. It is used by gRPC # (https://github.com/grpc). Each Status message contains three pieces of data: diff --git a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/gem_version.rb b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/gem_version.rb index 46c9b7cb7c8..6a640aa4ef5 100644 --- a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/gem_version.rb +++ b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/gem_version.rb @@ -16,13 +16,13 @@ module Google module Apis module MetastoreV1 # Version of the google-apis-metastore_v1 gem - GEM_VERSION = "0.27.0" + GEM_VERSION = "0.28.0" # Version of the code generator used to generate this client GENERATOR_VERSION = "0.15.0" # Revision of the discovery document this client was generated from - REVISION = "20240611" + REVISION = "20240627" end end end diff --git a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/representations.rb b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/representations.rb index 53792022a35..ed4b2417c89 100644 --- a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/representations.rb +++ b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/representations.rb @@ -52,6 +52,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class AutoscalingConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class AuxiliaryVersionConfig class Representation < Google::Apis::Core::JsonRepresentation; end @@ -76,12 +82,42 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class CancelMigrationRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class CancelOperationRequest class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class CdcConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CloudSqlConnectionConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CloudSqlMigrationConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CompleteMigrationRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class Consumer class Representation < Google::Apis::Core::JsonRepresentation; end @@ -160,6 +196,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class LimitConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ListBackupsResponse class Representation < Google::Apis::Core::JsonRepresentation; end @@ -184,6 +226,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class ListMigrationExecutionsResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ListOperationsResponse class Representation < Google::Apis::Core::JsonRepresentation; end @@ -238,6 +286,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class MigrationExecution + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class MoveTableToDatabaseRequest class Representation < Google::Apis::Core::JsonRepresentation; end @@ -334,6 +388,12 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class StartMigrationRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class Status class Representation < Google::Apis::Core::JsonRepresentation; end @@ -398,6 +458,16 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class AutoscalingConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :autoscaling_enabled, as: 'autoscalingEnabled' + property :autoscaling_factor, as: 'autoscalingFactor' + property :limit_config, as: 'limitConfig', class: Google::Apis::MetastoreV1::LimitConfig, decorator: Google::Apis::MetastoreV1::LimitConfig::Representation + + end + end + class AuxiliaryVersionConfig # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -440,12 +510,61 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class CancelMigrationRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + end + end + class CancelOperationRequest # @private class Representation < Google::Apis::Core::JsonRepresentation end end + class CdcConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :bucket, as: 'bucket' + property :password, as: 'password' + property :reverse_proxy_subnet, as: 'reverseProxySubnet' + property :root_path, as: 'rootPath' + property :subnet_ip_range, as: 'subnetIpRange' + property :username, as: 'username' + property :vpc_network, as: 'vpcNetwork' + end + end + + class CloudSqlConnectionConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :hive_database_name, as: 'hiveDatabaseName' + property :instance_connection_name, as: 'instanceConnectionName' + property :ip_address, as: 'ipAddress' + property :nat_subnet, as: 'natSubnet' + property :password, as: 'password' + property :port, as: 'port' + property :proxy_subnet, as: 'proxySubnet' + property :username, as: 'username' + end + end + + class CloudSqlMigrationConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :cdc_config, as: 'cdcConfig', class: Google::Apis::MetastoreV1::CdcConfig, decorator: Google::Apis::MetastoreV1::CdcConfig::Representation + + property :cloud_sql_connection_config, as: 'cloudSqlConnectionConfig', class: Google::Apis::MetastoreV1::CloudSqlConnectionConfig, decorator: Google::Apis::MetastoreV1::CloudSqlConnectionConfig::Representation + + end + end + + class CompleteMigrationRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + end + end + class Consumer # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -569,6 +688,14 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class LimitConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :max_scaling_factor, as: 'maxScalingFactor' + property :min_scaling_factor, as: 'minScalingFactor' + end + end + class ListBackupsResponse # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -608,6 +735,16 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class ListMigrationExecutionsResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :migration_executions, as: 'migrationExecutions', class: Google::Apis::MetastoreV1::MigrationExecution, decorator: Google::Apis::MetastoreV1::MigrationExecution::Representation + + property :next_page_token, as: 'nextPageToken' + collection :unreachable, as: 'unreachable' + end + end + class ListOperationsResponse # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -699,6 +836,20 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class MigrationExecution + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :cloud_sql_migration_config, as: 'cloudSqlMigrationConfig', class: Google::Apis::MetastoreV1::CloudSqlMigrationConfig, decorator: Google::Apis::MetastoreV1::CloudSqlMigrationConfig::Representation + + property :create_time, as: 'createTime' + property :end_time, as: 'endTime' + property :name, as: 'name' + property :phase, as: 'phase' + property :state, as: 'state' + property :state_message, as: 'stateMessage' + end + end + class MoveTableToDatabaseRequest # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -806,6 +957,8 @@ class Representation < Google::Apis::Core::JsonRepresentation class ScalingConfig # @private class Representation < Google::Apis::Core::JsonRepresentation + property :autoscaling_config, as: 'autoscalingConfig', class: Google::Apis::MetastoreV1::AutoscalingConfig, decorator: Google::Apis::MetastoreV1::AutoscalingConfig::Representation + property :instance_size, as: 'instanceSize' property :scaling_factor, as: 'scalingFactor' end @@ -879,6 +1032,15 @@ class Representation < Google::Apis::Core::JsonRepresentation end end + class StartMigrationRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :migration_execution, as: 'migrationExecution', class: Google::Apis::MetastoreV1::MigrationExecution, decorator: Google::Apis::MetastoreV1::MigrationExecution::Representation + + property :request_id, as: 'requestId' + end + end + class Status # @private class Representation < Google::Apis::Core::JsonRepresentation diff --git a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/service.rb b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/service.rb index 557bc05e30a..a1ef1a9b2e8 100644 --- a/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/service.rb +++ b/generated/google-apis-metastore_v1/lib/google/apis/metastore_v1/service.rb @@ -690,6 +690,77 @@ def alter_service_table_properties(service, alter_table_properties_request_objec execute_or_queue_command(command, &block) end + # Cancels the ongoing Managed Migration process. + # @param [String] service + # Required. The relative resource name of the metastore service to cancel the + # ongoing migration to, in the following format:projects/`project_id`/locations/` + # location_id`/services/`service_id`. + # @param [Google::Apis::MetastoreV1::CancelMigrationRequest] cancel_migration_request_object + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::Operation] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def cancel_service_migration(service, cancel_migration_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1/{+service}:cancelMigration', options) + command.request_representation = Google::Apis::MetastoreV1::CancelMigrationRequest::Representation + command.request_object = cancel_migration_request_object + command.response_representation = Google::Apis::MetastoreV1::Operation::Representation + command.response_class = Google::Apis::MetastoreV1::Operation + command.params['service'] = service unless service.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Completes the managed migration process. The Dataproc Metastore service will + # switch to using its own backend database after successful migration. + # @param [String] service + # Required. The relative resource name of the metastore service to complete the + # migration to, in the following format:projects/`project_id`/locations/` + # location_id`/services/`service_id`. + # @param [Google::Apis::MetastoreV1::CompleteMigrationRequest] complete_migration_request_object + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::Operation] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def complete_service_migration(service, complete_migration_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1/{+service}:completeMigration', options) + command.request_representation = Google::Apis::MetastoreV1::CompleteMigrationRequest::Representation + command.request_object = complete_migration_request_object + command.response_representation = Google::Apis::MetastoreV1::Operation::Representation + command.response_class = Google::Apis::MetastoreV1::Operation + command.params['service'] = service unless service.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + # Creates a metastore service in a project and location. # @param [String] parent # Required. The relative resource name of the location in which to create a @@ -1139,6 +1210,41 @@ def set_service_iam_policy(resource, set_iam_policy_request_object = nil, fields execute_or_queue_command(command, &block) end + # Starts the Managed Migration process. + # @param [String] service + # Required. The relative resource name of the metastore service to start + # migrating to, in the following format:projects/`project_id`/locations/` + # location_id`/services/`service_id`. + # @param [Google::Apis::MetastoreV1::StartMigrationRequest] start_migration_request_object + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::Operation] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def start_service_migration(service, start_migration_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1/{+service}:startMigration', options) + command.request_representation = Google::Apis::MetastoreV1::StartMigrationRequest::Representation + command.request_object = start_migration_request_object + command.response_representation = Google::Apis::MetastoreV1::Operation::Representation + command.response_class = Google::Apis::MetastoreV1::Operation + command.params['service'] = service unless service.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + # Returns permissions that a caller has on the specified resource. If the # resource does not exist, this will return an empty set of permissions, not a # NOT_FOUND error.Note: This operation is designed to be used for building @@ -1786,6 +1892,133 @@ def patch_project_location_service_metadata_import(name, metadata_import_object command.query['quotaUser'] = quota_user unless quota_user.nil? execute_or_queue_command(command, &block) end + + # Deletes a single migration execution. + # @param [String] name + # Required. The relative resource name of the migrationExecution to delete, in + # the following form:projects/`project_number`/locations/`location_id`/services/` + # service_id`/migrationExecutions/`migration_execution_id`. + # @param [String] request_id + # Optional. A request ID. Specify a unique request ID to allow the server to + # ignore the request if it has completed. The server will ignore subsequent + # requests that provide a duplicate request ID for at least 60 minutes after the + # first request.For example, if an initial request times out, followed by + # another request with the same request ID, the server ignores the second + # request to prevent the creation of duplicate commitments.The request ID must + # be a valid UUID (https://en.wikipedia.org/wiki/Universally_unique_identifier# + # Format) A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::Operation] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def delete_project_location_service_migration_execution(name, request_id: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:delete, 'v1/{+name}', options) + command.response_representation = Google::Apis::MetastoreV1::Operation::Representation + command.response_class = Google::Apis::MetastoreV1::Operation + command.params['name'] = name unless name.nil? + command.query['requestId'] = request_id unless request_id.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Gets details of a single migration execution. + # @param [String] name + # Required. The relative resource name of the migration execution to retrieve, + # in the following form:projects/`project_number`/locations/`location_id`/ + # services/`service_id`/migrationExecutions/`migration_execution_id`. + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::MigrationExecution] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::MigrationExecution] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def get_project_location_service_migration_execution(name, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1/{+name}', options) + command.response_representation = Google::Apis::MetastoreV1::MigrationExecution::Representation + command.response_class = Google::Apis::MetastoreV1::MigrationExecution + command.params['name'] = name unless name.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Lists migration executions on a service. + # @param [String] parent + # Required. The relative resource name of the service whose migration executions + # to list, in the following form:projects/`project_number`/locations/` + # location_id`/services/`service_id`/migrationExecutions. + # @param [String] filter + # Optional. The filter to apply to list results. + # @param [String] order_by + # Optional. Specify the ordering of results as described in Sorting Order (https: + # //cloud.google.com/apis/design/design_patterns#sorting_order). If not + # specified, the results will be sorted in the default order. + # @param [Fixnum] page_size + # Optional. The maximum number of migration executions to return. The response + # may contain less than the maximum number. If unspecified, no more than 500 + # migration executions are returned. The maximum value is 1000; values above + # 1000 are changed to 1000. + # @param [String] page_token + # Optional. A page token, received from a previous DataprocMetastore. + # ListMigrationExecutions call. Provide this token to retrieve the subsequent + # page.To retrieve the first page, supply an empty page token.When paginating, + # other parameters provided to DataprocMetastore.ListMigrationExecutions must + # match the call that provided the page token. + # @param [String] fields + # Selector specifying which fields to include in a partial response. + # @param [String] quota_user + # Available to use for quota purposes for server-side applications. Can be any + # arbitrary string assigned to a user, but should not exceed 40 characters. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::MetastoreV1::ListMigrationExecutionsResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::MetastoreV1::ListMigrationExecutionsResponse] + # + # @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried + # @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification + # @raise [Google::Apis::AuthorizationError] Authorization is required + def list_project_location_service_migration_executions(parent, filter: nil, order_by: nil, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1/{+parent}/migrationExecutions', options) + command.response_representation = Google::Apis::MetastoreV1::ListMigrationExecutionsResponse::Representation + command.response_class = Google::Apis::MetastoreV1::ListMigrationExecutionsResponse + command.params['parent'] = parent unless parent.nil? + command.query['filter'] = filter unless filter.nil? + command.query['orderBy'] = order_by unless order_by.nil? + command.query['pageSize'] = page_size unless page_size.nil? + command.query['pageToken'] = page_token unless page_token.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end protected