Autogenerated update (2018-11-15)
Update: - adexchangebuyer2_v2beta1 - alertcenter_v1beta1 - classroom_v1 - dataflow_v1b3 - dlp_v2
This commit is contained in:
Google APIs committed
1 parent
2b3c5faf5c
commit
fbf1113798
16 files changed
+2735
-14
No files matched your search
@@ -1699,6 +1699,12 @@ module Google
|
||||
# @return [String]
|
||||
attr_accessor :create_time
|
||||
|
||||
# If this is specified, the job's initial state is populated from the given
|
||||
# snapshot.
|
||||
# Corresponds to the JSON property `createdFromSnapshotId`
|
||||
# @return [String]
|
||||
attr_accessor :created_from_snapshot_id
|
||||
|
||||
# The current state of the job.
|
||||
# Jobs are created in the `JOB_STATE_STOPPED` state unless otherwise
|
||||
# specified.
|
||||
@@ -1820,11 +1826,17 @@ module Google
|
||||
# @return [String]
|
||||
attr_accessor :start_time
|
||||
|
||||
# Exactly one of step or steps_location should be specified.
|
||||
# The top-level steps that constitute the entire job.
|
||||
# Corresponds to the JSON property `steps`
|
||||
# @return [Array<Google::Apis::DataflowV1b3::Step>]
|
||||
attr_accessor :steps
|
||||
|
||||
# The GCS location where the steps are stored.
|
||||
# Corresponds to the JSON property `stepsLocation`
|
||||
# @return [String]
|
||||
attr_accessor :steps_location
|
||||
|
||||
# A set of files the system should be aware of that are used
|
||||
# for temporary storage. These temporary files will be
|
||||
# removed on job completion.
|
||||
@@ -1857,6 +1869,7 @@ module Google
|
||||
def update!(**args)
|
||||
@client_request_id = args[:client_request_id] if args.key?(:client_request_id)
|
||||
@create_time = args[:create_time] if args.key?(:create_time)
|
||||
@created_from_snapshot_id = args[:created_from_snapshot_id] if args.key?(:created_from_snapshot_id)
|
||||
@current_state = args[:current_state] if args.key?(:current_state)
|
||||
@current_state_time = args[:current_state_time] if args.key?(:current_state_time)
|
||||
@environment = args[:environment] if args.key?(:environment)
|
||||
@@ -1874,6 +1887,7 @@ module Google
|
||||
@stage_states = args[:stage_states] if args.key?(:stage_states)
|
||||
@start_time = args[:start_time] if args.key?(:start_time)
|
||||
@steps = args[:steps] if args.key?(:steps)
|
||||
@steps_location = args[:steps_location] if args.key?(:steps_location)
|
||||
@temp_files = args[:temp_files] if args.key?(:temp_files)
|
||||
@transform_name_mapping = args[:transform_name_mapping] if args.key?(:transform_name_mapping)
|
||||
@type = args[:type] if args.key?(:type)
|
||||
@@ -3561,6 +3575,74 @@ 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
|
||||
|
||||
# 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)
|
||||
@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
|
||||
|
||||
@@ -562,6 +562,18 @@ 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
|
||||
|
||||
@@ -1294,6 +1306,7 @@ module Google
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :client_request_id, as: 'clientRequestId'
|
||||
property :create_time, as: 'createTime'
|
||||
property :created_from_snapshot_id, as: 'createdFromSnapshotId'
|
||||
property :current_state, as: 'currentState'
|
||||
property :current_state_time, as: 'currentStateTime'
|
||||
property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::Environment, decorator: Google::Apis::DataflowV1b3::Environment::Representation
|
||||
@@ -1317,6 +1330,7 @@ module Google
|
||||
property :start_time, as: 'startTime'
|
||||
collection :steps, as: 'steps', class: Google::Apis::DataflowV1b3::Step, decorator: Google::Apis::DataflowV1b3::Step::Representation
|
||||
|
||||
property :steps_location, as: 'stepsLocation'
|
||||
collection :temp_files, as: 'tempFiles'
|
||||
hash :transform_name_mapping, as: 'transformNameMapping'
|
||||
property :type, as: 'type'
|
||||
@@ -1802,6 +1816,25 @@ 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 :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
|
||||
|
||||
@@ -297,6 +297,42 @@ 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.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the job belongs to.
|
||||
@@ -742,6 +778,45 @@ 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.
|
||||
# @param [String] project_id
|
||||
# The ID of the Cloud Platform project that the job belongs to.
|
||||
@@ -1038,7 +1113,7 @@ module Google
|
||||
# @param [String] gcs_path
|
||||
# Required. A Cloud Storage path to the template from which to
|
||||
# create the job.
|
||||
# Must be a valid Cloud Storage URL, beginning with `gs://`.
|
||||
# Must be valid Cloud Storage URL, beginning with 'gs://'.
|
||||
# @param [String] view
|
||||
# The view to retrieve. Defaults to METADATA_ONLY.
|
||||
# @param [String] fields
|
||||
@@ -1077,8 +1152,14 @@ module Google
|
||||
# @param [String] location
|
||||
# The location to which to direct the request.
|
||||
# @param [Google::Apis::DataflowV1b3::LaunchTemplateParameters] launch_template_parameters_object
|
||||
# @param [String] dynamic_template_gcs_path
|
||||
# Path to dynamic template spec file on GCS.
|
||||
# The file must be a Json serialized DynamicTemplateFieSpec object.
|
||||
# @param [String] dynamic_template_staging_location
|
||||
# Cloud Storage path for staging dependencies.
|
||||
# Must be a valid Cloud Storage URL, beginning with `gs://`.
|
||||
# @param [String] gcs_path
|
||||
# Required. A Cloud Storage path to the template from which to create
|
||||
# A Cloud Storage path to the template from which to create
|
||||
# the job.
|
||||
# Must be valid Cloud Storage URL, beginning with 'gs://'.
|
||||
# @param [Boolean] validate_only
|
||||
@@ -1101,7 +1182,7 @@ module Google
|
||||
# @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 launch_project_location_template(project_id, location, launch_template_parameters_object = nil, gcs_path: nil, validate_only: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
def launch_project_location_template(project_id, location, launch_template_parameters_object = nil, dynamic_template_gcs_path: nil, dynamic_template_staging_location: nil, gcs_path: nil, validate_only: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:post, 'v1b3/projects/{projectId}/locations/{location}/templates:launch', options)
|
||||
command.request_representation = Google::Apis::DataflowV1b3::LaunchTemplateParameters::Representation
|
||||
command.request_object = launch_template_parameters_object
|
||||
@@ -1109,6 +1190,8 @@ module Google
|
||||
command.response_class = Google::Apis::DataflowV1b3::LaunchTemplateResponse
|
||||
command.params['projectId'] = project_id unless project_id.nil?
|
||||
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?
|
||||
@@ -1155,7 +1238,7 @@ module Google
|
||||
# @param [String] gcs_path
|
||||
# Required. A Cloud Storage path to the template from which to
|
||||
# create the job.
|
||||
# Must be a valid Cloud Storage URL, beginning with `gs://`.
|
||||
# Must be valid Cloud Storage URL, beginning with 'gs://'.
|
||||
# @param [String] location
|
||||
# The location to which to direct the request.
|
||||
# @param [String] view
|
||||
@@ -1194,8 +1277,14 @@ module Google
|
||||
# @param [String] project_id
|
||||
# Required. The ID of the Cloud Platform project that the job belongs to.
|
||||
# @param [Google::Apis::DataflowV1b3::LaunchTemplateParameters] launch_template_parameters_object
|
||||
# @param [String] dynamic_template_gcs_path
|
||||
# Path to dynamic template spec file on GCS.
|
||||
# The file must be a Json serialized DynamicTemplateFieSpec object.
|
||||
# @param [String] dynamic_template_staging_location
|
||||
# Cloud Storage path for staging dependencies.
|
||||
# Must be a valid Cloud Storage URL, beginning with `gs://`.
|
||||
# @param [String] gcs_path
|
||||
# Required. A Cloud Storage path to the template from which to create
|
||||
# A Cloud Storage path to the template from which to create
|
||||
# the job.
|
||||
# Must be valid Cloud Storage URL, beginning with 'gs://'.
|
||||
# @param [String] location
|
||||
@@ -1220,13 +1309,15 @@ module Google
|
||||
# @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 launch_project_template(project_id, launch_template_parameters_object = nil, gcs_path: nil, location: nil, validate_only: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
def launch_project_template(project_id, launch_template_parameters_object = nil, dynamic_template_gcs_path: nil, dynamic_template_staging_location: nil, gcs_path: nil, location: nil, validate_only: nil, fields: nil, quota_user: nil, options: nil, &block)
|
||||
command = make_simple_command(:post, 'v1b3/projects/{projectId}/templates:launch', options)
|
||||
command.request_representation = Google::Apis::DataflowV1b3::LaunchTemplateParameters::Representation
|
||||
command.request_object = launch_template_parameters_object
|
||||
command.response_representation = Google::Apis::DataflowV1b3::LaunchTemplateResponse::Representation
|
||||
command.response_class = Google::Apis::DataflowV1b3::LaunchTemplateResponse
|
||||
command.params['projectId'] = project_id unless project_id.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['location'] = location unless location.nil?
|
||||
command.query['validateOnly'] = validate_only unless validate_only.nil?
|
||||
|
||||
Reference in new issue
Block a user