From d32b26f4c52d62f01a330660a16d12050ebedfcc Mon Sep 17 00:00:00 2001 From: Google APIs Date: Tue, 26 May 2020 00:38:26 +0000 Subject: [PATCH] Autogenerated update (2020-05-26) Update: - apigee_v1 - dataflow_v1b3 --- generated/google/apis/apigee_v1.rb | 2 +- generated/google/apis/apigee_v1/classes.rb | 43 ++- .../google/apis/apigee_v1/representations.rb | 5 + generated/google/apis/apigee_v1/service.rb | 28 +- generated/google/apis/dataflow_v1b3.rb | 2 +- .../google/apis/dataflow_v1b3/classes.rb | 331 ++++++++++++++++++ .../apis/dataflow_v1b3/representations.rb | 164 +++++++++ .../google/apis/dataflow_v1b3/service.rb | 261 ++++++++++++++ 8 files changed, 817 insertions(+), 19 deletions(-) diff --git a/generated/google/apis/apigee_v1.rb b/generated/google/apis/apigee_v1.rb index 28acfdb99..ceae6a6fe 100644 --- a/generated/google/apis/apigee_v1.rb +++ b/generated/google/apis/apigee_v1.rb @@ -31,7 +31,7 @@ module Google # @see https://cloud.google.com/apigee-api-management/ module ApigeeV1 VERSION = 'V1' - REVISION = '20200514' + REVISION = '20200521' # 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/apigee_v1/classes.rb b/generated/google/apis/apigee_v1/classes.rb index b68cbdfc3..c93ecb2ff 100644 --- a/generated/google/apis/apigee_v1/classes.rb +++ b/generated/google/apis/apigee_v1/classes.rb @@ -1596,6 +1596,17 @@ module Google # @return [String] attr_accessor :name + # The uid of the proxy revision. + # Corresponds to the JSON property `proxyUid` + # @return [String] + attr_accessor :proxy_uid + + # A unique id that will only change if the deployment is deleted and + # recreated. + # Corresponds to the JSON property `uid` + # @return [String] + attr_accessor :uid + def initialize(**args) update!(**args) end @@ -1606,6 +1617,8 @@ module Google @base_path = args[:base_path] if args.key?(:base_path) @location = args[:location] if args.key?(:location) @name = args[:name] if args.key?(:name) + @proxy_uid = args[:proxy_uid] if args.key?(:proxy_uid) + @uid = args[:uid] if args.key?(:uid) end end @@ -1816,6 +1829,10 @@ module Google include Google::Apis::Core::Hashable # List of API products for which the credential can be used. + # **Note**: Do not specify the list of API products when creating a consumer + # key and secret for a developer app. Instead, use the + # UpdateDeveloperAppKey API to + # make the association after the consumer key and secret are created. # Corresponds to the JSON property `apiProducts` # @return [Array] attr_accessor :api_products @@ -2044,10 +2061,14 @@ module Google # @return [Array] attr_accessor :resources - # A sequence number that defines an ordering on environment configs. No two - # configs under an environment will ever have the same sequence number. - # A higher sequence number means that the config was deployed more - # recently than one with a lower sequence number. + # Revision id that defines the ordering on the environment config. + # The higher the revision, the more recently the configuration + # was deployed. + # Corresponds to the JSON property `revisionId` + # @return [Fixnum] + attr_accessor :revision_id + + # DEPRECATED: use revision_id # Corresponds to the JSON property `sequenceNumber` # @return [Fixnum] attr_accessor :sequence_number @@ -2058,6 +2079,12 @@ module Google # @return [Array] attr_accessor :targets + # A unique id for the environment config that will only change if the + # environment is deleted and recreated. + # Corresponds to the JSON property `uid` + # @return [String] + attr_accessor :uid + def initialize(**args) update!(**args) end @@ -2075,8 +2102,10 @@ module Google @pubsub_topic = args[:pubsub_topic] if args.key?(:pubsub_topic) @resource_references = args[:resource_references] if args.key?(:resource_references) @resources = args[:resources] if args.key?(:resources) + @revision_id = args[:revision_id] if args.key?(:revision_id) @sequence_number = args[:sequence_number] if args.key?(:sequence_number) @targets = args[:targets] if args.key?(:targets) + @uid = args[:uid] if args.key?(:uid) end end @@ -3693,6 +3722,11 @@ module Google # @return [Fixnum] attr_accessor :created_at + # Description of the shared flow revision. + # Corresponds to the JSON property `description` + # @return [String] + attr_accessor :description + # The human readable name of this shared flow. # Corresponds to the JSON property `displayName` # @return [String] @@ -3754,6 +3788,7 @@ module Google @configuration_version = args[:configuration_version] if args.key?(:configuration_version) @context_info = args[:context_info] if args.key?(:context_info) @created_at = args[:created_at] if args.key?(:created_at) + @description = args[:description] if args.key?(:description) @display_name = args[:display_name] if args.key?(:display_name) @entity_meta_data_as_properties = args[:entity_meta_data_as_properties] if args.key?(:entity_meta_data_as_properties) @last_modified_at = args[:last_modified_at] if args.key?(:last_modified_at) diff --git a/generated/google/apis/apigee_v1/representations.rb b/generated/google/apis/apigee_v1/representations.rb index 696edd99d..9dcb50727 100644 --- a/generated/google/apis/apigee_v1/representations.rb +++ b/generated/google/apis/apigee_v1/representations.rb @@ -1017,6 +1017,8 @@ module Google property :base_path, as: 'basePath' property :location, as: 'location' property :name, as: 'name' + property :proxy_uid, as: 'proxyUid' + property :uid, as: 'uid' end end @@ -1128,9 +1130,11 @@ module Google collection :resources, as: 'resources', class: Google::Apis::ApigeeV1::GoogleCloudApigeeV1ResourceConfig, decorator: Google::Apis::ApigeeV1::GoogleCloudApigeeV1ResourceConfig::Representation + property :revision_id, :numeric_string => true, as: 'revisionId' property :sequence_number, :numeric_string => true, as: 'sequenceNumber' collection :targets, as: 'targets', class: Google::Apis::ApigeeV1::GoogleCloudApigeeV1TargetServerConfig, decorator: Google::Apis::ApigeeV1::GoogleCloudApigeeV1TargetServerConfig::Representation + property :uid, as: 'uid' end end @@ -1590,6 +1594,7 @@ module Google property :context_info, as: 'contextInfo' property :created_at, :numeric_string => true, as: 'createdAt' + property :description, as: 'description' property :display_name, as: 'displayName' hash :entity_meta_data_as_properties, as: 'entityMetaDataAsProperties' property :last_modified_at, :numeric_string => true, as: 'lastModifiedAt' diff --git a/generated/google/apis/apigee_v1/service.rb b/generated/google/apis/apigee_v1/service.rb index c64d0bad5..782291cea 100644 --- a/generated/google/apis/apigee_v1/service.rb +++ b/generated/google/apis/apigee_v1/service.rb @@ -2101,12 +2101,13 @@ module Google # particularly useful if you want to migrate existing consumer keys and # secrets to Apigee hybrid from another system. # Consumer keys and secrets can contain letters, numbers, underscores, and - # hyphens. No other special characters are allowed. - # **Note**: To avoid service disruptions, a consumer key and secret - # should not exceed 2 KBs each. - # After creating the consumer key and secret, associate the key with - # an API product using the - # UpdateDeveloperAppKey API. + # hyphens. No other special characters are allowed. To avoid service + # disruptions, a consumer key and secret should not exceed 2 KBs each. + # **Note**: When creating the consumer key and secret, an association to + # API products will not be made. Therefore, you should not specify the + # associated API products in your request. Instead, use the + # UpdateDeveloperAppKey API to + # make the association after the consumer key and secret are created. # If a consumer key and secret already exist, you can keep them or # delete them using the # DeleteDeveloperAppKey API. @@ -2385,12 +2386,13 @@ module Google # particularly useful if you want to migrate existing consumer keys and # secrets to Apigee hybrid from another system. # Consumer keys and secrets can contain letters, numbers, underscores, and - # hyphens. No other special characters are allowed. - # **Note**: To avoid service disruptions, a consumer key and secret - # should not exceed 2 KBs each. - # After creating the consumer key and secret, associate the key with - # an API product using the - # UpdateDeveloperAppKey API. + # hyphens. No other special characters are allowed. To avoid service + # disruptions, a consumer key and secret should not exceed 2 KBs each. + # **Note**: When creating the consumer key and secret, an association to + # API products will not be made. Therefore, you should not specify the + # associated API products in your request. Instead, use the + # UpdateDeveloperAppKey API to + # make the association after the consumer key and secret are created. # If a consumer key and secret already exist, you can keep them or # delete them using the # DeleteDeveloperAppKey API. @@ -2575,7 +2577,7 @@ module Google # @param [String] name # Optional. Name of the environment. Alternatively, the name may # be specified in the request body in the - # environment_id field. + # name field. # @param [String] fields # Selector specifying which fields to include in a partial response. # @param [String] quota_user diff --git a/generated/google/apis/dataflow_v1b3.rb b/generated/google/apis/dataflow_v1b3.rb index b399cf59e..a79771584 100644 --- a/generated/google/apis/dataflow_v1b3.rb +++ b/generated/google/apis/dataflow_v1b3.rb @@ -25,7 +25,7 @@ module Google # @see https://cloud.google.com/dataflow module DataflowV1b3 VERSION = 'V1b3' - REVISION = '20200305' + REVISION = '20200507' # 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/dataflow_v1b3/classes.rb b/generated/google/apis/dataflow_v1b3/classes.rb index 007b41108..56ac2b94e 100644 --- a/generated/google/apis/dataflow_v1b3/classes.rb +++ b/generated/google/apis/dataflow_v1b3/classes.rb @@ -132,6 +132,37 @@ module Google end end + # Job information for templates. + class Artifact + include Google::Apis::Core::Hashable + + # Container Spec. + # Corresponds to the JSON property `containerSpec` + # @return [Google::Apis::DataflowV1b3::ContainerSpec] + attr_accessor :container_spec + + # job_graph_gcs_path set for legacy Template. + # Corresponds to the JSON property `jobGraphGcsPath` + # @return [String] + attr_accessor :job_graph_gcs_path + + # Metadata describing a template. + # Corresponds to the JSON property `metadata` + # @return [Google::Apis::DataflowV1b3::TemplateMetadata] + attr_accessor :metadata + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @container_spec = args[:container_spec] if args.key?(:container_spec) + @job_graph_gcs_path = args[:job_graph_gcs_path] if args.key?(:job_graph_gcs_path) + @metadata = args[:metadata] if args.key?(:metadata) + end + end + # A structured message reporting an autoscaling decision made by the Dataflow # service. class AutoscalingEvent @@ -312,6 +343,33 @@ module Google end end + # Commit will add a new TemplateVersion to an existing template. + class CommitTemplateVersionRequest + include Google::Apis::Core::Hashable + + # ///////////////////////////////////////////////////////////////////////////// + # //// Template Catalog is used to organize user TemplateVersions. + # //// TemplateVersions that have the same project_id and display_name are + # //// belong to the same Template. + # //// Templates with the same project_id belong to the same Project. + # //// TemplateVersion may have labels and multiple labels are allowed. + # //// Duplicated labels in the same `TemplateVersion` are not allowed. + # //// TemplateVersion may have tags and multiple tags are allowed. Duplicated + # //// tags in the same `Template` are not allowed! + # Corresponds to the JSON property `templateVersion` + # @return [Google::Apis::DataflowV1b3::TemplateVersion] + attr_accessor :template_version + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @template_version = args[:template_version] if args.key?(:template_version) + end + end + # Description of an interstitial value between transforms in an execution # stage. class ComponentSource @@ -793,6 +851,33 @@ module Google end end + # Creates a new Template with TemplateVersions. + class CreateTemplateVersionRequest + include Google::Apis::Core::Hashable + + # ///////////////////////////////////////////////////////////////////////////// + # //// Template Catalog is used to organize user TemplateVersions. + # //// TemplateVersions that have the same project_id and display_name are + # //// belong to the same Template. + # //// Templates with the same project_id belong to the same Project. + # //// TemplateVersion may have labels and multiple labels are allowed. + # //// Duplicated labels in the same `TemplateVersion` are not allowed. + # //// TemplateVersion may have tags and multiple tags are allowed. Duplicated + # //// tags in the same `Template` are not allowed! + # Corresponds to the JSON property `templateVersion` + # @return [Google::Apis::DataflowV1b3::TemplateVersion] + attr_accessor :template_version + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @template_version = args[:template_version] if args.key?(:template_version) + end + end + # Identifies the location of a custom souce. class CustomSourceLocation include Google::Apis::Core::Hashable @@ -1141,6 +1226,25 @@ module Google end end + # A generic empty message that you can re-use to avoid defining duplicated + # empty messages in your APIs. A typical example is to use it as the request + # or the response type of an API method. For instance: + # service Foo ` + # rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); + # ` + # The JSON representation for `Empty` is empty JSON object ````. + class Empty + include Google::Apis::Core::Hashable + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + end + end + # Describes the environment in which a Dataflow Job runs. class Environment include Google::Apis::Core::Hashable @@ -2573,6 +2677,32 @@ module Google end end + # Respond a list of TemplateVersions. + class ListTemplateVersionsResponse + include Google::Apis::Core::Hashable + + # A token that can be sent as `page_token` to retrieve the next page. + # If this field is omitted, there are no subsequent pages. + # Corresponds to the JSON property `nextPageToken` + # @return [String] + attr_accessor :next_page_token + + # A list of TemplateVersions. + # Corresponds to the JSON property `templateVersions` + # @return [Array] + attr_accessor :template_versions + + 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) + @template_versions = args[:template_versions] if args.key?(:template_versions) + end + end + # MapTask consists of an ordered set of instructions, each of which # describes one particular low-level operation for the worker to # perform in order to accomplish the MapTask's WorkItem. @@ -2822,6 +2952,107 @@ module Google end end + # Either add the label to TemplateVersion or remove it from the + # TemplateVersion. + class ModifyTemplateVersionLabelRequest + include Google::Apis::Core::Hashable + + # The label key for update. + # Corresponds to the JSON property `key` + # @return [String] + attr_accessor :key + + # Requests for add label to TemplateVersion or remove label from + # TemplateVersion. + # Corresponds to the JSON property `op` + # @return [String] + attr_accessor :op + + # The label value for update. + # Corresponds to the JSON property `value` + # @return [String] + attr_accessor :value + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @key = args[:key] if args.key?(:key) + @op = args[:op] if args.key?(:op) + @value = args[:value] if args.key?(:value) + end + end + + # Respond the labels in the TemplateVersion. + class ModifyTemplateVersionLabelResponse + include Google::Apis::Core::Hashable + + # All the label in the TemplateVersion. + # 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) + @labels = args[:labels] if args.key?(:labels) + end + end + + # Add a tag to the current TemplateVersion. If tag exist in another + # TemplateVersion in the Template, remove the tag before add it to the current + # TemplateVersion. If remove_only set, remove the tag from the current + # TemplateVersion. + class ModifyTemplateVersionTagRequest + include Google::Apis::Core::Hashable + + # The flag that indicates if the request is only for remove tag from + # TemplateVersion. + # Corresponds to the JSON property `removeOnly` + # @return [Boolean] + attr_accessor :remove_only + alias_method :remove_only?, :remove_only + + # The tag for update. + # Corresponds to the JSON property `tag` + # @return [String] + attr_accessor :tag + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @remove_only = args[:remove_only] if args.key?(:remove_only) + @tag = args[:tag] if args.key?(:tag) + end + end + + # Respond the current tags in the TemplateVersion. + class ModifyTemplateVersionTagResponse + include Google::Apis::Core::Hashable + + # All the tags in the TemplateVersion. + # Corresponds to the JSON property `tags` + # @return [Array] + attr_accessor :tags + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @tags = args[:tags] if args.key?(:tags) + end + end + # Describes mounted data disk. class MountedDataDisk include Google::Apis::Core::Hashable @@ -3382,6 +3613,25 @@ module Google end end + # Information about a validated query. + class QueryInfo + include Google::Apis::Core::Hashable + + # Includes an entry for each satisfied QueryProperty. + # Corresponds to the JSON property `queryProperty` + # @return [Array] + attr_accessor :query_property + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @query_property = args[:query_property] if args.key?(:query_property) + end + end + # An instruction that reads records. # Takes no inputs, produces one output. class ReadInstruction @@ -5328,6 +5578,81 @@ module Google end end + # ///////////////////////////////////////////////////////////////////////////// + # //// Template Catalog is used to organize user TemplateVersions. + # //// TemplateVersions that have the same project_id and display_name are + # //// belong to the same Template. + # //// Templates with the same project_id belong to the same Project. + # //// TemplateVersion may have labels and multiple labels are allowed. + # //// Duplicated labels in the same `TemplateVersion` are not allowed. + # //// TemplateVersion may have tags and multiple tags are allowed. Duplicated + # //// tags in the same `Template` are not allowed! + class TemplateVersion + include Google::Apis::Core::Hashable + + # Job information for templates. + # Corresponds to the JSON property `artifact` + # @return [Google::Apis::DataflowV1b3::Artifact] + attr_accessor :artifact + + # Creation time of this TemplateVersion. + # Corresponds to the JSON property `createTime` + # @return [String] + attr_accessor :create_time + + # Template description from the user. + # Corresponds to the JSON property `description` + # @return [String] + attr_accessor :description + + # A customized name for Template. Multiple TemplateVersions per Template. + # Corresponds to the JSON property `displayName` + # @return [String] + attr_accessor :display_name + + # Labels for the Template Version. Labels can be duplicate within Template. + # Corresponds to the JSON property `labels` + # @return [Hash] + attr_accessor :labels + + # A unique project_id. Multiple Templates per Project. + # Corresponds to the JSON property `projectId` + # @return [String] + attr_accessor :project_id + + # Alias for version_id, helps locate a TemplateVersion. + # Corresponds to the JSON property `tags` + # @return [Array] + attr_accessor :tags + + # Either LEGACY or FLEX. This should match with the type of artifact. + # Corresponds to the JSON property `type` + # @return [String] + attr_accessor :type + + # An auto generated version_id for TemplateVersion. + # Corresponds to the JSON property `versionId` + # @return [String] + attr_accessor :version_id + + def initialize(**args) + update!(**args) + end + + # Update properties of this object + def update!(**args) + @artifact = args[:artifact] if args.key?(:artifact) + @create_time = args[:create_time] if args.key?(:create_time) + @description = args[:description] if args.key?(:description) + @display_name = args[:display_name] if args.key?(:display_name) + @labels = args[:labels] if args.key?(:labels) + @project_id = args[:project_id] if args.key?(:project_id) + @tags = args[:tags] if args.key?(:tags) + @type = args[:type] if args.key?(:type) + @version_id = args[:version_id] if args.key?(:version_id) + end + end + # Global topology of the streaming Dataflow job, including all # computations and their sharded locations. class TopologyConfig @@ -5430,6 +5755,11 @@ module Google # @return [String] attr_accessor :error_message + # Information about a validated query. + # Corresponds to the JSON property `queryInfo` + # @return [Google::Apis::DataflowV1b3::QueryInfo] + attr_accessor :query_info + def initialize(**args) update!(**args) end @@ -5437,6 +5767,7 @@ module Google # Update properties of this object def update!(**args) @error_message = args[:error_message] if args.key?(:error_message) + @query_info = args[:query_info] if args.key?(:query_info) end end diff --git a/generated/google/apis/dataflow_v1b3/representations.rb b/generated/google/apis/dataflow_v1b3/representations.rb index 96d515303..dcc42eeb0 100644 --- a/generated/google/apis/dataflow_v1b3/representations.rb +++ b/generated/google/apis/dataflow_v1b3/representations.rb @@ -40,6 +40,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class Artifact + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class AutoscalingEvent class Representation < Google::Apis::Core::JsonRepresentation; end @@ -70,6 +76,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class CommitTemplateVersionRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ComponentSource class Representation < Google::Apis::Core::JsonRepresentation; end @@ -130,6 +142,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class CreateTemplateVersionRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class CustomSourceLocation class Representation < Google::Apis::Core::JsonRepresentation; end @@ -184,6 +202,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class Empty + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class Environment class Representation < Google::Apis::Core::JsonRepresentation; end @@ -400,6 +424,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class ListTemplateVersionsResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class MapTask class Representation < Google::Apis::Core::JsonRepresentation; end @@ -430,6 +460,30 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class ModifyTemplateVersionLabelRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ModifyTemplateVersionLabelResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ModifyTemplateVersionTagRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ModifyTemplateVersionTagResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class MountedDataDisk class Representation < Google::Apis::Core::JsonRepresentation; end @@ -514,6 +568,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class QueryInfo + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ReadInstruction class Representation < Google::Apis::Core::JsonRepresentation; end @@ -826,6 +886,12 @@ module Google include Google::Apis::Core::JsonObjectSupport end + class TemplateVersion + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class TopologyConfig class Representation < Google::Apis::Core::JsonRepresentation; end @@ -961,6 +1027,17 @@ module Google end end + class Artifact + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :container_spec, as: 'containerSpec', class: Google::Apis::DataflowV1b3::ContainerSpec, decorator: Google::Apis::DataflowV1b3::ContainerSpec::Representation + + property :job_graph_gcs_path, as: 'jobGraphGcsPath' + property :metadata, as: 'metadata', class: Google::Apis::DataflowV1b3::TemplateMetadata, decorator: Google::Apis::DataflowV1b3::TemplateMetadata::Representation + + end + end + class AutoscalingEvent # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1010,6 +1087,14 @@ module Google end end + class CommitTemplateVersionRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :template_version, as: 'templateVersion', class: Google::Apis::DataflowV1b3::TemplateVersion, decorator: Google::Apis::DataflowV1b3::TemplateVersion::Representation + + end + end + class ComponentSource # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1143,6 +1228,14 @@ module Google end end + class CreateTemplateVersionRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :template_version, as: 'templateVersion', class: Google::Apis::DataflowV1b3::TemplateVersion, decorator: Google::Apis::DataflowV1b3::TemplateVersion::Representation + + end + end + class CustomSourceLocation # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1235,6 +1328,12 @@ module Google end end + class Empty + # @private + class Representation < Google::Apis::Core::JsonRepresentation + end + end + class Environment # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1623,6 +1722,15 @@ module Google end end + class ListTemplateVersionsResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :next_page_token, as: 'nextPageToken' + collection :template_versions, as: 'templateVersions', class: Google::Apis::DataflowV1b3::TemplateVersion, decorator: Google::Apis::DataflowV1b3::TemplateVersion::Representation + + end + end + class MapTask # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1679,6 +1787,37 @@ module Google end end + class ModifyTemplateVersionLabelRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :key, as: 'key' + property :op, as: 'op' + property :value, as: 'value' + end + end + + class ModifyTemplateVersionLabelResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + hash :labels, as: 'labels' + end + end + + class ModifyTemplateVersionTagRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :remove_only, as: 'removeOnly' + property :tag, as: 'tag' + end + end + + class ModifyTemplateVersionTagResponse + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :tags, as: 'tags' + end + end + class MountedDataDisk # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -1833,6 +1972,13 @@ module Google end end + class QueryInfo + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :query_property, as: 'queryProperty' + end + end + class ReadInstruction # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -2367,6 +2513,22 @@ module Google end end + class TemplateVersion + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :artifact, as: 'artifact', class: Google::Apis::DataflowV1b3::Artifact, decorator: Google::Apis::DataflowV1b3::Artifact::Representation + + property :create_time, as: 'createTime' + property :description, as: 'description' + property :display_name, as: 'displayName' + hash :labels, as: 'labels' + property :project_id, as: 'projectId' + collection :tags, as: 'tags' + property :type, as: 'type' + property :version_id, as: 'versionId' + end + end + class TopologyConfig # @private class Representation < Google::Apis::Core::JsonRepresentation @@ -2397,6 +2559,8 @@ module Google # @private class Representation < Google::Apis::Core::JsonRepresentation property :error_message, as: 'errorMessage' + property :query_info, as: 'queryInfo', class: Google::Apis::DataflowV1b3::QueryInfo, decorator: Google::Apis::DataflowV1b3::QueryInfo::Representation + end end diff --git a/generated/google/apis/dataflow_v1b3/service.rb b/generated/google/apis/dataflow_v1b3/service.rb index e16a26d99..c720a8858 100644 --- a/generated/google/apis/dataflow_v1b3/service.rb +++ b/generated/google/apis/dataflow_v1b3/service.rb @@ -116,6 +116,224 @@ module Google execute_or_queue_command(command, &block) end + # Creates a new TemplateVersion (Important: not new Template) entry in the + # spanner table. Requires project_id and display_name (template). + # @param [String] name + # The location of the template, name includes project_id and display_name. + # Commit using project_id(pid1) and display_name(tid1). + # Format: projects/`pid1`/catalogTemplates/`tid1` + # @param [Google::Apis::DataflowV1b3::CommitTemplateVersionRequest] commit_template_version_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::DataflowV1b3::TemplateVersion] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::TemplateVersion] + # + # @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 commit_catalog_template_template_version(name, commit_template_version_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1b3/{+name}:commit', options) + command.request_representation = Google::Apis::DataflowV1b3::CommitTemplateVersionRequest::Representation + command.request_object = commit_template_version_request_object + command.response_representation = Google::Apis::DataflowV1b3::TemplateVersion::Representation + command.response_class = Google::Apis::DataflowV1b3::TemplateVersion + 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 + + # Deletes an existing Template. Do nothing if Template does not exist. + # @param [String] name + # name includes project_id and display_name. + # Delete by project_id(pid1) and display_name(tid1). + # Format: projects/`pid1`/catalogTemplates/`tid1` + # @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::DataflowV1b3::Empty] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::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_catalog_template(name, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:delete, 'v1b3/{+name}', options) + command.response_representation = Google::Apis::DataflowV1b3::Empty::Representation + command.response_class = Google::Apis::DataflowV1b3::Empty + 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 + + # Get TemplateVersion using project_id and display_name with an optional + # version_id field. Get latest (has tag "latest") TemplateVersion if + # version_id not set. + # @param [String] name + # Resource name includes project_id and display_name. version_id is optional. + # Get the latest TemplateVersion if version_id not set. + # Get by project_id(pid1) and display_name(tid1): + # Format: projects/`pid1`/catalogTemplates/`tid1` + # Get by project_id(pid1), display_name(tid1), and version_id(vid1): + # Format: projects/`pid1`/catalogTemplates/`tid1@vid` + # @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::DataflowV1b3::TemplateVersion] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::TemplateVersion] + # + # @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_catalog_template(name, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1b3/{+name}', options) + command.response_representation = Google::Apis::DataflowV1b3::TemplateVersion::Representation + command.response_class = Google::Apis::DataflowV1b3::TemplateVersion + 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 + + # Updates the label of the TemplateVersion. Label can be duplicated in + # Template, so either add or remove the label in the TemplateVersion. + # @param [String] name + # Resource name includes project_id, display_name, and version_id. + # Updates by project_id(pid1), display_name(tid1), and version_id(vid1): + # Format: projects/`pid1`/catalogTemplates/`tid1@vid` + # @param [Google::Apis::DataflowV1b3::ModifyTemplateVersionLabelRequest] modify_template_version_label_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::DataflowV1b3::ModifyTemplateVersionLabelResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::ModifyTemplateVersionLabelResponse] + # + # @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 label_project_catalog_template(name, modify_template_version_label_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1b3/{+name}:label', options) + command.request_representation = Google::Apis::DataflowV1b3::ModifyTemplateVersionLabelRequest::Representation + command.request_object = modify_template_version_label_request_object + command.response_representation = Google::Apis::DataflowV1b3::ModifyTemplateVersionLabelResponse::Representation + command.response_class = Google::Apis::DataflowV1b3::ModifyTemplateVersionLabelResponse + 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 + + # Updates the tag of the TemplateVersion, and tag is unique in Template. + # If tag exists in another TemplateVersion in the Template, updates the tag + # to this TemplateVersion will remove it from the old TemplateVersion and add + # it to this TemplateVersion. If request is remove_only (remove_only = true), + # remove the tag from this TemplateVersion. + # @param [String] name + # Resource name includes project_id, display_name, and version_id. + # Updates by project_id(pid1), display_name(tid1), and version_id(vid1): + # Format: projects/`pid1`/catalogTemplates/`tid1@vid` + # @param [Google::Apis::DataflowV1b3::ModifyTemplateVersionTagRequest] modify_template_version_tag_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::DataflowV1b3::ModifyTemplateVersionTagResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::ModifyTemplateVersionTagResponse] + # + # @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 tag_project_catalog_template(name, modify_template_version_tag_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1b3/{+name}:tag', options) + command.request_representation = Google::Apis::DataflowV1b3::ModifyTemplateVersionTagRequest::Representation + command.request_object = modify_template_version_tag_request_object + command.response_representation = Google::Apis::DataflowV1b3::ModifyTemplateVersionTagResponse::Representation + command.response_class = Google::Apis::DataflowV1b3::ModifyTemplateVersionTagResponse + 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 new Template with TemplateVersion. Requires + # project_id(projects) and template display_name(catalogTemplates). + # The template display_name is set by the user. + # @param [String] parent + # The parent project and template that the TemplateVersion will be created + # under. + # Create using project_id(pid1) and display_name(tid1). + # Format: projects/`pid1`/catalogTemplates/`tid1` + # @param [Google::Apis::DataflowV1b3::CreateTemplateVersionRequest] create_template_version_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::DataflowV1b3::TemplateVersion] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::TemplateVersion] + # + # @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_template_version(parent, create_template_version_request_object = nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:post, 'v1b3/{+parent}/templateVersions', options) + command.request_representation = Google::Apis::DataflowV1b3::CreateTemplateVersionRequest::Representation + command.request_object = create_template_version_request_object + command.response_representation = Google::Apis::DataflowV1b3::TemplateVersion::Representation + command.response_class = Google::Apis::DataflowV1b3::TemplateVersion + 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 + # List the jobs of a project across all regions. # @param [String] project_id # The project which owns the jobs. @@ -1634,6 +1852,49 @@ module Google execute_or_queue_command(command, &block) end + # List TemplateVersions using project_id and an optional display_name field. + # List all the TemplateVersions in the Template if display set. + # List all the TemplateVersions in the Project if display_name not set. + # @param [String] parent + # parent includes project_id, and display_name is optional. + # List by project_id(pid1) and display_name(tid1). + # Format: projects/`pid1`/catalogTemplates/`tid1` + # List by project_id(pid1). + # Format: projects/`pid1` + # @param [Fixnum] page_size + # The maximum number of TemplateVersions to return per page. + # @param [String] page_token + # The page token, received from a previous ListTemplateVersions call. + # Provide this to retrieve the subsequent page. + # @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::DataflowV1b3::ListTemplateVersionsResponse] parsed result object + # @yieldparam err [StandardError] error object if request failed + # + # @return [Google::Apis::DataflowV1b3::ListTemplateVersionsResponse] + # + # @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_template_versions(parent, page_size: nil, page_token: nil, fields: nil, quota_user: nil, options: nil, &block) + command = make_simple_command(:get, 'v1b3/{+parent}/templateVersions', options) + command.response_representation = Google::Apis::DataflowV1b3::ListTemplateVersionsResponse::Representation + command.response_class = Google::Apis::DataflowV1b3::ListTemplateVersionsResponse + 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 + # Creates a Cloud Dataflow job from a template. # @param [String] project_id # Required. The ID of the Cloud Platform project that the job belongs to.