diff --git a/api_names_out.yaml b/api_names_out.yaml index 728f19d85..bb77fd09b 100644 --- a/api_names_out.yaml +++ b/api_names_out.yaml @@ -30915,6 +30915,10 @@ "/dataproc:v1beta2/ClusterMetrics/hdfsMetrics/hdfs_metric": hdfs_metric "/dataproc:v1beta2/ClusterMetrics/yarnMetrics": yarn_metrics "/dataproc:v1beta2/ClusterMetrics/yarnMetrics/yarn_metric": yarn_metric +"/dataproc:v1beta2/ClusterOperation": cluster_operation +"/dataproc:v1beta2/ClusterOperation/done": done +"/dataproc:v1beta2/ClusterOperation/error": error +"/dataproc:v1beta2/ClusterOperation/operationId": operation_id "/dataproc:v1beta2/ClusterOperationMetadata": cluster_operation_metadata "/dataproc:v1beta2/ClusterOperationMetadata/clusterName": cluster_name "/dataproc:v1beta2/ClusterOperationMetadata/clusterUuid": cluster_uuid @@ -30932,6 +30936,10 @@ "/dataproc:v1beta2/ClusterOperationStatus/innerState": inner_state "/dataproc:v1beta2/ClusterOperationStatus/state": state "/dataproc:v1beta2/ClusterOperationStatus/stateStartTime": state_start_time +"/dataproc:v1beta2/ClusterSelector": cluster_selector +"/dataproc:v1beta2/ClusterSelector/clusterLabels": cluster_labels +"/dataproc:v1beta2/ClusterSelector/clusterLabels/cluster_label": cluster_label +"/dataproc:v1beta2/ClusterSelector/zone": zone "/dataproc:v1beta2/ClusterStatus": cluster_status "/dataproc:v1beta2/ClusterStatus/detail": detail "/dataproc:v1beta2/ClusterStatus/state": state @@ -30991,6 +30999,9 @@ "/dataproc:v1beta2/InstanceGroupConfig/machineTypeUri": machine_type_uri "/dataproc:v1beta2/InstanceGroupConfig/managedGroupConfig": managed_group_config "/dataproc:v1beta2/InstanceGroupConfig/numInstances": num_instances +"/dataproc:v1beta2/InstantiateWorkflowTemplateRequest": instantiate_workflow_template_request +"/dataproc:v1beta2/InstantiateWorkflowTemplateRequest/instanceId": instance_id +"/dataproc:v1beta2/InstantiateWorkflowTemplateRequest/version": version "/dataproc:v1beta2/Job": job "/dataproc:v1beta2/Job/driverControlFilesUri": driver_control_files_uri "/dataproc:v1beta2/Job/driverOutputResourceUri": driver_output_resource_uri @@ -31039,9 +31050,18 @@ "/dataproc:v1beta2/ListOperationsResponse/nextPageToken": next_page_token "/dataproc:v1beta2/ListOperationsResponse/operations": operations "/dataproc:v1beta2/ListOperationsResponse/operations/operation": operation +"/dataproc:v1beta2/ListWorkflowTemplatesResponse": list_workflow_templates_response +"/dataproc:v1beta2/ListWorkflowTemplatesResponse/nextPageToken": next_page_token +"/dataproc:v1beta2/ListWorkflowTemplatesResponse/templates": templates +"/dataproc:v1beta2/ListWorkflowTemplatesResponse/templates/template": template "/dataproc:v1beta2/LoggingConfig": logging_config "/dataproc:v1beta2/LoggingConfig/driverLogLevels": driver_log_levels "/dataproc:v1beta2/LoggingConfig/driverLogLevels/driver_log_level": driver_log_level +"/dataproc:v1beta2/ManagedCluster": managed_cluster +"/dataproc:v1beta2/ManagedCluster/clusterName": cluster_name +"/dataproc:v1beta2/ManagedCluster/config": config +"/dataproc:v1beta2/ManagedCluster/labels": labels +"/dataproc:v1beta2/ManagedCluster/labels/label": label "/dataproc:v1beta2/ManagedGroupConfig": managed_group_config "/dataproc:v1beta2/ManagedGroupConfig/instanceGroupManagerName": instance_group_manager_name "/dataproc:v1beta2/ManagedGroupConfig/instanceTemplateName": instance_template_name @@ -31056,6 +31076,19 @@ "/dataproc:v1beta2/Operation/name": name "/dataproc:v1beta2/Operation/response": response "/dataproc:v1beta2/Operation/response/response": response +"/dataproc:v1beta2/OrderedJob": ordered_job +"/dataproc:v1beta2/OrderedJob/hadoopJob": hadoop_job +"/dataproc:v1beta2/OrderedJob/hiveJob": hive_job +"/dataproc:v1beta2/OrderedJob/labels": labels +"/dataproc:v1beta2/OrderedJob/labels/label": label +"/dataproc:v1beta2/OrderedJob/pigJob": pig_job +"/dataproc:v1beta2/OrderedJob/prerequisiteStepIds": prerequisite_step_ids +"/dataproc:v1beta2/OrderedJob/prerequisiteStepIds/prerequisite_step_id": prerequisite_step_id +"/dataproc:v1beta2/OrderedJob/pysparkJob": pyspark_job +"/dataproc:v1beta2/OrderedJob/scheduling": scheduling +"/dataproc:v1beta2/OrderedJob/sparkJob": spark_job +"/dataproc:v1beta2/OrderedJob/sparkSqlJob": spark_sql_job +"/dataproc:v1beta2/OrderedJob/stepId": step_id "/dataproc:v1beta2/PigJob": pig_job "/dataproc:v1beta2/PigJob/continueOnFailure": continue_on_failure "/dataproc:v1beta2/PigJob/jarFileUris": jar_file_uris @@ -31134,11 +31167,59 @@ "/dataproc:v1beta2/TestIamPermissionsResponse": test_iam_permissions_response "/dataproc:v1beta2/TestIamPermissionsResponse/permissions": permissions "/dataproc:v1beta2/TestIamPermissionsResponse/permissions/permission": permission +"/dataproc:v1beta2/WorkflowGraph": workflow_graph +"/dataproc:v1beta2/WorkflowGraph/nodes": nodes +"/dataproc:v1beta2/WorkflowGraph/nodes/node": node +"/dataproc:v1beta2/WorkflowMetadata": workflow_metadata +"/dataproc:v1beta2/WorkflowMetadata/clusterName": cluster_name +"/dataproc:v1beta2/WorkflowMetadata/createCluster": create_cluster +"/dataproc:v1beta2/WorkflowMetadata/deleteCluster": delete_cluster +"/dataproc:v1beta2/WorkflowMetadata/graph": graph +"/dataproc:v1beta2/WorkflowMetadata/state": state +"/dataproc:v1beta2/WorkflowMetadata/template": template +"/dataproc:v1beta2/WorkflowMetadata/version": version +"/dataproc:v1beta2/WorkflowNode": workflow_node +"/dataproc:v1beta2/WorkflowNode/error": error +"/dataproc:v1beta2/WorkflowNode/jobId": job_id +"/dataproc:v1beta2/WorkflowNode/prerequisiteStepIds": prerequisite_step_ids +"/dataproc:v1beta2/WorkflowNode/prerequisiteStepIds/prerequisite_step_id": prerequisite_step_id +"/dataproc:v1beta2/WorkflowNode/state": state +"/dataproc:v1beta2/WorkflowNode/stepId": step_id +"/dataproc:v1beta2/WorkflowTemplate": workflow_template +"/dataproc:v1beta2/WorkflowTemplate/createTime": create_time +"/dataproc:v1beta2/WorkflowTemplate/id": id +"/dataproc:v1beta2/WorkflowTemplate/jobs": jobs +"/dataproc:v1beta2/WorkflowTemplate/jobs/job": job +"/dataproc:v1beta2/WorkflowTemplate/labels": labels +"/dataproc:v1beta2/WorkflowTemplate/labels/label": label +"/dataproc:v1beta2/WorkflowTemplate/name": name +"/dataproc:v1beta2/WorkflowTemplate/placement": placement +"/dataproc:v1beta2/WorkflowTemplate/updateTime": update_time +"/dataproc:v1beta2/WorkflowTemplate/version": version +"/dataproc:v1beta2/WorkflowTemplatePlacement": workflow_template_placement +"/dataproc:v1beta2/WorkflowTemplatePlacement/clusterSelector": cluster_selector +"/dataproc:v1beta2/WorkflowTemplatePlacement/managedCluster": managed_cluster "/dataproc:v1beta2/YarnApplication": yarn_application "/dataproc:v1beta2/YarnApplication/name": name "/dataproc:v1beta2/YarnApplication/progress": progress "/dataproc:v1beta2/YarnApplication/state": state "/dataproc:v1beta2/YarnApplication/trackingUrl": tracking_url +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.create": create_project_location_workflow_template +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.create/parent": parent +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.delete": delete_project_location_workflow_template +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.delete/name": name +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.delete/version": version +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.get": get_project_location_workflow_template +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.get/name": name +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.get/version": version +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.instantiate": instantiate_project_location_workflow_template +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.instantiate/name": name +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.list": list_project_location_workflow_templates +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.list/pageSize": page_size +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.list/pageToken": page_token +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.list/parent": parent +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.update": update_project_location_workflow_template +"/dataproc:v1beta2/dataproc.projects.locations.workflowTemplates.update/name": name "/dataproc:v1beta2/dataproc.projects.regions.clusters.create": create_project_region_cluster "/dataproc:v1beta2/dataproc.projects.regions.clusters.create/projectId": project_id "/dataproc:v1beta2/dataproc.projects.regions.clusters.create/region": region @@ -31211,6 +31292,22 @@ "/dataproc:v1beta2/dataproc.projects.regions.operations.list/name": name "/dataproc:v1beta2/dataproc.projects.regions.operations.list/pageSize": page_size "/dataproc:v1beta2/dataproc.projects.regions.operations.list/pageToken": page_token +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.create": create_project_region_workflow_template +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.create/parent": parent +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.delete": delete_project_region_workflow_template +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.delete/name": name +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.delete/version": version +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.get": get_project_region_workflow_template +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.get/name": name +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.get/version": version +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.instantiate": instantiate_project_region_workflow_template +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.instantiate/name": name +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.list": list_project_region_workflow_templates +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.list/pageSize": page_size +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.list/pageToken": page_token +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.list/parent": parent +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.update": update_project_region_workflow_template +"/dataproc:v1beta2/dataproc.projects.regions.workflowTemplates.update/name": name "/dataproc:v1beta2/fields": fields "/dataproc:v1beta2/key": key "/dataproc:v1beta2/quotaUser": quota_user @@ -38376,6 +38473,10 @@ "/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig/cryptoKey": crypto_key "/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig/customAlphabet": custom_alphabet "/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig/radix": radix +"/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig": google_privacy_dlp_v2beta1_crypto_replace_regex_fpe_config +"/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig/context": context +"/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig/cryptoKey": crypto_key +"/dlp:v2beta1/GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig/regex": regex "/dlp:v2beta1/GooglePrivacyDlpV2beta1DatastoreKey": google_privacy_dlp_v2beta1_datastore_key "/dlp:v2beta1/GooglePrivacyDlpV2beta1DatastoreKey/entityKey": entity_key "/dlp:v2beta1/GooglePrivacyDlpV2beta1DatastoreOptions": google_privacy_dlp_v2beta1_datastore_options @@ -38573,6 +38674,7 @@ "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/characterMaskConfig": character_mask_config "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/cryptoHashConfig": crypto_hash_config "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/cryptoReplaceFfxFpeConfig": crypto_replace_ffx_fpe_config +"/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/cryptoReplaceRegexFpeConfig": crypto_replace_regex_fpe_config "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/fixedSizeBucketingConfig": fixed_size_bucketing_config "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/redactConfig": redact_config "/dlp:v2beta1/GooglePrivacyDlpV2beta1PrimitiveTransformation/replaceConfig": replace_config @@ -51251,6 +51353,7 @@ "/servicecontrol:v1/ReportResponse/serviceConfigId": service_config_id "/servicecontrol:v1/RequestMetadata": request_metadata "/servicecontrol:v1/RequestMetadata/callerIp": caller_ip +"/servicecontrol:v1/RequestMetadata/callerNetwork": caller_network "/servicecontrol:v1/RequestMetadata/callerSuppliedUserAgent": caller_supplied_user_agent "/servicecontrol:v1/ResourceInfo": resource_info "/servicecontrol:v1/ResourceInfo/resourceContainer": resource_container @@ -61640,6 +61743,13 @@ "/youtubePartner:v1/TerritoryOwners/territories": territories "/youtubePartner:v1/TerritoryOwners/territories/territory": territory "/youtubePartner:v1/TerritoryOwners/type": type +"/youtubePartner:v1/Uploader": uploader +"/youtubePartner:v1/Uploader/kind": kind +"/youtubePartner:v1/Uploader/uploaderName": uploader_name +"/youtubePartner:v1/UploaderListResponse": uploader_list_response +"/youtubePartner:v1/UploaderListResponse/items": items +"/youtubePartner:v1/UploaderListResponse/items/item": item +"/youtubePartner:v1/UploaderListResponse/kind": kind "/youtubePartner:v1/ValidateAsyncRequest": validate_async_request "/youtubePartner:v1/ValidateAsyncRequest/content": content "/youtubePartner:v1/ValidateAsyncRequest/kind": kind @@ -61944,6 +62054,8 @@ "/youtubePartner:v1/youtubePartner.references.update/onBehalfOfContentOwner": on_behalf_of_content_owner "/youtubePartner:v1/youtubePartner.references.update/referenceId": reference_id "/youtubePartner:v1/youtubePartner.references.update/releaseClaims": release_claims +"/youtubePartner:v1/youtubePartner.uploader.list": list_uploaders +"/youtubePartner:v1/youtubePartner.uploader.list/onBehalfOfContentOwner": on_behalf_of_content_owner "/youtubePartner:v1/youtubePartner.validator.validate": validate_validator "/youtubePartner:v1/youtubePartner.validator.validate/onBehalfOfContentOwner": on_behalf_of_content_owner "/youtubePartner:v1/youtubePartner.validator.validateAsync": validate_validator_async diff --git a/generated/google/apis/analytics_v3/service.rb b/generated/google/apis/analytics_v3/service.rb index 547619e57..a2b87aa80 100644 --- a/generated/google/apis/analytics_v3/service.rb +++ b/generated/google/apis/analytics_v3/service.rb @@ -50,7 +50,7 @@ module Google def initialize super('https://www.googleapis.com/', 'analytics/v3/') - @batch_path = 'batch' + @batch_path = 'batch/analytics/v3' end # Returns Analytics data for a view (profile). diff --git a/generated/google/apis/cloudmonitoring_v2beta2/service.rb b/generated/google/apis/cloudmonitoring_v2beta2/service.rb index 5d0b53e79..077df06e5 100644 --- a/generated/google/apis/cloudmonitoring_v2beta2/service.rb +++ b/generated/google/apis/cloudmonitoring_v2beta2/service.rb @@ -50,7 +50,7 @@ module Google def initialize super('https://www.googleapis.com/', 'cloudmonitoring/v2beta2/projects/') - @batch_path = 'batch' + @batch_path = 'batch/cloudmonitoring/v2beta2' end # Create a new metric. diff --git a/generated/google/apis/cloudtrace_v1.rb b/generated/google/apis/cloudtrace_v1.rb index 7a2813fb9..8889a5ad8 100644 --- a/generated/google/apis/cloudtrace_v1.rb +++ b/generated/google/apis/cloudtrace_v1.rb @@ -28,7 +28,7 @@ module Google # @see https://cloud.google.com/trace module CloudtraceV1 VERSION = 'V1' - REVISION = '20170815' + REVISION = '20170927' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/cloudtrace_v2.rb b/generated/google/apis/cloudtrace_v2.rb index 30b6ebebd..c697fa42a 100644 --- a/generated/google/apis/cloudtrace_v2.rb +++ b/generated/google/apis/cloudtrace_v2.rb @@ -28,7 +28,7 @@ module Google # @see https://cloud.google.com/trace module CloudtraceV2 VERSION = 'V2' - REVISION = '20170919' + REVISION = '20170927' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/cloudtrace_v2/classes.rb b/generated/google/apis/cloudtrace_v2/classes.rb index 90cd64240..d058bcf59 100644 --- a/generated/google/apis/cloudtrace_v2/classes.rb +++ b/generated/google/apis/cloudtrace_v2/classes.rb @@ -327,7 +327,7 @@ module Google attr_accessor :links # The resource name of the span in the following format: - # projects/[PROJECT_ID]traces/[TRACE_ID]/spans/SPAN_ID is a unique + # projects/[PROJECT_ID]/traces/[TRACE_ID]/spans/SPAN_ID is a unique # identifier for a trace within a project. # [SPAN_ID] is a unique identifier for a span within a trace, # assigned when the span is created. diff --git a/generated/google/apis/cloudtrace_v2/service.rb b/generated/google/apis/cloudtrace_v2/service.rb index 70ae64fe9..af2cf35a6 100644 --- a/generated/google/apis/cloudtrace_v2/service.rb +++ b/generated/google/apis/cloudtrace_v2/service.rb @@ -91,7 +91,7 @@ module Google # Creates a new Span. # @param [String] name # The resource name of the span in the following format: - # projects/[PROJECT_ID]traces/[TRACE_ID]/spans/SPAN_ID is a unique + # projects/[PROJECT_ID]/traces/[TRACE_ID]/spans/SPAN_ID is a unique # identifier for a trace within a project. # [SPAN_ID] is a unique identifier for a span within a trace, # assigned when the span is created. diff --git a/generated/google/apis/dataproc_v1beta2.rb b/generated/google/apis/dataproc_v1beta2.rb index e38686904..9cd0a8ee4 100644 --- a/generated/google/apis/dataproc_v1beta2.rb +++ b/generated/google/apis/dataproc_v1beta2.rb @@ -25,7 +25,7 @@ module Google # @see https://cloud.google.com/dataproc/ module DataprocV1beta2 VERSION = 'V1beta2' - REVISION = '20170919' + REVISION = '20170926' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/dataproc_v1beta2/classes.rb b/generated/google/apis/dataproc_v1beta2/classes.rb index ca2cbb1f3..96b6e2d1a 100644 --- a/generated/google/apis/dataproc_v1beta2/classes.rb +++ b/generated/google/apis/dataproc_v1beta2/classes.rb @@ -282,6 +282,38 @@ module Google end end + # + class ClusterOperation + include Google::Apis::Core::Hashable + + # Output-only Indicates the operation is done. + # Corresponds to the JSON property `done` + # @return [Boolean] + attr_accessor :done + alias_method :done?, :done + + # Output-only Error, if operation failed. + # Corresponds to the JSON property `error` + # @return [String] + attr_accessor :error + + # Output-only The id of the cluster operation. + # Corresponds to the JSON property `operationId` + # @return [String] + attr_accessor :operation_id + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @done = args[:done] if args.key?(:done) + @error = args[:error] if args.key?(:error) + @operation_id = args[:operation_id] if args.key?(:operation_id) + end + end + # Metadata describing the operation. class ClusterOperationMetadata include Google::Apis::Core::Hashable @@ -380,6 +412,31 @@ module Google end end + # A selector that chooses target cluster for jobs based on metadata. + class ClusterSelector + include Google::Apis::Core::Hashable + + # Required The cluster labels. Cluster must have all labels to match. + # Corresponds to the JSON property `clusterLabels` + # @return [Hash] + attr_accessor :cluster_labels + + # Required The cluster target zone. + # Corresponds to the JSON property `zone` + # @return [String] + attr_accessor :zone + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cluster_labels = args[:cluster_labels] if args.key?(:cluster_labels) + @zone = args[:zone] if args.key?(:zone) + end + end + # The status of a cluster and its instances. class ClusterStatus include Google::Apis::Core::Hashable @@ -816,6 +873,39 @@ module Google end end + # A request to instantiate a workflow template. + class InstantiateWorkflowTemplateRequest + include Google::Apis::Core::Hashable + + # Optional A tag that prevents multiple concurrent workflow instances with the + # same tag from running. This mitigates risk of concurrent instances started due + # to retries.It is recommended to always set this value to a UUID (https://en. + # wikipedia.org/wiki/Universally_unique_identifier).The tag must contain only + # letters (a-z, A-Z), numbers (0-9), underscores (_), and hyphens (-). The + # maximum length is 40 characters. + # Corresponds to the JSON property `instanceId` + # @return [String] + attr_accessor :instance_id + + # Optional The version of workflow template to instantiate. If specified, the + # workflow will be instantiated only if the current version of the workflow + # template has the supplied version.This option cannot be used to instantiate a + # previous version of workflow template. + # Corresponds to the JSON property `version` + # @return [Fixnum] + attr_accessor :version + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @instance_id = args[:instance_id] if args.key?(:instance_id) + @version = args[:version] if args.key?(:version) + end + end + # A Cloud Dataproc job resource. class Job include Google::Apis::Core::Hashable @@ -1166,6 +1256,33 @@ module Google end end + # A response to a request to list workflow templates in a project. + class ListWorkflowTemplatesResponse + include Google::Apis::Core::Hashable + + # Output-only This token is included in the response if there are more results + # to fetch. To fetch additional results, provide this value as the page_token in + # a subsequent ListWorkflowTemplatesRequest. + # Corresponds to the JSON property `nextPageToken` + # @return [String] + attr_accessor :next_page_token + + # Output-only WorkflowTemplates list. + # Corresponds to the JSON property `templates` + # @return [Array] + attr_accessor :templates + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @next_page_token = args[:next_page_token] if args.key?(:next_page_token) + @templates = args[:templates] if args.key?(:templates) + end + end + # The runtime logging config of the job. class LoggingConfig include Google::Apis::Core::Hashable @@ -1187,6 +1304,42 @@ module Google end end + # Cluster that is managed by the workflow. + class ManagedCluster + include Google::Apis::Core::Hashable + + # Required The cluster name. Cluster names within a project must be unique. + # Names from deleted clusters can be reused. + # Corresponds to the JSON property `clusterName` + # @return [String] + attr_accessor :cluster_name + + # The cluster config. + # Corresponds to the JSON property `config` + # @return [Google::Apis::DataprocV1beta2::ClusterConfig] + attr_accessor :config + + # Optional The labels to associate with this cluster.Label keys must be between + # 1 and 63 characters long, and must conform to the following PCRE regular + # expression: \p`Ll`\p`Lo``0,62`Label values must be between 1 and 63 characters + # long, and must conform to the following PCRE regular expression: \p`Ll`\p`Lo`\ + # p`N`_-`0,63`No more than 64 labels can be associated with a given cluster. + # Corresponds to the JSON property `labels` + # @return [Hash] + attr_accessor :labels + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cluster_name = args[:cluster_name] if args.key?(:cluster_name) + @config = args[:config] if args.key?(:config) + @labels = args[:labels] if args.key?(:labels) + end + end + # Specifies the resources used to actively manage an instance group. class ManagedGroupConfig include Google::Apis::Core::Hashable @@ -1332,6 +1485,95 @@ module Google end end + # + class OrderedJob + include Google::Apis::Core::Hashable + + # A Cloud Dataproc job for running Apache Hadoop MapReduce (https://hadoop. + # apache.org/docs/current/hadoop-mapreduce-client/hadoop-mapreduce-client-core/ + # MapReduceTutorial.html) jobs on Apache Hadoop YARN (https://hadoop.apache.org/ + # docs/r2.7.1/hadoop-yarn/hadoop-yarn-site/YARN.html). + # Corresponds to the JSON property `hadoopJob` + # @return [Google::Apis::DataprocV1beta2::HadoopJob] + attr_accessor :hadoop_job + + # A Cloud Dataproc job for running Apache Hive (https://hive.apache.org/) + # queries on YARN. + # Corresponds to the JSON property `hiveJob` + # @return [Google::Apis::DataprocV1beta2::HiveJob] + attr_accessor :hive_job + + # Optional The labels to associate with this job.Label keys must be between 1 + # and 63 characters long, and must conform to the following regular expression: \ + # p`Ll`\p`Lo``0,62`Label values must be between 1 and 63 characters long, and + # must conform to the following regular expression: \p`Ll`\p`Lo`\p`N`_-`0,63`No + # more than 64 labels can be associated with a given job. + # Corresponds to the JSON property `labels` + # @return [Hash] + attr_accessor :labels + + # A Cloud Dataproc job for running Apache Pig (https://pig.apache.org/) queries + # on YARN. + # Corresponds to the JSON property `pigJob` + # @return [Google::Apis::DataprocV1beta2::PigJob] + attr_accessor :pig_job + + # Optional The optional list of prerequisite job step_ids. If not specified, the + # job will start at the beginning of workflow. + # Corresponds to the JSON property `prerequisiteStepIds` + # @return [Array] + attr_accessor :prerequisite_step_ids + + # A Cloud Dataproc job for running Apache PySpark (https://spark.apache.org/docs/ + # 0.9.0/python-programming-guide.html) applications on YARN. + # Corresponds to the JSON property `pysparkJob` + # @return [Google::Apis::DataprocV1beta2::PySparkJob] + attr_accessor :pyspark_job + + # Job scheduling options.Beta Feature: These options are available for testing + # purposes only. They may be changed before final release. + # Corresponds to the JSON property `scheduling` + # @return [Google::Apis::DataprocV1beta2::JobScheduling] + attr_accessor :scheduling + + # A Cloud Dataproc job for running Apache Spark (http://spark.apache.org/) + # applications on YARN. + # Corresponds to the JSON property `sparkJob` + # @return [Google::Apis::DataprocV1beta2::SparkJob] + attr_accessor :spark_job + + # A Cloud Dataproc job for running Apache Spark SQL (http://spark.apache.org/sql/ + # ) queries. + # Corresponds to the JSON property `sparkSqlJob` + # @return [Google::Apis::DataprocV1beta2::SparkSqlJob] + attr_accessor :spark_sql_job + + # Required The step id. The id must be unique among all jobs within the template. + # The step id is used as prefix for job id, as job workflow-step-id label, and + # in prerequisite_step_ids field from other steps. + # Corresponds to the JSON property `stepId` + # @return [String] + attr_accessor :step_id + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @hadoop_job = args[:hadoop_job] if args.key?(:hadoop_job) + @hive_job = args[:hive_job] if args.key?(:hive_job) + @labels = args[:labels] if args.key?(:labels) + @pig_job = args[:pig_job] if args.key?(:pig_job) + @prerequisite_step_ids = args[:prerequisite_step_ids] if args.key?(:prerequisite_step_ids) + @pyspark_job = args[:pyspark_job] if args.key?(:pyspark_job) + @scheduling = args[:scheduling] if args.key?(:scheduling) + @spark_job = args[:spark_job] if args.key?(:spark_job) + @spark_sql_job = args[:spark_sql_job] if args.key?(:spark_sql_job) + @step_id = args[:step_id] if args.key?(:step_id) + end + end + # A Cloud Dataproc job for running Apache Pig (https://pig.apache.org/) queries # on YARN. class PigJob @@ -1893,6 +2135,225 @@ module Google end end + # The workflow graph. + class WorkflowGraph + include Google::Apis::Core::Hashable + + # Output-only The workflow nodes. + # Corresponds to the JSON property `nodes` + # @return [Array] + attr_accessor :nodes + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @nodes = args[:nodes] if args.key?(:nodes) + end + end + + # A Cloud Dataproc workflow template resource. + class WorkflowMetadata + include Google::Apis::Core::Hashable + + # Output-only The name of the managed cluster. + # Corresponds to the JSON property `clusterName` + # @return [String] + attr_accessor :cluster_name + + # Output-only The create cluster operation metadata. + # Corresponds to the JSON property `createCluster` + # @return [Google::Apis::DataprocV1beta2::ClusterOperation] + attr_accessor :create_cluster + + # Output-only The delete cluster operation metadata. + # Corresponds to the JSON property `deleteCluster` + # @return [Google::Apis::DataprocV1beta2::ClusterOperation] + attr_accessor :delete_cluster + + # The workflow graph. + # Corresponds to the JSON property `graph` + # @return [Google::Apis::DataprocV1beta2::WorkflowGraph] + attr_accessor :graph + + # Output-only The workflow state. + # Corresponds to the JSON property `state` + # @return [String] + attr_accessor :state + + # Output-only The "resource name" of the template. + # Corresponds to the JSON property `template` + # @return [String] + attr_accessor :template + + # Output-only The version of template at the time of workflow instantiation. + # Corresponds to the JSON property `version` + # @return [Fixnum] + attr_accessor :version + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cluster_name = args[:cluster_name] if args.key?(:cluster_name) + @create_cluster = args[:create_cluster] if args.key?(:create_cluster) + @delete_cluster = args[:delete_cluster] if args.key?(:delete_cluster) + @graph = args[:graph] if args.key?(:graph) + @state = args[:state] if args.key?(:state) + @template = args[:template] if args.key?(:template) + @version = args[:version] if args.key?(:version) + end + end + + # The workflow node. + class WorkflowNode + include Google::Apis::Core::Hashable + + # Output-only The error detail. + # Corresponds to the JSON property `error` + # @return [String] + attr_accessor :error + + # Output-only The job id; populated after the node enters RUNNING state. + # Corresponds to the JSON property `jobId` + # @return [String] + attr_accessor :job_id + + # Output-only Node's prerequisite nodes. + # Corresponds to the JSON property `prerequisiteStepIds` + # @return [Array] + attr_accessor :prerequisite_step_ids + + # Output-only The node state. + # Corresponds to the JSON property `state` + # @return [String] + attr_accessor :state + + # Output-only The name of the node. + # Corresponds to the JSON property `stepId` + # @return [String] + attr_accessor :step_id + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @error = args[:error] if args.key?(:error) + @job_id = args[:job_id] if args.key?(:job_id) + @prerequisite_step_ids = args[:prerequisite_step_ids] if args.key?(:prerequisite_step_ids) + @state = args[:state] if args.key?(:state) + @step_id = args[:step_id] if args.key?(:step_id) + end + end + + # A Cloud Dataproc workflow template resource. + class WorkflowTemplate + include Google::Apis::Core::Hashable + + # Output-only The time template was created. + # Corresponds to the JSON property `createTime` + # @return [String] + attr_accessor :create_time + + # Required The template id. + # Corresponds to the JSON property `id` + # @return [String] + attr_accessor :id + + # Required The Directed Acyclic Graph of Jobs to submit. + # Corresponds to the JSON property `jobs` + # @return [Array] + attr_accessor :jobs + + # Optional The labels to associate with this template. These labels will be + # propagated to all jobs and clusters created by the workflow instance.Label + # keys must contain 1 to 63 characters, and must conform to RFC 1035 (https:// + # www.ietf.org/rfc/rfc1035.txt).Label values may be empty, but, if present, must + # contain 1 to 63 characters, and must conform to RFC 1035 (https://www.ietf.org/ + # rfc/rfc1035.txt).No more than 32 labels can be associated with a template. + # Corresponds to the JSON property `labels` + # @return [Hash] + attr_accessor :labels + + # Output-only The "resource name" of the template, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # Corresponds to the JSON property `name` + # @return [String] + attr_accessor :name + + # Specifies workflow execution target.Either managed_cluster or cluster_selector + # is required. + # Corresponds to the JSON property `placement` + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplatePlacement] + attr_accessor :placement + + # Output-only The time template was last updated. + # Corresponds to the JSON property `updateTime` + # @return [String] + attr_accessor :update_time + + # Optional Used to perform a consistent read-modify-write.This field should be + # left blank for a CreateWorkflowTemplate request. It is required for an + # UpdateWorkflowTemplate request, and must match the current server version. A + # typical update template flow would fetch the current template with a + # GetWorkflowTemplate request, which will return the current template with the + # version field filled in with the current server version. The user updates + # other fields in the template, then returns it as part of the + # UpdateWorkflowTemplate request. + # Corresponds to the JSON property `version` + # @return [Fixnum] + attr_accessor :version + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @create_time = args[:create_time] if args.key?(:create_time) + @id = args[:id] if args.key?(:id) + @jobs = args[:jobs] if args.key?(:jobs) + @labels = args[:labels] if args.key?(:labels) + @name = args[:name] if args.key?(:name) + @placement = args[:placement] if args.key?(:placement) + @update_time = args[:update_time] if args.key?(:update_time) + @version = args[:version] if args.key?(:version) + end + end + + # Specifies workflow execution target.Either managed_cluster or cluster_selector + # is required. + class WorkflowTemplatePlacement + include Google::Apis::Core::Hashable + + # A selector that chooses target cluster for jobs based on metadata. + # Corresponds to the JSON property `clusterSelector` + # @return [Google::Apis::DataprocV1beta2::ClusterSelector] + attr_accessor :cluster_selector + + # Cluster that is managed by the workflow. + # Corresponds to the JSON property `managedCluster` + # @return [Google::Apis::DataprocV1beta2::ManagedCluster] + attr_accessor :managed_cluster + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @cluster_selector = args[:cluster_selector] if args.key?(:cluster_selector) + @managed_cluster = args[:managed_cluster] if args.key?(:managed_cluster) + end + end + # A YARN application created by a job. Application information is a subset of < # code>org.apache.hadoop.yarn.proto.YarnProtos.ApplicationReportProto. # Beta Feature: This report is available for testing purposes only. It may be diff --git a/generated/google/apis/dataproc_v1beta2/representations.rb b/generated/google/apis/dataproc_v1beta2/representations.rb index fc9819fe8..ec3e1818b 100644 --- a/generated/google/apis/dataproc_v1beta2/representations.rb +++ b/generated/google/apis/dataproc_v1beta2/representations.rb @@ -58,6 +58,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class ClusterOperation + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ClusterOperationMetadata class Representation < Google::Apis::Core::JsonRepresentation; end @@ -70,6 +76,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class ClusterSelector + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ClusterStatus class Representation < Google::Apis::Core::JsonRepresentation; end @@ -124,6 +136,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class InstantiateWorkflowTemplateRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class Job class Representation < Google::Apis::Core::JsonRepresentation; end @@ -178,12 +196,24 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class ListWorkflowTemplatesResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class LoggingConfig class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class ManagedCluster + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ManagedGroupConfig class Representation < Google::Apis::Core::JsonRepresentation; end @@ -202,6 +232,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class OrderedJob + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class PigJob class Representation < Google::Apis::Core::JsonRepresentation; end @@ -274,6 +310,36 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class WorkflowGraph + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkflowMetadata + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkflowNode + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkflowTemplate + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkflowTemplatePlacement + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class YarnApplication class Representation < Google::Apis::Core::JsonRepresentation; end @@ -349,6 +415,15 @@ module Google end end + class ClusterOperation + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :done, as: 'done' + property :error, as: 'error' + property :operation_id, as: 'operationId' + end + end + class ClusterOperationMetadata # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -375,6 +450,14 @@ module Google end end + class ClusterSelector + # @private + class Representation < Google::Apis::Core::JsonRepresentation + hash :cluster_labels, as: 'clusterLabels' + property :zone, as: 'zone' + end + end + class ClusterStatus # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -471,6 +554,14 @@ module Google end end + class InstantiateWorkflowTemplateRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :instance_id, as: 'instanceId' + property :version, as: 'version' + end + end + class Job # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -573,6 +664,15 @@ module Google end end + class ListWorkflowTemplatesResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :next_page_token, as: 'nextPageToken' + collection :templates, as: 'templates', class: Google::Apis::DataprocV1beta2::WorkflowTemplate, decorator: Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + + end + end + class LoggingConfig # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -580,6 +680,16 @@ module Google end end + class ManagedCluster + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :cluster_name, as: 'clusterName' + property :config, as: 'config', class: Google::Apis::DataprocV1beta2::ClusterConfig, decorator: Google::Apis::DataprocV1beta2::ClusterConfig::Representation + + hash :labels, as: 'labels' + end + end + class ManagedGroupConfig # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -608,6 +718,29 @@ module Google end end + class OrderedJob + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :hadoop_job, as: 'hadoopJob', class: Google::Apis::DataprocV1beta2::HadoopJob, decorator: Google::Apis::DataprocV1beta2::HadoopJob::Representation + + property :hive_job, as: 'hiveJob', class: Google::Apis::DataprocV1beta2::HiveJob, decorator: Google::Apis::DataprocV1beta2::HiveJob::Representation + + hash :labels, as: 'labels' + property :pig_job, as: 'pigJob', class: Google::Apis::DataprocV1beta2::PigJob, decorator: Google::Apis::DataprocV1beta2::PigJob::Representation + + collection :prerequisite_step_ids, as: 'prerequisiteStepIds' + property :pyspark_job, as: 'pysparkJob', class: Google::Apis::DataprocV1beta2::PySparkJob, decorator: Google::Apis::DataprocV1beta2::PySparkJob::Representation + + property :scheduling, as: 'scheduling', class: Google::Apis::DataprocV1beta2::JobScheduling, decorator: Google::Apis::DataprocV1beta2::JobScheduling::Representation + + property :spark_job, as: 'sparkJob', class: Google::Apis::DataprocV1beta2::SparkJob, decorator: Google::Apis::DataprocV1beta2::SparkJob::Representation + + property :spark_sql_job, as: 'sparkSqlJob', class: Google::Apis::DataprocV1beta2::SparkSqlJob, decorator: Google::Apis::DataprocV1beta2::SparkSqlJob::Representation + + property :step_id, as: 'stepId' + end + end + class PigJob # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -731,6 +864,67 @@ module Google end end + class WorkflowGraph + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :nodes, as: 'nodes', class: Google::Apis::DataprocV1beta2::WorkflowNode, decorator: Google::Apis::DataprocV1beta2::WorkflowNode::Representation + + end + end + + class WorkflowMetadata + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :cluster_name, as: 'clusterName' + property :create_cluster, as: 'createCluster', class: Google::Apis::DataprocV1beta2::ClusterOperation, decorator: Google::Apis::DataprocV1beta2::ClusterOperation::Representation + + property :delete_cluster, as: 'deleteCluster', class: Google::Apis::DataprocV1beta2::ClusterOperation, decorator: Google::Apis::DataprocV1beta2::ClusterOperation::Representation + + property :graph, as: 'graph', class: Google::Apis::DataprocV1beta2::WorkflowGraph, decorator: Google::Apis::DataprocV1beta2::WorkflowGraph::Representation + + property :state, as: 'state' + property :template, as: 'template' + property :version, as: 'version' + end + end + + class WorkflowNode + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :error, as: 'error' + property :job_id, as: 'jobId' + collection :prerequisite_step_ids, as: 'prerequisiteStepIds' + property :state, as: 'state' + property :step_id, as: 'stepId' + end + end + + class WorkflowTemplate + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :create_time, as: 'createTime' + property :id, as: 'id' + collection :jobs, as: 'jobs', class: Google::Apis::DataprocV1beta2::OrderedJob, decorator: Google::Apis::DataprocV1beta2::OrderedJob::Representation + + hash :labels, as: 'labels' + property :name, as: 'name' + property :placement, as: 'placement', class: Google::Apis::DataprocV1beta2::WorkflowTemplatePlacement, decorator: Google::Apis::DataprocV1beta2::WorkflowTemplatePlacement::Representation + + property :update_time, as: 'updateTime' + property :version, as: 'version' + end + end + + class WorkflowTemplatePlacement + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :cluster_selector, as: 'clusterSelector', class: Google::Apis::DataprocV1beta2::ClusterSelector, decorator: Google::Apis::DataprocV1beta2::ClusterSelector::Representation + + property :managed_cluster, as: 'managedCluster', class: Google::Apis::DataprocV1beta2::ManagedCluster, decorator: Google::Apis::DataprocV1beta2::ManagedCluster::Representation + + end + end + class YarnApplication # @private class Representation < Google::Apis::Core::JsonRepresentation diff --git a/generated/google/apis/dataproc_v1beta2/service.rb b/generated/google/apis/dataproc_v1beta2/service.rb index 543d229e6..c87c51a00 100644 --- a/generated/google/apis/dataproc_v1beta2/service.rb +++ b/generated/google/apis/dataproc_v1beta2/service.rb @@ -47,6 +47,232 @@ module Google @batch_path = 'batch' end + # Creates new workflow template. + # @param [String] parent + # Required The "resource name" of the region, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region` + # @param [Google::Apis::DataprocV1beta2::WorkflowTemplate] workflow_template_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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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 create_project_location_workflow_template(parent, workflow_template_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1beta2/{+parent}/workflowTemplates', options) + command.request_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.request_object = workflow_template_object + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + command.params['parent'] = parent unless parent.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Deletes a workflow template. It does not cancel in-progress workflows. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Fixnum] version + # Optional The version of workflow template to delete. If specified, will only + # delete the template if the current server version matches specified version. + # @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::DataprocV1beta2::Empty] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::Empty] + # + # @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_workflow_template(name, version: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:delete, 'v1beta2/{+name}', options) + command.response_representation = Google::Apis::DataprocV1beta2::Empty::Representation + command.response_class = Google::Apis::DataprocV1beta2::Empty + command.params['name'] = name unless name.nil? + command.query['version'] = version unless version.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Retrieves the latest workflow template.Can retrieve previously instantiated + # template by specifying optional version parameter. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Fixnum] version + # Optional The version of workflow template to retrieve. Only previously + # instatiated versions can be retrieved.If unspecified, retrieves the current + # version. + # @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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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_workflow_template(name, version: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1beta2/{+name}', options) + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + command.params['name'] = name unless name.nil? + command.query['version'] = version unless version.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Instantiates a template and begins execution.The returned Operation can be + # used to track execution of workflow by polling google.cloud.dataproc.v1beta2. + # OperationService.GetOperation. The Operation will complete when entire + # workflow is finished.The running workflow can be aborted via google.cloud. + # dataproc.v1beta2.OperationService.CancelOperation.The google.cloud.dataproc. + # v1beta2.Operation.metadata will always be google.cloud.dataproc.v1beta2. + # WorkflowMetadata.The google.cloud.dataproc.v1beta2.Operation.result will + # always be google.protobuf.Empty. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Google::Apis::DataprocV1beta2::InstantiateWorkflowTemplateRequest] instantiate_workflow_template_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::DataprocV1beta2::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::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 instantiate_project_location_workflow_template(name, instantiate_workflow_template_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1beta2/{+name}:instantiate', options) + command.request_representation = Google::Apis::DataprocV1beta2::InstantiateWorkflowTemplateRequest::Representation + command.request_object = instantiate_workflow_template_request_object + command.response_representation = Google::Apis::DataprocV1beta2::Operation::Representation + command.response_class = Google::Apis::DataprocV1beta2::Operation + 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 workflows that match the specified filter in the request. + # @param [String] parent + # Required The "resource name" of the region, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region` + # @param [Fixnum] page_size + # Optional The maximum number of results to return in each response. + # @param [String] page_token + # Optional The page token, returned by a previous call, to request the next page + # of results. + # @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::DataprocV1beta2::ListWorkflowTemplatesResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse] + # + # @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_workflow_templates(parent, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1beta2/{+parent}/workflowTemplates', options) + command.response_representation = Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse::Representation + command.response_class = Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse + command.params['parent'] = parent unless parent.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 + + # Updates (replaces) workflow template. The updated template must contain + # version that matches the current server version. + # @param [String] name + # Output-only The "resource name" of the template, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Google::Apis::DataprocV1beta2::WorkflowTemplate] workflow_template_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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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 update_project_location_workflow_template(name, workflow_template_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:put, 'v1beta2/{+name}', options) + command.request_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.request_object = workflow_template_object + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + 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 + # Creates a cluster in a project. # @param [String] project_id # Required. The ID of the Google Cloud Platform project that the cluster belongs @@ -831,6 +1057,232 @@ module Google command.query['quotaUser'] = quota_user unless quota_user.nil? execute_or_queue_command(command, &block) end + + # Creates new workflow template. + # @param [String] parent + # Required The "resource name" of the region, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region` + # @param [Google::Apis::DataprocV1beta2::WorkflowTemplate] workflow_template_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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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 create_project_region_workflow_template(parent, workflow_template_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1beta2/{+parent}/workflowTemplates', options) + command.request_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.request_object = workflow_template_object + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + command.params['parent'] = parent unless parent.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Deletes a workflow template. It does not cancel in-progress workflows. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Fixnum] version + # Optional The version of workflow template to delete. If specified, will only + # delete the template if the current server version matches specified version. + # @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::DataprocV1beta2::Empty] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::Empty] + # + # @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_region_workflow_template(name, version: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:delete, 'v1beta2/{+name}', options) + command.response_representation = Google::Apis::DataprocV1beta2::Empty::Representation + command.response_class = Google::Apis::DataprocV1beta2::Empty + command.params['name'] = name unless name.nil? + command.query['version'] = version unless version.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Retrieves the latest workflow template.Can retrieve previously instantiated + # template by specifying optional version parameter. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Fixnum] version + # Optional The version of workflow template to retrieve. Only previously + # instatiated versions can be retrieved.If unspecified, retrieves the current + # version. + # @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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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_region_workflow_template(name, version: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1beta2/{+name}', options) + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + command.params['name'] = name unless name.nil? + command.query['version'] = version unless version.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + execute_or_queue_command(command, &block) + end + + # Instantiates a template and begins execution.The returned Operation can be + # used to track execution of workflow by polling google.cloud.dataproc.v1beta2. + # OperationService.GetOperation. The Operation will complete when entire + # workflow is finished.The running workflow can be aborted via google.cloud. + # dataproc.v1beta2.OperationService.CancelOperation.The google.cloud.dataproc. + # v1beta2.Operation.metadata will always be google.cloud.dataproc.v1beta2. + # WorkflowMetadata.The google.cloud.dataproc.v1beta2.Operation.result will + # always be google.protobuf.Empty. + # @param [String] name + # Required The "resource name" of the workflow template, as described in https:// + # cloud.google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Google::Apis::DataprocV1beta2::InstantiateWorkflowTemplateRequest] instantiate_workflow_template_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::DataprocV1beta2::Operation] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::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 instantiate_project_region_workflow_template(name, instantiate_workflow_template_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1beta2/{+name}:instantiate', options) + command.request_representation = Google::Apis::DataprocV1beta2::InstantiateWorkflowTemplateRequest::Representation + command.request_object = instantiate_workflow_template_request_object + command.response_representation = Google::Apis::DataprocV1beta2::Operation::Representation + command.response_class = Google::Apis::DataprocV1beta2::Operation + 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 workflows that match the specified filter in the request. + # @param [String] parent + # Required The "resource name" of the region, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region` + # @param [Fixnum] page_size + # Optional The maximum number of results to return in each response. + # @param [String] page_token + # Optional The page token, returned by a previous call, to request the next page + # of results. + # @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::DataprocV1beta2::ListWorkflowTemplatesResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse] + # + # @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_region_workflow_templates(parent, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1beta2/{+parent}/workflowTemplates', options) + command.response_representation = Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse::Representation + command.response_class = Google::Apis::DataprocV1beta2::ListWorkflowTemplatesResponse + command.params['parent'] = parent unless parent.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 + + # Updates (replaces) workflow template. The updated template must contain + # version that matches the current server version. + # @param [String] name + # Output-only The "resource name" of the template, as described in https://cloud. + # google.com/apis/design/resource_names of the form projects/`project_id`/ + # regions/`region`/workflowTemplates/`template_id` + # @param [Google::Apis::DataprocV1beta2::WorkflowTemplate] workflow_template_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::DataprocV1beta2::WorkflowTemplate] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataprocV1beta2::WorkflowTemplate] + # + # @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 update_project_region_workflow_template(name, workflow_template_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:put, 'v1beta2/{+name}', options) + command.request_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.request_object = workflow_template_object + command.response_representation = Google::Apis::DataprocV1beta2::WorkflowTemplate::Representation + command.response_class = Google::Apis::DataprocV1beta2::WorkflowTemplate + 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 protected diff --git a/generated/google/apis/dlp_v2beta1.rb b/generated/google/apis/dlp_v2beta1.rb index f9b25013e..bcb9568ad 100644 --- a/generated/google/apis/dlp_v2beta1.rb +++ b/generated/google/apis/dlp_v2beta1.rb @@ -27,7 +27,7 @@ module Google # @see https://cloud.google.com/dlp/docs/ module DlpV2beta1 VERSION = 'V2beta1' - REVISION = '20170918' + REVISION = '20170927' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/dlp_v2beta1/classes.rb b/generated/google/apis/dlp_v2beta1/classes.rb index 878773fee..fdcdfc96c 100644 --- a/generated/google/apis/dlp_v2beta1/classes.rb +++ b/generated/google/apis/dlp_v2beta1/classes.rb @@ -792,7 +792,7 @@ module Google # Replaces an identifier with an surrogate using FPE with the FFX # mode of operation. - # The identifier must be encoded as ASCII. + # The identifier must be representable by the US-ASCII character set. # For a given crypto key and context, the same identifier will be # replaced with the same surrogate. # Note that a given identifier must be either the empty string or be at @@ -849,6 +849,55 @@ module Google end end + # Replaces an identifier with a surrogate using FPE based + # on a regular expression. + # The identifier must be representable by the ISO LATIN-1 character set. + # For a given crypto key and context, the same identifier will be + # replaced with the same surrogate. + class GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig + include Google::Apis::Core::Hashable + + # General identifier of a data field in a storage service. + # Corresponds to the JSON property `context` + # @return [Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1FieldId] + attr_accessor :context + + # This is a data encryption key (DEK) (as opposed to + # a key encryption key (KEK) stored by KMS). + # When using KMS to wrap/unwrap DEKs, be sure to set an appropriate + # IAM policy on the KMS CryptoKey (KEK) to ensure an attacker cannot + # unwrap the data crypto key. + # Corresponds to the JSON property `cryptoKey` + # @return [Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoKey] + attr_accessor :crypto_key + + # The regular expression to match the identifier/surrogate values. + # There are several restrictions on the regular expression: + # - It must match at least two distinct strings + # (for example, 'a' is invalid but '[ab]' is valid). + # - Both the regular expression itself and the strings it matches must be + # representable by the ISO LATIN-1 character set. + # - Its [syntax](https://github.com/google/re2/wiki/Syntax) can be found + # under the google/re2 repository on GitHub. + # - It is advisable to anchor the regex (with '^' and '$'); otherwise + # implicit '.*'s are assumed. + # - It must be 1000 characters at most. + # Corresponds to the JSON property `regex` + # @return [String] + attr_accessor :regex + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @context = args[:context] if args.key?(:context) + @crypto_key = args[:crypto_key] if args.key?(:crypto_key) + @regex = args[:regex] if args.key?(:regex) + end + end + # Record key for a finding in Cloud Datastore. class GooglePrivacyDlpV2beta1DatastoreKey include Google::Apis::Core::Hashable @@ -2319,7 +2368,7 @@ module Google # Replaces an identifier with an surrogate using FPE with the FFX # mode of operation. - # The identifier must be encoded as ASCII. + # The identifier must be representable by the US-ASCII character set. # For a given crypto key and context, the same identifier will be # replaced with the same surrogate. # Note that a given identifier must be either the empty string or be at @@ -2328,6 +2377,15 @@ module Google # @return [Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig] attr_accessor :crypto_replace_ffx_fpe_config + # Replaces an identifier with a surrogate using FPE based + # on a regular expression. + # The identifier must be representable by the ISO LATIN-1 character set. + # For a given crypto key and context, the same identifier will be + # replaced with the same surrogate. + # Corresponds to the JSON property `cryptoReplaceRegexFpeConfig` + # @return [Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig] + attr_accessor :crypto_replace_regex_fpe_config + # Buckets values based on fixed size ranges. The # Bucketing transformation can provide all of this functionality, # but requires more configuration. This message is provided as a convenience to @@ -2375,6 +2433,7 @@ module Google @character_mask_config = args[:character_mask_config] if args.key?(:character_mask_config) @crypto_hash_config = args[:crypto_hash_config] if args.key?(:crypto_hash_config) @crypto_replace_ffx_fpe_config = args[:crypto_replace_ffx_fpe_config] if args.key?(:crypto_replace_ffx_fpe_config) + @crypto_replace_regex_fpe_config = args[:crypto_replace_regex_fpe_config] if args.key?(:crypto_replace_regex_fpe_config) @fixed_size_bucketing_config = args[:fixed_size_bucketing_config] if args.key?(:fixed_size_bucketing_config) @redact_config = args[:redact_config] if args.key?(:redact_config) @replace_config = args[:replace_config] if args.key?(:replace_config) diff --git a/generated/google/apis/dlp_v2beta1/representations.rb b/generated/google/apis/dlp_v2beta1/representations.rb index fb16c1c95..9e99779e4 100644 --- a/generated/google/apis/dlp_v2beta1/representations.rb +++ b/generated/google/apis/dlp_v2beta1/representations.rb @@ -172,6 +172,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class GooglePrivacyDlpV2beta1DatastoreKey class Representation < Google::Apis::Core::JsonRepresentation; end @@ -891,6 +897,17 @@ module Google end end + class GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :context, as: 'context', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1FieldId, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1FieldId::Representation + + property :crypto_key, as: 'cryptoKey', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoKey, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoKey::Representation + + property :regex, as: 'regex' + end + end + class GooglePrivacyDlpV2beta1DatastoreKey # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1372,6 +1389,8 @@ module Google property :crypto_replace_ffx_fpe_config, as: 'cryptoReplaceFfxFpeConfig', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceFfxFpeConfig::Representation + property :crypto_replace_regex_fpe_config, as: 'cryptoReplaceRegexFpeConfig', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1CryptoReplaceRegexFpeConfig::Representation + property :fixed_size_bucketing_config, as: 'fixedSizeBucketingConfig', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1FixedSizeBucketingConfig, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1FixedSizeBucketingConfig::Representation property :redact_config, as: 'redactConfig', class: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1RedactConfig, decorator: Google::Apis::DlpV2beta1::GooglePrivacyDlpV2beta1RedactConfig::Representation diff --git a/generated/google/apis/fitness_v1.rb b/generated/google/apis/fitness_v1.rb index de2d0526d..b6aa7b634 100644 --- a/generated/google/apis/fitness_v1.rb +++ b/generated/google/apis/fitness_v1.rb @@ -25,7 +25,7 @@ module Google # @see https://developers.google.com/fit/rest/ module FitnessV1 VERSION = 'V1' - REVISION = '20170830' + REVISION = '20170922' # View your activity information in Google Fit AUTH_FITNESS_ACTIVITY_READ = 'https://www.googleapis.com/auth/fitness.activity.read' diff --git a/generated/google/apis/fitness_v1/classes.rb b/generated/google/apis/fitness_v1/classes.rb index 7992f2b9d..6e2217c16 100644 --- a/generated/google/apis/fitness_v1/classes.rb +++ b/generated/google/apis/fitness_v1/classes.rb @@ -725,13 +725,13 @@ module Google # @return [String] attr_accessor :data_source_id - # Data points that have been removed and will not be included in any other - # request for dataset contents. + # Deleted data points for the user. Note, for modifications this should be + # parsed before handling insertions. # Corresponds to the JSON property `deletedDataPoint` # @return [Array] attr_accessor :deleted_data_point - # Data points listed. + # Inserted data points for the user. # Corresponds to the JSON property `insertedDataPoint` # @return [Array] attr_accessor :inserted_data_point diff --git a/generated/google/apis/fitness_v1/service.rb b/generated/google/apis/fitness_v1/service.rb index 45955503e..586afd72d 100644 --- a/generated/google/apis/fitness_v1/service.rb +++ b/generated/google/apis/fitness_v1/service.rb @@ -311,15 +311,15 @@ module Google execute_or_queue_command(command, &block) end - # results ordered by descending end_time + # Queries for user's data point changes for a particular data source. # @param [String] user_id - # List data points for the person identified. Use "me" to indicate the - # authenticated user. Only "me" is supported at this time. + # List data points for the person identified. Use me to indicate the + # authenticated user. Only me is supported at this time. # @param [String] data_source_id # The data stream ID of the data source that created the dataset. # @param [Fixnum] limit # If specified, no more than this many data point changes will be included in - # the response. The default is 500 data point changes. + # the response. # @param [String] page_token # The continuation token, which is used to page through large result sets. To # get the next page of results, set this parameter to the value of nextPageToken diff --git a/generated/google/apis/logging_v2beta1.rb b/generated/google/apis/logging_v2beta1.rb index e5876efd8..17ec2a8ce 100644 --- a/generated/google/apis/logging_v2beta1.rb +++ b/generated/google/apis/logging_v2beta1.rb @@ -25,7 +25,7 @@ module Google # @see https://cloud.google.com/logging/docs/ module LoggingV2beta1 VERSION = 'V2beta1' - REVISION = '20170905' + REVISION = '20170926' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/logging_v2beta1/classes.rb b/generated/google/apis/logging_v2beta1/classes.rb index 88d8a5918..564117397 100644 --- a/generated/google/apis/logging_v2beta1/classes.rb +++ b/generated/google/apis/logging_v2beta1/classes.rb @@ -598,15 +598,17 @@ module Google # "organizations/[ORGANIZATION_ID]/logs/[LOG_ID]" # "billingAccounts/[BILLING_ACCOUNT_ID]/logs/[LOG_ID]" # "folders/[FOLDER_ID]/logs/[LOG_ID]" - # [LOG_ID] must be URL-encoded within log_name. Example: "organizations/ - # 1234567890/logs/cloudresourcemanager.googleapis.com%2Factivity". [LOG_ID] must - # be less than 512 characters long and can only include the following characters: - # upper and lower case alphanumeric characters, forward-slash, underscore, - # hyphen, and period.For backward compatibility, if log_name begins with a - # forward-slash, such as /projects/..., then the log entry is ingested as usual - # but the forward-slash is removed. Listing the log entry will not show the - # leading slash and filtering for a log name with a leading slash will never - # return any results. + # A project number may optionally be used in place of PROJECT_ID. The project + # number is translated to its corresponding PROJECT_ID internally and the + # log_name field will contain PROJECT_ID in queries and exports.[LOG_ID] must be + # URL-encoded within log_name. Example: "organizations/1234567890/logs/ + # cloudresourcemanager.googleapis.com%2Factivity". [LOG_ID] must be less than + # 512 characters long and can only include the following characters: upper and + # lower case alphanumeric characters, forward-slash, underscore, hyphen, and + # period.For backward compatibility, if log_name begins with a forward-slash, + # such as /projects/..., then the log entry is ingested as usual but the forward- + # slash is removed. Listing the log entry will not show the leading slash and + # filtering for a log name with a leading slash will never return any results. # Corresponds to the JSON property `logName` # @return [String] attr_accessor :log_name diff --git a/generated/google/apis/resourceviews_v1beta1/service.rb b/generated/google/apis/resourceviews_v1beta1/service.rb index efc1ee88d..ad2c56f26 100644 --- a/generated/google/apis/resourceviews_v1beta1/service.rb +++ b/generated/google/apis/resourceviews_v1beta1/service.rb @@ -51,7 +51,7 @@ module Google def initialize super('https://www.googleapis.com/', 'resourceviews/v1beta1/projects/') - @batch_path = 'batch' + @batch_path = 'batch/resourceviews/v1beta1' end # Add resources to the view. diff --git a/generated/google/apis/servicecontrol_v1.rb b/generated/google/apis/servicecontrol_v1.rb index 0a8bed7b2..9c7f5e0e6 100644 --- a/generated/google/apis/servicecontrol_v1.rb +++ b/generated/google/apis/servicecontrol_v1.rb @@ -26,7 +26,7 @@ module Google # @see https://cloud.google.com/service-control/ module ServicecontrolV1 VERSION = 'V1' - REVISION = '20170918' + REVISION = '20170925' # View and manage your data across Google Cloud Platform services AUTH_CLOUD_PLATFORM = 'https://www.googleapis.com/auth/cloud-platform' diff --git a/generated/google/apis/servicecontrol_v1/classes.rb b/generated/google/apis/servicecontrol_v1/classes.rb index d52717a90..7db0958d9 100644 --- a/generated/google/apis/servicecontrol_v1/classes.rb +++ b/generated/google/apis/servicecontrol_v1/classes.rb @@ -1084,6 +1084,7 @@ module Google # @return [Google::Apis::ServicecontrolV1::QuotaProperties] attr_accessor :quota_properties + # DO NOT USE. This field is deprecated, use "resources" field instead. # The resource name of the parent of a resource in the resource hierarchy. # This can be in one of the following formats: # - “projects/” @@ -1292,21 +1293,6 @@ module Google class QuotaProperties include Google::Apis::Core::Hashable - # LimitType IDs that should be used for checking quota. Key in this map - # should be a valid LimitType string, and the value is the ID to be used. For - # example, an entry will cause all user quota limits to use 123 - # as the user ID. See google/api/quota.proto for the definition of LimitType. - # CLIENT_PROJECT: Not supported. - # USER: Value of this entry will be used for enforcing user-level quota - # limits. If none specified, caller IP passed in the - # servicecontrol.googleapis.com/caller_ip label will be used instead. - # If the server cannot resolve a value for this LimitType, an error - # will be thrown. No validation will be performed on this ID. - # Deprecated: use servicecontrol.googleapis.com/user label to send user ID. - # Corresponds to the JSON property `limitByIds` - # @return [Hash] - attr_accessor :limit_by_ids - # Quota mode for this operation. # Corresponds to the JSON property `quotaMode` # @return [String] @@ -1318,7 +1304,6 @@ module Google # Update properties of this object def update!(**args) - @limit_by_ids = args[:limit_by_ids] if args.key?(:limit_by_ids) @quota_mode = args[:quota_mode] if args.key?(:quota_mode) end end @@ -1575,16 +1560,27 @@ module Google # The IP address of the caller. # For caller from internet, this will be public IPv4 or IPv6 address. - # For caller from GCE VM with external IP address, this will be the VM's - # external IP address. For caller from GCE VM without external IP address, if - # the VM is in the same GCP organization (or project) as the accessed - # resource, `caller_ip` will be the GCE VM's internal IPv4 address, otherwise - # it will be redacted to "gce-internal-ip". + # For caller from a Compute Engine VM with external IP address, this + # will be the VM's external IP address. For caller from a Compute + # Engine VM without external IP address, if the VM is in the same + # organization (or project) as the accessed resource, `caller_ip` will + # be the VM's internal IPv4 address, otherwise the `caller_ip` will be + # redacted to "gce-internal-ip". # See https://cloud.google.com/compute/docs/vpc/ for more information. # Corresponds to the JSON property `callerIp` # @return [String] attr_accessor :caller_ip + # The network of the caller. + # Set only if the network host project is part of the same GCP organization + # (or project) as the accessed resource. + # See https://cloud.google.com/compute/docs/vpc/ for more information. + # This is a scheme-less URI full resource name. For example: + # "//compute.googleapis.com/projects/PROJECT_ID/global/networks/NETWORK_ID" + # Corresponds to the JSON property `callerNetwork` + # @return [String] + attr_accessor :caller_network + # The user agent of the caller. # This information is not authenticated and should be treated accordingly. # For example: @@ -1607,12 +1603,12 @@ module Google # Update properties of this object def update!(**args) @caller_ip = args[:caller_ip] if args.key?(:caller_ip) + @caller_network = args[:caller_network] if args.key?(:caller_network) @caller_supplied_user_agent = args[:caller_supplied_user_agent] if args.key?(:caller_supplied_user_agent) end end - # DO NOT USE. - # This definition is not ready for use yet. + # Describes a resource associated with this operation. class ResourceInfo include Google::Apis::Core::Hashable diff --git a/generated/google/apis/servicecontrol_v1/representations.rb b/generated/google/apis/servicecontrol_v1/representations.rb index 3a476b823..05792faa7 100644 --- a/generated/google/apis/servicecontrol_v1/representations.rb +++ b/generated/google/apis/servicecontrol_v1/representations.rb @@ -534,7 +534,6 @@ module Google class QuotaProperties # @private class Representation < Google::Apis::Core::JsonRepresentation - hash :limit_by_ids, as: 'limitByIds' property :quota_mode, as: 'quotaMode' end end @@ -602,6 +601,7 @@ module Google # @private class Representation < Google::Apis::Core::JsonRepresentation property :caller_ip, as: 'callerIp' + property :caller_network, as: 'callerNetwork' property :caller_supplied_user_agent, as: 'callerSuppliedUserAgent' end end diff --git a/generated/google/apis/streetviewpublish_v1.rb b/generated/google/apis/streetviewpublish_v1.rb index 7103cf2c8..36e9c742f 100644 --- a/generated/google/apis/streetviewpublish_v1.rb +++ b/generated/google/apis/streetviewpublish_v1.rb @@ -27,7 +27,7 @@ module Google # @see https://developers.google.com/streetview/publish/ module StreetviewpublishV1 VERSION = 'V1' - REVISION = '20170920' + REVISION = '20170927' # Publish and manage your 360 photos on Google Street View AUTH_STREETVIEWPUBLISH = 'https://www.googleapis.com/auth/streetviewpublish' diff --git a/generated/google/apis/streetviewpublish_v1/service.rb b/generated/google/apis/streetviewpublish_v1/service.rb index 095b9914a..6a75ae987 100644 --- a/generated/google/apis/streetviewpublish_v1/service.rb +++ b/generated/google/apis/streetviewpublish_v1/service.rb @@ -54,6 +54,12 @@ module Google # CreatePhoto # publishes the uploaded Photo to # Street View on Google Maps. + # Currently, the only way to set heading, pitch, and roll in CreatePhoto is + # through the [Photo Sphere XMP + # metadata](https://developers.google.com/streetview/spherical-metadata) in + # the photo bytes. The `pose.heading`, `pose.pitch`, `pose.roll`, + # `pose.altitude`, and `pose.level` fields in Pose are ignored for + # CreatePhoto. # This method returns the following error codes: # * google.rpc.Code.INVALID_ARGUMENT if the request is malformed. # * google.rpc.Code.NOT_FOUND if the upload reference does not exist. @@ -430,6 +436,7 @@ module Google # the user. # @param [String] filter # The filter expression. For example: `placeId=ChIJj61dQgK6j4AR4GeTYWZsKWw`. + # The only filter supported at the moment is `placeId`. # @param [Fixnum] page_size # The maximum number of photos to return. # `pageSize` must be non-negative. If `pageSize` is zero or is not provided, diff --git a/generated/google/apis/taskqueue_v1beta2/service.rb b/generated/google/apis/taskqueue_v1beta2/service.rb index 212ad4616..61eda38cf 100644 --- a/generated/google/apis/taskqueue_v1beta2/service.rb +++ b/generated/google/apis/taskqueue_v1beta2/service.rb @@ -50,7 +50,7 @@ module Google def initialize super('https://www.googleapis.com/', 'taskqueue/v1beta2/projects/') - @batch_path = 'batch' + @batch_path = 'batch/taskqueue/v1beta2' end # Get detailed information about a TaskQueue. diff --git a/generated/google/apis/youtube_partner_v1.rb b/generated/google/apis/youtube_partner_v1.rb index a8ac000f8..204e2cdc5 100644 --- a/generated/google/apis/youtube_partner_v1.rb +++ b/generated/google/apis/youtube_partner_v1.rb @@ -25,7 +25,7 @@ module Google # @see https://developers.google.com/youtube/partner/ module YoutubePartnerV1 VERSION = 'V1' - REVISION = '20170918' + REVISION = '20170925' # View and manage your assets and associated content on YouTube AUTH_YOUTUBEPARTNER = 'https://www.googleapis.com/auth/youtubepartner' diff --git a/generated/google/apis/youtube_partner_v1/classes.rb b/generated/google/apis/youtube_partner_v1/classes.rb index 85c794bbe..9ce28c67a 100644 --- a/generated/google/apis/youtube_partner_v1/classes.rb +++ b/generated/google/apis/youtube_partner_v1/classes.rb @@ -3658,6 +3658,59 @@ module Google end end + # + class Uploader + include Google::Apis::Core::Hashable + + # The type of the API resource. For uploader resources, the value is + # youtubePartner#uploader. + # Corresponds to the JSON property `kind` + # @return [String] + attr_accessor :kind + + # The uploader name. + # Corresponds to the JSON property `uploaderName` + # @return [String] + attr_accessor :uploader_name + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @kind = args[:kind] if args.key?(:kind) + @uploader_name = args[:uploader_name] if args.key?(:uploader_name) + end + end + + # + class UploaderListResponse + include Google::Apis::Core::Hashable + + # A list of uploader (youtubePartner#uploader) resources that match the request + # criteria. + # Corresponds to the JSON property `items` + # @return [Array] + attr_accessor :items + + # The type of the API response. For this operation, the value is youtubePartner# + # uploaderList. + # Corresponds to the JSON property `kind` + # @return [String] + attr_accessor :kind + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @items = args[:items] if args.key?(:items) + @kind = args[:kind] if args.key?(:kind) + end + end + # class ValidateAsyncRequest include Google::Apis::Core::Hashable diff --git a/generated/google/apis/youtube_partner_v1/representations.rb b/generated/google/apis/youtube_partner_v1/representations.rb index 5163d8948..75ece704b 100644 --- a/generated/google/apis/youtube_partner_v1/representations.rb +++ b/generated/google/apis/youtube_partner_v1/representations.rb @@ -490,6 +490,18 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class Uploader + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class UploaderListResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ValidateAsyncRequest class Representation < Google::Apis::Core::JsonRepresentation; end @@ -1516,6 +1528,23 @@ module Google end end + class Uploader + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :kind, as: 'kind' + property :uploader_name, as: 'uploaderName' + end + end + + class UploaderListResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :items, as: 'items', class: Google::Apis::YoutubePartnerV1::Uploader, decorator: Google::Apis::YoutubePartnerV1::Uploader::Representation + + property :kind, as: 'kind' + end + end + class ValidateAsyncRequest # @private class Representation < Google::Apis::Core::JsonRepresentation diff --git a/generated/google/apis/youtube_partner_v1/service.rb b/generated/google/apis/youtube_partner_v1/service.rb index 173363eb1..2b2784cdd 100644 --- a/generated/google/apis/youtube_partner_v1/service.rb +++ b/generated/google/apis/youtube_partner_v1/service.rb @@ -2957,6 +2957,43 @@ module Google execute_or_queue_command(command, &block) end + # Retrieves a list of uploaders for a content owner. + # @param [String] on_behalf_of_content_owner + # The onBehalfOfContentOwner parameter identifies the content owner that the + # user is acting on behalf of. This parameter supports users whose accounts are + # associated with multiple content owners. + # @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. + # Overrides userIp if both are provided. + # @param [String] user_ip + # IP address of the site where the request originates. Use this if you want to + # enforce per-user limits. + # @param [Google::Apis::RequestOptions] options + # Request-specific options + # + # @yield [result, err] Result & error if block supplied + # @yieldparam result [Google::Apis::YoutubePartnerV1::UploaderListResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::YoutubePartnerV1::UploaderListResponse] + # + # @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_uploaders(on_behalf_of_content_owner: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block) + command = make_simple_command(:get, 'uploader', options) + command.response_representation = Google::Apis::YoutubePartnerV1::UploaderListResponse::Representation + command.response_class = Google::Apis::YoutubePartnerV1::UploaderListResponse + command.query['onBehalfOfContentOwner'] = on_behalf_of_content_owner unless on_behalf_of_content_owner.nil? + command.query['fields'] = fields unless fields.nil? + command.query['quotaUser'] = quota_user unless quota_user.nil? + command.query['userIp'] = user_ip unless user_ip.nil? + execute_or_queue_command(command, &block) + end + # Validate a metadata file. # @param [Google::Apis::YoutubePartnerV1::ValidateRequest] validate_request_object # @param [String] on_behalf_of_content_owner