Api-roll 33: 2016-03-14

generated/googleapis_beta/lib/dataproc/v1beta1.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataproc.v1beta1;
 
 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:crypto/crypto.dart' as crypto;
 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 dataproc/v1beta1';
 
 /**
  * An API for managing Hadoop-based clusters and jobs on Google Cloud Platform.
  */
@@ skipping 412 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Cluster.fromJson(data));
   }
 
   /**
+   * Gets the access control policy for a `resource`. Returns an empty policy if
+   * the resource exists and does not have a policy set.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy is being
+   * requested. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `getIamPolicy` documentation.
+   * Value must have pattern "^projects/[^/] * / clusters/[^/]*$".
+   *
+   * Completes with a [Policy].
+   *
+   * 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<Policy> getIamPolicy(core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':getIamPolicy';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Policy.fromJson(data));
+  }
+
+  /**
    * Lists all clusters in a project.
    *
    * Request parameters:
    *
    * [projectId] - [Required] The ID of the Google Cloud Platform project that
    * the cluster belongs to.
    *
    * [pageSize] - The standard List page size.
    *
    * [pageToken] - The standard List page token.
@@ skipping 91 matching lines @@
     var _response = _requester.request(_url,
                                        "PATCH",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Operation.fromJson(data));
   }
 
+  /**
+   * Sets the access control policy on the specified resource. Replaces any
+   * existing policy.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy is being
+   * specified. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `setIamPolicy` documentation.
+   * Value must have pattern "^projects/[^/] * / clusters/[^/]*$".
+   *
+   * Completes with a [Policy].
+   *
+   * 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<Policy> setIamPolicy(SetIamPolicyRequest request, core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':setIamPolicy';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Policy.fromJson(data));
+  }
+
+  /**
+   * Returns permissions that a caller has on the specified resource.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy detail is being
+   * requested. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `testIamPermissions` documentation.
+   * Value must have pattern "^projects/[^/] * / clusters/[^/]*$".
+   *
+   * Completes with a [TestIamPermissionsResponse].
+   *
+   * 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<TestIamPermissionsResponse> testIamPermissions(TestIamPermissionsRequest request, core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':testIamPermissions';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new TestIamPermissionsResponse.fromJson(data));
+  }
+
 }
 
 
 class ProjectsJobsResourceApi {
   final commons.ApiRequester _requester;
 
   ProjectsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
@@ skipping 134 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
+   * Gets the access control policy for a `resource`. Returns an empty policy if
+   * the resource exists and does not have a policy set.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy is being
+   * requested. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `getIamPolicy` documentation.
+   * Value must have pattern "^projects/[^/] * / jobs/[^/]*$".
+   *
+   * Completes with a [Policy].
+   *
+   * 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<Policy> getIamPolicy(core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':getIamPolicy';
+
+    var _response = _requester.request(_url,
+                                       "GET",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Policy.fromJson(data));
+  }
+
+  /**
    * Lists jobs in a project.
    *
    * Request parameters:
    *
    * [projectId] - [Required] The ID of the Google Cloud Platform project that
    * the job belongs to.
    *
    * [pageSize] - [Optional] The number of results to return in each response.
    *
    * [pageToken] - [Optional] The page token, returned by a previous call, to
@@ skipping 47 matching lines @@
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobsResponse.fromJson(data));
   }
 
   /**
+   * Sets the access control policy on the specified resource. Replaces any
+   * existing policy.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy is being
+   * specified. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `setIamPolicy` documentation.
+   * Value must have pattern "^projects/[^/] * / jobs/[^/]*$".
+   *
+   * Completes with a [Policy].
+   *
+   * 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<Policy> setIamPolicy(SetIamPolicyRequest request, core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':setIamPolicy';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new Policy.fromJson(data));
+  }
+
+  /**
    * Submits a job to a cluster.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - [Required] The ID of the Google Cloud Platform project that
    * the job belongs to.
    *
    * Completes with a [Job].
@@ skipping 24 matching lines @@
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
+  /**
+   * Returns permissions that a caller has on the specified resource.
+   *
+   * [request] - The metadata request object.
+   *
+   * Request parameters:
+   *
+   * [resource] - REQUIRED: The resource for which the policy detail is being
+   * requested. `resource` is usually specified as a path, such as `projects / *
+   * project * / zones / * zone * / disks / * disk*`. The format for the path
+   * specified in this value is resource specific and is specified in the
+   * `testIamPermissions` documentation.
+   * Value must have pattern "^projects/[^/] * / jobs/[^/]*$".
+   *
+   * Completes with a [TestIamPermissionsResponse].
+   *
+   * 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<TestIamPermissionsResponse> testIamPermissions(TestIamPermissionsRequest request, core.String resource) {
+    var _url = null;
+    var _queryParams = new core.Map();
+    var _uploadMedia = null;
+    var _uploadOptions = null;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
+    var _body = null;
+
+    if (request != null) {
+      _body = convert.JSON.encode((request).toJson());
+    }
+    if (resource == null) {
+      throw new core.ArgumentError("Parameter resource is required.");
+    }
+
+    _url = 'v1beta1/' + commons.Escaper.ecapeVariableReserved('$resource') + ':testIamPermissions';
+
+    var _response = _requester.request(_url,
+                                       "POST",
+                                       body: _body,
+                                       queryParams: _queryParams,
+                                       uploadOptions: _uploadOptions,
+                                       uploadMedia: _uploadMedia,
+                                       downloadOptions: _downloadOptions);
+    return _response.then((data) => new TestIamPermissionsResponse.fromJson(data));
+  }
+
 }
 
 
 
+/** Associates `members` with a `role`. */
+class Binding {
+  /**
+   * Specifies the identities requesting access for a Cloud Platform resource.
+   * `members` can have the following values: * `allUsers`: A special identifier
+   * that represents anyone who is on the internet; with or without a Google
+   * account. * `allAuthenticatedUsers`: A special identifier that represents
+   * anyone who is authenticated with a Google account or a service account. *
+   * `user:{emailid}`: An email address that represents a specific Google
+   * account. For example, `alice@gmail.com` or `joe@example.com`. *
+   * `serviceAccount:{emailid}`: An email address that represents a service
+   * account. For example, `my-other-app@appspot.gserviceaccount.com`. *
+   * `group:{emailid}`: An email address that represents a Google group. For
+   * example, `admins@example.com`. * `domain:{domain}`: A Google Apps domain
+   * name that represents all the users of that domain. For example,
+   * `google.com` or `example.com`.
+   */
+  core.List<core.String> members;
+  /**
+   * Role that is assigned to `members`. For example, `roles/viewer`,
+   * `roles/editor`, or `roles/owner`. Required
+   */
+  core.String role;
+
+  Binding();
+
+  Binding.fromJson(core.Map _json) {
+    if (_json.containsKey("members")) {
+      members = _json["members"];
+    }
+    if (_json.containsKey("role")) {
+      role = _json["role"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (members != null) {
+      _json["members"] = members;
+    }
+    if (role != null) {
+      _json["role"] = role;
+    }
+    return _json;
+  }
+}
+
 /** A request to cancel a job. */
 class CancelJobRequest {
 
   CancelJobRequest();
 
   CancelJobRequest.fromJson(core.Map _json) {
   }
 
   core.Map toJson() {
     var _json = new core.Map();
@@ skipping 181 matching lines @@
     if (softwareConfiguration != null) {
       _json["softwareConfiguration"] = (softwareConfiguration).toJson();
     }
     if (workerConfiguration != null) {
       _json["workerConfiguration"] = (workerConfiguration).toJson();
     }
     return _json;
   }
 }
 
+/** Metadata describing the operation. */
+class ClusterOperationMetadata {
+  /** Name of the cluster for the operation. */
+  core.String clusterName;
+  /** Cluster UUId for the operation. */
+  core.String clusterUuid;
+  /** [Output-only] Short description of operation. */
+  core.String description;
+  /** [Output-only] The operation type. */
+  core.String operationType;
+  /** [Output-only] Current operation status. */
+  ClusterOperationStatus status;
+  /** [Output-only] The previous operation status. */
+  core.List<ClusterOperationStatus> statusHistory;
+
+  ClusterOperationMetadata();
+
+  ClusterOperationMetadata.fromJson(core.Map _json) {
+    if (_json.containsKey("clusterName")) {
+      clusterName = _json["clusterName"];
+    }
+    if (_json.containsKey("clusterUuid")) {
+      clusterUuid = _json["clusterUuid"];
+    }
+    if (_json.containsKey("description")) {
+      description = _json["description"];
+    }
+    if (_json.containsKey("operationType")) {
+      operationType = _json["operationType"];
+    }
+    if (_json.containsKey("status")) {
+      status = new ClusterOperationStatus.fromJson(_json["status"]);
+    }
+    if (_json.containsKey("statusHistory")) {
+      statusHistory = _json["statusHistory"].map((value) => new ClusterOperationStatus.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (clusterName != null) {
+      _json["clusterName"] = clusterName;
+    }
+    if (clusterUuid != null) {
+      _json["clusterUuid"] = clusterUuid;
+    }
+    if (description != null) {
+      _json["description"] = description;
+    }
+    if (operationType != null) {
+      _json["operationType"] = operationType;
+    }
+    if (status != null) {
+      _json["status"] = (status).toJson();
+    }
+    if (statusHistory != null) {
+      _json["statusHistory"] = statusHistory.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
+}
+
+/** The status of the operation. */
+class ClusterOperationStatus {
+  /** A message containing any operation metadata details. */
+  core.String details;
+  /** A message containing the detailed operation state. */
+  core.String innerState;
+  /**
+   * A message containing the operation state.
+   * Possible string values are:
+   * - "UNKNOWN" : A UNKNOWN.
+   * - "PENDING" : A PENDING.
+   * - "RUNNING" : A RUNNING.
+   * - "DONE" : A DONE.
+   */
+  core.String state;
+  /** The time this state was entered. */
+  core.String stateStartTime;
+
+  ClusterOperationStatus();
+
+  ClusterOperationStatus.fromJson(core.Map _json) {
+    if (_json.containsKey("details")) {
+      details = _json["details"];
+    }
+    if (_json.containsKey("innerState")) {
+      innerState = _json["innerState"];
+    }
+    if (_json.containsKey("state")) {
+      state = _json["state"];
+    }
+    if (_json.containsKey("stateStartTime")) {
+      stateStartTime = _json["stateStartTime"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (details != null) {
+      _json["details"] = details;
+    }
+    if (innerState != null) {
+      _json["innerState"] = innerState;
+    }
+    if (state != null) {
+      _json["state"] = state;
+    }
+    if (stateStartTime != null) {
+      _json["stateStartTime"] = stateStartTime;
+    }
+    return _json;
+  }
+}
+
 /** The status of a cluster and its instances. */
 class ClusterStatus {
   /** Optional details of cluster's state. */
   core.String detail;
   /**
    * The cluster's state.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "CREATING" : A CREATING.
    * - "RUNNING" : A RUNNING.
@@ skipping 66 matching lines @@
 
   DiagnoseClusterRequest.fromJson(core.Map _json) {
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     return _json;
   }
 }
 
+/** The location of diagnostic output. */
+class DiagnoseClusterResults {
+  /**
+   * [Output-only] The Google Cloud Storage URI of the diagnostic output. This
+   * is a plain text file with a summary of collected diagnostics.
+   */
+  core.String outputUri;
+
+  DiagnoseClusterResults();
+
+  DiagnoseClusterResults.fromJson(core.Map _json) {
+    if (_json.containsKey("outputUri")) {
+      outputUri = _json["outputUri"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (outputUri != null) {
+      _json["outputUri"] = outputUri;
+    }
+    return _json;
+  }
+}
+
 /** Specifies the configuration of disk options for a group of VM instances. */
 class DiskConfiguration {
   /** [Optional] Size in GB of the boot disk (default is 500GB). */
   core.int bootDiskSizeGb;
   /**
    * [Optional] Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are
    * not attached, the boot disk is used to store runtime logs and HDFS data. If
    * one or more SSDs are attached, this runtime bulk data is spread across
    * them, and the boot disk contains only basic configuration and installed
    * binaries.
@@ skipping 41 matching lines @@
     var _json = new core.Map();
     return _json;
   }
 }
 
 /**
  * Common configuration settings for resources of Google Compute Engine cluster
  * instances, applicable to all instances in the cluster.
  */
 class GceClusterConfiguration {
+  /** The Google Compute Engine metadata entries to add to all instances. */
+  core.Map<core.String, core.String> metadata;
   /**
    * The Google Compute Engine network to be used for machine communications.
-   * Inbound SSH connections are necessary to complete cluster configuration.
+   * Cannot be specified with subnetwork_uri. If neither network_uri nor
+   * subnetwork_uri is specified, the "default" network of the project is used,
+   * if it exists. Cannot be a "Custom Subnet Network" (see
+   * https://cloud.google.com/compute/docs/subnetworks for more information).
    * Example:
-   * `compute.googleapis.com/projects/[project_id]/zones/us-east1-a/default`.
+   * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default`.
    */
   core.String networkUri;
   /**
    * The URIs of service account scopes to be included in Google Compute Engine
    * instances. The following base set of scopes is always included: -
    * https://www.googleapis.com/auth/cloud.useraccounts.readonly -
    * https://www.googleapis.com/auth/devstorage.read_write -
    * https://www.googleapis.com/auth/logging.write If no scopes are specfied,
    * the following defaults are also provided: -
    * https://www.googleapis.com/auth/bigquery -
    * https://www.googleapis.com/auth/bigtable.admin.table -
    * https://www.googleapis.com/auth/bigtable.data -
    * https://www.googleapis.com/auth/devstorage.full_control
    */
   core.List<core.String> serviceAccountScopes;
   /**
+   * The Google Compute Engine subnetwork to be used for machine communications.
+   * Cannot be specified with network_uri. Example:
+   * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/sub0`.
+   */
+  core.String subnetworkUri;
+  /** The Google Compute Engine tags to add to all instances. */
+  core.List<core.String> tags;
+  /**
    * [Required] The zone where the Google Compute Engine cluster will be
    * located. Example:
-   * `compute.googleapis.com/projects/[project_id]/zones/us-east1-a`.
+   * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]`.
    */
   core.String zoneUri;
 
   GceClusterConfiguration();
 
   GceClusterConfiguration.fromJson(core.Map _json) {
+    if (_json.containsKey("metadata")) {
+      metadata = _json["metadata"];
+    }
     if (_json.containsKey("networkUri")) {
       networkUri = _json["networkUri"];
     }
     if (_json.containsKey("serviceAccountScopes")) {
       serviceAccountScopes = _json["serviceAccountScopes"];
     }
+    if (_json.containsKey("subnetworkUri")) {
+      subnetworkUri = _json["subnetworkUri"];
+    }
+    if (_json.containsKey("tags")) {
+      tags = _json["tags"];
+    }
     if (_json.containsKey("zoneUri")) {
       zoneUri = _json["zoneUri"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (metadata != null) {
+      _json["metadata"] = metadata;
+    }
     if (networkUri != null) {
       _json["networkUri"] = networkUri;
     }
     if (serviceAccountScopes != null) {
       _json["serviceAccountScopes"] = serviceAccountScopes;
     }
+    if (subnetworkUri != null) {
+      _json["subnetworkUri"] = subnetworkUri;
+    }
+    if (tags != null) {
+      _json["tags"] = tags;
+    }
     if (zoneUri != null) {
       _json["zoneUri"] = zoneUri;
     }
     return _json;
   }
 }
 
 /** A Cloud Dataproc job for running Hadoop MapReduce jobs on YARN. */
 class HadoopJob {
   /**
@@ skipping 179 matching lines @@
 
 /**
  * The configuration settings for Google Compute Engine resources in an instance
  * group, such as a master or worker group.
  */
 class InstanceGroupConfiguration {
   /** Disk option configuration settings. */
   DiskConfiguration diskConfiguration;
   /**
    * [Output-only] The Google Compute Engine image resource used for cluster
-   * instances. Inferred from `SoftwareConfiguration.image_version`. Example:
-   * `compute.googleapis.com/projects/debian-cloud/global/images/backports-debian-7-wheezy-v20140904`.
+   * instances. Inferred from `SoftwareConfiguration.image_version`.
    */
   core.String imageUri;
   /**
    * The list of instance names. Dataproc derives the names from `cluster_name`,
    * `num_instances`, and the instance group if not set by user (recommended
    * practice is to let Dataproc derive the name).
    */
   core.List<core.String> instanceNames;
   /** Specifies that this instance group contains Preemptible Instances. */
   core.bool isPreemptible;
   /**
    * The Google Compute Engine machine type used for cluster instances. Example:
-   * `compute.googleapis.com/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2`.
+   * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2`.
    */
   core.String machineTypeUri;
   /**
    * [Output-only] The configuration for Google Compute Engine Instance Group
    * Manager that manages this group. This is only used for preemptible instance
    * groups.
    */
   ManagedGroupConfiguration managedGroupConfiguration;
   /**
    * The number of VM instances in the instance group. For master instance
@@ skipping 556 matching lines @@
    * contains progress information and common metadata such as create time. Some
    * services might not provide such metadata. Any method that returns a
    * long-running operation should document the metadata type, if any.
    *
    * 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> metadata;
   /**
    * The server-assigned name, which is only unique within the same service that
-   * originally returns it. If you use the default HTTP mapping above, the
-   * `name` should have the format of `operations/some/unique/name`.
+   * originally returns it. If you use the default HTTP mapping, the `name`
+   * should have the format of `operations/some/unique/name`.
    */
   core.String name;
   /**
    * The normal response of the operation in case of success. If the original
    * method returns no data on success, such as `Delete`, the response is
    * `google.protobuf.Empty`. If the original method is standard
    * `Get`/`Create`/`Update`, the response should be the resource. For other
    * methods, the response should have the type `XxxResponse`, where `Xxx` is
    * the original method name. For example, if the original method name is
    * `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
@@ skipping 43 matching lines @@
     return _json;
   }
 }
 
 /** Metadata describing the operation. */
 class OperationMetadata {
   /** Name of the cluster for the operation. */
   core.String clusterName;
   /** Cluster UUId for the operation. */
   core.String clusterUuid;
+  /** [Output-only] Short description of operation. */
+  core.String description;
   /** A message containing any operation metadata details. */
   core.String details;
   /** The time that the operation completed. */
   core.String endTime;
   /** A message containing the detailed operation state. */
   core.String innerState;
   /** The time that the operation was requested. */
   core.String insertTime;
+  /** [Output-only] The operation type. */
+  core.String operationType;
   /** The time that the operation was started by the server. */
   core.String startTime;
   /**
    * A message containing the operation state.
    * Possible string values are:
    * - "UNKNOWN" : A UNKNOWN.
    * - "PENDING" : A PENDING.
    * - "RUNNING" : A RUNNING.
    * - "DONE" : A DONE.
    */
   core.String state;
   /** [Output-only] Current operation status. */
   OperationStatus status;
   /** [Output-only] Previous operation status. */
   core.List<OperationStatus> statusHistory;
 
   OperationMetadata();
 
   OperationMetadata.fromJson(core.Map _json) {
     if (_json.containsKey("clusterName")) {
       clusterName = _json["clusterName"];
     }
     if (_json.containsKey("clusterUuid")) {
       clusterUuid = _json["clusterUuid"];
     }
+    if (_json.containsKey("description")) {
+      description = _json["description"];
+    }
     if (_json.containsKey("details")) {
       details = _json["details"];
     }
     if (_json.containsKey("endTime")) {
       endTime = _json["endTime"];
     }
     if (_json.containsKey("innerState")) {
       innerState = _json["innerState"];
     }
     if (_json.containsKey("insertTime")) {
       insertTime = _json["insertTime"];
     }
+    if (_json.containsKey("operationType")) {
+      operationType = _json["operationType"];
+    }
     if (_json.containsKey("startTime")) {
       startTime = _json["startTime"];
     }
     if (_json.containsKey("state")) {
       state = _json["state"];
     }
     if (_json.containsKey("status")) {
       status = new OperationStatus.fromJson(_json["status"]);
     }
     if (_json.containsKey("statusHistory")) {
       statusHistory = _json["statusHistory"].map((value) => new OperationStatus.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (clusterName != null) {
       _json["clusterName"] = clusterName;
     }
     if (clusterUuid != null) {
       _json["clusterUuid"] = clusterUuid;
     }
+    if (description != null) {
+      _json["description"] = description;
+    }
     if (details != null) {
       _json["details"] = details;
     }
     if (endTime != null) {
       _json["endTime"] = endTime;
     }
     if (innerState != null) {
       _json["innerState"] = innerState;
     }
     if (insertTime != null) {
       _json["insertTime"] = insertTime;
     }
+    if (operationType != null) {
+      _json["operationType"] = operationType;
+    }
     if (startTime != null) {
       _json["startTime"] = startTime;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (status != null) {
       _json["status"] = (status).toJson();
     }
     if (statusHistory != null) {
@@ skipping 134 matching lines @@
     if (queryList != null) {
       _json["queryList"] = (queryList).toJson();
     }
     if (scriptVariables != null) {
       _json["scriptVariables"] = scriptVariables;
     }
     return _json;
   }
 }
 
+/**
+ * Defines an Identity and Access Management (IAM) policy. It is used to specify
+ * access control policies for Cloud Platform resources. A `Policy` consists of
+ * a list of `bindings`. A `Binding` binds a list of `members` to a `role`,
+ * where the members can be user accounts, Google groups, Google domains, and
+ * service accounts. A `role` is a named list of permissions defined by IAM.
+ * **Example** { "bindings": [ { "role": "roles/owner", "members": [
+ * "user:mike@example.com", "group:admins@example.com", "domain:google.com",
+ * "serviceAccount:my-other-app@appspot.gserviceaccount.com", ] }, { "role":
+ * "roles/viewer", "members": ["user:sean@example.com"] } ] } For a description
+ * of IAM and its features, see the [IAM developer's
+ * guide](https://cloud.google.com/iam).
+ */
+class Policy {
+  /**
+   * Associates a list of `members` to a `role`. Multiple `bindings` must not be
+   * specified for the same `role`. `bindings` with no members will result in an
+   * error.
+   */
+  core.List<Binding> bindings;
+  /**
+   * `etag` is used for optimistic concurrency control as a way to help prevent
+   * simultaneous updates of a policy from overwriting each other. It is
+   * strongly suggested that systems make use of the `etag` in the
+   * read-modify-write cycle to perform policy updates in order to avoid race
+   * conditions: An `etag` is returned in the response to `getIamPolicy`, and
+   * systems are expected to put that etag in the request to `setIamPolicy` to
+   * ensure that their change will be applied to the same version of the policy.
+   * If no `etag` is provided in the call to `setIamPolicy`, then the existing
+   * policy is overwritten blindly.
+   */
+  core.String etag;
+  core.List<core.int> get etagAsBytes {
+    return crypto.CryptoUtils.base64StringToBytes(etag);
+  }
+
+  void set etagAsBytes(core.List<core.int> _bytes) {
+    etag = crypto.CryptoUtils.bytesToBase64(_bytes, urlSafe: true);
+  }
+  /** Version of the `Policy`. The default version is 0. */
+  core.int version;
+
+  Policy();
+
+  Policy.fromJson(core.Map _json) {
+    if (_json.containsKey("bindings")) {
+      bindings = _json["bindings"].map((value) => new Binding.fromJson(value)).toList();
+    }
+    if (_json.containsKey("etag")) {
+      etag = _json["etag"];
+    }
+    if (_json.containsKey("version")) {
+      version = _json["version"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (bindings != null) {
+      _json["bindings"] = bindings.map((value) => (value).toJson()).toList();
+    }
+    if (etag != null) {
+      _json["etag"] = etag;
+    }
+    if (version != null) {
+      _json["version"] = version;
+    }
+    return _json;
+  }
+}
+
 /** A Cloud Dataproc job for running PySpark applications on YARN. */
 class PySparkJob {
   /**
    * [Optional] HCFS URIs of archives to be extracted in the working directory
    * of .jar, .tar, .tar.gz, .tgz, and .zip.
    */
   core.List<core.String> archiveUris;
   /**
    * [Optional] The arguments to pass to the driver. Do not include arguments,
    * such as `--conf`, that can be set as job properties, since a collision may
@@ skipping 110 matching lines @@
 
   core.Map toJson() {
     var _json = new core.Map();
     if (queries != null) {
       _json["queries"] = queries;
     }
     return _json;
   }
 }
 
+/** Request message for `SetIamPolicy` method. */
+class SetIamPolicyRequest {
+  /**
+   * REQUIRED: The complete policy to be applied to the `resource`. The size of
+   * the policy is limited to a few 10s of KB. An empty policy is a valid policy
+   * but certain Cloud Platform services (such as Projects) might reject them.
+   */
+  Policy policy;
+
+  SetIamPolicyRequest();
+
+  SetIamPolicyRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("policy")) {
+      policy = new Policy.fromJson(_json["policy"]);
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (policy != null) {
+      _json["policy"] = (policy).toJson();
+    }
+    return _json;
+  }
+}
+
 /**
  * Specifies the selection and configuration of software inside the cluster.
  */
 class SoftwareConfiguration {
   /**
    * [Optional] The version of software inside the cluster. It must match the
    * regular expression `[0-9]+\.[0-9]+`. If unspecified, it defaults to the
    * latest version (see [Cloud Dataproc Versioning](/dataproc/versioning)).
    */
   core.String imageVersion;
+  /**
+   * [Optional] The properties to set on daemon configuration files. Property
+   * keys are specified in "prefix:property" format, such as
+   * "core:fs.defaultFS". The following are supported prefixes and their
+   * mappings: core - core-site.xml hdfs - hdfs-site.xml mapred -
+   * mapred-site.xml yarn - yarn-site.xml hive - hive-site.xml pig -
+   * pig.properties spark - spark-defaults.conf
+   */
+  core.Map<core.String, core.String> properties;
 
   SoftwareConfiguration();
 
   SoftwareConfiguration.fromJson(core.Map _json) {
     if (_json.containsKey("imageVersion")) {
       imageVersion = _json["imageVersion"];
     }
+    if (_json.containsKey("properties")) {
+      properties = _json["properties"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (imageVersion != null) {
       _json["imageVersion"] = imageVersion;
     }
+    if (properties != null) {
+      _json["properties"] = properties;
+    }
     return _json;
   }
 }
 
 /** A Cloud Dataproc job for running Spark applications on YARN. */
 class SparkJob {
   /**
    * [Optional] HCFS URIs of archives to be extracted in the working directory
    * of Spark drivers and tasks. Supported file types: .jar, .tar, .tar.gz,
    * .tgz, and .zip.
@@ skipping 260 matching lines @@
 
   core.Map toJson() {
     var _json = new core.Map();
     if (job != null) {
       _json["job"] = (job).toJson();
     }
     return _json;
   }
 }
 
+/** Request message for `TestIamPermissions` method. */
+class TestIamPermissionsRequest {
+  /**
+   * The set of permissions to check for the `resource`. Permissions with
+   * wildcards (such as '*' or 'storage.*') are not allowed. For more
+   * information see IAM Overview.
+   */
+  core.List<core.String> permissions;
+
+  TestIamPermissionsRequest();
+
+  TestIamPermissionsRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("permissions")) {
+      permissions = _json["permissions"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (permissions != null) {
+      _json["permissions"] = permissions;
+    }
+    return _json;
+  }
+}
+
+/** Response message for `TestIamPermissions` method. */
+class TestIamPermissionsResponse {
+  /**
+   * A subset of `TestPermissionsRequest.permissions` that the caller is
+   * allowed.
+   */
+  core.List<core.String> permissions;
+
+  TestIamPermissionsResponse();
+
+  TestIamPermissionsResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("permissions")) {
+      permissions = _json["permissions"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (permissions != null) {
+      _json["permissions"] = permissions;
+    }
+    return _json;
+  }
+}
+
 /**
  * A YARN application created by a job. Application information is a subset of
  * org.apache.hadoop.yarn.proto.YarnProtos.ApplicationReportProto.
  */
 class YarnApplication {
   /** [Required] The application name. */
   core.String name;
   /** [Required] The numerical progress of the application, from 1 to 100. */
   core.double progress;
   /**
@@ skipping 45 matching lines @@
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }