Class: Google::Apis::DataflowV1b3::WorkerLifecycleEvent

Inherits:
Object
  • Object
show all
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

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.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ WorkerLifecycleEvent

Returns a new instance of WorkerLifecycleEvent



5222
5223
5224
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5222

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#container_start_time ⇒ String

The start time of this container. All events will report this so that events can be grouped together across container/VM restarts. Corresponds to the JSON property containerStartTime

Returns:

  • (String) 


5209
5210
5211
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5209

def container_start_time
  @container_start_time
end

#event ⇒ String

The event being reported. Corresponds to the JSON property event

Returns:

  • (String) 


5214
5215
5216
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5214

def event
  @event
end

#metadata ⇒ Hash<String,String>

Other stats that can accompany an event. E.g. "downloaded_bytes" : "123456" Corresponds to the JSON property metadata

Returns:

  • (Hash<String,String>) 


5220
5221
5222
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5220

def metadata
  @metadata
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



5227
5228
5229
5230
5231
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5227

def update!(**args)
  @container_start_time = args[:container_start_time] if args.key?(:container_start_time)
  @event = args[:event] if args.key?(:event)
  @metadata = args[:metadata] if args.key?(:metadata)
end