generated/google/apis/dataflow_v1b3/service.rb in google-api-client-0.30.9 vs generated/google/apis/dataflow_v1b3/service.rb in google-api-client-0.30.10
- old
+ new
@@ -45,46 +45,10 @@
def initialize
super('https://dataflow.googleapis.com/', '')
@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.
# @param [Google::Apis::DataflowV1b3::SendWorkerMessagesRequest] send_worker_messages_request_object
# @param [String] fields
@@ -362,46 +326,10 @@
command.query['fields'] = fields unless fields.nil?
command.query['quotaUser'] = quota_user unless quota_user.nil?
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]
# (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using
# `projects.jobs.update` is not recommended, as you can only update the state
@@ -888,49 +816,10 @@
command.query['fields'] = fields unless fields.nil?
command.query['quotaUser'] = quota_user unless quota_user.nil?
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]
# (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using
# `projects.jobs.update` is not recommended, as you can only update the state
@@ -1119,46 +1008,10 @@
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_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.
# @param [String] location
# The [regional endpoint]
@@ -1237,118 +1090,10 @@
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 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
# analyzes properly as well.
# @param [String] project_id
@@ -1517,81 +1262,9 @@
command.params['location'] = location unless location.nil?
command.query['dynamicTemplate.gcsPath'] = dynamic_template_gcs_path unless dynamic_template_gcs_path.nil?
command.query['dynamicTemplate.stagingLocation'] = dynamic_template_staging_location unless dynamic_template_staging_location.nil?
command.query['gcsPath'] = gcs_path unless gcs_path.nil?
command.query['validateOnly'] = validate_only unless validate_only.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] 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