WorkerMessage

import type { WorkerMessage } from "https://googleapis.deno.dev/v1/dataflow:v1b3.ts";

WorkerMessage provides information to the backend about a worker.

interface WorkerMessage {

dataSamplingReport?: DataSamplingReport;

labels?: {

[key: string]: string;

};

perWorkerMetrics?: PerWorkerMetrics;

streamingScalingReport?: StreamingScalingReport;

time?: Date;

workerHealthReport?: WorkerHealthReport;

workerLifecycleEvent?: WorkerLifecycleEvent;

workerMessageCode?: WorkerMessageCode;

workerMetrics?: ResourceUtilizationReport;

workerShutdownNotice?: WorkerShutdownNotice;

workerThreadScalingReport?: WorkerThreadScalingReport;

}

§Properties

dataSamplingReport?: DataSamplingReport

[src]

Optional. Contains metrics related to go/dataflow-data-sampling-telemetry.

labels?: {

[key: string]: string;

}

[src]

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.

perWorkerMetrics?: PerWorkerMetrics

[src]

System defined metrics for this worker.

streamingScalingReport?: StreamingScalingReport

[src]

Contains per-user worker telemetry used in streaming autoscaling.

time?: Date

[src]

The timestamp of the worker_message.

workerHealthReport?: WorkerHealthReport

[src]

The health of a worker.