generated/google/apis/dataflow_v1b3/service.rb in google-api-client-0.28.7 vs generated/google/apis/dataflow_v1b3/service.rb in google-api-client-0.29.0
- old
+ new
@@ -45,10 +45,46 @@
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
@@ -1165,10 +1201,156 @@
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] 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, 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['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
+ # Required. The ID of the Cloud Platform project that the job belongs to.
+ # @param [String] location
+ # The [regional endpoint]
+ # (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) to
+ # which to direct the request.
+ # @param [String] query
+ # The sql query to validate.
+ # @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::ValidateResponse] parsed result object
+ # @yieldparam err [StandardError] error object if request failed
+ #
+ # @return [Google::Apis::DataflowV1b3::ValidateResponse]
+ #
+ # @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 validate_project_location_sql(project_id, location, query: nil, fields: nil, quota_user: nil, options: nil, &block)
+ command = make_simple_command(:get, 'v1b3/projects/{projectId}/locations/{location}/sql:validate', options)
+ command.response_representation = Google::Apis::DataflowV1b3::ValidateResponse::Representation
+ command.response_class = Google::Apis::DataflowV1b3::ValidateResponse
+ command.params['projectId'] = project_id unless project_id.nil?
+ command.params['location'] = location unless location.nil?
+ command.query['query'] = query unless query.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.
# @param [String] location
# The [regional endpoint]
@@ -1296,9 +1478,78 @@
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] 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, 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['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