Api-roll 44: 2017-01-23

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
 
 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show
     ApiRequestError, DetailedApiRequestError;
 
 const core.String USER_AGENT = 'dart-api-client dataflow/v1b3';
 
-/**
- * Develops and executes data processing patterns like ETL, batch computation,
- * and continuous computation.
- */
+/** Manages Google Cloud Dataflow projects on Google Cloud Platform. */
 class DataflowApi {
   /** View and manage your data across Google Cloud Platform services */
   static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
 
   /** View your email address */
   static const UserinfoEmailScope = "https://www.googleapis.com/auth/userinfo.email";
 
 
   final commons.ApiRequester _requester;
 
@@ skipping 65 matching lines @@
   final commons.ApiRequester _requester;
 
   ProjectsJobsDebugResourceApi get debug => new ProjectsJobsDebugResourceApi(_requester);
   ProjectsJobsMessagesResourceApi get messages => new ProjectsJobsMessagesResourceApi(_requester);
   ProjectsJobsWorkItemsResourceApi get workItems => new ProjectsJobsWorkItemsResourceApi(_requester);
 
   ProjectsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
-   * Creates a dataflow job.
+   * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [view] - Level of information requested in response.
+   * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
-   * [replaceJobId] - DEPRECATED. This field is now on the Job message.
+   * [replaceJobId] - Deprecated. This field is now in the Job message.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> create(Job request, core.String projectId, {core.String view, core.String replaceJobId, core.String location}) {
@@ skipping 26 matching lines @@
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
-   * Gets the state of the specified dataflow job.
+   * Gets the state of the specified Cloud Dataflow job.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [jobId] - Identifies a single job.
+   * [jobId] - The job ID.
    *
-   * [view] - Level of information requested in response.
+   * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> get(core.String projectId, core.String jobId, {core.String view, core.String location}) {
@@ skipping 78 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new JobMetrics.fromJson(data));
   }
 
   /**
-   * List the jobs of a project
+   * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
    * [filter] - The kind of filter to use.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "ALL" : A ALL.
    * - "TERMINATED" : A TERMINATED.
    * - "ACTIVE" : A ACTIVE.
    *
-   * [view] - Level of information requested in response. Default is SUMMARY.
+   * [view] - Level of information requested in response. Default is
+   * `JOB_VIEW_SUMMARY`.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses and
    * an unspecified server-defined limit.
    *
    * [pageToken] - Set this to the 'next_page_token' field of a previous
    * response to request additional results in a long list.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
    * Completes with a [ListJobsResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String view, core.int pageSize, core.String pageToken, core.String location}) {
@@ skipping 29 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobsResponse.fromJson(data));
   }
 
   /**
-   * Updates the state of an existing dataflow job.
+   * Updates the state of an existing Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [jobId] - Identifies a single job.
+   * [jobId] - The job ID.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> update(Job request, core.String projectId, core.String jobId, {core.String location}) {
@@ skipping 356 matching lines @@
 class ProjectsLocationsJobsResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsLocationsJobsMessagesResourceApi get messages => new ProjectsLocationsJobsMessagesResourceApi(_requester);
   ProjectsLocationsJobsWorkItemsResourceApi get workItems => new ProjectsLocationsJobsWorkItemsResourceApi(_requester);
 
   ProjectsLocationsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
-   * Creates a dataflow job.
+   * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
-   * [view] - Level of information requested in response.
+   * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
-   * [replaceJobId] - DEPRECATED. This field is now on the Job message.
+   * [replaceJobId] - Deprecated. This field is now in the Job message.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String view, core.String replaceJobId}) {
@@ skipping 26 matching lines @@
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
-   * Gets the state of the specified dataflow job.
+   * Gets the state of the specified Cloud Dataflow job.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
-   * [jobId] - Identifies a single job.
+   * [jobId] - The job ID.
    *
-   * [view] - Level of information requested in response.
+   * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
@@ skipping 82 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new JobMetrics.fromJson(data));
   }
 
   /**
-   * List the jobs of a project
+   * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
    * [filter] - The kind of filter to use.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "ALL" : A ALL.
    * - "TERMINATED" : A TERMINATED.
    * - "ACTIVE" : A ACTIVE.
    *
-   * [view] - Level of information requested in response. Default is SUMMARY.
+   * [view] - Level of information requested in response. Default is
+   * `JOB_VIEW_SUMMARY`.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    *
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses and
    * an unspecified server-defined limit.
    *
    * [pageToken] - Set this to the 'next_page_token' field of a previous
@@ skipping 40 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobsResponse.fromJson(data));
   }
 
   /**
-   * Updates the state of an existing dataflow job.
+   * Updates the state of an existing Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
-   * [location] - The location which contains this job.
+   * [location] - The location that contains this job.
    *
-   * [jobId] - Identifies a single job.
+   * [jobId] - The job ID.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> update(Job request, core.String projectId, core.String location, core.String jobId) {
@@ skipping 246 matching lines @@
 }
 
 
 class ProjectsTemplatesResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsTemplatesResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
-   * Creates a dataflow job from a template.
+   * Creates a Cloud Dataflow job from a template.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
-   * [projectId] - The project which owns the job.
+   * [projectId] - Required. The ID of the Cloud Platform project that the job
+   * belongs to.
    *
    * Completes with a [Job].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
   async.Future<Job> create(CreateJobFromTemplateRequest request, core.String projectId) {
@@ skipping 327 matching lines @@
    * Counter aggregation kind.
    * Possible string values are:
    * - "INVALID" : A INVALID.
    * - "SUM" : A SUM.
    * - "MAX" : A MAX.
    * - "MIN" : A MIN.
    * - "MEAN" : A MEAN.
    * - "OR" : A OR.
    * - "AND" : A AND.
    * - "SET" : A SET.
+   * - "DISTRIBUTION" : A DISTRIBUTION.
    */
   core.String kind;
   /** A string referring to the unit type. */
   core.String otherUnits;
   /**
    * System defined Units, see above enum.
    * Possible string values are:
    * - "BYTES" : A BYTES.
    * - "BYTES_PER_SEC" : A BYTES_PER_SEC.
    * - "MILLISECONDS" : A MILLISECONDS.
@@ skipping 176 matching lines @@
 /** An update to a Counter sent from a worker. */
 class CounterUpdate {
   /** Boolean value for And, Or. */
   core.bool boolean;
   /**
    * True if this counter is reported as the total cumulative aggregate value
    * accumulated since the worker started working on this WorkItem. By default
    * this is false, indicating that this counter is reported as a delta.
    */
   core.bool cumulative;
+  /** Distribution data */
+  DistributionUpdate distribution;
   /** Floating point value for Sum, Max, Min. */
   core.double floatingPoint;
   /** List of floating point numbers, for Set. */
   FloatingPointList floatingPointList;
   /** Floating point mean aggregation value for Mean. */
   FloatingPointMean floatingPointMean;
   /** Integer value for Sum, Max, Min. */
   SplitInt64 integer;
   /** List of integers, for Set. */
   IntegerList integerList;
@@ skipping 20 matching lines @@
 
   CounterUpdate();
 
   CounterUpdate.fromJson(core.Map _json) {
     if (_json.containsKey("boolean")) {
       boolean = _json["boolean"];
     }
     if (_json.containsKey("cumulative")) {
       cumulative = _json["cumulative"];
     }
+    if (_json.containsKey("distribution")) {
+      distribution = new DistributionUpdate.fromJson(_json["distribution"]);
+    }
     if (_json.containsKey("floatingPoint")) {
       floatingPoint = _json["floatingPoint"];
     }
     if (_json.containsKey("floatingPointList")) {
       floatingPointList = new FloatingPointList.fromJson(_json["floatingPointList"]);
     }
     if (_json.containsKey("floatingPointMean")) {
       floatingPointMean = new FloatingPointMean.fromJson(_json["floatingPointMean"]);
     }
     if (_json.containsKey("integer")) {
@@ skipping 23 matching lines @@
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (boolean != null) {
       _json["boolean"] = boolean;
     }
     if (cumulative != null) {
       _json["cumulative"] = cumulative;
     }
+    if (distribution != null) {
+      _json["distribution"] = (distribution).toJson();
+    }
     if (floatingPoint != null) {
       _json["floatingPoint"] = floatingPoint;
     }
     if (floatingPointList != null) {
       _json["floatingPointList"] = (floatingPointList).toJson();
     }
     if (floatingPointMean != null) {
       _json["floatingPointMean"] = (floatingPointMean).toJson();
     }
     if (integer != null) {
@@ skipping 17 matching lines @@
     if (stringList != null) {
       _json["stringList"] = (stringList).toJson();
     }
     if (structuredNameAndMetadata != null) {
       _json["structuredNameAndMetadata"] = (structuredNameAndMetadata).toJson();
     }
     return _json;
   }
 }
 
-/** Request to create a Dataflow job. */
+/** A request to create a Cloud Dataflow job from a template. */
 class CreateJobFromTemplateRequest {
-  /** Runtime environment for the job. */
+  /** The runtime environment for the job. */
   RuntimeEnvironment environment;
-  /** A path to the serialized JSON representation of the job. */
+  /**
+   * Required. A Cloud Storage path to the template from which to create the
+   * job. Must be a valid Cloud Storage URL, beginning with `gs://`.
+   */
   core.String gcsPath;
-  /** The job name to use for the created job.. */
+  /** Required. The job name to use for the created job. */
   core.String jobName;
-  /** Dynamic parameterization of the job's runtime environment. */
+  /** The runtime parameters to pass to the job. */
   core.Map<core.String, core.String> parameters;
 
   CreateJobFromTemplateRequest();
 
   CreateJobFromTemplateRequest.fromJson(core.Map _json) {
     if (_json.containsKey("environment")) {
       environment = new RuntimeEnvironment.fromJson(_json["environment"]);
     }
     if (_json.containsKey("gcsPath")) {
       gcsPath = _json["gcsPath"];
@@ skipping 131 matching lines @@
 
 /** Describes the data disk used by a workflow job. */
 class Disk {
   /**
    * Disk storage type, as defined by Google Compute Engine. This must be a disk
    * type appropriate to the project and zone in which the workers will run. If
    * unknown or unspecified, the service will attempt to choose a reasonable
    * default. For example, the standard persistent disk type is a resource name
    * typically ending in "pd-standard". If SSD persistent disks are available,
    * the resource name typically ends with "pd-ssd". The actual valid values are
-   * defined the Google Compute Engine API, not by the Dataflow API; consult the
-   * Google Compute Engine documentation for more information about determining
-   * the set of available disk types for a particular project and zone. Google
-   * Compute Engine Disk types are local to a particular project in a particular
-   * zone, and so the resource name will typically look something like this:
-   * compute.googleapis.com/projects/
-   * /zones//diskTypes/pd-standard
+   * defined the Google Compute Engine API, not by the Cloud Dataflow API;
+   * consult the Google Compute Engine documentation for more information about
+   * determining the set of available disk types for a particular project and
+   * zone. Google Compute Engine Disk types are local to a particular project in
+   * a particular zone, and so the resource name will typically look something
+   * like this:
+   * compute.googleapis.com/projects/project-id/zones/zone/diskTypes/pd-standard
    */
   core.String diskType;
   /** Directory in a VM where disk is mounted. */
   core.String mountPoint;
   /**
    * Size of disk in GB. If zero or unspecified, the service will attempt to
    * choose a reasonable default.
    */
   core.int sizeGb;
 
@@ skipping 19 matching lines @@
     if (mountPoint != null) {
       _json["mountPoint"] = mountPoint;
     }
     if (sizeGb != null) {
       _json["sizeGb"] = sizeGb;
     }
     return _json;
   }
 }
 
+/** A metric value representing a distribution. */
+class DistributionUpdate {
+  /** The count of the number of elements present in the distribution. */
+  SplitInt64 count;
+  /** The maximum value present in the distribution. */
+  SplitInt64 max;
+  /** The minimum value present in the distribution. */
+  SplitInt64 min;
+  /**
+   * Use an int64 since we'd prefer the added precision. If overflow is a common
+   * problem we can detect it and use an additional int64 or a double.
+   */
+  SplitInt64 sum;
+  /** Use a double since the sum of squares is likely to overflow int64. */
+  core.double sumOfSquares;
+
+  DistributionUpdate();
+
+  DistributionUpdate.fromJson(core.Map _json) {
+    if (_json.containsKey("count")) {
+      count = new SplitInt64.fromJson(_json["count"]);
+    }
+    if (_json.containsKey("max")) {
+      max = new SplitInt64.fromJson(_json["max"]);
+    }
+    if (_json.containsKey("min")) {
+      min = new SplitInt64.fromJson(_json["min"]);
+    }
+    if (_json.containsKey("sum")) {
+      sum = new SplitInt64.fromJson(_json["sum"]);
+    }
+    if (_json.containsKey("sumOfSquares")) {
+      sumOfSquares = _json["sumOfSquares"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (count != null) {
+      _json["count"] = (count).toJson();
+    }
+    if (max != null) {
+      _json["max"] = (max).toJson();
+    }
+    if (min != null) {
+      _json["min"] = (min).toJson();
+    }
+    if (sum != null) {
+      _json["sum"] = (sum).toJson();
+    }
+    if (sumOfSquares != null) {
+      _json["sumOfSquares"] = sumOfSquares;
+    }
+    return _json;
+  }
+}
+
 /**
  * When a task splits using WorkItemStatus.dynamic_source_split, this message
  * describes the two parts of the split relative to the description of the
  * current task's input.
  */
 class DynamicSourceSplit {
   /**
    * Primary part (continued to be processed by worker). Specified relative to
    * the previously-current source. Becomes current.
    */
@@ skipping 44 matching lines @@
   /** The list of experiments to enable. */
   core.List<core.String> experiments;
   /**
    * Experimental settings.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> internalExperiments;
   /**
-   * The Dataflow SDK pipeline options specified by the user. These options are
-   * passed through the service and are used to recreate the SDK pipeline
-   * options on the worker in a language agnostic and platform independent way.
+   * The Cloud Dataflow SDK pipeline options specified by the user. These
+   * options are passed through the service and are used to recreate the SDK
+   * pipeline options on the worker in a language agnostic and platform
+   * independent way.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> sdkPipelineOptions;
   /** Identity to run virtual machines as. Defaults to the default account. */
   core.String serviceAccountEmail;
   /**
    * The prefix of the resources the system should use for temporary storage.
    * The system will append the suffix "/temp-{JOBNAME} to this resource prefix,
@@ skipping 14 matching lines @@
   core.Map<core.String, core.Object> userAgent;
   /**
    * A structure describing which components and their versions of the service
    * are required in order to run the job.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> version;
   /**
-   * Worker pools. At least one "harness" worker pool must be specified in order
-   * for the job to have workers.
+   * The worker pools. At least one "harness" worker pool must be specified in
+   * order for the job to have workers.
    */
   core.List<WorkerPool> workerPools;
 
   Environment();
 
   Environment.fromJson(core.Map _json) {
     if (_json.containsKey("clusterManagerApiService")) {
       clusterManagerApiService = _json["clusterManagerApiService"];
     }
     if (_json.containsKey("dataset")) {
@@ skipping 54 matching lines @@
     if (version != null) {
       _json["version"] = version;
     }
     if (workerPools != null) {
       _json["workerPools"] = workerPools.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
-/**
- * FailedLocation indicates which location failed to respond to a request for
- * data.
- */
+/** Indicates which location failed to respond to a request for data. */
 class FailedLocation {
   /** The name of the failed location. */
   core.String name;
 
   FailedLocation();
 
   FailedLocation.fromJson(core.Map _json) {
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
@@ skipping 294 matching lines @@
     if (count != null) {
       _json["count"] = (count).toJson();
     }
     if (sum != null) {
       _json["sum"] = (sum).toJson();
     }
     return _json;
   }
 }
 
-/** Defines a job to be run by the Dataflow service. */
+/** Defines a job to be run by the Cloud Dataflow service. */
 class Job {
   /**
-   * Client's unique identifier of the job, re-used by SDK across retried
-   * attempts. If this field is set, the service will ensure its uniqueness.
-   * That is, the request to create a job will fail if the service has knowledge
-   * of a previously submitted job with the same client's id and job name. The
-   * caller may, for example, use this field to ensure idempotence of job
-   * creation across retried attempts to create a job. By default, the field is
-   * empty and, in that case, the service ignores it.
+   * The client's unique identifier of the job, re-used across retried attempts.
+   * If this field is set, the service will ensure its uniqueness. The request
+   * to create a job will fail if the service has knowledge of a previously
+   * submitted job with the same client's ID and job name. The caller may use
+   * this field to ensure idempotence of job creation across retried attempts to
+   * create a job. By default, the field is empty and, in that case, the service
+   * ignores it.
    */
   core.String clientRequestId;
   /**
-   * Timestamp when job was initially created. Immutable, set by the Dataflow
-   * service.
+   * The timestamp when the job was initially created. Immutable and set by the
+   * Cloud Dataflow service.
    */
   core.String createTime;
   /**
-   * The current state of the job. Jobs are created in the JOB_STATE_STOPPED
-   * state unless otherwise specified. A job in the JOB_STATE_RUNNING state may
-   * asynchronously enter a terminal state. Once a job has reached a terminal
-   * state, no further state updates may be made. This field may be mutated by
-   * the Dataflow service; callers cannot mutate it.
+   * The current state of the job. Jobs are created in the `JOB_STATE_STOPPED`
+   * state unless otherwise specified. A job in the `JOB_STATE_RUNNING` state
+   * may asynchronously enter a terminal state. After a job has reached a
+   * terminal state, no further state updates may be made. This field may be
+   * mutated by the Cloud Dataflow service; callers cannot mutate it.
    * Possible string values are:
    * - "JOB_STATE_UNKNOWN" : A JOB_STATE_UNKNOWN.
    * - "JOB_STATE_STOPPED" : A JOB_STATE_STOPPED.
    * - "JOB_STATE_RUNNING" : A JOB_STATE_RUNNING.
    * - "JOB_STATE_DONE" : A JOB_STATE_DONE.
    * - "JOB_STATE_FAILED" : A JOB_STATE_FAILED.
    * - "JOB_STATE_CANCELLED" : A JOB_STATE_CANCELLED.
    * - "JOB_STATE_UPDATED" : A JOB_STATE_UPDATED.
    * - "JOB_STATE_DRAINING" : A JOB_STATE_DRAINING.
    * - "JOB_STATE_DRAINED" : A JOB_STATE_DRAINED.
    */
   core.String currentState;
   /** The timestamp associated with the current state. */
   core.String currentStateTime;
-  /** Environment for the job. */
+  /** The environment for the job. */
   Environment environment;
-  /** Information about how the Dataflow service will actually run the job. */
+  /** Information about how the Cloud Dataflow service will run the job. */
   JobExecutionInfo executionInfo;
   /**
-   * The unique ID of this job. This field is set by the Dataflow service when
-   * the Job is created, and is immutable for the life of the Job.
+   * The unique ID of this job. This field is set by the Cloud Dataflow service
+   * when the Job is created, and is immutable for the life of the job.
    */
   core.String id;
   /**
    * User-defined labels for this job. The labels map can contain no more than
    * 64 entries. Entries of the labels map are UTF8 strings that comply with the
    * following restrictions: * Keys must conform to regexp: \p{Ll}\p{Lo}{0,62} *
    * Values must conform to regexp: [\p{Ll}\p{Lo}\p{N}_-]{0,63} * Both keys and
    * values are additionally constrained to be <= 128 bytes in size.
    */
   core.Map<core.String, core.String> labels;
-  /** The location which contains this job. */
+  /** The location that contains this job. */
   core.String location;
   /**
-   * The user-specified Dataflow job name. Only one Job with a given name may
-   * exist in a project at any given time. If a caller attempts to create a Job
-   * with the same name as an already-existing Job, the attempt will return the
+   * The user-specified Cloud Dataflow job name. Only one Job with a given name
+   * may exist in a project at any given time. If a caller attempts to create a
+   * Job with the same name as an already-existing Job, the attempt returns the
    * existing Job. The name must match the regular expression
-   * [a-z]([-a-z0-9]{0,38}[a-z0-9])?
+   * `[a-z]([-a-z0-9]{0,38}[a-z0-9])?`
    */
   core.String name;
-  /** The project which owns the job. */
+  /** The ID of the Cloud Platform project that the job belongs to. */
   core.String projectId;
   /**
-   * If this job is an update of an existing job, this field will be the ID of
-   * the job it replaced. When sending a CreateJobRequest, you can update a job
-   * by specifying it here. The job named here will be stopped, and its
-   * intermediate state transferred to this job.
+   * If this job is an update of an existing job, this field is the job ID of
+   * the job it replaced. When sending a `CreateJobRequest`, you can update a
+   * job by specifying it here. The job named here is stopped, and its
+   * intermediate state is transferred to this job.
    */
   core.String replaceJobId;
   /**
    * If another job is an update of this job (and thus, this job is in
-   * JOB_STATE_UPDATED), this field will contain the ID of that job.
+   * `JOB_STATE_UPDATED`), this field contains the ID of that job.
    */
   core.String replacedByJobId;
   /**
-   * The job's requested state. UpdateJob may be used to switch between the
-   * JOB_STATE_STOPPED and JOB_STATE_RUNNING states, by setting requested_state.
-   * UpdateJob may also be used to directly set a job's requested state to
-   * JOB_STATE_CANCELLED or JOB_STATE_DONE, irrevocably terminating the job if
-   * it has not already reached a terminal state.
+   * The job's requested state. `UpdateJob` may be used to switch between the
+   * `JOB_STATE_STOPPED` and `JOB_STATE_RUNNING` states, by setting
+   * requested_state. `UpdateJob` may also be used to directly set a job's
+   * requested state to `JOB_STATE_CANCELLED` or `JOB_STATE_DONE`, irrevocably
+   * terminating the job if it has not already reached a terminal state.
    * Possible string values are:
    * - "JOB_STATE_UNKNOWN" : A JOB_STATE_UNKNOWN.
    * - "JOB_STATE_STOPPED" : A JOB_STATE_STOPPED.
    * - "JOB_STATE_RUNNING" : A JOB_STATE_RUNNING.
    * - "JOB_STATE_DONE" : A JOB_STATE_DONE.
    * - "JOB_STATE_FAILED" : A JOB_STATE_FAILED.
    * - "JOB_STATE_CANCELLED" : A JOB_STATE_CANCELLED.
    * - "JOB_STATE_UPDATED" : A JOB_STATE_UPDATED.
    * - "JOB_STATE_DRAINING" : A JOB_STATE_DRAINING.
    * - "JOB_STATE_DRAINED" : A JOB_STATE_DRAINED.
    */
   core.String requestedState;
   /** The top-level steps that constitute the entire job. */
   core.List<Step> steps;
   /**
    * A set of files the system should be aware of that are used for temporary
    * storage. These temporary files will be removed on job completion. No
    * duplicates are allowed. No file patterns are supported. The supported files
    * are: Google Cloud Storage: storage.googleapis.com/{bucket}/{object}
    * bucket.storage.googleapis.com/{object}
    */
   core.List<core.String> tempFiles;
   /**
-   * Map of transform name prefixes of the job to be replaced to the
+   * The map of transform name prefixes of the job to be replaced to the
    * corresponding name prefixes of the new job.
    */
   core.Map<core.String, core.String> transformNameMapping;
   /**
-   * The type of dataflow job.
+   * The type of Cloud Dataflow job.
    * Possible string values are:
    * - "JOB_TYPE_UNKNOWN" : A JOB_TYPE_UNKNOWN.
    * - "JOB_TYPE_BATCH" : A JOB_TYPE_BATCH.
    * - "JOB_TYPE_STREAMING" : A JOB_TYPE_STREAMING.
    */
   core.String type;
 
   Job();
 
   Job.fromJson(core.Map _json) {
@@ skipping 107 matching lines @@
       _json["transformNameMapping"] = transformNameMapping;
     }
     if (type != null) {
       _json["type"] = type;
     }
     return _json;
   }
 }
 
 /**
- * Additional information about how a Dataflow job will be executed which isn’t
- * contained in the submitted job.
+ * Additional information about how a Cloud Dataflow job will be executed that
+ * isn't contained in the submitted job.
  */
 class JobExecutionInfo {
   /** A mapping from each stage to the information about that stage. */
   core.Map<core.String, JobExecutionStageInfo> stages;
 
   JobExecutionInfo();
 
   JobExecutionInfo.fromJson(core.Map _json) {
     if (_json.containsKey("stages")) {
       stages = commons.mapMap(_json["stages"], (item) => new JobExecutionStageInfo.fromJson(item));
@@ skipping 361 matching lines @@
       _json["jobMessages"] = jobMessages.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
 /**
- * Response to a request to list Dataflow jobs. This may be a partial response,
- * depending on the page size in the ListJobsRequest.
+ * Response to a request to list Cloud Dataflow jobs. This may be a partial
+ * response, depending on the page size in the ListJobsRequest.
  */
 class ListJobsResponse {
   /** Zero or more messages describing locations that failed to respond. */
   core.List<FailedLocation> failedLocation;
   /** A subset of the requested job information. */
   core.List<Job> jobs;
   /** Set if there may be more results than fit in this response. */
   core.String nextPageToken;
 
   ListJobsResponse();
@@ skipping 349 matching lines @@
    * Counter aggregation kind.
    * Possible string values are:
    * - "INVALID" : A INVALID.
    * - "SUM" : A SUM.
    * - "MAX" : A MAX.
    * - "MIN" : A MIN.
    * - "MEAN" : A MEAN.
    * - "OR" : A OR.
    * - "AND" : A AND.
    * - "SET" : A SET.
+   * - "DISTRIBUTION" : A DISTRIBUTION.
    */
   core.String kind;
   /** Name of the counter. */
   core.String name;
 
   NameAndKind();
 
   NameAndKind.fromJson(core.Map _json) {
     if (_json.containsKey("kind")) {
       kind = _json["kind"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (kind != null) {
       _json["kind"] = kind;
     }
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
 /**
- * Packages that need to be installed in order for a worker to run the steps of
- * the Dataflow job which will be assigned to its worker pool. This is the
- * mechanism by which the SDK causes code to be loaded onto the workers. For
- * example, the Dataflow Java SDK might use this to install jars containing the
- * user's code and all of the various dependencies (libraries, data files, etc)
- * required in order for that code to run.
+ * The packages that must be installed in order for a worker to run the steps of
+ * the Cloud Dataflow job that will be assigned to its worker pool. This is the
+ * mechanism by which the Cloud Dataflow SDK causes code to be loaded onto the
+ * workers. For example, the Cloud Dataflow Java SDK might use this to install
+ * jars containing the user's code and all of the various dependencies
+ * (libraries, data files, etc.) required in order for that code to run.
  */
 class Package {
   /**
    * The resource to read the package from. The supported resource type is:
    * Google Cloud Storage: storage.googleapis.com/{bucket}
    * bucket.storage.googleapis.com/
    */
   core.String location;
   /** The name of the package. */
   core.String name;
@@ skipping 543 matching lines @@
     if (isInfinite != null) {
       _json["isInfinite"] = isInfinite;
     }
     if (value != null) {
       _json["value"] = value;
     }
     return _json;
   }
 }
 
-/** Environment values to set at runtime. */
+/**
+ * Worker metrics exported from workers. This contains resource utilization
+ * metrics accumulated from a variety of sources. For more information, see
+ * go/df-resource-signals. Note that this proto closely follows the structure of
+ * its DFE siblings in its contents.
+ */
+class ResourceUtilizationReport {
+  /**
+   * Each Struct must parallel DFE worker metrics protos (eg., cpu_time metric
+   * will have nested values “timestamp_ms, total_ms, rate”).
+   *
+   * The values for Object must be JSON objects. It can consist of `num`,
+   * `String`, `bool` and `null` as well as `Map` and `List` values.
+   */
+  core.List<core.Map<core.String, core.Object>> metrics;
+
+  ResourceUtilizationReport();
+
+  ResourceUtilizationReport.fromJson(core.Map _json) {
+    if (_json.containsKey("metrics")) {
+      metrics = _json["metrics"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (metrics != null) {
+      _json["metrics"] = metrics;
+    }
+    return _json;
+  }
+}
+
+/** Service-side response to WorkerMessage reporting resource utilization. */
+class ResourceUtilizationReportResponse {
+
+  ResourceUtilizationReportResponse();
+
+  ResourceUtilizationReportResponse.fromJson(core.Map _json) {
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    return _json;
+  }
+}
+
+/** The environment values to set at runtime. */
 class RuntimeEnvironment {
-  /** The maximum number of workers to start for the job. */
+  /**
+   * Whether to bypass the safety checks for the job's temporary directory. Use
+   * with caution.
+   */
+  core.bool bypassTempDirValidation;
+  /**
+   * The maximum number of Google Compute Engine instances to be made available
+   * to your pipeline during execution, from 1 to 1000.
+   */
   core.int maxWorkers;
-  /** The service account to run the job as. */
+  /** The email address of the service account to run the job as. */
   core.String serviceAccountEmail;
-  /** The zone to start the workers in. */
+  /**
+   * The Cloud Storage path to use for temporary files. Must be a valid Cloud
+   * Storage URL, beginning with `gs://`.
+   */
+  core.String tempLocation;
+  /**
+   * The Compute Engine [availability
+   * zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones)
+   * for launching worker instances to run your pipeline.
+   */
   core.String zone;
 
   RuntimeEnvironment();
 
   RuntimeEnvironment.fromJson(core.Map _json) {
+    if (_json.containsKey("bypassTempDirValidation")) {
+      bypassTempDirValidation = _json["bypassTempDirValidation"];
+    }
     if (_json.containsKey("maxWorkers")) {
       maxWorkers = _json["maxWorkers"];
     }
     if (_json.containsKey("serviceAccountEmail")) {
       serviceAccountEmail = _json["serviceAccountEmail"];
     }
+    if (_json.containsKey("tempLocation")) {
+      tempLocation = _json["tempLocation"];
+    }
     if (_json.containsKey("zone")) {
       zone = _json["zone"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (bypassTempDirValidation != null) {
+      _json["bypassTempDirValidation"] = bypassTempDirValidation;
+    }
     if (maxWorkers != null) {
       _json["maxWorkers"] = maxWorkers;
     }
     if (serviceAccountEmail != null) {
       _json["serviceAccountEmail"] = serviceAccountEmail;
     }
+    if (tempLocation != null) {
+      _json["tempLocation"] = tempLocation;
+    }
     if (zone != null) {
       _json["zone"] = zone;
     }
     return _json;
   }
 }
 
 /** Request to send encoded debug information. */
 class SendDebugCaptureRequest {
   /** The internal component id for which debug information is sent. */
@@ skipping 920 matching lines @@
       _json["details"] = details;
     }
     if (message != null) {
       _json["message"] = message;
     }
     return _json;
   }
 }
 
 /**
- * Defines a particular step within a Dataflow job. A job consists of multiple
- * steps, each of which performs some specific operation as part of the overall
- * job. Data is typically passed from one step to another as part of the job.
- * Here's an example of a sequence of steps which together implement a
+ * Defines a particular step within a Cloud Dataflow job. A job consists of
+ * multiple steps, each of which performs some specific operation as part of the
+ * overall job. Data is typically passed from one step to another as part of the
+ * job. Here's an example of a sequence of steps which together implement a
  * Map-Reduce job: * Read a collection of data from some source, parsing the
  * collection's elements. * Validate the elements. * Apply a user-defined
  * function to map each element to some value and extract an element-specific
  * key value. * Group elements with the same key into a single element with that
  * key, transforming a multiply-keyed collection into a uniquely-keyed
- * collection. * Write the elements out to some data sink. (Note that the
+ * collection. * Write the elements out to some data sink. Note that the Cloud
  * Dataflow service may be used to run many different types of jobs, not just
- * Map-Reduce).
+ * Map-Reduce.
  */
 class Step {
-  /** The kind of step in the dataflow Job. */
+  /** The kind of step in the Cloud Dataflow job. */
   core.String kind;
   /**
-   * Name identifying the step. This must be unique for each step with respect
-   * to all other steps in the dataflow Job.
+   * The name that identifies the step. This must be unique for each step with
+   * respect to all other steps in the Cloud Dataflow job.
    */
   core.String name;
   /**
    * Named properties associated with the step. Each kind of predefined step has
    * its own required set of properties.
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> properties;
@@ skipping 364 matching lines @@
     var _json = new core.Map();
     if (elements != null) {
       _json["elements"] = elements;
     }
     return _json;
   }
 }
 
 /** Taskrunner configuration settings. */
 class TaskRunnerSettings {
-  /** Also send taskrunner log info to stderr? */
+  /** Whether to also send taskrunner log info to stderr. */
   core.bool alsologtostderr;
-  /** Location on the worker for task-specific subdirectories. */
+  /** The location on the worker for task-specific subdirectories. */
   core.String baseTaskDir;
   /**
    * The base URL for the taskrunner to use when accessing Google Cloud APIs.
    * When workers access Google Cloud APIs, they logically do so via relative
    * URLs. If this field is specified, it supplies the base URL to use for
    * resolving these relative URLs. The normative algorithm used is defined by
    * RFC 1808, "Relative Uniform Resource Locators". If not specified, the
    * default value is "http://www.googleapis.com/"
    */
   core.String baseUrl;
-  /** Store preprocessing commands in this file. */
+  /** The file to store preprocessing commands in. */
   core.String commandlinesFileName;
-  /** Do we continue taskrunner if an exception is hit? */
+  /** Whether to continue taskrunner if an exception is hit. */
   core.bool continueOnException;
-  /** API version of endpoint, e.g. "v1b3" */
+  /** The API version of endpoint, e.g. "v1b3" */
   core.String dataflowApiVersion;
-  /** Command to launch the worker harness. */
+  /** The command to launch the worker harness. */
   core.String harnessCommand;
-  /** Suggested backend language. */
+  /** The suggested backend language. */
   core.String languageHint;
-  /** Directory on the VM to store logs. */
+  /** The directory on the VM to store logs. */
   core.String logDir;
-  /** Send taskrunner log into to Google Compute Engine VM serial console? */
+  /**
+   * Whether to send taskrunner log info to Google Compute Engine VM serial
+   * console.
+   */
   core.bool logToSerialconsole;
   /**
    * Indicates where to put logs. If this is not specified, the logs will not be
    * uploaded. The supported resource type is: Google Cloud Storage:
    * storage.googleapis.com/{bucket}/{object}
    * bucket.storage.googleapis.com/{object}
    */
   core.String logUploadLocation;
   /**
-   * OAuth2 scopes to be requested by the taskrunner in order to access the
-   * dataflow API.
+   * The OAuth2 scopes to be requested by the taskrunner in order to access the
+   * Cloud Dataflow API.
    */
   core.List<core.String> oauthScopes;
-  /** Settings to pass to the parallel worker harness. */
+  /** The settings to pass to the parallel worker harness. */
   WorkerSettings parallelWorkerSettings;
-  /** Streaming worker main class name. */
+  /** The streaming worker main class name. */
   core.String streamingWorkerMainClass;
   /**
    * The UNIX group ID on the worker VM to use for tasks launched by taskrunner;
    * e.g. "wheel".
    */
   core.String taskGroup;
   /**
    * The UNIX user ID on the worker VM to use for tasks launched by taskrunner;
    * e.g. "root".
    */
   core.String taskUser;
   /**
    * The prefix of the resources the taskrunner should use for temporary
    * storage. The supported resource type is: Google Cloud Storage:
    * storage.googleapis.com/{bucket}/{object}
    * bucket.storage.googleapis.com/{object}
    */
   core.String tempStoragePrefix;
-  /** ID string of VM. */
+  /** The ID string of the VM. */
   core.String vmId;
-  /** Store the workflow in this file. */
+  /** The file to store the workflow in. */
   core.String workflowFileName;
 
   TaskRunnerSettings();
 
   TaskRunnerSettings.fromJson(core.Map _json) {
     if (_json.containsKey("alsologtostderr")) {
       alsologtostderr = _json["alsologtostderr"];
     }
     if (_json.containsKey("baseTaskDir")) {
       baseTaskDir = _json["baseTaskDir"];
@@ skipping 671 matching lines @@
    * values. However, for ease of development other strings can be used as tags.
    * LABEL_UNSPECIFIED should not be used here.
    */
   core.Map<core.String, core.String> labels;
   /** The timestamp of the worker_message. */
   core.String time;
   /** The health of a worker. */
   WorkerHealthReport workerHealthReport;
   /** A worker message code. */
   WorkerMessageCode workerMessageCode;
+  /** Resource metrics reported by workers. */
+  ResourceUtilizationReport workerMetrics;
 
   WorkerMessage();
 
   WorkerMessage.fromJson(core.Map _json) {
     if (_json.containsKey("labels")) {
       labels = _json["labels"];
     }
     if (_json.containsKey("time")) {
       time = _json["time"];
     }
     if (_json.containsKey("workerHealthReport")) {
       workerHealthReport = new WorkerHealthReport.fromJson(_json["workerHealthReport"]);
     }
     if (_json.containsKey("workerMessageCode")) {
       workerMessageCode = new WorkerMessageCode.fromJson(_json["workerMessageCode"]);
     }
+    if (_json.containsKey("workerMetrics")) {
+      workerMetrics = new ResourceUtilizationReport.fromJson(_json["workerMetrics"]);
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (labels != null) {
       _json["labels"] = labels;
     }
     if (time != null) {
       _json["time"] = time;
     }
     if (workerHealthReport != null) {
       _json["workerHealthReport"] = (workerHealthReport).toJson();
     }
     if (workerMessageCode != null) {
       _json["workerMessageCode"] = (workerMessageCode).toJson();
     }
+    if (workerMetrics != null) {
+      _json["workerMetrics"] = (workerMetrics).toJson();
+    }
     return _json;
   }
 }
 
 /**
  * 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).
@@ skipping 50 matching lines @@
   }
 }
 
 /**
  * A worker_message response allows the server to pass information to the
  * sender.
  */
 class WorkerMessageResponse {
   /** The service's response to a worker's health report. */
   WorkerHealthReportResponse workerHealthReportResponse;
+  /** Service's response to reporting worker metrics (currently empty). */
+  ResourceUtilizationReportResponse workerMetricsResponse;
 
   WorkerMessageResponse();
 
   WorkerMessageResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workerHealthReportResponse")) {
       workerHealthReportResponse = new WorkerHealthReportResponse.fromJson(_json["workerHealthReportResponse"]);
     }
+    if (_json.containsKey("workerMetricsResponse")) {
+      workerMetricsResponse = new ResourceUtilizationReportResponse.fromJson(_json["workerMetricsResponse"]);
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (workerHealthReportResponse != null) {
       _json["workerHealthReportResponse"] = (workerHealthReportResponse).toJson();
     }
+    if (workerMetricsResponse != null) {
+      _json["workerMetricsResponse"] = (workerMetricsResponse).toJson();
+    }
     return _json;
   }
 }
 
 /**
- * Describes one particular pool of Dataflow workers to be instantiated by the
- * Dataflow service in order to perform the computations required by a job. Note
- * that a workflow job may use multiple pools, in order to match the various
- * computational requirements of the various stages of the job.
+ * Describes one particular pool of Cloud Dataflow workers to be instantiated by
+ * the Cloud Dataflow service in order to perform the computations required by a
+ * job. Note that a workflow job may use multiple pools, in order to match the
+ * various computational requirements of the various stages of the job.
  */
 class WorkerPool {
   /** Settings for autoscaling of this WorkerPool. */
   AutoscalingSettings autoscalingSettings;
   /** Data disks that are used by a VM in this workflow. */
   core.List<Disk> dataDisks;
   /**
    * The default package set to install. This allows the service to select a
    * default set of packages which are useful to worker harnesses written in a
    * particular language.
@@ skipping 18 matching lines @@
   core.String diskType;
   /**
    * Configuration for VM IPs.
    * Possible string values are:
    * - "WORKER_IP_UNSPECIFIED" : A WORKER_IP_UNSPECIFIED.
    * - "WORKER_IP_PUBLIC" : A WORKER_IP_PUBLIC.
    * - "WORKER_IP_PRIVATE" : A WORKER_IP_PRIVATE.
    */
   core.String ipConfiguration;
   /**
-   * The kind of the worker pool; currently only 'harness' and 'shuffle' are
+   * The kind of the worker pool; currently only `harness` and `shuffle` are
    * supported.
    */
   core.String kind;
   /**
    * Machine type (e.g. "n1-standard-1"). If empty or unspecified, the service
    * will attempt to choose a reasonable default.
    */
   core.String machineType;
   /** Metadata to set on the Google Compute Engine VMs. */
   core.Map<core.String, core.String> metadata;
@@ skipping 33 matching lines @@
    * form "regions/REGION/subnetworks/SUBNETWORK".
    */
   core.String subnetwork;
   /**
    * Settings passed through to Google Compute Engine workers when using the
    * standard Dataflow task runner. Users should ignore this field.
    */
   TaskRunnerSettings taskrunnerSettings;
   /**
    * Sets the policy for determining when to turndown worker pool. Allowed
-   * values are: TEARDOWN_ALWAYS, TEARDOWN_ON_SUCCESS, and TEARDOWN_NEVER.
-   * TEARDOWN_ALWAYS means workers are always torn down regardless of whether
-   * the job succeeds. TEARDOWN_ON_SUCCESS means workers are torn down if the
-   * job succeeds. TEARDOWN_NEVER means the workers are never torn down. If the
-   * workers are not torn down by the service, they will continue to run and use
-   * Google Compute Engine VM resources in the user's project until they are
+   * values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and `TEARDOWN_NEVER`.
+   * `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
+   * the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down if the
+   * job succeeds. `TEARDOWN_NEVER` means the workers are never torn down. If
+   * the workers are not torn down by the service, they will continue to run and
+   * use Google Compute Engine VM resources in the user's project until they are
    * explicitly terminated by the user. Because of this, Google recommends using
-   * the TEARDOWN_ALWAYS policy except for small, manually supervised test jobs.
-   * If unknown or unspecified, the service will attempt to choose a reasonable
-   * default.
+   * the `TEARDOWN_ALWAYS` policy except for small, manually supervised test
+   * jobs. If unknown or unspecified, the service will attempt to choose a
+   * reasonable default.
    * Possible string values are:
    * - "TEARDOWN_POLICY_UNKNOWN" : A TEARDOWN_POLICY_UNKNOWN.
    * - "TEARDOWN_ALWAYS" : A TEARDOWN_ALWAYS.
    * - "TEARDOWN_ON_SUCCESS" : A TEARDOWN_ON_SUCCESS.
    * - "TEARDOWN_NEVER" : A TEARDOWN_NEVER.
    */
   core.String teardownPolicy;
   /**
-   * Docker container image that executes Dataflow worker harness, residing in
-   * Google Container Registry. Required.
+   * Required. Docker container image that executes the Cloud Dataflow worker
+   * harness, residing in Google Container Registry.
    */
   core.String workerHarnessContainerImage;
   /**
    * Zone to run the worker pools in. If empty or unspecified, the service will
    * attempt to choose a reasonable default.
    */
   core.String zone;
 
   WorkerPool();
 
@@ skipping 136 matching lines @@
 class WorkerSettings {
   /**
    * The base URL for accessing Google Cloud APIs. When workers access Google
    * Cloud APIs, they logically do so via relative URLs. If this field is
    * specified, it supplies the base URL to use for resolving these relative
    * URLs. The normative algorithm used is defined by RFC 1808, "Relative
    * Uniform Resource Locators". If not specified, the default value is
    * "http://www.googleapis.com/"
    */
   core.String baseUrl;
-  /** Send work progress updates to service. */
+  /** Whether to send work progress updates to the service. */
   core.bool reportingEnabled;
   /**
-   * The Dataflow service path relative to the root URL, for example,
+   * The Cloud Dataflow service path relative to the root URL, for example,
    * "dataflow/v1b3/projects".
    */
   core.String servicePath;
   /**
    * The Shuffle service path relative to the root URL, for example,
    * "shuffle/v1beta1".
    */
   core.String shuffleServicePath;
   /**
    * The prefix of the resources the system should use for temporary storage.
    * The supported resource type is: Google Cloud Storage:
    * storage.googleapis.com/{bucket}/{object}
    * bucket.storage.googleapis.com/{object}
    */
   core.String tempStoragePrefix;
-  /** ID of the worker running this pipeline. */
+  /** The ID of the worker running this pipeline. */
   core.String workerId;
 
   WorkerSettings();
 
   WorkerSettings.fromJson(core.Map _json) {
     if (_json.containsKey("baseUrl")) {
       baseUrl = _json["baseUrl"];
     }
     if (_json.containsKey("reportingEnabled")) {
       reportingEnabled = _json["reportingEnabled"];
@@ skipping 60 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }