Class: Google::Apis::DataflowV1b3::WorkerMessageCode

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 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).

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) ⇒ WorkerMessageCode

Returns a new instance of WorkerMessageCode



4217
4218
4219
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4217

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

Instance Attribute Details

#codeString

The code is a string intended for consumption by a machine that identifies the type of message being sent. Examples:

  1. "HARNESS_STARTED" might be used to indicate the worker harness has started.
  2. "GCS_DOWNLOAD_ERROR" might be used to indicate an error downloading a GCS file as part of the boot process of one of the worker containers. This is a string and not an enum to make it easy to add new codes without waiting for an API change. Corresponds to the JSON property code

Returns:

  • (String)


4215
4216
4217
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4215

def code
  @code
end

#parametersHash<String,Object>

Parameters contains specific information about the code. This is a struct to allow parameters of different types. Examples:

  1. For a "HARNESS_STARTED" message parameters might provide the name of the worker and additional data like timing information.
  2. For a "GCS_DOWNLOAD_ERROR" parameters might contain fields listing the GCS objects being downloaded and fields containing errors. In general complex data structures should be avoided. If a worker needs to send a specific and complicated data structure then please consider defining a new proto and adding it to the data oneof in WorkerMessageResponse. Conventions: Parameters should only be used for information that isn't typically passed as a label. hostname and other worker identifiers should almost always be passed as labels since they will be included on most messages. Corresponds to the JSON property parameters

Returns:

  • (Hash<String,Object>)


4202
4203
4204
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4202

def parameters
  @parameters
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



4222
4223
4224
4225
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4222

def update!(**args)
  @parameters = args[:parameters] if args.key?(:parameters)
  @code = args[:code] if args.key?(:code)
end