Class: Google::Apis::DataflowV1b3::WorkerMessage
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::WorkerMessage
- 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
WorkerMessage provides information to the backend about a worker.
Instance Attribute Summary collapse
-
#labels ⇒ Hash<String,String>
Labels are used to group WorkerMessages.
-
#time ⇒ String
The timestamp of the worker_message.
-
#worker_health_report ⇒ Google::Apis::DataflowV1b3::WorkerHealthReport
WorkerHealthReport contains information about the health of a worker.
-
#worker_lifecycle_event ⇒ Google::Apis::DataflowV1b3::WorkerLifecycleEvent
A report of an event in a worker's lifecycle.
-
#worker_message_code ⇒ Google::Apis::DataflowV1b3::WorkerMessageCode
A message code is used to report status and error messages to the service.
-
#worker_metrics ⇒ Google::Apis::DataflowV1b3::ResourceUtilizationReport
Worker metrics exported from workers.
-
#worker_shutdown_notice ⇒ Google::Apis::DataflowV1b3::WorkerShutdownNotice
Shutdown notification from workers.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkerMessage
constructor
A new instance of WorkerMessage.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ WorkerMessage
Returns a new instance of WorkerMessage
5544 5545 5546 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5544 def initialize(**args) update!(**args) end |
Instance Attribute Details
#labels ⇒ Hash<String,String>
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
5494 5495 5496 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5494 def labels @labels end |
#time ⇒ String
The timestamp of the worker_message.
Corresponds to the JSON property time
5499 5500 5501 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5499 def time @time end |
#worker_health_report ⇒ Google::Apis::DataflowV1b3::WorkerHealthReport
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
5506 5507 5508 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5506 def worker_health_report @worker_health_report end |
#worker_lifecycle_event ⇒ Google::Apis::DataflowV1b3::WorkerLifecycleEvent
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
5516 5517 5518 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5516 def worker_lifecycle_event @worker_lifecycle_event end |
#worker_message_code ⇒ Google::Apis::DataflowV1b3::WorkerMessageCode
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:
- Worker processes reporting successful startup.
- Worker processes reporting specific errors (e.g. package staging
failure).
Corresponds to the JSON property
workerMessageCode
5528 5529 5530 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5528 def @worker_message_code end |
#worker_metrics ⇒ Google::Apis::DataflowV1b3::ResourceUtilizationReport
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
5535 5536 5537 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5535 def worker_metrics @worker_metrics end |
#worker_shutdown_notice ⇒ Google::Apis::DataflowV1b3::WorkerShutdownNotice
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
5542 5543 5544 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5542 def worker_shutdown_notice @worker_shutdown_notice end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
5549 5550 5551 5552 5553 5554 5555 5556 5557 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5549 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 |