1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/dataproc/v1/clusters.proto 3 4package dataproc 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 duration "github.com/golang/protobuf/ptypes/duration" 13 timestamp "github.com/golang/protobuf/ptypes/timestamp" 14 _ "google.golang.org/genproto/googleapis/api/annotations" 15 longrunning "google.golang.org/genproto/googleapis/longrunning" 16 field_mask "google.golang.org/genproto/protobuf/field_mask" 17 grpc "google.golang.org/grpc" 18) 19 20// Reference imports to suppress errors if they are not otherwise used. 21var _ = proto.Marshal 22var _ = fmt.Errorf 23var _ = math.Inf 24 25// This is a compile-time assertion to ensure that this generated file 26// is compatible with the proto package it is being compiled against. 27// A compilation error at this line likely means your copy of the 28// proto package needs to be updated. 29const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 30 31// The cluster state. 32type ClusterStatus_State int32 33 34const ( 35 // The cluster state is unknown. 36 ClusterStatus_UNKNOWN ClusterStatus_State = 0 37 // The cluster is being created and set up. It is not ready for use. 38 ClusterStatus_CREATING ClusterStatus_State = 1 39 // The cluster is currently running and healthy. It is ready for use. 40 ClusterStatus_RUNNING ClusterStatus_State = 2 41 // The cluster encountered an error. It is not ready for use. 42 ClusterStatus_ERROR ClusterStatus_State = 3 43 // The cluster is being deleted. It cannot be used. 44 ClusterStatus_DELETING ClusterStatus_State = 4 45 // The cluster is being updated. It continues to accept and process jobs. 46 ClusterStatus_UPDATING ClusterStatus_State = 5 47) 48 49var ClusterStatus_State_name = map[int32]string{ 50 0: "UNKNOWN", 51 1: "CREATING", 52 2: "RUNNING", 53 3: "ERROR", 54 4: "DELETING", 55 5: "UPDATING", 56} 57 58var ClusterStatus_State_value = map[string]int32{ 59 "UNKNOWN": 0, 60 "CREATING": 1, 61 "RUNNING": 2, 62 "ERROR": 3, 63 "DELETING": 4, 64 "UPDATING": 5, 65} 66 67func (x ClusterStatus_State) String() string { 68 return proto.EnumName(ClusterStatus_State_name, int32(x)) 69} 70 71func (ClusterStatus_State) EnumDescriptor() ([]byte, []int) { 72 return fileDescriptor_29f9b85b3c7e3a5f, []int{9, 0} 73} 74 75// The cluster substate. 76type ClusterStatus_Substate int32 77 78const ( 79 // The cluster substate is unknown. 80 ClusterStatus_UNSPECIFIED ClusterStatus_Substate = 0 81 // The cluster is known to be in an unhealthy state 82 // (for example, critical daemons are not running or HDFS capacity is 83 // exhausted). 84 // 85 // Applies to RUNNING state. 86 ClusterStatus_UNHEALTHY ClusterStatus_Substate = 1 87 // The agent-reported status is out of date (may occur if 88 // Cloud Dataproc loses communication with Agent). 89 // 90 // Applies to RUNNING state. 91 ClusterStatus_STALE_STATUS ClusterStatus_Substate = 2 92) 93 94var ClusterStatus_Substate_name = map[int32]string{ 95 0: "UNSPECIFIED", 96 1: "UNHEALTHY", 97 2: "STALE_STATUS", 98} 99 100var ClusterStatus_Substate_value = map[string]int32{ 101 "UNSPECIFIED": 0, 102 "UNHEALTHY": 1, 103 "STALE_STATUS": 2, 104} 105 106func (x ClusterStatus_Substate) String() string { 107 return proto.EnumName(ClusterStatus_Substate_name, int32(x)) 108} 109 110func (ClusterStatus_Substate) EnumDescriptor() ([]byte, []int) { 111 return fileDescriptor_29f9b85b3c7e3a5f, []int{9, 1} 112} 113 114// Describes the identifying information, config, and status of 115// a cluster of Compute Engine instances. 116type Cluster struct { 117 // Required. The Google Cloud Platform project ID that the cluster belongs to. 118 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 119 // Required. The cluster name. Cluster names within a project must be 120 // unique. Names of deleted clusters can be reused. 121 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 122 // Required. The cluster config. Note that Cloud Dataproc may set 123 // default values, and values may change when clusters are updated. 124 Config *ClusterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` 125 // Optional. The labels to associate with this cluster. 126 // Label **keys** must contain 1 to 63 characters, and must conform to 127 // [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). 128 // Label **values** may be empty, but, if present, must contain 1 to 63 129 // characters, and must conform to [RFC 130 // 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be 131 // associated with a cluster. 132 Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 133 // Output only. Cluster status. 134 Status *ClusterStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` 135 // Output only. The previous cluster status. 136 StatusHistory []*ClusterStatus `protobuf:"bytes,7,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"` 137 // Output only. A cluster UUID (Unique Universal Identifier). Cloud Dataproc 138 // generates this value when it creates the cluster. 139 ClusterUuid string `protobuf:"bytes,6,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"` 140 // Contains cluster daemon metrics such as HDFS and YARN stats. 141 // 142 // **Beta Feature**: This report is available for testing purposes only. It 143 // may be changed before final release. 144 Metrics *ClusterMetrics `protobuf:"bytes,9,opt,name=metrics,proto3" json:"metrics,omitempty"` 145 XXX_NoUnkeyedLiteral struct{} `json:"-"` 146 XXX_unrecognized []byte `json:"-"` 147 XXX_sizecache int32 `json:"-"` 148} 149 150func (m *Cluster) Reset() { *m = Cluster{} } 151func (m *Cluster) String() string { return proto.CompactTextString(m) } 152func (*Cluster) ProtoMessage() {} 153func (*Cluster) Descriptor() ([]byte, []int) { 154 return fileDescriptor_29f9b85b3c7e3a5f, []int{0} 155} 156 157func (m *Cluster) XXX_Unmarshal(b []byte) error { 158 return xxx_messageInfo_Cluster.Unmarshal(m, b) 159} 160func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 161 return xxx_messageInfo_Cluster.Marshal(b, m, deterministic) 162} 163func (m *Cluster) XXX_Merge(src proto.Message) { 164 xxx_messageInfo_Cluster.Merge(m, src) 165} 166func (m *Cluster) XXX_Size() int { 167 return xxx_messageInfo_Cluster.Size(m) 168} 169func (m *Cluster) XXX_DiscardUnknown() { 170 xxx_messageInfo_Cluster.DiscardUnknown(m) 171} 172 173var xxx_messageInfo_Cluster proto.InternalMessageInfo 174 175func (m *Cluster) GetProjectId() string { 176 if m != nil { 177 return m.ProjectId 178 } 179 return "" 180} 181 182func (m *Cluster) GetClusterName() string { 183 if m != nil { 184 return m.ClusterName 185 } 186 return "" 187} 188 189func (m *Cluster) GetConfig() *ClusterConfig { 190 if m != nil { 191 return m.Config 192 } 193 return nil 194} 195 196func (m *Cluster) GetLabels() map[string]string { 197 if m != nil { 198 return m.Labels 199 } 200 return nil 201} 202 203func (m *Cluster) GetStatus() *ClusterStatus { 204 if m != nil { 205 return m.Status 206 } 207 return nil 208} 209 210func (m *Cluster) GetStatusHistory() []*ClusterStatus { 211 if m != nil { 212 return m.StatusHistory 213 } 214 return nil 215} 216 217func (m *Cluster) GetClusterUuid() string { 218 if m != nil { 219 return m.ClusterUuid 220 } 221 return "" 222} 223 224func (m *Cluster) GetMetrics() *ClusterMetrics { 225 if m != nil { 226 return m.Metrics 227 } 228 return nil 229} 230 231// The cluster config. 232type ClusterConfig struct { 233 // Optional. A Google Cloud Storage bucket used to stage job 234 // dependencies, config files, and job driver console output. 235 // If you do not specify a staging bucket, Cloud 236 // Dataproc will determine a Cloud Storage location (US, 237 // ASIA, or EU) for your cluster's staging bucket according to the Google 238 // Compute Engine zone where your cluster is deployed, and then create 239 // and manage this project-level, per-location bucket (see 240 // [Cloud Dataproc staging 241 // bucket](/dataproc/docs/concepts/configuring-clusters/staging-bucket)). 242 ConfigBucket string `protobuf:"bytes,1,opt,name=config_bucket,json=configBucket,proto3" json:"config_bucket,omitempty"` 243 // Optional. The shared Compute Engine config settings for 244 // all instances in a cluster. 245 GceClusterConfig *GceClusterConfig `protobuf:"bytes,8,opt,name=gce_cluster_config,json=gceClusterConfig,proto3" json:"gce_cluster_config,omitempty"` 246 // Optional. The Compute Engine config settings for 247 // the master instance in a cluster. 248 MasterConfig *InstanceGroupConfig `protobuf:"bytes,9,opt,name=master_config,json=masterConfig,proto3" json:"master_config,omitempty"` 249 // Optional. The Compute Engine config settings for 250 // worker instances in a cluster. 251 WorkerConfig *InstanceGroupConfig `protobuf:"bytes,10,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"` 252 // Optional. The Compute Engine config settings for 253 // additional worker instances in a cluster. 254 SecondaryWorkerConfig *InstanceGroupConfig `protobuf:"bytes,12,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"` 255 // Optional. The config settings for software inside the cluster. 256 SoftwareConfig *SoftwareConfig `protobuf:"bytes,13,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"` 257 // Optional. Commands to execute on each node after config is 258 // completed. By default, executables are run on master and all worker nodes. 259 // You can test a node's `role` metadata to run an executable on 260 // a master or worker node, as shown below using `curl` (you can also use 261 // `wget`): 262 // 263 // ROLE=$(curl -H Metadata-Flavor:Google 264 // http://metadata/computeMetadata/v1/instance/attributes/dataproc-role) 265 // if [[ "${ROLE}" == 'Master' ]]; then 266 // ... master specific actions ... 267 // else 268 // ... worker specific actions ... 269 // fi 270 InitializationActions []*NodeInitializationAction `protobuf:"bytes,11,rep,name=initialization_actions,json=initializationActions,proto3" json:"initialization_actions,omitempty"` 271 // Optional. Encryption settings for the cluster. 272 EncryptionConfig *EncryptionConfig `protobuf:"bytes,15,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"` 273 XXX_NoUnkeyedLiteral struct{} `json:"-"` 274 XXX_unrecognized []byte `json:"-"` 275 XXX_sizecache int32 `json:"-"` 276} 277 278func (m *ClusterConfig) Reset() { *m = ClusterConfig{} } 279func (m *ClusterConfig) String() string { return proto.CompactTextString(m) } 280func (*ClusterConfig) ProtoMessage() {} 281func (*ClusterConfig) Descriptor() ([]byte, []int) { 282 return fileDescriptor_29f9b85b3c7e3a5f, []int{1} 283} 284 285func (m *ClusterConfig) XXX_Unmarshal(b []byte) error { 286 return xxx_messageInfo_ClusterConfig.Unmarshal(m, b) 287} 288func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 289 return xxx_messageInfo_ClusterConfig.Marshal(b, m, deterministic) 290} 291func (m *ClusterConfig) XXX_Merge(src proto.Message) { 292 xxx_messageInfo_ClusterConfig.Merge(m, src) 293} 294func (m *ClusterConfig) XXX_Size() int { 295 return xxx_messageInfo_ClusterConfig.Size(m) 296} 297func (m *ClusterConfig) XXX_DiscardUnknown() { 298 xxx_messageInfo_ClusterConfig.DiscardUnknown(m) 299} 300 301var xxx_messageInfo_ClusterConfig proto.InternalMessageInfo 302 303func (m *ClusterConfig) GetConfigBucket() string { 304 if m != nil { 305 return m.ConfigBucket 306 } 307 return "" 308} 309 310func (m *ClusterConfig) GetGceClusterConfig() *GceClusterConfig { 311 if m != nil { 312 return m.GceClusterConfig 313 } 314 return nil 315} 316 317func (m *ClusterConfig) GetMasterConfig() *InstanceGroupConfig { 318 if m != nil { 319 return m.MasterConfig 320 } 321 return nil 322} 323 324func (m *ClusterConfig) GetWorkerConfig() *InstanceGroupConfig { 325 if m != nil { 326 return m.WorkerConfig 327 } 328 return nil 329} 330 331func (m *ClusterConfig) GetSecondaryWorkerConfig() *InstanceGroupConfig { 332 if m != nil { 333 return m.SecondaryWorkerConfig 334 } 335 return nil 336} 337 338func (m *ClusterConfig) GetSoftwareConfig() *SoftwareConfig { 339 if m != nil { 340 return m.SoftwareConfig 341 } 342 return nil 343} 344 345func (m *ClusterConfig) GetInitializationActions() []*NodeInitializationAction { 346 if m != nil { 347 return m.InitializationActions 348 } 349 return nil 350} 351 352func (m *ClusterConfig) GetEncryptionConfig() *EncryptionConfig { 353 if m != nil { 354 return m.EncryptionConfig 355 } 356 return nil 357} 358 359// Encryption settings for the cluster. 360type EncryptionConfig struct { 361 // Optional. The Cloud KMS key name to use for PD disk encryption for all 362 // instances in the cluster. 363 GcePdKmsKeyName string `protobuf:"bytes,1,opt,name=gce_pd_kms_key_name,json=gcePdKmsKeyName,proto3" json:"gce_pd_kms_key_name,omitempty"` 364 XXX_NoUnkeyedLiteral struct{} `json:"-"` 365 XXX_unrecognized []byte `json:"-"` 366 XXX_sizecache int32 `json:"-"` 367} 368 369func (m *EncryptionConfig) Reset() { *m = EncryptionConfig{} } 370func (m *EncryptionConfig) String() string { return proto.CompactTextString(m) } 371func (*EncryptionConfig) ProtoMessage() {} 372func (*EncryptionConfig) Descriptor() ([]byte, []int) { 373 return fileDescriptor_29f9b85b3c7e3a5f, []int{2} 374} 375 376func (m *EncryptionConfig) XXX_Unmarshal(b []byte) error { 377 return xxx_messageInfo_EncryptionConfig.Unmarshal(m, b) 378} 379func (m *EncryptionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 380 return xxx_messageInfo_EncryptionConfig.Marshal(b, m, deterministic) 381} 382func (m *EncryptionConfig) XXX_Merge(src proto.Message) { 383 xxx_messageInfo_EncryptionConfig.Merge(m, src) 384} 385func (m *EncryptionConfig) XXX_Size() int { 386 return xxx_messageInfo_EncryptionConfig.Size(m) 387} 388func (m *EncryptionConfig) XXX_DiscardUnknown() { 389 xxx_messageInfo_EncryptionConfig.DiscardUnknown(m) 390} 391 392var xxx_messageInfo_EncryptionConfig proto.InternalMessageInfo 393 394func (m *EncryptionConfig) GetGcePdKmsKeyName() string { 395 if m != nil { 396 return m.GcePdKmsKeyName 397 } 398 return "" 399} 400 401// Common config settings for resources of Compute Engine cluster 402// instances, applicable to all instances in the cluster. 403type GceClusterConfig struct { 404 // Optional. The zone where the Compute Engine cluster will be located. 405 // On a create request, it is required in the "global" region. If omitted 406 // in a non-global Cloud Dataproc region, the service will pick a zone in the 407 // corresponding Compute Engine region. On a get request, zone will 408 // always be present. 409 // 410 // A full URL, partial URI, or short name are valid. Examples: 411 // 412 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]` 413 // * `projects/[project_id]/zones/[zone]` 414 // * `us-central1-f` 415 ZoneUri string `protobuf:"bytes,1,opt,name=zone_uri,json=zoneUri,proto3" json:"zone_uri,omitempty"` 416 // Optional. The Compute Engine network to be used for machine 417 // communications. Cannot be specified with subnetwork_uri. If neither 418 // `network_uri` nor `subnetwork_uri` is specified, the "default" network of 419 // the project is used, if it exists. Cannot be a "Custom Subnet Network" (see 420 // [Using Subnetworks](/compute/docs/subnetworks) for more information). 421 // 422 // A full URL, partial URI, or short name are valid. Examples: 423 // 424 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default` 425 // * `projects/[project_id]/regions/global/default` 426 // * `default` 427 NetworkUri string `protobuf:"bytes,2,opt,name=network_uri,json=networkUri,proto3" json:"network_uri,omitempty"` 428 // Optional. The Compute Engine subnetwork to be used for machine 429 // communications. Cannot be specified with network_uri. 430 // 431 // A full URL, partial URI, or short name are valid. Examples: 432 // 433 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/subnetworks/sub0` 434 // * `projects/[project_id]/regions/us-east1/subnetworks/sub0` 435 // * `sub0` 436 SubnetworkUri string `protobuf:"bytes,6,opt,name=subnetwork_uri,json=subnetworkUri,proto3" json:"subnetwork_uri,omitempty"` 437 // Optional. If true, all instances in the cluster will only have internal IP 438 // addresses. By default, clusters are not restricted to internal IP 439 // addresses, and will have ephemeral external IP addresses assigned to each 440 // instance. This `internal_ip_only` restriction can only be enabled for 441 // subnetwork enabled networks, and all off-cluster dependencies must be 442 // configured to be accessible without external IP addresses. 443 InternalIpOnly bool `protobuf:"varint,7,opt,name=internal_ip_only,json=internalIpOnly,proto3" json:"internal_ip_only,omitempty"` 444 // Optional. The service account of the instances. Defaults to the default 445 // Compute Engine service account. Custom service accounts need 446 // permissions equivalent to the following IAM roles: 447 // 448 // * roles/logging.logWriter 449 // * roles/storage.objectAdmin 450 // 451 // (see 452 // https://cloud.google.com/compute/docs/access/service-accounts#custom_service_accounts 453 // for more information). 454 // Example: `[account_id]@[project_id].iam.gserviceaccount.com` 455 ServiceAccount string `protobuf:"bytes,8,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` 456 // Optional. The URIs of service account scopes to be included in 457 // Compute Engine instances. The following base set of scopes is always 458 // included: 459 // 460 // * https://www.googleapis.com/auth/cloud.useraccounts.readonly 461 // * https://www.googleapis.com/auth/devstorage.read_write 462 // * https://www.googleapis.com/auth/logging.write 463 // 464 // If no scopes are specified, the following defaults are also provided: 465 // 466 // * https://www.googleapis.com/auth/bigquery 467 // * https://www.googleapis.com/auth/bigtable.admin.table 468 // * https://www.googleapis.com/auth/bigtable.data 469 // * https://www.googleapis.com/auth/devstorage.full_control 470 ServiceAccountScopes []string `protobuf:"bytes,3,rep,name=service_account_scopes,json=serviceAccountScopes,proto3" json:"service_account_scopes,omitempty"` 471 // The Compute Engine tags to add to all instances (see 472 // [Tagging instances](/compute/docs/label-or-tag-resources#tags)). 473 Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"` 474 // The Compute Engine metadata entries to add to all instances (see 475 // [Project and instance 476 // metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)). 477 Metadata map[string]string `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 478 XXX_NoUnkeyedLiteral struct{} `json:"-"` 479 XXX_unrecognized []byte `json:"-"` 480 XXX_sizecache int32 `json:"-"` 481} 482 483func (m *GceClusterConfig) Reset() { *m = GceClusterConfig{} } 484func (m *GceClusterConfig) String() string { return proto.CompactTextString(m) } 485func (*GceClusterConfig) ProtoMessage() {} 486func (*GceClusterConfig) Descriptor() ([]byte, []int) { 487 return fileDescriptor_29f9b85b3c7e3a5f, []int{3} 488} 489 490func (m *GceClusterConfig) XXX_Unmarshal(b []byte) error { 491 return xxx_messageInfo_GceClusterConfig.Unmarshal(m, b) 492} 493func (m *GceClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 494 return xxx_messageInfo_GceClusterConfig.Marshal(b, m, deterministic) 495} 496func (m *GceClusterConfig) XXX_Merge(src proto.Message) { 497 xxx_messageInfo_GceClusterConfig.Merge(m, src) 498} 499func (m *GceClusterConfig) XXX_Size() int { 500 return xxx_messageInfo_GceClusterConfig.Size(m) 501} 502func (m *GceClusterConfig) XXX_DiscardUnknown() { 503 xxx_messageInfo_GceClusterConfig.DiscardUnknown(m) 504} 505 506var xxx_messageInfo_GceClusterConfig proto.InternalMessageInfo 507 508func (m *GceClusterConfig) GetZoneUri() string { 509 if m != nil { 510 return m.ZoneUri 511 } 512 return "" 513} 514 515func (m *GceClusterConfig) GetNetworkUri() string { 516 if m != nil { 517 return m.NetworkUri 518 } 519 return "" 520} 521 522func (m *GceClusterConfig) GetSubnetworkUri() string { 523 if m != nil { 524 return m.SubnetworkUri 525 } 526 return "" 527} 528 529func (m *GceClusterConfig) GetInternalIpOnly() bool { 530 if m != nil { 531 return m.InternalIpOnly 532 } 533 return false 534} 535 536func (m *GceClusterConfig) GetServiceAccount() string { 537 if m != nil { 538 return m.ServiceAccount 539 } 540 return "" 541} 542 543func (m *GceClusterConfig) GetServiceAccountScopes() []string { 544 if m != nil { 545 return m.ServiceAccountScopes 546 } 547 return nil 548} 549 550func (m *GceClusterConfig) GetTags() []string { 551 if m != nil { 552 return m.Tags 553 } 554 return nil 555} 556 557func (m *GceClusterConfig) GetMetadata() map[string]string { 558 if m != nil { 559 return m.Metadata 560 } 561 return nil 562} 563 564// Optional. The config settings for Compute Engine resources in 565// an instance group, such as a master or worker group. 566type InstanceGroupConfig struct { 567 // Optional. The number of VM instances in the instance group. 568 // For master instance groups, must be set to 1. 569 NumInstances int32 `protobuf:"varint,1,opt,name=num_instances,json=numInstances,proto3" json:"num_instances,omitempty"` 570 // Output only. The list of instance names. Cloud Dataproc derives the names 571 // from `cluster_name`, `num_instances`, and the instance group. 572 InstanceNames []string `protobuf:"bytes,2,rep,name=instance_names,json=instanceNames,proto3" json:"instance_names,omitempty"` 573 // Optional. The Compute Engine image resource used for cluster 574 // instances. It can be specified or may be inferred from 575 // `SoftwareConfig.image_version`. 576 ImageUri string `protobuf:"bytes,3,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"` 577 // Optional. The Compute Engine machine type used for cluster instances. 578 // 579 // A full URL, partial URI, or short name are valid. Examples: 580 // 581 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` 582 // * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` 583 // * `n1-standard-2` 584 // 585 // **Auto Zone Exception**: If you are using the Cloud Dataproc 586 // [Auto Zone 587 // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement) 588 // feature, you must use the short name of the machine type 589 // resource, for example, `n1-standard-2`. 590 MachineTypeUri string `protobuf:"bytes,4,opt,name=machine_type_uri,json=machineTypeUri,proto3" json:"machine_type_uri,omitempty"` 591 // Optional. Disk option config settings. 592 DiskConfig *DiskConfig `protobuf:"bytes,5,opt,name=disk_config,json=diskConfig,proto3" json:"disk_config,omitempty"` 593 // Optional. Specifies that this instance group contains preemptible 594 // instances. 595 IsPreemptible bool `protobuf:"varint,6,opt,name=is_preemptible,json=isPreemptible,proto3" json:"is_preemptible,omitempty"` 596 // Output only. The config for Compute Engine Instance Group 597 // Manager that manages this group. 598 // This is only used for preemptible instance groups. 599 ManagedGroupConfig *ManagedGroupConfig `protobuf:"bytes,7,opt,name=managed_group_config,json=managedGroupConfig,proto3" json:"managed_group_config,omitempty"` 600 // Optional. The Compute Engine accelerator configuration for these 601 // instances. 602 // 603 // **Beta Feature**: This feature is still under development. It may be 604 // changed before final release. 605 Accelerators []*AcceleratorConfig `protobuf:"bytes,8,rep,name=accelerators,proto3" json:"accelerators,omitempty"` 606 XXX_NoUnkeyedLiteral struct{} `json:"-"` 607 XXX_unrecognized []byte `json:"-"` 608 XXX_sizecache int32 `json:"-"` 609} 610 611func (m *InstanceGroupConfig) Reset() { *m = InstanceGroupConfig{} } 612func (m *InstanceGroupConfig) String() string { return proto.CompactTextString(m) } 613func (*InstanceGroupConfig) ProtoMessage() {} 614func (*InstanceGroupConfig) Descriptor() ([]byte, []int) { 615 return fileDescriptor_29f9b85b3c7e3a5f, []int{4} 616} 617 618func (m *InstanceGroupConfig) XXX_Unmarshal(b []byte) error { 619 return xxx_messageInfo_InstanceGroupConfig.Unmarshal(m, b) 620} 621func (m *InstanceGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 622 return xxx_messageInfo_InstanceGroupConfig.Marshal(b, m, deterministic) 623} 624func (m *InstanceGroupConfig) XXX_Merge(src proto.Message) { 625 xxx_messageInfo_InstanceGroupConfig.Merge(m, src) 626} 627func (m *InstanceGroupConfig) XXX_Size() int { 628 return xxx_messageInfo_InstanceGroupConfig.Size(m) 629} 630func (m *InstanceGroupConfig) XXX_DiscardUnknown() { 631 xxx_messageInfo_InstanceGroupConfig.DiscardUnknown(m) 632} 633 634var xxx_messageInfo_InstanceGroupConfig proto.InternalMessageInfo 635 636func (m *InstanceGroupConfig) GetNumInstances() int32 { 637 if m != nil { 638 return m.NumInstances 639 } 640 return 0 641} 642 643func (m *InstanceGroupConfig) GetInstanceNames() []string { 644 if m != nil { 645 return m.InstanceNames 646 } 647 return nil 648} 649 650func (m *InstanceGroupConfig) GetImageUri() string { 651 if m != nil { 652 return m.ImageUri 653 } 654 return "" 655} 656 657func (m *InstanceGroupConfig) GetMachineTypeUri() string { 658 if m != nil { 659 return m.MachineTypeUri 660 } 661 return "" 662} 663 664func (m *InstanceGroupConfig) GetDiskConfig() *DiskConfig { 665 if m != nil { 666 return m.DiskConfig 667 } 668 return nil 669} 670 671func (m *InstanceGroupConfig) GetIsPreemptible() bool { 672 if m != nil { 673 return m.IsPreemptible 674 } 675 return false 676} 677 678func (m *InstanceGroupConfig) GetManagedGroupConfig() *ManagedGroupConfig { 679 if m != nil { 680 return m.ManagedGroupConfig 681 } 682 return nil 683} 684 685func (m *InstanceGroupConfig) GetAccelerators() []*AcceleratorConfig { 686 if m != nil { 687 return m.Accelerators 688 } 689 return nil 690} 691 692// Specifies the resources used to actively manage an instance group. 693type ManagedGroupConfig struct { 694 // Output only. The name of the Instance Template used for the Managed 695 // Instance Group. 696 InstanceTemplateName string `protobuf:"bytes,1,opt,name=instance_template_name,json=instanceTemplateName,proto3" json:"instance_template_name,omitempty"` 697 // Output only. The name of the Instance Group Manager for this group. 698 InstanceGroupManagerName string `protobuf:"bytes,2,opt,name=instance_group_manager_name,json=instanceGroupManagerName,proto3" json:"instance_group_manager_name,omitempty"` 699 XXX_NoUnkeyedLiteral struct{} `json:"-"` 700 XXX_unrecognized []byte `json:"-"` 701 XXX_sizecache int32 `json:"-"` 702} 703 704func (m *ManagedGroupConfig) Reset() { *m = ManagedGroupConfig{} } 705func (m *ManagedGroupConfig) String() string { return proto.CompactTextString(m) } 706func (*ManagedGroupConfig) ProtoMessage() {} 707func (*ManagedGroupConfig) Descriptor() ([]byte, []int) { 708 return fileDescriptor_29f9b85b3c7e3a5f, []int{5} 709} 710 711func (m *ManagedGroupConfig) XXX_Unmarshal(b []byte) error { 712 return xxx_messageInfo_ManagedGroupConfig.Unmarshal(m, b) 713} 714func (m *ManagedGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 715 return xxx_messageInfo_ManagedGroupConfig.Marshal(b, m, deterministic) 716} 717func (m *ManagedGroupConfig) XXX_Merge(src proto.Message) { 718 xxx_messageInfo_ManagedGroupConfig.Merge(m, src) 719} 720func (m *ManagedGroupConfig) XXX_Size() int { 721 return xxx_messageInfo_ManagedGroupConfig.Size(m) 722} 723func (m *ManagedGroupConfig) XXX_DiscardUnknown() { 724 xxx_messageInfo_ManagedGroupConfig.DiscardUnknown(m) 725} 726 727var xxx_messageInfo_ManagedGroupConfig proto.InternalMessageInfo 728 729func (m *ManagedGroupConfig) GetInstanceTemplateName() string { 730 if m != nil { 731 return m.InstanceTemplateName 732 } 733 return "" 734} 735 736func (m *ManagedGroupConfig) GetInstanceGroupManagerName() string { 737 if m != nil { 738 return m.InstanceGroupManagerName 739 } 740 return "" 741} 742 743// Specifies the type and number of accelerator cards attached to the instances 744// of an instance. See [GPUs on Compute Engine](/compute/docs/gpus/). 745type AcceleratorConfig struct { 746 // Full URL, partial URI, or short name of the accelerator type resource to 747 // expose to this instance. See 748 // [Compute Engine 749 // AcceleratorTypes](/compute/docs/reference/beta/acceleratorTypes). 750 // 751 // Examples: 752 // 753 // * `https://www.googleapis.com/compute/beta/projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` 754 // * `projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` 755 // * `nvidia-tesla-k80` 756 // 757 // **Auto Zone Exception**: If you are using the Cloud Dataproc 758 // [Auto Zone 759 // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement) 760 // feature, you must use the short name of the accelerator type 761 // resource, for example, `nvidia-tesla-k80`. 762 AcceleratorTypeUri string `protobuf:"bytes,1,opt,name=accelerator_type_uri,json=acceleratorTypeUri,proto3" json:"accelerator_type_uri,omitempty"` 763 // The number of the accelerator cards of this type exposed to this instance. 764 AcceleratorCount int32 `protobuf:"varint,2,opt,name=accelerator_count,json=acceleratorCount,proto3" json:"accelerator_count,omitempty"` 765 XXX_NoUnkeyedLiteral struct{} `json:"-"` 766 XXX_unrecognized []byte `json:"-"` 767 XXX_sizecache int32 `json:"-"` 768} 769 770func (m *AcceleratorConfig) Reset() { *m = AcceleratorConfig{} } 771func (m *AcceleratorConfig) String() string { return proto.CompactTextString(m) } 772func (*AcceleratorConfig) ProtoMessage() {} 773func (*AcceleratorConfig) Descriptor() ([]byte, []int) { 774 return fileDescriptor_29f9b85b3c7e3a5f, []int{6} 775} 776 777func (m *AcceleratorConfig) XXX_Unmarshal(b []byte) error { 778 return xxx_messageInfo_AcceleratorConfig.Unmarshal(m, b) 779} 780func (m *AcceleratorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 781 return xxx_messageInfo_AcceleratorConfig.Marshal(b, m, deterministic) 782} 783func (m *AcceleratorConfig) XXX_Merge(src proto.Message) { 784 xxx_messageInfo_AcceleratorConfig.Merge(m, src) 785} 786func (m *AcceleratorConfig) XXX_Size() int { 787 return xxx_messageInfo_AcceleratorConfig.Size(m) 788} 789func (m *AcceleratorConfig) XXX_DiscardUnknown() { 790 xxx_messageInfo_AcceleratorConfig.DiscardUnknown(m) 791} 792 793var xxx_messageInfo_AcceleratorConfig proto.InternalMessageInfo 794 795func (m *AcceleratorConfig) GetAcceleratorTypeUri() string { 796 if m != nil { 797 return m.AcceleratorTypeUri 798 } 799 return "" 800} 801 802func (m *AcceleratorConfig) GetAcceleratorCount() int32 { 803 if m != nil { 804 return m.AcceleratorCount 805 } 806 return 0 807} 808 809// Specifies the config of disk options for a group of VM instances. 810type DiskConfig struct { 811 // Optional. Type of the boot disk (default is "pd-standard"). 812 // Valid values: "pd-ssd" (Persistent Disk Solid State Drive) or 813 // "pd-standard" (Persistent Disk Hard Disk Drive). 814 BootDiskType string `protobuf:"bytes,3,opt,name=boot_disk_type,json=bootDiskType,proto3" json:"boot_disk_type,omitempty"` 815 // Optional. Size in GB of the boot disk (default is 500GB). 816 BootDiskSizeGb int32 `protobuf:"varint,1,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"` 817 // Optional. Number of attached SSDs, from 0 to 4 (default is 0). 818 // If SSDs are not attached, the boot disk is used to store runtime logs and 819 // [HDFS](https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. 820 // If one or more SSDs are attached, this runtime bulk 821 // data is spread across them, and the boot disk contains only basic 822 // config and installed binaries. 823 NumLocalSsds int32 `protobuf:"varint,2,opt,name=num_local_ssds,json=numLocalSsds,proto3" json:"num_local_ssds,omitempty"` 824 XXX_NoUnkeyedLiteral struct{} `json:"-"` 825 XXX_unrecognized []byte `json:"-"` 826 XXX_sizecache int32 `json:"-"` 827} 828 829func (m *DiskConfig) Reset() { *m = DiskConfig{} } 830func (m *DiskConfig) String() string { return proto.CompactTextString(m) } 831func (*DiskConfig) ProtoMessage() {} 832func (*DiskConfig) Descriptor() ([]byte, []int) { 833 return fileDescriptor_29f9b85b3c7e3a5f, []int{7} 834} 835 836func (m *DiskConfig) XXX_Unmarshal(b []byte) error { 837 return xxx_messageInfo_DiskConfig.Unmarshal(m, b) 838} 839func (m *DiskConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 840 return xxx_messageInfo_DiskConfig.Marshal(b, m, deterministic) 841} 842func (m *DiskConfig) XXX_Merge(src proto.Message) { 843 xxx_messageInfo_DiskConfig.Merge(m, src) 844} 845func (m *DiskConfig) XXX_Size() int { 846 return xxx_messageInfo_DiskConfig.Size(m) 847} 848func (m *DiskConfig) XXX_DiscardUnknown() { 849 xxx_messageInfo_DiskConfig.DiscardUnknown(m) 850} 851 852var xxx_messageInfo_DiskConfig proto.InternalMessageInfo 853 854func (m *DiskConfig) GetBootDiskType() string { 855 if m != nil { 856 return m.BootDiskType 857 } 858 return "" 859} 860 861func (m *DiskConfig) GetBootDiskSizeGb() int32 { 862 if m != nil { 863 return m.BootDiskSizeGb 864 } 865 return 0 866} 867 868func (m *DiskConfig) GetNumLocalSsds() int32 { 869 if m != nil { 870 return m.NumLocalSsds 871 } 872 return 0 873} 874 875// Specifies an executable to run on a fully configured node and a 876// timeout period for executable completion. 877type NodeInitializationAction struct { 878 // Required. Cloud Storage URI of executable file. 879 ExecutableFile string `protobuf:"bytes,1,opt,name=executable_file,json=executableFile,proto3" json:"executable_file,omitempty"` 880 // Optional. Amount of time executable has to complete. Default is 881 // 10 minutes. Cluster creation fails with an explanatory error message (the 882 // name of the executable that caused the error and the exceeded timeout 883 // period) if the executable is not completed at end of the timeout period. 884 ExecutionTimeout *duration.Duration `protobuf:"bytes,2,opt,name=execution_timeout,json=executionTimeout,proto3" json:"execution_timeout,omitempty"` 885 XXX_NoUnkeyedLiteral struct{} `json:"-"` 886 XXX_unrecognized []byte `json:"-"` 887 XXX_sizecache int32 `json:"-"` 888} 889 890func (m *NodeInitializationAction) Reset() { *m = NodeInitializationAction{} } 891func (m *NodeInitializationAction) String() string { return proto.CompactTextString(m) } 892func (*NodeInitializationAction) ProtoMessage() {} 893func (*NodeInitializationAction) Descriptor() ([]byte, []int) { 894 return fileDescriptor_29f9b85b3c7e3a5f, []int{8} 895} 896 897func (m *NodeInitializationAction) XXX_Unmarshal(b []byte) error { 898 return xxx_messageInfo_NodeInitializationAction.Unmarshal(m, b) 899} 900func (m *NodeInitializationAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 901 return xxx_messageInfo_NodeInitializationAction.Marshal(b, m, deterministic) 902} 903func (m *NodeInitializationAction) XXX_Merge(src proto.Message) { 904 xxx_messageInfo_NodeInitializationAction.Merge(m, src) 905} 906func (m *NodeInitializationAction) XXX_Size() int { 907 return xxx_messageInfo_NodeInitializationAction.Size(m) 908} 909func (m *NodeInitializationAction) XXX_DiscardUnknown() { 910 xxx_messageInfo_NodeInitializationAction.DiscardUnknown(m) 911} 912 913var xxx_messageInfo_NodeInitializationAction proto.InternalMessageInfo 914 915func (m *NodeInitializationAction) GetExecutableFile() string { 916 if m != nil { 917 return m.ExecutableFile 918 } 919 return "" 920} 921 922func (m *NodeInitializationAction) GetExecutionTimeout() *duration.Duration { 923 if m != nil { 924 return m.ExecutionTimeout 925 } 926 return nil 927} 928 929// The status of a cluster and its instances. 930type ClusterStatus struct { 931 // Output only. The cluster's state. 932 State ClusterStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1.ClusterStatus_State" json:"state,omitempty"` 933 // Output only. Optional details of cluster's state. 934 Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"` 935 // Output only. Time when this state was entered. 936 StateStartTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"` 937 // Output only. Additional state information that includes 938 // status reported by the agent. 939 Substate ClusterStatus_Substate `protobuf:"varint,4,opt,name=substate,proto3,enum=google.cloud.dataproc.v1.ClusterStatus_Substate" json:"substate,omitempty"` 940 XXX_NoUnkeyedLiteral struct{} `json:"-"` 941 XXX_unrecognized []byte `json:"-"` 942 XXX_sizecache int32 `json:"-"` 943} 944 945func (m *ClusterStatus) Reset() { *m = ClusterStatus{} } 946func (m *ClusterStatus) String() string { return proto.CompactTextString(m) } 947func (*ClusterStatus) ProtoMessage() {} 948func (*ClusterStatus) Descriptor() ([]byte, []int) { 949 return fileDescriptor_29f9b85b3c7e3a5f, []int{9} 950} 951 952func (m *ClusterStatus) XXX_Unmarshal(b []byte) error { 953 return xxx_messageInfo_ClusterStatus.Unmarshal(m, b) 954} 955func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 956 return xxx_messageInfo_ClusterStatus.Marshal(b, m, deterministic) 957} 958func (m *ClusterStatus) XXX_Merge(src proto.Message) { 959 xxx_messageInfo_ClusterStatus.Merge(m, src) 960} 961func (m *ClusterStatus) XXX_Size() int { 962 return xxx_messageInfo_ClusterStatus.Size(m) 963} 964func (m *ClusterStatus) XXX_DiscardUnknown() { 965 xxx_messageInfo_ClusterStatus.DiscardUnknown(m) 966} 967 968var xxx_messageInfo_ClusterStatus proto.InternalMessageInfo 969 970func (m *ClusterStatus) GetState() ClusterStatus_State { 971 if m != nil { 972 return m.State 973 } 974 return ClusterStatus_UNKNOWN 975} 976 977func (m *ClusterStatus) GetDetail() string { 978 if m != nil { 979 return m.Detail 980 } 981 return "" 982} 983 984func (m *ClusterStatus) GetStateStartTime() *timestamp.Timestamp { 985 if m != nil { 986 return m.StateStartTime 987 } 988 return nil 989} 990 991func (m *ClusterStatus) GetSubstate() ClusterStatus_Substate { 992 if m != nil { 993 return m.Substate 994 } 995 return ClusterStatus_UNSPECIFIED 996} 997 998// Specifies the selection and config of software inside the cluster. 999type SoftwareConfig struct { 1000 // Optional. The version of software inside the cluster. It must be one of the 1001 // supported [Cloud Dataproc 1002 // Versions](/dataproc/docs/concepts/versioning/dataproc-versions#supported_cloud_dataproc_versions), 1003 // such as "1.2" (including a subminor version, such as "1.2.29"), or the 1004 // ["preview" 1005 // version](/dataproc/docs/concepts/versioning/dataproc-versions#other_versions). 1006 // If unspecified, it defaults to the latest Debian version. 1007 ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"` 1008 // Optional. The properties to set on daemon config files. 1009 // 1010 // Property keys are specified in `prefix:property` format, for example 1011 // `core:hadoop.tmp.dir`. The following are supported prefixes 1012 // and their mappings: 1013 // 1014 // * capacity-scheduler: `capacity-scheduler.xml` 1015 // * core: `core-site.xml` 1016 // * distcp: `distcp-default.xml` 1017 // * hdfs: `hdfs-site.xml` 1018 // * hive: `hive-site.xml` 1019 // * mapred: `mapred-site.xml` 1020 // * pig: `pig.properties` 1021 // * spark: `spark-defaults.conf` 1022 // * yarn: `yarn-site.xml` 1023 // 1024 // For more information, see 1025 // [Cluster properties](/dataproc/docs/concepts/cluster-properties). 1026 Properties map[string]string `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1027 // The set of optional components to activate on the cluster. 1028 OptionalComponents []Component `protobuf:"varint,3,rep,packed,name=optional_components,json=optionalComponents,proto3,enum=google.cloud.dataproc.v1.Component" json:"optional_components,omitempty"` 1029 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1030 XXX_unrecognized []byte `json:"-"` 1031 XXX_sizecache int32 `json:"-"` 1032} 1033 1034func (m *SoftwareConfig) Reset() { *m = SoftwareConfig{} } 1035func (m *SoftwareConfig) String() string { return proto.CompactTextString(m) } 1036func (*SoftwareConfig) ProtoMessage() {} 1037func (*SoftwareConfig) Descriptor() ([]byte, []int) { 1038 return fileDescriptor_29f9b85b3c7e3a5f, []int{10} 1039} 1040 1041func (m *SoftwareConfig) XXX_Unmarshal(b []byte) error { 1042 return xxx_messageInfo_SoftwareConfig.Unmarshal(m, b) 1043} 1044func (m *SoftwareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1045 return xxx_messageInfo_SoftwareConfig.Marshal(b, m, deterministic) 1046} 1047func (m *SoftwareConfig) XXX_Merge(src proto.Message) { 1048 xxx_messageInfo_SoftwareConfig.Merge(m, src) 1049} 1050func (m *SoftwareConfig) XXX_Size() int { 1051 return xxx_messageInfo_SoftwareConfig.Size(m) 1052} 1053func (m *SoftwareConfig) XXX_DiscardUnknown() { 1054 xxx_messageInfo_SoftwareConfig.DiscardUnknown(m) 1055} 1056 1057var xxx_messageInfo_SoftwareConfig proto.InternalMessageInfo 1058 1059func (m *SoftwareConfig) GetImageVersion() string { 1060 if m != nil { 1061 return m.ImageVersion 1062 } 1063 return "" 1064} 1065 1066func (m *SoftwareConfig) GetProperties() map[string]string { 1067 if m != nil { 1068 return m.Properties 1069 } 1070 return nil 1071} 1072 1073func (m *SoftwareConfig) GetOptionalComponents() []Component { 1074 if m != nil { 1075 return m.OptionalComponents 1076 } 1077 return nil 1078} 1079 1080// Contains cluster daemon metrics, such as HDFS and YARN stats. 1081// 1082// **Beta Feature**: This report is available for testing purposes only. It may 1083// be changed before final release. 1084type ClusterMetrics struct { 1085 // The HDFS metrics. 1086 HdfsMetrics map[string]int64 `protobuf:"bytes,1,rep,name=hdfs_metrics,json=hdfsMetrics,proto3" json:"hdfs_metrics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` 1087 // The YARN metrics. 1088 YarnMetrics map[string]int64 `protobuf:"bytes,2,rep,name=yarn_metrics,json=yarnMetrics,proto3" json:"yarn_metrics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` 1089 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1090 XXX_unrecognized []byte `json:"-"` 1091 XXX_sizecache int32 `json:"-"` 1092} 1093 1094func (m *ClusterMetrics) Reset() { *m = ClusterMetrics{} } 1095func (m *ClusterMetrics) String() string { return proto.CompactTextString(m) } 1096func (*ClusterMetrics) ProtoMessage() {} 1097func (*ClusterMetrics) Descriptor() ([]byte, []int) { 1098 return fileDescriptor_29f9b85b3c7e3a5f, []int{11} 1099} 1100 1101func (m *ClusterMetrics) XXX_Unmarshal(b []byte) error { 1102 return xxx_messageInfo_ClusterMetrics.Unmarshal(m, b) 1103} 1104func (m *ClusterMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1105 return xxx_messageInfo_ClusterMetrics.Marshal(b, m, deterministic) 1106} 1107func (m *ClusterMetrics) XXX_Merge(src proto.Message) { 1108 xxx_messageInfo_ClusterMetrics.Merge(m, src) 1109} 1110func (m *ClusterMetrics) XXX_Size() int { 1111 return xxx_messageInfo_ClusterMetrics.Size(m) 1112} 1113func (m *ClusterMetrics) XXX_DiscardUnknown() { 1114 xxx_messageInfo_ClusterMetrics.DiscardUnknown(m) 1115} 1116 1117var xxx_messageInfo_ClusterMetrics proto.InternalMessageInfo 1118 1119func (m *ClusterMetrics) GetHdfsMetrics() map[string]int64 { 1120 if m != nil { 1121 return m.HdfsMetrics 1122 } 1123 return nil 1124} 1125 1126func (m *ClusterMetrics) GetYarnMetrics() map[string]int64 { 1127 if m != nil { 1128 return m.YarnMetrics 1129 } 1130 return nil 1131} 1132 1133// A request to create a cluster. 1134type CreateClusterRequest struct { 1135 // Required. The ID of the Google Cloud Platform project that the cluster 1136 // belongs to. 1137 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1138 // Required. The Cloud Dataproc region in which to handle the request. 1139 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1140 // Required. The cluster to create. 1141 Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` 1142 // Optional. A unique id used to identify the request. If the server 1143 // receives two [CreateClusterRequest][google.cloud.dataproc.v1.CreateClusterRequest] requests with the same 1144 // id, then the second request will be ignored and the 1145 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the backend 1146 // is returned. 1147 // 1148 // It is recommended to always set this value to a 1149 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1150 // 1151 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1152 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1153 RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1154 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1155 XXX_unrecognized []byte `json:"-"` 1156 XXX_sizecache int32 `json:"-"` 1157} 1158 1159func (m *CreateClusterRequest) Reset() { *m = CreateClusterRequest{} } 1160func (m *CreateClusterRequest) String() string { return proto.CompactTextString(m) } 1161func (*CreateClusterRequest) ProtoMessage() {} 1162func (*CreateClusterRequest) Descriptor() ([]byte, []int) { 1163 return fileDescriptor_29f9b85b3c7e3a5f, []int{12} 1164} 1165 1166func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error { 1167 return xxx_messageInfo_CreateClusterRequest.Unmarshal(m, b) 1168} 1169func (m *CreateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1170 return xxx_messageInfo_CreateClusterRequest.Marshal(b, m, deterministic) 1171} 1172func (m *CreateClusterRequest) XXX_Merge(src proto.Message) { 1173 xxx_messageInfo_CreateClusterRequest.Merge(m, src) 1174} 1175func (m *CreateClusterRequest) XXX_Size() int { 1176 return xxx_messageInfo_CreateClusterRequest.Size(m) 1177} 1178func (m *CreateClusterRequest) XXX_DiscardUnknown() { 1179 xxx_messageInfo_CreateClusterRequest.DiscardUnknown(m) 1180} 1181 1182var xxx_messageInfo_CreateClusterRequest proto.InternalMessageInfo 1183 1184func (m *CreateClusterRequest) GetProjectId() string { 1185 if m != nil { 1186 return m.ProjectId 1187 } 1188 return "" 1189} 1190 1191func (m *CreateClusterRequest) GetRegion() string { 1192 if m != nil { 1193 return m.Region 1194 } 1195 return "" 1196} 1197 1198func (m *CreateClusterRequest) GetCluster() *Cluster { 1199 if m != nil { 1200 return m.Cluster 1201 } 1202 return nil 1203} 1204 1205func (m *CreateClusterRequest) GetRequestId() string { 1206 if m != nil { 1207 return m.RequestId 1208 } 1209 return "" 1210} 1211 1212// A request to update a cluster. 1213type UpdateClusterRequest struct { 1214 // Required. The ID of the Google Cloud Platform project the 1215 // cluster belongs to. 1216 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1217 // Required. The Cloud Dataproc region in which to handle the request. 1218 Region string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"` 1219 // Required. The cluster name. 1220 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1221 // Required. The changes to the cluster. 1222 Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"` 1223 // Optional. Timeout for graceful YARN decomissioning. Graceful 1224 // decommissioning allows removing nodes from the cluster without 1225 // interrupting jobs in progress. Timeout specifies how long to wait for jobs 1226 // in progress to finish before forcefully removing nodes (and potentially 1227 // interrupting jobs). Default timeout is 0 (for forceful decommission), and 1228 // the maximum allowed timeout is 1 day. 1229 // 1230 // Only supported on Dataproc image versions 1.2 and higher. 1231 GracefulDecommissionTimeout *duration.Duration `protobuf:"bytes,6,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"` 1232 // Required. Specifies the path, relative to `Cluster`, of 1233 // the field to update. For example, to change the number of workers 1234 // in a cluster to 5, the `update_mask` parameter would be 1235 // specified as `config.worker_config.num_instances`, 1236 // and the `PATCH` request body would specify the new value, as follows: 1237 // 1238 // { 1239 // "config":{ 1240 // "workerConfig":{ 1241 // "numInstances":"5" 1242 // } 1243 // } 1244 // } 1245 // Similarly, to change the number of preemptible workers in a cluster to 5, 1246 // the `update_mask` parameter would be 1247 // `config.secondary_worker_config.num_instances`, and the `PATCH` request 1248 // body would be set as follows: 1249 // 1250 // { 1251 // "config":{ 1252 // "secondaryWorkerConfig":{ 1253 // "numInstances":"5" 1254 // } 1255 // } 1256 // } 1257 // <strong>Note:</strong> Currently, only the following fields can be updated: 1258 // 1259 // <table> 1260 // <tbody> 1261 // <tr> 1262 // <td><strong>Mask</strong></td> 1263 // <td><strong>Purpose</strong></td> 1264 // </tr> 1265 // <tr> 1266 // <td><strong><em>labels</em></strong></td> 1267 // <td>Update labels</td> 1268 // </tr> 1269 // <tr> 1270 // <td><strong><em>config.worker_config.num_instances</em></strong></td> 1271 // <td>Resize primary worker group</td> 1272 // </tr> 1273 // <tr> 1274 // <td><strong><em>config.secondary_worker_config.num_instances</em></strong></td> 1275 // <td>Resize secondary worker group</td> 1276 // </tr> 1277 // </tbody> 1278 // </table> 1279 UpdateMask *field_mask.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 1280 // Optional. A unique id used to identify the request. If the server 1281 // receives two [UpdateClusterRequest][google.cloud.dataproc.v1.UpdateClusterRequest] requests with the same 1282 // id, then the second request will be ignored and the 1283 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the 1284 // backend is returned. 1285 // 1286 // It is recommended to always set this value to a 1287 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1288 // 1289 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1290 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1291 RequestId string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1292 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1293 XXX_unrecognized []byte `json:"-"` 1294 XXX_sizecache int32 `json:"-"` 1295} 1296 1297func (m *UpdateClusterRequest) Reset() { *m = UpdateClusterRequest{} } 1298func (m *UpdateClusterRequest) String() string { return proto.CompactTextString(m) } 1299func (*UpdateClusterRequest) ProtoMessage() {} 1300func (*UpdateClusterRequest) Descriptor() ([]byte, []int) { 1301 return fileDescriptor_29f9b85b3c7e3a5f, []int{13} 1302} 1303 1304func (m *UpdateClusterRequest) XXX_Unmarshal(b []byte) error { 1305 return xxx_messageInfo_UpdateClusterRequest.Unmarshal(m, b) 1306} 1307func (m *UpdateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1308 return xxx_messageInfo_UpdateClusterRequest.Marshal(b, m, deterministic) 1309} 1310func (m *UpdateClusterRequest) XXX_Merge(src proto.Message) { 1311 xxx_messageInfo_UpdateClusterRequest.Merge(m, src) 1312} 1313func (m *UpdateClusterRequest) XXX_Size() int { 1314 return xxx_messageInfo_UpdateClusterRequest.Size(m) 1315} 1316func (m *UpdateClusterRequest) XXX_DiscardUnknown() { 1317 xxx_messageInfo_UpdateClusterRequest.DiscardUnknown(m) 1318} 1319 1320var xxx_messageInfo_UpdateClusterRequest proto.InternalMessageInfo 1321 1322func (m *UpdateClusterRequest) GetProjectId() string { 1323 if m != nil { 1324 return m.ProjectId 1325 } 1326 return "" 1327} 1328 1329func (m *UpdateClusterRequest) GetRegion() string { 1330 if m != nil { 1331 return m.Region 1332 } 1333 return "" 1334} 1335 1336func (m *UpdateClusterRequest) GetClusterName() string { 1337 if m != nil { 1338 return m.ClusterName 1339 } 1340 return "" 1341} 1342 1343func (m *UpdateClusterRequest) GetCluster() *Cluster { 1344 if m != nil { 1345 return m.Cluster 1346 } 1347 return nil 1348} 1349 1350func (m *UpdateClusterRequest) GetGracefulDecommissionTimeout() *duration.Duration { 1351 if m != nil { 1352 return m.GracefulDecommissionTimeout 1353 } 1354 return nil 1355} 1356 1357func (m *UpdateClusterRequest) GetUpdateMask() *field_mask.FieldMask { 1358 if m != nil { 1359 return m.UpdateMask 1360 } 1361 return nil 1362} 1363 1364func (m *UpdateClusterRequest) GetRequestId() string { 1365 if m != nil { 1366 return m.RequestId 1367 } 1368 return "" 1369} 1370 1371// A request to delete a cluster. 1372type DeleteClusterRequest struct { 1373 // Required. The ID of the Google Cloud Platform project that the cluster 1374 // belongs to. 1375 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1376 // Required. The Cloud Dataproc region in which to handle the request. 1377 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1378 // Required. The cluster name. 1379 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1380 // Optional. Specifying the `cluster_uuid` means the RPC should fail 1381 // (with error NOT_FOUND) if cluster with specified UUID does not exist. 1382 ClusterUuid string `protobuf:"bytes,4,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"` 1383 // Optional. A unique id used to identify the request. If the server 1384 // receives two [DeleteClusterRequest][google.cloud.dataproc.v1.DeleteClusterRequest] requests with the same 1385 // id, then the second request will be ignored and the 1386 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the 1387 // backend is returned. 1388 // 1389 // It is recommended to always set this value to a 1390 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1391 // 1392 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1393 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1394 RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1395 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1396 XXX_unrecognized []byte `json:"-"` 1397 XXX_sizecache int32 `json:"-"` 1398} 1399 1400func (m *DeleteClusterRequest) Reset() { *m = DeleteClusterRequest{} } 1401func (m *DeleteClusterRequest) String() string { return proto.CompactTextString(m) } 1402func (*DeleteClusterRequest) ProtoMessage() {} 1403func (*DeleteClusterRequest) Descriptor() ([]byte, []int) { 1404 return fileDescriptor_29f9b85b3c7e3a5f, []int{14} 1405} 1406 1407func (m *DeleteClusterRequest) XXX_Unmarshal(b []byte) error { 1408 return xxx_messageInfo_DeleteClusterRequest.Unmarshal(m, b) 1409} 1410func (m *DeleteClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1411 return xxx_messageInfo_DeleteClusterRequest.Marshal(b, m, deterministic) 1412} 1413func (m *DeleteClusterRequest) XXX_Merge(src proto.Message) { 1414 xxx_messageInfo_DeleteClusterRequest.Merge(m, src) 1415} 1416func (m *DeleteClusterRequest) XXX_Size() int { 1417 return xxx_messageInfo_DeleteClusterRequest.Size(m) 1418} 1419func (m *DeleteClusterRequest) XXX_DiscardUnknown() { 1420 xxx_messageInfo_DeleteClusterRequest.DiscardUnknown(m) 1421} 1422 1423var xxx_messageInfo_DeleteClusterRequest proto.InternalMessageInfo 1424 1425func (m *DeleteClusterRequest) GetProjectId() string { 1426 if m != nil { 1427 return m.ProjectId 1428 } 1429 return "" 1430} 1431 1432func (m *DeleteClusterRequest) GetRegion() string { 1433 if m != nil { 1434 return m.Region 1435 } 1436 return "" 1437} 1438 1439func (m *DeleteClusterRequest) GetClusterName() string { 1440 if m != nil { 1441 return m.ClusterName 1442 } 1443 return "" 1444} 1445 1446func (m *DeleteClusterRequest) GetClusterUuid() string { 1447 if m != nil { 1448 return m.ClusterUuid 1449 } 1450 return "" 1451} 1452 1453func (m *DeleteClusterRequest) GetRequestId() string { 1454 if m != nil { 1455 return m.RequestId 1456 } 1457 return "" 1458} 1459 1460// Request to get the resource representation for a cluster in a project. 1461type GetClusterRequest struct { 1462 // Required. The ID of the Google Cloud Platform project that the cluster 1463 // belongs to. 1464 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1465 // Required. The Cloud Dataproc region in which to handle the request. 1466 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1467 // Required. The cluster name. 1468 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1469 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1470 XXX_unrecognized []byte `json:"-"` 1471 XXX_sizecache int32 `json:"-"` 1472} 1473 1474func (m *GetClusterRequest) Reset() { *m = GetClusterRequest{} } 1475func (m *GetClusterRequest) String() string { return proto.CompactTextString(m) } 1476func (*GetClusterRequest) ProtoMessage() {} 1477func (*GetClusterRequest) Descriptor() ([]byte, []int) { 1478 return fileDescriptor_29f9b85b3c7e3a5f, []int{15} 1479} 1480 1481func (m *GetClusterRequest) XXX_Unmarshal(b []byte) error { 1482 return xxx_messageInfo_GetClusterRequest.Unmarshal(m, b) 1483} 1484func (m *GetClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1485 return xxx_messageInfo_GetClusterRequest.Marshal(b, m, deterministic) 1486} 1487func (m *GetClusterRequest) XXX_Merge(src proto.Message) { 1488 xxx_messageInfo_GetClusterRequest.Merge(m, src) 1489} 1490func (m *GetClusterRequest) XXX_Size() int { 1491 return xxx_messageInfo_GetClusterRequest.Size(m) 1492} 1493func (m *GetClusterRequest) XXX_DiscardUnknown() { 1494 xxx_messageInfo_GetClusterRequest.DiscardUnknown(m) 1495} 1496 1497var xxx_messageInfo_GetClusterRequest proto.InternalMessageInfo 1498 1499func (m *GetClusterRequest) GetProjectId() string { 1500 if m != nil { 1501 return m.ProjectId 1502 } 1503 return "" 1504} 1505 1506func (m *GetClusterRequest) GetRegion() string { 1507 if m != nil { 1508 return m.Region 1509 } 1510 return "" 1511} 1512 1513func (m *GetClusterRequest) GetClusterName() string { 1514 if m != nil { 1515 return m.ClusterName 1516 } 1517 return "" 1518} 1519 1520// A request to list the clusters in a project. 1521type ListClustersRequest struct { 1522 // Required. The ID of the Google Cloud Platform project that the cluster 1523 // belongs to. 1524 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1525 // Required. The Cloud Dataproc region in which to handle the request. 1526 Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"` 1527 // Optional. A filter constraining the clusters to list. Filters are 1528 // case-sensitive and have the following syntax: 1529 // 1530 // field = value [AND [field = value]] ... 1531 // 1532 // where **field** is one of `status.state`, `clusterName`, or `labels.[KEY]`, 1533 // and `[KEY]` is a label key. **value** can be `*` to match all values. 1534 // `status.state` can be one of the following: `ACTIVE`, `INACTIVE`, 1535 // `CREATING`, `RUNNING`, `ERROR`, `DELETING`, or `UPDATING`. `ACTIVE` 1536 // contains the `CREATING`, `UPDATING`, and `RUNNING` states. `INACTIVE` 1537 // contains the `DELETING` and `ERROR` states. 1538 // `clusterName` is the name of the cluster provided at creation time. 1539 // Only the logical `AND` operator is supported; space-separated items are 1540 // treated as having an implicit `AND` operator. 1541 // 1542 // Example filter: 1543 // 1544 // status.state = ACTIVE AND clusterName = mycluster 1545 // AND labels.env = staging AND labels.starred = * 1546 Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"` 1547 // Optional. The standard List page size. 1548 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1549 // Optional. The standard List page token. 1550 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1551 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1552 XXX_unrecognized []byte `json:"-"` 1553 XXX_sizecache int32 `json:"-"` 1554} 1555 1556func (m *ListClustersRequest) Reset() { *m = ListClustersRequest{} } 1557func (m *ListClustersRequest) String() string { return proto.CompactTextString(m) } 1558func (*ListClustersRequest) ProtoMessage() {} 1559func (*ListClustersRequest) Descriptor() ([]byte, []int) { 1560 return fileDescriptor_29f9b85b3c7e3a5f, []int{16} 1561} 1562 1563func (m *ListClustersRequest) XXX_Unmarshal(b []byte) error { 1564 return xxx_messageInfo_ListClustersRequest.Unmarshal(m, b) 1565} 1566func (m *ListClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1567 return xxx_messageInfo_ListClustersRequest.Marshal(b, m, deterministic) 1568} 1569func (m *ListClustersRequest) XXX_Merge(src proto.Message) { 1570 xxx_messageInfo_ListClustersRequest.Merge(m, src) 1571} 1572func (m *ListClustersRequest) XXX_Size() int { 1573 return xxx_messageInfo_ListClustersRequest.Size(m) 1574} 1575func (m *ListClustersRequest) XXX_DiscardUnknown() { 1576 xxx_messageInfo_ListClustersRequest.DiscardUnknown(m) 1577} 1578 1579var xxx_messageInfo_ListClustersRequest proto.InternalMessageInfo 1580 1581func (m *ListClustersRequest) GetProjectId() string { 1582 if m != nil { 1583 return m.ProjectId 1584 } 1585 return "" 1586} 1587 1588func (m *ListClustersRequest) GetRegion() string { 1589 if m != nil { 1590 return m.Region 1591 } 1592 return "" 1593} 1594 1595func (m *ListClustersRequest) GetFilter() string { 1596 if m != nil { 1597 return m.Filter 1598 } 1599 return "" 1600} 1601 1602func (m *ListClustersRequest) GetPageSize() int32 { 1603 if m != nil { 1604 return m.PageSize 1605 } 1606 return 0 1607} 1608 1609func (m *ListClustersRequest) GetPageToken() string { 1610 if m != nil { 1611 return m.PageToken 1612 } 1613 return "" 1614} 1615 1616// The list of all clusters in a project. 1617type ListClustersResponse struct { 1618 // Output only. The clusters in the project. 1619 Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` 1620 // Output only. This token is included in the response if there are more 1621 // results to fetch. To fetch additional results, provide this value as the 1622 // `page_token` in a subsequent `ListClustersRequest`. 1623 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 1624 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1625 XXX_unrecognized []byte `json:"-"` 1626 XXX_sizecache int32 `json:"-"` 1627} 1628 1629func (m *ListClustersResponse) Reset() { *m = ListClustersResponse{} } 1630func (m *ListClustersResponse) String() string { return proto.CompactTextString(m) } 1631func (*ListClustersResponse) ProtoMessage() {} 1632func (*ListClustersResponse) Descriptor() ([]byte, []int) { 1633 return fileDescriptor_29f9b85b3c7e3a5f, []int{17} 1634} 1635 1636func (m *ListClustersResponse) XXX_Unmarshal(b []byte) error { 1637 return xxx_messageInfo_ListClustersResponse.Unmarshal(m, b) 1638} 1639func (m *ListClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1640 return xxx_messageInfo_ListClustersResponse.Marshal(b, m, deterministic) 1641} 1642func (m *ListClustersResponse) XXX_Merge(src proto.Message) { 1643 xxx_messageInfo_ListClustersResponse.Merge(m, src) 1644} 1645func (m *ListClustersResponse) XXX_Size() int { 1646 return xxx_messageInfo_ListClustersResponse.Size(m) 1647} 1648func (m *ListClustersResponse) XXX_DiscardUnknown() { 1649 xxx_messageInfo_ListClustersResponse.DiscardUnknown(m) 1650} 1651 1652var xxx_messageInfo_ListClustersResponse proto.InternalMessageInfo 1653 1654func (m *ListClustersResponse) GetClusters() []*Cluster { 1655 if m != nil { 1656 return m.Clusters 1657 } 1658 return nil 1659} 1660 1661func (m *ListClustersResponse) GetNextPageToken() string { 1662 if m != nil { 1663 return m.NextPageToken 1664 } 1665 return "" 1666} 1667 1668// A request to collect cluster diagnostic information. 1669type DiagnoseClusterRequest struct { 1670 // Required. The ID of the Google Cloud Platform project that the cluster 1671 // belongs to. 1672 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1673 // Required. The Cloud Dataproc region in which to handle the request. 1674 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1675 // Required. The cluster name. 1676 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1677 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1678 XXX_unrecognized []byte `json:"-"` 1679 XXX_sizecache int32 `json:"-"` 1680} 1681 1682func (m *DiagnoseClusterRequest) Reset() { *m = DiagnoseClusterRequest{} } 1683func (m *DiagnoseClusterRequest) String() string { return proto.CompactTextString(m) } 1684func (*DiagnoseClusterRequest) ProtoMessage() {} 1685func (*DiagnoseClusterRequest) Descriptor() ([]byte, []int) { 1686 return fileDescriptor_29f9b85b3c7e3a5f, []int{18} 1687} 1688 1689func (m *DiagnoseClusterRequest) XXX_Unmarshal(b []byte) error { 1690 return xxx_messageInfo_DiagnoseClusterRequest.Unmarshal(m, b) 1691} 1692func (m *DiagnoseClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1693 return xxx_messageInfo_DiagnoseClusterRequest.Marshal(b, m, deterministic) 1694} 1695func (m *DiagnoseClusterRequest) XXX_Merge(src proto.Message) { 1696 xxx_messageInfo_DiagnoseClusterRequest.Merge(m, src) 1697} 1698func (m *DiagnoseClusterRequest) XXX_Size() int { 1699 return xxx_messageInfo_DiagnoseClusterRequest.Size(m) 1700} 1701func (m *DiagnoseClusterRequest) XXX_DiscardUnknown() { 1702 xxx_messageInfo_DiagnoseClusterRequest.DiscardUnknown(m) 1703} 1704 1705var xxx_messageInfo_DiagnoseClusterRequest proto.InternalMessageInfo 1706 1707func (m *DiagnoseClusterRequest) GetProjectId() string { 1708 if m != nil { 1709 return m.ProjectId 1710 } 1711 return "" 1712} 1713 1714func (m *DiagnoseClusterRequest) GetRegion() string { 1715 if m != nil { 1716 return m.Region 1717 } 1718 return "" 1719} 1720 1721func (m *DiagnoseClusterRequest) GetClusterName() string { 1722 if m != nil { 1723 return m.ClusterName 1724 } 1725 return "" 1726} 1727 1728// The location of diagnostic output. 1729type DiagnoseClusterResults struct { 1730 // Output only. The Cloud Storage URI of the diagnostic output. 1731 // The output report is a plain text file with a summary of collected 1732 // diagnostics. 1733 OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"` 1734 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1735 XXX_unrecognized []byte `json:"-"` 1736 XXX_sizecache int32 `json:"-"` 1737} 1738 1739func (m *DiagnoseClusterResults) Reset() { *m = DiagnoseClusterResults{} } 1740func (m *DiagnoseClusterResults) String() string { return proto.CompactTextString(m) } 1741func (*DiagnoseClusterResults) ProtoMessage() {} 1742func (*DiagnoseClusterResults) Descriptor() ([]byte, []int) { 1743 return fileDescriptor_29f9b85b3c7e3a5f, []int{19} 1744} 1745 1746func (m *DiagnoseClusterResults) XXX_Unmarshal(b []byte) error { 1747 return xxx_messageInfo_DiagnoseClusterResults.Unmarshal(m, b) 1748} 1749func (m *DiagnoseClusterResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1750 return xxx_messageInfo_DiagnoseClusterResults.Marshal(b, m, deterministic) 1751} 1752func (m *DiagnoseClusterResults) XXX_Merge(src proto.Message) { 1753 xxx_messageInfo_DiagnoseClusterResults.Merge(m, src) 1754} 1755func (m *DiagnoseClusterResults) XXX_Size() int { 1756 return xxx_messageInfo_DiagnoseClusterResults.Size(m) 1757} 1758func (m *DiagnoseClusterResults) XXX_DiscardUnknown() { 1759 xxx_messageInfo_DiagnoseClusterResults.DiscardUnknown(m) 1760} 1761 1762var xxx_messageInfo_DiagnoseClusterResults proto.InternalMessageInfo 1763 1764func (m *DiagnoseClusterResults) GetOutputUri() string { 1765 if m != nil { 1766 return m.OutputUri 1767 } 1768 return "" 1769} 1770 1771func init() { 1772 proto.RegisterEnum("google.cloud.dataproc.v1.ClusterStatus_State", ClusterStatus_State_name, ClusterStatus_State_value) 1773 proto.RegisterEnum("google.cloud.dataproc.v1.ClusterStatus_Substate", ClusterStatus_Substate_name, ClusterStatus_Substate_value) 1774 proto.RegisterType((*Cluster)(nil), "google.cloud.dataproc.v1.Cluster") 1775 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1.Cluster.LabelsEntry") 1776 proto.RegisterType((*ClusterConfig)(nil), "google.cloud.dataproc.v1.ClusterConfig") 1777 proto.RegisterType((*EncryptionConfig)(nil), "google.cloud.dataproc.v1.EncryptionConfig") 1778 proto.RegisterType((*GceClusterConfig)(nil), "google.cloud.dataproc.v1.GceClusterConfig") 1779 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1.GceClusterConfig.MetadataEntry") 1780 proto.RegisterType((*InstanceGroupConfig)(nil), "google.cloud.dataproc.v1.InstanceGroupConfig") 1781 proto.RegisterType((*ManagedGroupConfig)(nil), "google.cloud.dataproc.v1.ManagedGroupConfig") 1782 proto.RegisterType((*AcceleratorConfig)(nil), "google.cloud.dataproc.v1.AcceleratorConfig") 1783 proto.RegisterType((*DiskConfig)(nil), "google.cloud.dataproc.v1.DiskConfig") 1784 proto.RegisterType((*NodeInitializationAction)(nil), "google.cloud.dataproc.v1.NodeInitializationAction") 1785 proto.RegisterType((*ClusterStatus)(nil), "google.cloud.dataproc.v1.ClusterStatus") 1786 proto.RegisterType((*SoftwareConfig)(nil), "google.cloud.dataproc.v1.SoftwareConfig") 1787 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1.SoftwareConfig.PropertiesEntry") 1788 proto.RegisterType((*ClusterMetrics)(nil), "google.cloud.dataproc.v1.ClusterMetrics") 1789 proto.RegisterMapType((map[string]int64)(nil), "google.cloud.dataproc.v1.ClusterMetrics.HdfsMetricsEntry") 1790 proto.RegisterMapType((map[string]int64)(nil), "google.cloud.dataproc.v1.ClusterMetrics.YarnMetricsEntry") 1791 proto.RegisterType((*CreateClusterRequest)(nil), "google.cloud.dataproc.v1.CreateClusterRequest") 1792 proto.RegisterType((*UpdateClusterRequest)(nil), "google.cloud.dataproc.v1.UpdateClusterRequest") 1793 proto.RegisterType((*DeleteClusterRequest)(nil), "google.cloud.dataproc.v1.DeleteClusterRequest") 1794 proto.RegisterType((*GetClusterRequest)(nil), "google.cloud.dataproc.v1.GetClusterRequest") 1795 proto.RegisterType((*ListClustersRequest)(nil), "google.cloud.dataproc.v1.ListClustersRequest") 1796 proto.RegisterType((*ListClustersResponse)(nil), "google.cloud.dataproc.v1.ListClustersResponse") 1797 proto.RegisterType((*DiagnoseClusterRequest)(nil), "google.cloud.dataproc.v1.DiagnoseClusterRequest") 1798 proto.RegisterType((*DiagnoseClusterResults)(nil), "google.cloud.dataproc.v1.DiagnoseClusterResults") 1799} 1800 1801func init() { 1802 proto.RegisterFile("google/cloud/dataproc/v1/clusters.proto", fileDescriptor_29f9b85b3c7e3a5f) 1803} 1804 1805var fileDescriptor_29f9b85b3c7e3a5f = []byte{ 1806 // 2120 bytes of a gzipped FileDescriptorProto 1807 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x59, 0x4b, 0x73, 0x1b, 0xc7, 1808 0xf1, 0xf7, 0x02, 0x04, 0x09, 0x36, 0x1e, 0x04, 0x47, 0x34, 0xff, 0x30, 0x65, 0xfd, 0x2d, 0x43, 1809 0x76, 0x44, 0xcb, 0x0e, 0x20, 0xd1, 0x49, 0xc5, 0x96, 0x62, 0xc7, 0x14, 0x01, 0x49, 0x8c, 0x28, 1810 0x88, 0x59, 0x80, 0x92, 0x9d, 0x4a, 0xb2, 0x35, 0xd8, 0x1d, 0x42, 0x13, 0xee, 0xcb, 0x3b, 0xb3, 1811 0xb4, 0x21, 0x95, 0x2e, 0x49, 0x55, 0xaa, 0x52, 0x39, 0xa6, 0x2a, 0xe7, 0x1c, 0x9c, 0xaa, 0xc4, 1812 0x47, 0x27, 0xa7, 0x7c, 0x81, 0x5c, 0x72, 0xcb, 0x57, 0xc8, 0x21, 0x1f, 0x23, 0x35, 0x8f, 0x05, 1813 0x76, 0xc1, 0x07, 0x48, 0x45, 0xe5, 0x13, 0x77, 0x7a, 0x7e, 0xdd, 0xfd, 0x9b, 0x9e, 0x9e, 0x9e, 1814 0x1e, 0x10, 0xae, 0x0e, 0x83, 0x60, 0xe8, 0x92, 0x96, 0xed, 0x06, 0xb1, 0xd3, 0x72, 0x30, 0xc7, 1815 0x61, 0x14, 0xd8, 0xad, 0xc3, 0x1b, 0x2d, 0xdb, 0x8d, 0x19, 0x27, 0x11, 0x6b, 0x86, 0x51, 0xc0, 1816 0x03, 0x54, 0x57, 0xc0, 0xa6, 0x04, 0x36, 0x13, 0x60, 0xf3, 0xf0, 0xc6, 0xda, 0xeb, 0xda, 0x04, 1817 0x0e, 0x69, 0x0b, 0xfb, 0x7e, 0xc0, 0x31, 0xa7, 0x81, 0xaf, 0xf5, 0xd6, 0xde, 0x39, 0xd1, 0x41, 1818 0x10, 0x92, 0x28, 0x03, 0x7d, 0xfb, 0x44, 0x28, 0x7b, 0x82, 0x23, 0xe2, 0x68, 0xd8, 0x15, 0x0d, 1819 0x73, 0x03, 0x7f, 0x18, 0xc5, 0xbe, 0x4f, 0xfd, 0xe1, 0x51, 0x5b, 0xff, 0xaf, 0x41, 0x72, 0x34, 1820 0x88, 0xf7, 0x5b, 0x4e, 0xac, 0x00, 0x7a, 0xfe, 0xf2, 0xf4, 0xfc, 0x3e, 0x25, 0xae, 0x63, 0x79, 1821 0x98, 0x1d, 0x68, 0xc4, 0x1b, 0xd3, 0x08, 0x4e, 0x3d, 0xc2, 0x38, 0xf6, 0x42, 0x05, 0x68, 0xfc, 1822 0x66, 0x0e, 0x16, 0xb6, 0x54, 0x90, 0xd0, 0x25, 0x80, 0x30, 0x0a, 0x7e, 0x49, 0x6c, 0x6e, 0x51, 1823 0xa7, 0x6e, 0x5c, 0x36, 0xd6, 0x17, 0xcd, 0x45, 0x2d, 0xd9, 0x76, 0xd0, 0x9b, 0x50, 0xd6, 0xe1, 1824 0xb4, 0x7c, 0xec, 0x91, 0x7a, 0x4e, 0x02, 0x4a, 0x5a, 0xd6, 0xc5, 0x1e, 0x41, 0x3f, 0x82, 0x79, 1825 0x3b, 0xf0, 0xf7, 0xe9, 0xb0, 0x9e, 0xbf, 0x6c, 0xac, 0x97, 0x36, 0xae, 0x36, 0x4f, 0x0a, 0x78, 1826 0x53, 0x3b, 0xdd, 0x92, 0x70, 0x53, 0xab, 0xa1, 0x0e, 0xcc, 0xbb, 0x78, 0x40, 0x5c, 0x56, 0x2f, 1827 0x5e, 0xce, 0xaf, 0x97, 0x36, 0xbe, 0x3b, 0xd3, 0x40, 0x73, 0x47, 0xe2, 0x3b, 0x3e, 0x8f, 0x46, 1828 0xa6, 0x56, 0x16, 0x3c, 0x18, 0xc7, 0x3c, 0x66, 0xf5, 0xb9, 0x33, 0xf2, 0xe8, 0x49, 0xb8, 0xa9, 1829 0xd5, 0x50, 0x17, 0xaa, 0xea, 0xcb, 0x7a, 0x42, 0x19, 0x0f, 0xa2, 0x51, 0x7d, 0x41, 0xf2, 0x39, 1830 0xb3, 0xa1, 0x8a, 0x52, 0xbf, 0xa7, 0xb4, 0xd3, 0xb1, 0x8b, 0x63, 0xea, 0xd4, 0xe7, 0x33, 0xb1, 1831 0xdb, 0x8b, 0xa9, 0x83, 0x6e, 0xc3, 0x82, 0x47, 0x78, 0x44, 0x6d, 0x56, 0x5f, 0x94, 0xa4, 0xd7, 1832 0x67, 0xfa, 0x7a, 0xa0, 0xf0, 0x66, 0xa2, 0xb8, 0xf6, 0x21, 0x94, 0x52, 0xe1, 0x40, 0x35, 0xc8, 1833 0x1f, 0x90, 0x91, 0xde, 0x49, 0xf1, 0x89, 0x56, 0xa0, 0x70, 0x88, 0xdd, 0x38, 0xd9, 0x3c, 0x35, 1834 0xb8, 0x99, 0xfb, 0xc0, 0x68, 0xfc, 0xad, 0x00, 0x95, 0xcc, 0x9e, 0xa0, 0x2b, 0x50, 0x51, 0xbb, 1835 0x62, 0x0d, 0x62, 0xfb, 0x80, 0x70, 0x6d, 0xa7, 0xac, 0x84, 0xb7, 0xa5, 0x0c, 0x7d, 0x0a, 0x68, 1836 0x68, 0x13, 0x2b, 0x59, 0x9c, 0xde, 0xfd, 0xa2, 0x5c, 0xc0, 0xb5, 0x93, 0x17, 0x70, 0xd7, 0x26, 1837 0xd9, 0x04, 0xa8, 0x0d, 0xa7, 0x24, 0xc8, 0x84, 0x8a, 0x87, 0xd3, 0x46, 0x55, 0x54, 0x4e, 0xc9, 1838 0x88, 0x6d, 0x9f, 0x71, 0xec, 0xdb, 0xe4, 0x6e, 0x14, 0xc4, 0xa1, 0xb6, 0x5b, 0x56, 0x36, 0x26, 1839 0x36, 0xbf, 0x08, 0xa2, 0x83, 0x89, 0x4d, 0x78, 0x21, 0x9b, 0xca, 0x86, 0xb6, 0x49, 0xe0, 0xff, 1840 0x18, 0xb1, 0x03, 0xdf, 0xc1, 0xd1, 0xc8, 0xca, 0x5a, 0x2f, 0xbf, 0x88, 0xf5, 0x57, 0xc7, 0xd6, 1841 0x1e, 0xa7, 0xdd, 0xfc, 0x04, 0x96, 0x58, 0xb0, 0xcf, 0xbf, 0xc0, 0x11, 0x49, 0xcc, 0x57, 0x66, 1842 0xa5, 0x49, 0x4f, 0x2b, 0x68, 0xcb, 0x55, 0x96, 0x19, 0x23, 0x0a, 0xab, 0xd4, 0xa7, 0x9c, 0x62, 1843 0x97, 0x3e, 0x95, 0x65, 0xc5, 0xc2, 0xb6, 0x2c, 0x3f, 0xf5, 0x92, 0x4c, 0xf6, 0x8d, 0x93, 0x2d, 1844 0x77, 0x03, 0x87, 0x6c, 0x67, 0x74, 0x37, 0xa5, 0xaa, 0xf9, 0x2a, 0x3d, 0x46, 0xca, 0xd0, 0x63, 1845 0x58, 0x26, 0xbe, 0x1d, 0x8d, 0x42, 0xe9, 0x46, 0xf3, 0x5f, 0x9a, 0x95, 0x25, 0x9d, 0xb1, 0x4a, 1846 0x92, 0x25, 0x64, 0x4a, 0xd2, 0xf8, 0x04, 0x6a, 0xd3, 0x28, 0xf4, 0x1e, 0x5c, 0x10, 0x39, 0x19, 1847 0x3a, 0xd6, 0x81, 0xc7, 0xac, 0x03, 0x32, 0x52, 0xf5, 0x4a, 0xa5, 0xef, 0xd2, 0xd0, 0x26, 0xbb, 1848 0xce, 0x7d, 0x8f, 0xdd, 0x27, 0x23, 0x51, 0xb3, 0x1a, 0x7f, 0xca, 0x43, 0x6d, 0x3a, 0x1d, 0xd1, 1849 0x6b, 0x50, 0x7c, 0x1a, 0xf8, 0xc4, 0x8a, 0x23, 0xaa, 0xf5, 0x16, 0xc4, 0x78, 0x2f, 0xa2, 0xe8, 1850 0x0d, 0x28, 0xf9, 0x84, 0x8b, 0x8d, 0x96, 0xb3, 0xea, 0x20, 0x81, 0x16, 0x09, 0xc0, 0xdb, 0x50, 1851 0x65, 0xf1, 0x20, 0x8d, 0x51, 0xa7, 0xbd, 0x32, 0x91, 0x0a, 0xd8, 0x3a, 0xd4, 0xa8, 0xcf, 0x49, 1852 0xe4, 0x63, 0xd7, 0xa2, 0xa1, 0x15, 0xf8, 0xae, 0x28, 0x32, 0xc6, 0x7a, 0xd1, 0xac, 0x26, 0xf2, 1853 0xed, 0xf0, 0xa1, 0xef, 0x8e, 0xd0, 0x55, 0x58, 0x62, 0x24, 0x3a, 0xa4, 0x36, 0xb1, 0xb0, 0x6d, 1854 0x07, 0xb1, 0xcf, 0xe5, 0x01, 0x5b, 0x34, 0xab, 0x5a, 0xbc, 0xa9, 0xa4, 0xe8, 0x7b, 0xb0, 0x3a, 1855 0x05, 0xb4, 0x98, 0x1d, 0x84, 0x84, 0xd5, 0xf3, 0x97, 0xf3, 0xeb, 0x8b, 0xe6, 0x4a, 0x16, 0xdf, 1856 0x93, 0x73, 0x08, 0xc1, 0x1c, 0xc7, 0x43, 0x51, 0x2a, 0x05, 0x46, 0x7e, 0xa3, 0x3e, 0x14, 0x3d, 1857 0xc2, 0xb1, 0xd8, 0x8c, 0x7a, 0x41, 0x26, 0xc3, 0x07, 0x67, 0x3f, 0xcc, 0xcd, 0x07, 0x5a, 0x55, 1858 0x15, 0xe5, 0xb1, 0xa5, 0xb5, 0x5b, 0x50, 0xc9, 0x4c, 0x9d, 0xab, 0x40, 0xfd, 0x23, 0x0f, 0x17, 1859 0x8e, 0x39, 0x2f, 0xa2, 0x4c, 0xf9, 0xb1, 0x67, 0x51, 0x3d, 0xc5, 0xa4, 0xb5, 0x82, 0x59, 0xf6, 1860 0x63, 0x2f, 0x81, 0x33, 0xb1, 0x27, 0x09, 0x40, 0x26, 0x03, 0xab, 0xe7, 0xe4, 0x6a, 0x2b, 0x89, 1861 0x54, 0xa4, 0x02, 0x43, 0x17, 0x61, 0x91, 0x7a, 0x78, 0xa8, 0xf6, 0x3d, 0x2f, 0x19, 0x14, 0xa5, 1862 0x40, 0x6f, 0x98, 0x87, 0xed, 0x27, 0xd4, 0x27, 0x16, 0x1f, 0x85, 0x0a, 0x33, 0xa7, 0xf6, 0x41, 1863 0xcb, 0xfb, 0xa3, 0x50, 0x22, 0x3b, 0x50, 0x72, 0x28, 0x3b, 0x48, 0xf2, 0xbc, 0x20, 0xf3, 0xfc, 1864 0xad, 0x93, 0x03, 0xd8, 0xa6, 0xec, 0x40, 0x67, 0x38, 0x38, 0xe3, 0x6f, 0x49, 0x9a, 0x59, 0x61, 1865 0x44, 0x88, 0x17, 0x72, 0x3a, 0x70, 0x89, 0x4c, 0xa4, 0xa2, 0x59, 0xa1, 0x6c, 0x77, 0x22, 0x44, 1866 0xbf, 0x80, 0x15, 0x0f, 0xfb, 0x78, 0x48, 0x1c, 0x6b, 0x28, 0xe2, 0x92, 0xb8, 0x5d, 0x90, 0x6e, 1867 0xdf, 0x3b, 0xd9, 0xed, 0x03, 0xa5, 0x95, 0x2e, 0x3e, 0xc8, 0x3b, 0x22, 0x43, 0x0f, 0xa1, 0x8c, 1868 0x6d, 0x9b, 0xb8, 0xa2, 0x39, 0x09, 0xa2, 0xe4, 0x66, 0x7e, 0xf7, 0x64, 0xbb, 0x9b, 0x13, 0x74, 1869 0x52, 0x31, 0xd3, 0x06, 0x1a, 0xbf, 0x35, 0x00, 0x1d, 0xf5, 0x2d, 0xb2, 0x77, 0xbc, 0x47, 0x9c, 1870 0x78, 0xa1, 0x8b, 0x39, 0x49, 0x9f, 0xdc, 0x95, 0x64, 0xb6, 0xaf, 0x27, 0x65, 0xcb, 0xf1, 0x11, 1871 0x5c, 0x1c, 0x6b, 0xa9, 0xe5, 0xab, 0x25, 0x64, 0x9a, 0x94, 0x3a, 0x4d, 0x27, 0x8e, 0xf2, 0x2d, 1872 0x3b, 0x96, 0x46, 0x04, 0xcb, 0x47, 0xe8, 0xa2, 0xeb, 0xb0, 0x92, 0x22, 0x3c, 0xd9, 0x6d, 0xc5, 1873 0x03, 0xa5, 0xe6, 0x92, 0x1d, 0x7f, 0x17, 0x96, 0xd3, 0x1a, 0xea, 0x90, 0xe6, 0x64, 0x22, 0xd6, 1874 0x70, 0xda, 0x7e, 0xec, 0xf3, 0xc6, 0xaf, 0x0d, 0x80, 0xc9, 0x96, 0xa3, 0xb7, 0xa0, 0x3a, 0x08, 1875 0x02, 0x6e, 0xc9, 0x94, 0x11, 0xbe, 0x74, 0xe6, 0x95, 0x85, 0x54, 0xe0, 0x84, 0x13, 0xf4, 0x0e, 1876 0x2c, 0x4f, 0x50, 0x8c, 0x3e, 0x25, 0xd6, 0x70, 0xa0, 0x53, 0xbd, 0x9a, 0x00, 0x7b, 0xf4, 0x29, 1877 0xb9, 0x3b, 0x10, 0x06, 0xc5, 0x89, 0x70, 0x03, 0x1b, 0xbb, 0x16, 0x63, 0x0e, 0xd3, 0x4c, 0xc4, 1878 0x91, 0xd8, 0x11, 0xc2, 0x1e, 0x73, 0x58, 0xe3, 0x77, 0x06, 0xd4, 0x4f, 0x2a, 0xe3, 0xa2, 0xe4, 1879 0x90, 0x2f, 0x89, 0x1d, 0x73, 0x3c, 0x70, 0x89, 0xb5, 0x4f, 0xdd, 0x64, 0x13, 0xaa, 0x13, 0xf1, 1880 0x1d, 0xea, 0x12, 0x74, 0x07, 0x96, 0x95, 0x44, 0xd4, 0x75, 0xd1, 0x5c, 0x06, 0xb1, 0x5a, 0x78, 1881 0x69, 0xe3, 0xb5, 0x24, 0x43, 0x92, 0xe6, 0xb3, 0xd9, 0xd6, 0xed, 0xab, 0x59, 0x1b, 0xeb, 0xf4, 1882 0x95, 0x4a, 0xe3, 0x0f, 0xf9, 0x71, 0xfb, 0xa1, 0x3a, 0x28, 0xb4, 0x05, 0x05, 0xd1, 0x43, 0x29, 1883 0xc7, 0xd5, 0x33, 0x74, 0x82, 0x4a, 0xaf, 0x29, 0xfe, 0x10, 0x53, 0xe9, 0xa2, 0x55, 0x98, 0x77, 1884 0x08, 0xc7, 0xd4, 0xd5, 0x89, 0xa0, 0x47, 0xa8, 0x0d, 0x35, 0x09, 0xb0, 0x18, 0xc7, 0x11, 0x97, 1885 0xc4, 0x75, 0xcb, 0xba, 0x76, 0x84, 0x75, 0x3f, 0x69, 0x99, 0x4d, 0xd9, 0x13, 0x92, 0x9e, 0x50, 1886 0x11, 0x42, 0xb4, 0x03, 0x45, 0x16, 0x0f, 0x14, 0xcb, 0x39, 0xc9, 0xf2, 0xfa, 0x99, 0x59, 0x6a, 1887 0x3d, 0x73, 0x6c, 0xa1, 0xf1, 0x08, 0x0a, 0x92, 0x3b, 0x2a, 0xc1, 0xc2, 0x5e, 0xf7, 0x7e, 0xf7, 1888 0xe1, 0xe3, 0x6e, 0xed, 0x15, 0x54, 0x86, 0xe2, 0x96, 0xd9, 0xd9, 0xec, 0x6f, 0x77, 0xef, 0xd6, 1889 0x0c, 0x31, 0x65, 0xee, 0x75, 0xbb, 0x62, 0x90, 0x43, 0x8b, 0x50, 0xe8, 0x98, 0xe6, 0x43, 0xb3, 1890 0x96, 0x17, 0xa8, 0x76, 0x67, 0xa7, 0x23, 0x51, 0x73, 0x62, 0xb4, 0xb7, 0xdb, 0x56, 0x3a, 0x85, 1891 0xc6, 0x0f, 0xa1, 0x98, 0x78, 0x43, 0x4b, 0x50, 0xda, 0xeb, 0xf6, 0x76, 0x3b, 0x5b, 0xdb, 0x77, 1892 0xb6, 0x3b, 0xed, 0xda, 0x2b, 0xa8, 0x02, 0x8b, 0x7b, 0xdd, 0x7b, 0x9d, 0xcd, 0x9d, 0xfe, 0xbd, 1893 0xcf, 0x6a, 0x06, 0xaa, 0x41, 0xb9, 0xd7, 0xdf, 0xdc, 0xe9, 0x58, 0xbd, 0xfe, 0x66, 0x7f, 0xaf, 1894 0x57, 0xcb, 0x35, 0xbe, 0xca, 0x41, 0x35, 0xdb, 0x47, 0x88, 0x8a, 0xab, 0xaa, 0xe4, 0x21, 0x89, 1895 0x18, 0x0d, 0xfc, 0xa4, 0x31, 0x94, 0xc2, 0x47, 0x4a, 0x86, 0x3e, 0x95, 0x8f, 0x89, 0x90, 0x44, 1896 0x9c, 0xea, 0x6a, 0x7b, 0xea, 0x1d, 0x92, 0x75, 0xd1, 0xdc, 0x1d, 0xab, 0xaa, 0x3b, 0x24, 0x65, 1897 0x0b, 0xf5, 0xe1, 0x42, 0x20, 0xaf, 0x7b, 0xec, 0x5a, 0x76, 0xe0, 0x85, 0x81, 0x4f, 0x7c, 0xae, 1898 0xae, 0xb8, 0xea, 0xc6, 0x95, 0x53, 0x36, 0x20, 0xc1, 0x9a, 0x28, 0xd1, 0x1f, 0x8b, 0xd8, 0xda, 1899 0x47, 0xb0, 0x34, 0xe5, 0xf4, 0x5c, 0xb7, 0xd3, 0x3f, 0x73, 0x50, 0xcd, 0x76, 0xe5, 0xe8, 0x67, 1900 0x50, 0x7e, 0xe2, 0xec, 0x33, 0x2b, 0xe9, 0xea, 0x0d, 0x19, 0x83, 0x0f, 0xcf, 0xda, 0xd5, 0x37, 1901 0xef, 0x39, 0xfb, 0x4c, 0x7f, 0xab, 0x20, 0x94, 0x9e, 0x4c, 0x24, 0xc2, 0xfa, 0x08, 0x47, 0xfe, 1902 0xd8, 0x7a, 0xee, 0x9c, 0xd6, 0x3f, 0xc3, 0x91, 0x9f, 0xb5, 0x3e, 0x9a, 0x48, 0xd6, 0x3e, 0x86, 1903 0xda, 0xb4, 0xfb, 0x59, 0xe1, 0xc8, 0xa7, 0xc2, 0x21, 0xf4, 0xa7, 0x1d, 0x9c, 0x47, 0xbf, 0xf1, 1904 0x17, 0x03, 0x56, 0xb6, 0x22, 0x82, 0x79, 0xd2, 0x59, 0x98, 0xe4, 0xf3, 0x98, 0x30, 0x3e, 0xeb, 1905 0x8d, 0xba, 0x0a, 0xf3, 0x11, 0x19, 0x8a, 0x9c, 0x54, 0x35, 0x54, 0x8f, 0xd0, 0x2d, 0x58, 0xd0, 1906 0x4f, 0x14, 0x5d, 0x9c, 0xde, 0x9c, 0x19, 0x28, 0x33, 0xd1, 0x10, 0x3e, 0x23, 0xe5, 0x5e, 0xf8, 1907 0x54, 0x57, 0xfe, 0xa2, 0x96, 0x6c, 0x3b, 0x8d, 0xff, 0xe4, 0x60, 0x65, 0x2f, 0x74, 0xfe, 0x07, 1908 0xae, 0x85, 0x0c, 0xd7, 0x33, 0xbc, 0xb3, 0x53, 0xcb, 0xc9, 0x9f, 0x7b, 0x39, 0x3f, 0x87, 0x4b, 1909 0xc3, 0x08, 0xdb, 0x64, 0x3f, 0x76, 0x2d, 0x87, 0xd8, 0x81, 0xe7, 0x51, 0xc6, 0xd2, 0xe5, 0x7b, 1910 0x7e, 0x56, 0xf9, 0xbe, 0x98, 0xe8, 0xb7, 0x53, 0xea, 0xba, 0x92, 0xa3, 0x5b, 0x50, 0x8a, 0x65, 1911 0x34, 0xe4, 0xef, 0x10, 0xfa, 0x01, 0x7e, 0xb4, 0xaa, 0xde, 0xa1, 0xc4, 0x75, 0x1e, 0x60, 0x76, 1912 0x60, 0x82, 0x82, 0x8b, 0xef, 0xa9, 0x50, 0x2f, 0x4c, 0x87, 0xfa, 0x1b, 0x03, 0x56, 0xda, 0xc4, 1913 0x25, 0x2f, 0x2b, 0x2d, 0xce, 0x10, 0xea, 0xe9, 0x97, 0xfb, 0xdc, 0xd1, 0x97, 0x7b, 0x96, 0x74, 1914 0x61, 0x9a, 0xb4, 0x07, 0xcb, 0x77, 0x09, 0xff, 0xb6, 0x08, 0x37, 0xfe, 0x68, 0xc0, 0x85, 0x1d, 1915 0xca, 0x12, 0x87, 0xec, 0xdc, 0x1e, 0xe7, 0x32, 0x1e, 0x57, 0x61, 0x7e, 0x9f, 0xba, 0x22, 0xd3, 1916 0x74, 0x96, 0xaa, 0x91, 0x68, 0x95, 0x43, 0x71, 0x07, 0x88, 0x56, 0x44, 0xf7, 0x17, 0x45, 0x21, 1917 0x10, 0x3d, 0x88, 0xf4, 0x25, 0x26, 0x79, 0x70, 0x40, 0x92, 0x25, 0x48, 0x78, 0x5f, 0x08, 0x1a, 1918 0xcf, 0x61, 0x25, 0xcb, 0x90, 0x85, 0x81, 0xcf, 0x44, 0x2f, 0x57, 0x4c, 0x7e, 0xb0, 0xd3, 0xd5, 1919 0xf2, 0x0c, 0x79, 0x3d, 0x56, 0x41, 0xdf, 0x81, 0x25, 0x9f, 0x7c, 0xc9, 0xad, 0x94, 0x6b, 0x15, 1920 0x9f, 0x8a, 0x10, 0xef, 0x8e, 0xdd, 0x47, 0xb0, 0xda, 0xa6, 0x78, 0xe8, 0x07, 0xec, 0x5b, 0x4b, 1921 0xa3, 0xc6, 0x0f, 0x8e, 0xf1, 0xc9, 0x62, 0x97, 0x33, 0xe1, 0x33, 0x88, 0x79, 0x18, 0xf3, 0x54, 1922 0x8b, 0xb9, 0xa8, 0x24, 0x7b, 0x11, 0xdd, 0xf8, 0xa6, 0x08, 0xcb, 0x93, 0xd7, 0x15, 0x8f, 0x02, 1923 0xd7, 0x25, 0x11, 0xfa, 0xca, 0x80, 0x4a, 0xa6, 0x3e, 0xa2, 0xe6, 0x29, 0x91, 0x3a, 0xa6, 0x90, 1924 0xae, 0x5d, 0x4a, 0xf0, 0xa9, 0x5f, 0x20, 0x9b, 0x0f, 0x93, 0x5f, 0x20, 0x1b, 0xed, 0x5f, 0xfd, 1925 0xeb, 0xdf, 0xbf, 0xcf, 0x7d, 0xdc, 0x78, 0xbf, 0x75, 0x78, 0xa3, 0xa5, 0x23, 0xc0, 0x5a, 0xcf, 1926 0x26, 0xd1, 0x79, 0xde, 0x52, 0x8b, 0x67, 0xad, 0x67, 0xea, 0xe3, 0xf9, 0xf8, 0xc7, 0xd6, 0x9b, 1927 0xe3, 0x52, 0xf3, 0x57, 0x03, 0x2a, 0x99, 0xd2, 0x78, 0x1a, 0xcd, 0xe3, 0x6a, 0xe8, 0x2c, 0x9a, 1928 0x3d, 0x49, 0xf3, 0xc1, 0xc6, 0xed, 0x17, 0xa0, 0xd9, 0x7a, 0x96, 0xde, 0xb4, 0xe7, 0x13, 0xd6, 1929 0x5f, 0x1b, 0x50, 0xc9, 0x54, 0x99, 0xd3, 0x58, 0x1f, 0x57, 0x8e, 0x66, 0xb1, 0xfe, 0xb1, 0x64, 1930 0xdd, 0xbe, 0xf6, 0x12, 0x58, 0xa3, 0x3f, 0x1b, 0x00, 0x93, 0xf2, 0x82, 0x4e, 0x79, 0x96, 0x1d, 1931 0x29, 0x42, 0x6b, 0xb3, 0x4f, 0x57, 0x42, 0x15, 0xbd, 0x0c, 0xaa, 0x5f, 0x1b, 0x50, 0x4e, 0x9f, 1932 0x7b, 0x74, 0x4a, 0x4f, 0x7f, 0x4c, 0x05, 0x5b, 0x6b, 0x9e, 0x15, 0xae, 0xca, 0x49, 0xe3, 0x96, 1933 0xe4, 0xfe, 0x7d, 0xf4, 0x22, 0x39, 0x8c, 0xfe, 0x6e, 0xc0, 0xd2, 0xd4, 0x89, 0x45, 0xd7, 0x4f, 1934 0x7b, 0xc2, 0x1f, 0x57, 0x50, 0x66, 0x25, 0xc2, 0x23, 0xc9, 0x70, 0xb7, 0x71, 0xff, 0x25, 0xa4, 1935 0xaf, 0xa3, 0x19, 0xdc, 0x34, 0xae, 0xdd, 0xfe, 0x1c, 0x5e, 0xb7, 0x03, 0xef, 0x44, 0xb6, 0xb7, 1936 0x93, 0xa7, 0x16, 0xdb, 0x15, 0xd7, 0xf1, 0xae, 0xf1, 0xd3, 0x4f, 0x34, 0x74, 0x18, 0xb8, 0xd8, 1937 0x1f, 0x36, 0x83, 0x68, 0xd8, 0x1a, 0x12, 0x5f, 0x5e, 0xd6, 0x2d, 0x35, 0x85, 0x43, 0xca, 0x8e, 1938 0xfe, 0x53, 0xe3, 0x56, 0xf2, 0x3d, 0x98, 0x97, 0xe0, 0xf7, 0xff, 0x1b, 0x00, 0x00, 0xff, 0xff, 1939 0x20, 0x87, 0x61, 0x95, 0x8c, 0x19, 0x00, 0x00, 1940} 1941 1942// Reference imports to suppress errors if they are not otherwise used. 1943var _ context.Context 1944var _ grpc.ClientConn 1945 1946// This is a compile-time assertion to ensure that this generated file 1947// is compatible with the grpc package it is being compiled against. 1948const _ = grpc.SupportPackageIsVersion4 1949 1950// ClusterControllerClient is the client API for ClusterController service. 1951// 1952// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1953type ClusterControllerClient interface { 1954 // Creates a cluster in a project. 1955 CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1956 // Updates a cluster in a project. 1957 UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1958 // Deletes a cluster in a project. 1959 DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1960 // Gets the resource representation for a cluster in a project. 1961 GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) 1962 // Lists all regions/{region}/clusters in a project. 1963 ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) 1964 // Gets cluster diagnostic information. 1965 // After the operation completes, the Operation.response field 1966 // contains `DiagnoseClusterOutputLocation`. 1967 DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 1968} 1969 1970type clusterControllerClient struct { 1971 cc *grpc.ClientConn 1972} 1973 1974func NewClusterControllerClient(cc *grpc.ClientConn) ClusterControllerClient { 1975 return &clusterControllerClient{cc} 1976} 1977 1978func (c *clusterControllerClient) CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1979 out := new(longrunning.Operation) 1980 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/CreateCluster", in, out, opts...) 1981 if err != nil { 1982 return nil, err 1983 } 1984 return out, nil 1985} 1986 1987func (c *clusterControllerClient) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1988 out := new(longrunning.Operation) 1989 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/UpdateCluster", in, out, opts...) 1990 if err != nil { 1991 return nil, err 1992 } 1993 return out, nil 1994} 1995 1996func (c *clusterControllerClient) DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 1997 out := new(longrunning.Operation) 1998 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/DeleteCluster", in, out, opts...) 1999 if err != nil { 2000 return nil, err 2001 } 2002 return out, nil 2003} 2004 2005func (c *clusterControllerClient) GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) { 2006 out := new(Cluster) 2007 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/GetCluster", in, out, opts...) 2008 if err != nil { 2009 return nil, err 2010 } 2011 return out, nil 2012} 2013 2014func (c *clusterControllerClient) ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) { 2015 out := new(ListClustersResponse) 2016 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/ListClusters", in, out, opts...) 2017 if err != nil { 2018 return nil, err 2019 } 2020 return out, nil 2021} 2022 2023func (c *clusterControllerClient) DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2024 out := new(longrunning.Operation) 2025 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/DiagnoseCluster", in, out, opts...) 2026 if err != nil { 2027 return nil, err 2028 } 2029 return out, nil 2030} 2031 2032// ClusterControllerServer is the server API for ClusterController service. 2033type ClusterControllerServer interface { 2034 // Creates a cluster in a project. 2035 CreateCluster(context.Context, *CreateClusterRequest) (*longrunning.Operation, error) 2036 // Updates a cluster in a project. 2037 UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunning.Operation, error) 2038 // Deletes a cluster in a project. 2039 DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunning.Operation, error) 2040 // Gets the resource representation for a cluster in a project. 2041 GetCluster(context.Context, *GetClusterRequest) (*Cluster, error) 2042 // Lists all regions/{region}/clusters in a project. 2043 ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error) 2044 // Gets cluster diagnostic information. 2045 // After the operation completes, the Operation.response field 2046 // contains `DiagnoseClusterOutputLocation`. 2047 DiagnoseCluster(context.Context, *DiagnoseClusterRequest) (*longrunning.Operation, error) 2048} 2049 2050func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer) { 2051 s.RegisterService(&_ClusterController_serviceDesc, srv) 2052} 2053 2054func _ClusterController_CreateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2055 in := new(CreateClusterRequest) 2056 if err := dec(in); err != nil { 2057 return nil, err 2058 } 2059 if interceptor == nil { 2060 return srv.(ClusterControllerServer).CreateCluster(ctx, in) 2061 } 2062 info := &grpc.UnaryServerInfo{ 2063 Server: srv, 2064 FullMethod: "/google.cloud.dataproc.v1.ClusterController/CreateCluster", 2065 } 2066 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2067 return srv.(ClusterControllerServer).CreateCluster(ctx, req.(*CreateClusterRequest)) 2068 } 2069 return interceptor(ctx, in, info, handler) 2070} 2071 2072func _ClusterController_UpdateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2073 in := new(UpdateClusterRequest) 2074 if err := dec(in); err != nil { 2075 return nil, err 2076 } 2077 if interceptor == nil { 2078 return srv.(ClusterControllerServer).UpdateCluster(ctx, in) 2079 } 2080 info := &grpc.UnaryServerInfo{ 2081 Server: srv, 2082 FullMethod: "/google.cloud.dataproc.v1.ClusterController/UpdateCluster", 2083 } 2084 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2085 return srv.(ClusterControllerServer).UpdateCluster(ctx, req.(*UpdateClusterRequest)) 2086 } 2087 return interceptor(ctx, in, info, handler) 2088} 2089 2090func _ClusterController_DeleteCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2091 in := new(DeleteClusterRequest) 2092 if err := dec(in); err != nil { 2093 return nil, err 2094 } 2095 if interceptor == nil { 2096 return srv.(ClusterControllerServer).DeleteCluster(ctx, in) 2097 } 2098 info := &grpc.UnaryServerInfo{ 2099 Server: srv, 2100 FullMethod: "/google.cloud.dataproc.v1.ClusterController/DeleteCluster", 2101 } 2102 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2103 return srv.(ClusterControllerServer).DeleteCluster(ctx, req.(*DeleteClusterRequest)) 2104 } 2105 return interceptor(ctx, in, info, handler) 2106} 2107 2108func _ClusterController_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2109 in := new(GetClusterRequest) 2110 if err := dec(in); err != nil { 2111 return nil, err 2112 } 2113 if interceptor == nil { 2114 return srv.(ClusterControllerServer).GetCluster(ctx, in) 2115 } 2116 info := &grpc.UnaryServerInfo{ 2117 Server: srv, 2118 FullMethod: "/google.cloud.dataproc.v1.ClusterController/GetCluster", 2119 } 2120 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2121 return srv.(ClusterControllerServer).GetCluster(ctx, req.(*GetClusterRequest)) 2122 } 2123 return interceptor(ctx, in, info, handler) 2124} 2125 2126func _ClusterController_ListClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2127 in := new(ListClustersRequest) 2128 if err := dec(in); err != nil { 2129 return nil, err 2130 } 2131 if interceptor == nil { 2132 return srv.(ClusterControllerServer).ListClusters(ctx, in) 2133 } 2134 info := &grpc.UnaryServerInfo{ 2135 Server: srv, 2136 FullMethod: "/google.cloud.dataproc.v1.ClusterController/ListClusters", 2137 } 2138 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2139 return srv.(ClusterControllerServer).ListClusters(ctx, req.(*ListClustersRequest)) 2140 } 2141 return interceptor(ctx, in, info, handler) 2142} 2143 2144func _ClusterController_DiagnoseCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2145 in := new(DiagnoseClusterRequest) 2146 if err := dec(in); err != nil { 2147 return nil, err 2148 } 2149 if interceptor == nil { 2150 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, in) 2151 } 2152 info := &grpc.UnaryServerInfo{ 2153 Server: srv, 2154 FullMethod: "/google.cloud.dataproc.v1.ClusterController/DiagnoseCluster", 2155 } 2156 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2157 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, req.(*DiagnoseClusterRequest)) 2158 } 2159 return interceptor(ctx, in, info, handler) 2160} 2161 2162var _ClusterController_serviceDesc = grpc.ServiceDesc{ 2163 ServiceName: "google.cloud.dataproc.v1.ClusterController", 2164 HandlerType: (*ClusterControllerServer)(nil), 2165 Methods: []grpc.MethodDesc{ 2166 { 2167 MethodName: "CreateCluster", 2168 Handler: _ClusterController_CreateCluster_Handler, 2169 }, 2170 { 2171 MethodName: "UpdateCluster", 2172 Handler: _ClusterController_UpdateCluster_Handler, 2173 }, 2174 { 2175 MethodName: "DeleteCluster", 2176 Handler: _ClusterController_DeleteCluster_Handler, 2177 }, 2178 { 2179 MethodName: "GetCluster", 2180 Handler: _ClusterController_GetCluster_Handler, 2181 }, 2182 { 2183 MethodName: "ListClusters", 2184 Handler: _ClusterController_ListClusters_Handler, 2185 }, 2186 { 2187 MethodName: "DiagnoseCluster", 2188 Handler: _ClusterController_DiagnoseCluster_Handler, 2189 }, 2190 }, 2191 Streams: []grpc.StreamDesc{}, 2192 Metadata: "google/cloud/dataproc/v1/clusters.proto", 2193} 2194