Class: Google::Apis::DataflowV1b3::ReportWorkItemStatusRequest
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::ReportWorkItemStatusRequest
- 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
Request to report the status of WorkItems.
Instance Attribute Summary collapse
-
#current_worker_time ⇒ String
The current timestamp at the worker.
-
#location ⇒ String
The regional endpoint that contains the WorkItem's job.
-
#unified_worker_request ⇒ Hash<String,Object>
Untranslated bag-of-bytes WorkProgressUpdateRequest from UnifiedWorker.
-
#work_item_statuses ⇒ Array<Google::Apis::DataflowV1b3::WorkItemStatus>
The order is unimportant, except that the order of the WorkItemServiceState messages in the ReportWorkItemStatusResponse corresponds to the order of WorkItemStatus messages here.
-
#worker_id ⇒ String
The ID of the worker reporting the WorkItem status.
Instance Method Summary collapse
-
#initialize(**args) ⇒ ReportWorkItemStatusRequest
constructor
A new instance of ReportWorkItemStatusRequest.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ ReportWorkItemStatusRequest
Returns a new instance of ReportWorkItemStatusRequest.
3340 3341 3342 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3340 def initialize(**args) update!(**args) end |
Instance Attribute Details
#current_worker_time ⇒ String
The current timestamp at the worker.
Corresponds to the JSON property currentWorkerTime
3311 3312 3313 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3311 def current_worker_time @current_worker_time end |
#location ⇒ String
The regional endpoint that
contains the WorkItem's job.
Corresponds to the JSON property location
3318 3319 3320 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3318 def location @location end |
#unified_worker_request ⇒ Hash<String,Object>
Untranslated bag-of-bytes WorkProgressUpdateRequest from UnifiedWorker.
Corresponds to the JSON property unifiedWorkerRequest
3323 3324 3325 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3323 def unified_worker_request @unified_worker_request end |
#work_item_statuses ⇒ Array<Google::Apis::DataflowV1b3::WorkItemStatus>
The order is unimportant, except that the order of the
WorkItemServiceState messages in the ReportWorkItemStatusResponse
corresponds to the order of WorkItemStatus messages here.
Corresponds to the JSON property workItemStatuses
3330 3331 3332 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3330 def work_item_statuses @work_item_statuses end |
#worker_id ⇒ String
The ID of the worker reporting the WorkItem status. If this
does not match the ID of the worker which the Dataflow service
believes currently has the lease on the WorkItem, the report
will be dropped (with an error response).
Corresponds to the JSON property workerId
3338 3339 3340 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3338 def worker_id @worker_id end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3345 3346 3347 3348 3349 3350 3351 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3345 def update!(**args) @current_worker_time = args[:current_worker_time] if args.key?(:current_worker_time) @location = args[:location] if args.key?(:location) @unified_worker_request = args[:unified_worker_request] if args.key?(:unified_worker_request) @work_item_statuses = args[:work_item_statuses] if args.key?(:work_item_statuses) @worker_id = args[:worker_id] if args.key?(:worker_id) end |