class Google::Apis::DataflowV1b3::LeaseWorkItemRequest

Request to lease WorkItems.

Attributes

current_worker_time[RW]

The current timestamp at the worker. Corresponds to the JSON property `currentWorkerTime` @return [String]

location[RW]

The [regional endpoint] (cloud.google.com/dataflow/docs/concepts/ regional-endpoints) that contains the WorkItem's job. Corresponds to the JSON property `location` @return [String]

requested_lease_duration[RW]

The initial lease period. Corresponds to the JSON property `requestedLeaseDuration` @return [String]

unified_worker_request[RW]

Untranslated bag-of-bytes WorkRequest from UnifiedWorker. Corresponds to the JSON property `unifiedWorkerRequest` @return [Hash<String,Object>]

work_item_types[RW]

Filter for WorkItem type. Corresponds to the JSON property `workItemTypes` @return [Array<String>]

worker_capabilities[RW]

Worker capabilities. WorkItems might be limited to workers with specific capabilities. Corresponds to the JSON property `workerCapabilities` @return [Array<String>]

worker_id[RW]

Identifies the worker leasing work – typically the ID of the virtual machine running the worker. Corresponds to the JSON property `workerId` @return [String]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 2691
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 2696
def update!(**args)
  @current_worker_time = args[:current_worker_time] if args.key?(:current_worker_time)
  @location = args[:location] if args.key?(:location)
  @requested_lease_duration = args[:requested_lease_duration] if args.key?(:requested_lease_duration)
  @unified_worker_request = args[:unified_worker_request] if args.key?(:unified_worker_request)
  @work_item_types = args[:work_item_types] if args.key?(:work_item_types)
  @worker_capabilities = args[:worker_capabilities] if args.key?(:worker_capabilities)
  @worker_id = args[:worker_id] if args.key?(:worker_id)
end