GoogleApi.Dataflow.V1b3.Model.WorkerMessage (google_api_dataflow v0.34.0) View Source

WorkerMessage provides information to the backend about a worker.

Attributes

labels (type: map(), default: nil) - 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.
time (type: DateTime.t, default: nil) - The timestamp of the worker_message.
workerHealthReport (type: GoogleApi.Dataflow.V1b3.Model.WorkerHealthReport.t, default: nil) - The health of a worker.
workerLifecycleEvent (type: GoogleApi.Dataflow.V1b3.Model.WorkerLifecycleEvent.t, default: nil) - Record of worker lifecycle events.
workerMessageCode (type: GoogleApi.Dataflow.V1b3.Model.WorkerMessageCode.t, default: nil) - A worker message code.
workerMetrics (type: GoogleApi.Dataflow.V1b3.Model.ResourceUtilizationReport.t, default: nil) - Resource metrics reported by workers.
workerShutdownNotice (type: GoogleApi.Dataflow.V1b3.Model.WorkerShutdownNotice.t, default: nil) - Shutdown notice by workers.

Link to this section Summary

Types

t()

Functions

decode(value, options)

Unwrap a decoded JSON object into its complex fields.

Link to this section Types

t()

Specs

t() :: %GoogleApi.Dataflow.V1b3.Model.WorkerMessage{
  labels: map(),
  time: DateTime.t(),
  workerHealthReport: GoogleApi.Dataflow.V1b3.Model.WorkerHealthReport.t(),
  workerLifecycleEvent: GoogleApi.Dataflow.V1b3.Model.WorkerLifecycleEvent.t(),
  workerMessageCode: GoogleApi.Dataflow.V1b3.Model.WorkerMessageCode.t(),
  workerMetrics: GoogleApi.Dataflow.V1b3.Model.ResourceUtilizationReport.t(),
  workerShutdownNotice: GoogleApi.Dataflow.V1b3.Model.WorkerShutdownNotice.t()
}

Link to this section Functions

decode(value, options)

Specs

decode(struct(), keyword()) :: struct()

Unwrap a decoded JSON object into its complex fields.