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
3215 3216 3217 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3215 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
3186 3187 3188 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3186 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
3193 3194 3195 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3193 def location @location end |
#unified_worker_request ⇒ Hash<String,Object>
Untranslated bag-of-bytes WorkProgressUpdateRequest from UnifiedWorker.
Corresponds to the JSON property unifiedWorkerRequest
3198 3199 3200 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3198 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
3205 3206 3207 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3205 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
3213 3214 3215 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3213 def worker_id @worker_id end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
3220 3221 3222 3223 3224 3225 3226 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3220 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 |