Autogenerated update (2019-09-10)
Delete: - appstate_v1 Update: - abusiveexperiencereport_v1 - adexperiencereport_v1 - analyticsreporting_v4 - androidmanagement_v1 - bigquery_v2 - bigtableadmin_v2 - binaryauthorization_v1beta1 - calendar_v3 - cloudasset_v1 - cloudasset_v1beta1 - cloudiot_v1 - cloudkms_v1 - cloudresourcemanager_v1 - cloudresourcemanager_v1beta1 - cloudresourcemanager_v2 - cloudresourcemanager_v2beta1 - cloudsearch_v1 - cloudtasks_v2beta3 - cloudtrace_v2 - commentanalyzer_v1alpha1 - composer_v1 - composer_v1beta1 - compute_alpha - compute_beta - compute_v1 - container_v1 - container_v1beta1 - content_v2 - content_v2_1 - dataflow_v1b3 - dataproc_v1 - dataproc_v1beta2 - datastore_v1 - datastore_v1beta1 - dfareporting_v3_1 - dialogflow_v2beta1 - dlp_v2 - docs_v1 - drive_v2 - drive_v3 - driveactivity_v2 - firestore_v1 - firestore_v1beta1 - firestore_v1beta2 - healthcare_v1alpha2 - healthcare_v1beta1 - logging_v2 - ml_v1 - monitoring_v3 - pagespeedonline_v5 - pubsub_v1 - pubsub_v1beta2 - run_v1alpha1 - runtimeconfig_v1beta1 - script_v1 - securitycenter_v1 - securitycenter_v1beta1 - serviceconsumermanagement_v1 - servicemanagement_v1 - servicenetworking_v1 - servicenetworking_v1beta - serviceusage_v1 - serviceusage_v1beta1 - slides_v1 - speech_v1 - speech_v1p1beta1 - speech_v2beta - sqladmin_v1beta4 - storage_v1 - storagetransfer_v1 - testing_v1 - toolresults_v1beta3 - translate_v3beta1 - vision_v1 - vision_v1p1beta1 - vision_v1p2beta1 - youtube_partner_v1 - youtube_v3
This commit is contained in:
Google APIs committed
1 parent
39975ca8dd
commit
300fd8ca30
234 files changed
+12877
-9106
No files matched your search
@@ -836,19 +836,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# Response from deleting a snapshot.
|
||||
class DeleteSnapshotResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
end
|
||||
end
|
||||
|
||||
# Specification of one of the bundles produced as a result of splitting
|
||||
# a Source (e.g. when executing a SourceSplitRequest, or when
|
||||
# splitting an active task using WorkItemStatus.dynamic_source_split),
|
||||
@@ -2404,25 +2391,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# List of snapshots.
|
||||
class ListSnapshotsResponse
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Returned snapshots.
|
||||
# Corresponds to the JSON property `snapshots`
|
||||
# @return [Array<Google::Apis::DataflowV1b3::Snapshot>]
|
||||
attr_accessor :snapshots
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@snapshots = args[:snapshots] if args.key?(:snapshots)
|
||||
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.
|
||||
@@ -3392,6 +3360,14 @@ module Google
|
||||
# @return [String]
|
||||
attr_accessor :temp_location
|
||||
|
||||
# Optional. Specifies whether worker pools should be started with private IP
|
||||
# addresses.
|
||||
# False by default.
|
||||
# Corresponds to the JSON property `usePrivateIps`
|
||||
# @return [Boolean]
|
||||
attr_accessor :use_private_ips
|
||||
alias_method :use_private_ips?, :use_private_ips
|
||||
|
||||
# The Compute Engine [availability
|
||||
# zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
|
||||
# for launching worker instances to run your pipeline.
|
||||
@@ -3416,6 +3392,7 @@ module Google
|
||||
@service_account_email = args[:service_account_email] if args.key?(:service_account_email)
|
||||
@subnetwork = args[:subnetwork] if args.key?(:subnetwork)
|
||||
@temp_location = args[:temp_location] if args.key?(:temp_location)
|
||||
@use_private_ips = args[:use_private_ips] if args.key?(:use_private_ips)
|
||||
@zone = args[:zone] if args.key?(:zone)
|
||||
end
|
||||
end
|
||||
@@ -3711,80 +3688,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# Represents a snapshot of a job.
|
||||
class Snapshot
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The time this snapshot was created.
|
||||
# Corresponds to the JSON property `creationTime`
|
||||
# @return [String]
|
||||
attr_accessor :creation_time
|
||||
|
||||
# The unique ID of this snapshot.
|
||||
# Corresponds to the JSON property `id`
|
||||
# @return [String]
|
||||
attr_accessor :id
|
||||
|
||||
# The project this snapshot belongs to.
|
||||
# Corresponds to the JSON property `projectId`
|
||||
# @return [String]
|
||||
attr_accessor :project_id
|
||||
|
||||
# The job this snapshot was created from.
|
||||
# Corresponds to the JSON property `sourceJobId`
|
||||
# @return [String]
|
||||
attr_accessor :source_job_id
|
||||
|
||||
# State of the snapshot.
|
||||
# Corresponds to the JSON property `state`
|
||||
# @return [String]
|
||||
attr_accessor :state
|
||||
|
||||
# The time after which this snapshot will be automatically deleted.
|
||||
# Corresponds to the JSON property `ttl`
|
||||
# @return [String]
|
||||
attr_accessor :ttl
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@creation_time = args[:creation_time] if args.key?(:creation_time)
|
||||
@id = args[:id] if args.key?(:id)
|
||||
@project_id = args[:project_id] if args.key?(:project_id)
|
||||
@source_job_id = args[:source_job_id] if args.key?(:source_job_id)
|
||||
@state = args[:state] if args.key?(:state)
|
||||
@ttl = args[:ttl] if args.key?(:ttl)
|
||||
end
|
||||
end
|
||||
|
||||
# Request to create a snapshot of a job.
|
||||
class SnapshotJobRequest
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# The location that contains this job.
|
||||
# Corresponds to the JSON property `location`
|
||||
# @return [String]
|
||||
attr_accessor :location
|
||||
|
||||
# TTL for the snapshot.
|
||||
# Corresponds to the JSON property `ttl`
|
||||
# @return [String]
|
||||
attr_accessor :ttl
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@location = args[:location] if args.key?(:location)
|
||||
@ttl = args[:ttl] if args.key?(:ttl)
|
||||
end
|
||||
end
|
||||
|
||||
# A source that records can be read and decoded from.
|
||||
class Source
|
||||
include Google::Apis::Core::Hashable
|
||||
@@ -4567,6 +4470,16 @@ module Google
|
||||
class StreamingConfigTask
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Chunk size for commit streams from the harness to windmill.
|
||||
# Corresponds to the JSON property `commitStreamChunkSizeBytes`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :commit_stream_chunk_size_bytes
|
||||
|
||||
# Chunk size for get data streams from the harness to windmill.
|
||||
# Corresponds to the JSON property `getDataStreamChunkSizeBytes`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :get_data_stream_chunk_size_bytes
|
||||
|
||||
# Maximum size for work item commit supported windmill storage layer.
|
||||
# Corresponds to the JSON property `maxWorkItemCommitBytes`
|
||||
# @return [Fixnum]
|
||||
@@ -4602,6 +4515,8 @@ module Google
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@commit_stream_chunk_size_bytes = args[:commit_stream_chunk_size_bytes] if args.key?(:commit_stream_chunk_size_bytes)
|
||||
@get_data_stream_chunk_size_bytes = args[:get_data_stream_chunk_size_bytes] if args.key?(:get_data_stream_chunk_size_bytes)
|
||||
@max_work_item_commit_bytes = args[:max_work_item_commit_bytes] if args.key?(:max_work_item_commit_bytes)
|
||||
@streaming_computation_configs = args[:streaming_computation_configs] if args.key?(:streaming_computation_configs)
|
||||
@user_step_to_state_family_name_map = args[:user_step_to_state_family_name_map] if args.key?(:user_step_to_state_family_name_map)
|
||||
|
||||
@@ -142,12 +142,6 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class DeleteSnapshotResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class DerivedSource
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
@@ -370,12 +364,6 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ListSnapshotsResponse
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class MapTask
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
@@ -580,18 +568,6 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Snapshot
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class SnapshotJobRequest
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class Source
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
@@ -1101,12 +1077,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class DeleteSnapshotResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
end
|
||||
end
|
||||
|
||||
class DerivedSource
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
@@ -1517,14 +1487,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class ListSnapshotsResponse
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :snapshots, as: 'snapshots', class: Google::Apis::DataflowV1b3::Snapshot, decorator: Google::Apis::DataflowV1b3::Snapshot::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class MapTask
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
@@ -1780,6 +1742,7 @@ module Google
|
||||
property :service_account_email, as: 'serviceAccountEmail'
|
||||
property :subnetwork, as: 'subnetwork'
|
||||
property :temp_location, as: 'tempLocation'
|
||||
property :use_private_ips, as: 'usePrivateIps'
|
||||
property :zone, as: 'zone'
|
||||
end
|
||||
end
|
||||
@@ -1875,26 +1838,6 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class Snapshot
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :creation_time, as: 'creationTime'
|
||||
property :id, as: 'id'
|
||||
property :project_id, as: 'projectId'
|
||||
property :source_job_id, as: 'sourceJobId'
|
||||
property :state, as: 'state'
|
||||
property :ttl, as: 'ttl'
|
||||
end
|
||||
end
|
||||
|
||||
class SnapshotJobRequest
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :location, as: 'location'
|
||||
property :ttl, as: 'ttl'
|
||||
end
|
||||
end
|
||||
|
||||
class Source
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
@@ -2118,6 +2061,8 @@ module Google
|
||||
class StreamingConfigTask
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :commit_stream_chunk_size_bytes, :numeric_string => true, as: 'commitStreamChunkSizeBytes'
|
||||
property :get_data_stream_chunk_size_bytes, :numeric_string => true, as: 'getDataStreamChunkSizeBytes'
|
||||
property :max_work_item_commit_bytes, :numeric_string => true, as: 'maxWorkItemCommitBytes'
|
||||
collection :streaming_computation_configs, as: 'streamingComputationConfigs', class: Google::Apis::DataflowV1b3::StreamingComputationConfig, decorator: Google::Apis::DataflowV1b3::StreamingComputationConfig::Representation
|
||||
|
||||
|
||||
@@ -47,42 +47,6 @@ module Google
|
||||
@batch_path = 'batch'
|
||||
end
|
||||
|
||||
# Deletes a snapshot.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the snapshot belongs to.
|
||||
# @param [String] location
|
||||
# The location that contains this snapshot.
|
||||
# @param [String] snapshot_id
|
||||
# The ID of the snapshot.
|
||||
# @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::DeleteSnapshotResponse] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::DeleteSnapshotResponse]
|
||||
#
|
||||
# @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_snapshots(project_id, location: nil, snapshot_id: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:delete, 'v1b3/projects/{projectId}/snapshots', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::DeleteSnapshotResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::DeleteSnapshotResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.query['location'] = location unless location.nil?
|
||||
command.query['snapshotId'] = snapshot_id unless snapshot_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Send a worker_message to the service.
|
||||
# @param [String] project_id
|
||||
# The project to send the WorkerMessages to.
|
||||
@@ -364,42 +328,6 @@ module Google
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Snapshot the state of a streaming job.
|
||||
# @param [String] project_id
|
||||
# The project which owns the job to be snapshotted.
|
||||
# @param [String] job_id
|
||||
# The job to be snapshotted.
|
||||
# @param [Google::Apis::DataflowV1b3::SnapshotJobRequest] snapshot_job_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::Snapshot] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::Snapshot]
|
||||
#
|
||||
# @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 snapshot_project_job(project_id, job_id, snapshot_job_request_object = nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:post, 'v1b3/projects/{projectId}/jobs/{jobId}:snapshot', options)
|
||||
command.request_representation = Google::Apis::DataflowV1b3::SnapshotJobRequest::Representation
|
||||
command.request_object = snapshot_job_request_object
|
||||
command.response_representation = Google::Apis::DataflowV1b3::Snapshot::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::Snapshot
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['jobId'] = job_id unless job_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Updates the state of an existing Cloud Dataflow job.
|
||||
# To update the state of an existing job, we recommend using
|
||||
# `projects.locations.jobs.update` with a [regional endpoint]
|
||||
@@ -890,45 +818,6 @@ module Google
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Snapshot the state of a streaming job.
|
||||
# @param [String] project_id
|
||||
# The project which owns the job to be snapshotted.
|
||||
# @param [String] location
|
||||
# The location that contains this job.
|
||||
# @param [String] job_id
|
||||
# The job to be snapshotted.
|
||||
# @param [Google::Apis::DataflowV1b3::SnapshotJobRequest] snapshot_job_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::Snapshot] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::Snapshot]
|
||||
#
|
||||
# @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 snapshot_project_location_job(project_id, location, job_id, snapshot_job_request_object = nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:post, 'v1b3/projects/{projectId}/locations/{location}/jobs/{jobId}:snapshot', options)
|
||||
command.request_representation = Google::Apis::DataflowV1b3::SnapshotJobRequest::Representation
|
||||
command.request_object = snapshot_job_request_object
|
||||
command.response_representation = Google::Apis::DataflowV1b3::Snapshot::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::Snapshot
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['location'] = location unless location.nil?
|
||||
command.params['jobId'] = job_id unless job_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Updates the state of an existing Cloud Dataflow job.
|
||||
# To update the state of an existing job, we recommend using
|
||||
# `projects.locations.jobs.update` with a [regional endpoint]
|
||||
@@ -1121,42 +1010,6 @@ module Google
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Lists snapshots.
|
||||
# @param [String] project_id
|
||||
# The project ID to list snapshots for.
|
||||
# @param [String] location
|
||||
# The location to list snapshots in.
|
||||
# @param [String] job_id
|
||||
# If specified, list snapshots created from this job.
|
||||
# @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::ListSnapshotsResponse] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::ListSnapshotsResponse]
|
||||
#
|
||||
# @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_job_snapshots(project_id, location, job_id, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:get, 'v1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/snapshots', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::ListSnapshotsResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::ListSnapshotsResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['location'] = location unless location.nil?
|
||||
command.params['jobId'] = job_id unless job_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Leases a dataflow WorkItem to run.
|
||||
# @param [String] project_id
|
||||
# Identifies the project this worker belongs to.
|
||||
@@ -1239,114 +1092,6 @@ module Google
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Deletes a snapshot.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the snapshot belongs to.
|
||||
# @param [String] location
|
||||
# The location that contains this snapshot.
|
||||
# @param [String] snapshot_id
|
||||
# The ID of the snapshot.
|
||||
# @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::DeleteSnapshotResponse] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::DeleteSnapshotResponse]
|
||||
#
|
||||
# @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_snapshot(project_id, location, snapshot_id, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:delete, 'v1b3/projects/{projectId}/locations/{location}/snapshots/{snapshotId}', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::DeleteSnapshotResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::DeleteSnapshotResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['location'] = location unless location.nil?
|
||||
command.params['snapshotId'] = snapshot_id unless snapshot_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Gets information about a snapshot.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the snapshot belongs to.
|
||||
# @param [String] location
|
||||
# The location that contains this snapshot.
|
||||
# @param [String] snapshot_id
|
||||
# The ID of the snapshot.
|
||||
# @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::Snapshot] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::Snapshot]
|
||||
#
|
||||
# @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_snapshot(project_id, location, snapshot_id, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:get, 'v1b3/projects/{projectId}/locations/{location}/snapshots/{snapshotId}', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::Snapshot::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::Snapshot
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['location'] = location unless location.nil?
|
||||
command.params['snapshotId'] = snapshot_id unless snapshot_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Lists snapshots.
|
||||
# @param [String] project_id
|
||||
# The project ID to list snapshots for.
|
||||
# @param [String] location
|
||||
# The location to list snapshots in.
|
||||
# @param [String] job_id
|
||||
# If specified, list snapshots created from this job.
|
||||
# @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::ListSnapshotsResponse] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::ListSnapshotsResponse]
|
||||
#
|
||||
# @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_snapshots(project_id, location, job_id: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:get, 'v1b3/projects/{projectId}/locations/{location}/snapshots', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::ListSnapshotsResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::ListSnapshotsResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['location'] = location unless location.nil?
|
||||
command.query['jobId'] = job_id unless job_id.nil?
|
||||
command.query['fields'] = fields unless fields.nil?
|
||||
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Validates a GoogleSQL query for Cloud Dataflow syntax. Will always
|
||||
# confirm the given query parses correctly, and if able to look up
|
||||
# schema information from DataCatalog, will validate that the query
|
||||
@@ -1524,78 +1269,6 @@ module Google
|
||||
execute_or_queue_command(command, &block)
|
||||
end
|
||||
|
||||
# Gets information about a snapshot.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the snapshot belongs to.
|
||||
# @param [String] snapshot_id
|
||||
# The ID of the snapshot.
|
||||
# @param [String] location
|
||||
# The location that contains this snapshot.
|
||||
# @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::Snapshot] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::Snapshot]
|
||||
#
|
||||
# @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_snapshot(project_id, snapshot_id, location: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:get, 'v1b3/projects/{projectId}/snapshots/{snapshotId}', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::Snapshot::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::Snapshot
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.params['snapshotId'] = snapshot_id unless snapshot_id.nil?
|
||||
command.query['location'] = location unless location.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 snapshots.
|
||||
# @param [String] project_id
|
||||
# The project ID to list snapshots for.
|
||||
# @param [String] job_id
|
||||
# If specified, list snapshots created from this job.
|
||||
# @param [String] location
|
||||
# The location to list snapshots in.
|
||||
# @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::ListSnapshotsResponse] parsed result object
|
||||
# @yieldparam err [StandardError] error object if request failed
|
||||
#
|
||||
# @return [Google::Apis::DataflowV1b3::ListSnapshotsResponse]
|
||||
#
|
||||
# @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_snapshots(project_id, job_id: nil, location: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:get, 'v1b3/projects/{projectId}/snapshots', options)
|
||||
command.response_representation = Google::Apis::DataflowV1b3::ListSnapshotsResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::ListSnapshotsResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
command.query['jobId'] = job_id unless job_id.nil?
|
||||
command.query['location'] = location unless location.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.
|
||||
|
||||
Reference in new issue
Block a user