Class: Google::Apis::DataflowV1b3::WorkerSettings
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::WorkerSettings
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb
Overview
Provides data to pass through to the worker harness.
Instance Attribute Summary collapse
-
#base_url ⇒ String
The base URL for accessing Google Cloud APIs.
-
#reporting_enabled ⇒ Boolean
(also: #reporting_enabled?)
Whether to send work progress updates to the service.
-
#service_path ⇒ String
The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
-
#shuffle_service_path ⇒ String
The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
-
#temp_storage_prefix ⇒ String
The prefix of the resources the system should use for temporary storage.
-
#worker_id ⇒ String
The ID of the worker running this pipeline.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkerSettings
constructor
A new instance of WorkerSettings.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ WorkerSettings
Returns a new instance of WorkerSettings
5574 5575 5576 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5574 def initialize(**args) update!(**args) end |
Instance Attribute Details
#base_url ⇒ String
The base URL for accessing Google Cloud APIs.
When workers access Google Cloud APIs, they logically do so via
relative URLs. If this field is specified, it supplies the base
URL to use for resolving these relative URLs. The normative
algorithm used is defined by RFC 1808, "Relative Uniform Resource
Locators".
If not specified, the default value is "http://www.googleapis.com/"
Corresponds to the JSON property baseUrl
5539 5540 5541 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5539 def base_url @base_url end |
#reporting_enabled ⇒ Boolean Also known as: reporting_enabled?
Whether to send work progress updates to the service.
Corresponds to the JSON property reportingEnabled
5544 5545 5546 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5544 def reporting_enabled @reporting_enabled end |
#service_path ⇒ String
The Cloud Dataflow service path relative to the root URL, for example,
"dataflow/v1b3/projects".
Corresponds to the JSON property servicePath
5551 5552 5553 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5551 def service_path @service_path end |
#shuffle_service_path ⇒ String
The Shuffle service path relative to the root URL, for example,
"shuffle/v1beta1".
Corresponds to the JSON property shuffleServicePath
5557 5558 5559 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5557 def shuffle_service_path @shuffle_service_path end |
#temp_storage_prefix ⇒ String
The prefix of the resources the system should use for temporary
storage.
The supported resource type is:
Google Cloud Storage:
storage.googleapis.com/bucket
/object
bucket.storage.googleapis.com/object
Corresponds to the JSON property tempStoragePrefix
5567 5568 5569 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5567 def temp_storage_prefix @temp_storage_prefix end |
#worker_id ⇒ String
The ID of the worker running this pipeline.
Corresponds to the JSON property workerId
5572 5573 5574 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5572 def worker_id @worker_id end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
5579 5580 5581 5582 5583 5584 5585 5586 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5579 def update!(**args) @base_url = args[:base_url] if args.key?(:base_url) @reporting_enabled = args[:reporting_enabled] if args.key?(:reporting_enabled) @service_path = args[:service_path] if args.key?(:service_path) @shuffle_service_path = args[:shuffle_service_path] if args.key?(:shuffle_service_path) @temp_storage_prefix = args[:temp_storage_prefix] if args.key?(:temp_storage_prefix) @worker_id = args[:worker_id] if args.key?(:worker_id) end |