class Google::Apis::DataflowV1b3::WorkerMessage

WorkerMessage provides information to the backend about a worker.

Attributes

labels[RW]

Labels are used to group WorkerMessages. For example, a worker_message about a particular container might have the labels: ` “JOB_ID”: “2015-04-22”, “ WORKER_ID”: “wordcount-vm-2015…” “CONTAINER_TYPE”: “worker”, “CONTAINER_ID”: “ ac1234def”` Label tags typically correspond to Label enum values. However, for ease of development other strings can be used as tags. LABEL_UNSPECIFIED should not be used here. Corresponds to the JSON property `labels` @return [Hash<String,String>]

time[RW]

The timestamp of the worker_message. Corresponds to the JSON property `time` @return [String]

worker_health_report[RW]

WorkerHealthReport contains information about the health of a worker. The VM should be identified by the labels attached to the WorkerMessage that this health ping belongs to. Corresponds to the JSON property `workerHealthReport` @return [Google::Apis::DataflowV1b3::WorkerHealthReport]

worker_lifecycle_event[RW]

A report of an event in a worker's lifecycle. The proto contains one event, because the worker is expected to asynchronously send each message immediately after the event. Due to this asynchrony, messages may arrive out of order (or missing), and it is up to the consumer to interpret. The timestamp of the event is in the enclosing WorkerMessage proto. Corresponds to the JSON property `workerLifecycleEvent` @return [Google::Apis::DataflowV1b3::WorkerLifecycleEvent]

worker_message_code[RW]

A message code is used to report status and error messages to the service. The message codes are intended to be machine readable. The service will take care of translating these into user understandable messages if necessary. Example use cases: 1. Worker processes reporting successful startup. 2. Worker processes reporting specific errors (e.g. package staging failure). Corresponds to the JSON property `workerMessageCode` @return [Google::Apis::DataflowV1b3::WorkerMessageCode]

worker_metrics[RW]

Worker metrics exported from workers. This contains resource utilization metrics accumulated from a variety of sources. For more information, see go/df- resource-signals. Corresponds to the JSON property `workerMetrics` @return [Google::Apis::DataflowV1b3::ResourceUtilizationReport]

worker_shutdown_notice[RW]

Shutdown notification from workers. This is to be sent by the shutdown script of the worker VM so that the backend knows that the VM is being shut down. Corresponds to the JSON property `workerShutdownNotice` @return [Google::Apis::DataflowV1b3::WorkerShutdownNotice]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6365
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 6370
def update!(**args)
  @labels = args[:labels] if args.key?(:labels)
  @time = args[:time] if args.key?(:time)
  @worker_health_report = args[:worker_health_report] if args.key?(:worker_health_report)
  @worker_lifecycle_event = args[:worker_lifecycle_event] if args.key?(:worker_lifecycle_event)
  @worker_message_code = args[:worker_message_code] if args.key?(:worker_message_code)
  @worker_metrics = args[:worker_metrics] if args.key?(:worker_metrics)
  @worker_shutdown_notice = args[:worker_shutdown_notice] if args.key?(:worker_shutdown_notice)
end