1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/dataproc/v1beta2/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 codes "google.golang.org/grpc/codes" 19 status "google.golang.org/grpc/status" 20) 21 22// Reference imports to suppress errors if they are not otherwise used. 23var _ = proto.Marshal 24var _ = fmt.Errorf 25var _ = math.Inf 26 27// This is a compile-time assertion to ensure that this generated file 28// is compatible with the proto package it is being compiled against. 29// A compilation error at this line likely means your copy of the 30// proto package needs to be updated. 31const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 32 33// The cluster state. 34type ClusterStatus_State int32 35 36const ( 37 // The cluster state is unknown. 38 ClusterStatus_UNKNOWN ClusterStatus_State = 0 39 // The cluster is being created and set up. It is not ready for use. 40 ClusterStatus_CREATING ClusterStatus_State = 1 41 // The cluster is currently running and healthy. It is ready for use. 42 ClusterStatus_RUNNING ClusterStatus_State = 2 43 // The cluster encountered an error. It is not ready for use. 44 ClusterStatus_ERROR ClusterStatus_State = 3 45 // The cluster is being deleted. It cannot be used. 46 ClusterStatus_DELETING ClusterStatus_State = 4 47 // The cluster is being updated. It continues to accept and process jobs. 48 ClusterStatus_UPDATING ClusterStatus_State = 5 49) 50 51var ClusterStatus_State_name = map[int32]string{ 52 0: "UNKNOWN", 53 1: "CREATING", 54 2: "RUNNING", 55 3: "ERROR", 56 4: "DELETING", 57 5: "UPDATING", 58} 59 60var ClusterStatus_State_value = map[string]int32{ 61 "UNKNOWN": 0, 62 "CREATING": 1, 63 "RUNNING": 2, 64 "ERROR": 3, 65 "DELETING": 4, 66 "UPDATING": 5, 67} 68 69func (x ClusterStatus_State) String() string { 70 return proto.EnumName(ClusterStatus_State_name, int32(x)) 71} 72 73func (ClusterStatus_State) EnumDescriptor() ([]byte, []int) { 74 return fileDescriptor_abc993f8d220b626, []int{14, 0} 75} 76 77// The cluster substate. 78type ClusterStatus_Substate int32 79 80const ( 81 // The cluster substate is unknown. 82 ClusterStatus_UNSPECIFIED ClusterStatus_Substate = 0 83 // The cluster is known to be in an unhealthy state 84 // (for example, critical daemons are not running or HDFS capacity is 85 // exhausted). 86 // 87 // Applies to RUNNING state. 88 ClusterStatus_UNHEALTHY ClusterStatus_Substate = 1 89 // The agent-reported status is out of date (may occur if 90 // Dataproc loses communication with Agent). 91 // 92 // Applies to RUNNING state. 93 ClusterStatus_STALE_STATUS ClusterStatus_Substate = 2 94) 95 96var ClusterStatus_Substate_name = map[int32]string{ 97 0: "UNSPECIFIED", 98 1: "UNHEALTHY", 99 2: "STALE_STATUS", 100} 101 102var ClusterStatus_Substate_value = map[string]int32{ 103 "UNSPECIFIED": 0, 104 "UNHEALTHY": 1, 105 "STALE_STATUS": 2, 106} 107 108func (x ClusterStatus_Substate) String() string { 109 return proto.EnumName(ClusterStatus_Substate_name, int32(x)) 110} 111 112func (ClusterStatus_Substate) EnumDescriptor() ([]byte, []int) { 113 return fileDescriptor_abc993f8d220b626, []int{14, 1} 114} 115 116// Indicates whether to consume capacity from an reservation or not. 117type ReservationAffinity_Type int32 118 119const ( 120 ReservationAffinity_TYPE_UNSPECIFIED ReservationAffinity_Type = 0 121 // Do not consume from any allocated capacity. 122 ReservationAffinity_NO_RESERVATION ReservationAffinity_Type = 1 123 // Consume any reservation available. 124 ReservationAffinity_ANY_RESERVATION ReservationAffinity_Type = 2 125 // Must consume from a specific reservation. Must specify key value fields 126 // for specifying the reservations. 127 ReservationAffinity_SPECIFIC_RESERVATION ReservationAffinity_Type = 3 128) 129 130var ReservationAffinity_Type_name = map[int32]string{ 131 0: "TYPE_UNSPECIFIED", 132 1: "NO_RESERVATION", 133 2: "ANY_RESERVATION", 134 3: "SPECIFIC_RESERVATION", 135} 136 137var ReservationAffinity_Type_value = map[string]int32{ 138 "TYPE_UNSPECIFIED": 0, 139 "NO_RESERVATION": 1, 140 "ANY_RESERVATION": 2, 141 "SPECIFIC_RESERVATION": 3, 142} 143 144func (x ReservationAffinity_Type) String() string { 145 return proto.EnumName(ReservationAffinity_Type_name, int32(x)) 146} 147 148func (ReservationAffinity_Type) EnumDescriptor() ([]byte, []int) { 149 return fileDescriptor_abc993f8d220b626, []int{25, 0} 150} 151 152// Describes the identifying information, config, and status of 153// a cluster of Compute Engine instances. 154type Cluster struct { 155 // Required. The Google Cloud Platform project ID that the cluster belongs to. 156 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 157 // Required. The cluster name. Cluster names within a project must be 158 // unique. Names of deleted clusters can be reused. 159 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 160 // Required. The cluster config. Note that Dataproc may set 161 // default values, and values may change when clusters are updated. 162 Config *ClusterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` 163 // Optional. The labels to associate with this cluster. 164 // Label **keys** must contain 1 to 63 characters, and must conform to 165 // [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). 166 // Label **values** may be empty, but, if present, must contain 1 to 63 167 // characters, and must conform to [RFC 168 // 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be 169 // associated with a cluster. 170 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"` 171 // Output only. Cluster status. 172 Status *ClusterStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` 173 // Output only. The previous cluster status. 174 StatusHistory []*ClusterStatus `protobuf:"bytes,7,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"` 175 // Output only. A cluster UUID (Unique Universal Identifier). Dataproc 176 // generates this value when it creates the cluster. 177 ClusterUuid string `protobuf:"bytes,6,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"` 178 // Output only. Contains cluster daemon metrics such as HDFS and YARN stats. 179 // 180 // **Beta Feature**: This report is available for testing purposes only. It 181 // may be changed before final release. 182 Metrics *ClusterMetrics `protobuf:"bytes,9,opt,name=metrics,proto3" json:"metrics,omitempty"` 183 XXX_NoUnkeyedLiteral struct{} `json:"-"` 184 XXX_unrecognized []byte `json:"-"` 185 XXX_sizecache int32 `json:"-"` 186} 187 188func (m *Cluster) Reset() { *m = Cluster{} } 189func (m *Cluster) String() string { return proto.CompactTextString(m) } 190func (*Cluster) ProtoMessage() {} 191func (*Cluster) Descriptor() ([]byte, []int) { 192 return fileDescriptor_abc993f8d220b626, []int{0} 193} 194 195func (m *Cluster) XXX_Unmarshal(b []byte) error { 196 return xxx_messageInfo_Cluster.Unmarshal(m, b) 197} 198func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 199 return xxx_messageInfo_Cluster.Marshal(b, m, deterministic) 200} 201func (m *Cluster) XXX_Merge(src proto.Message) { 202 xxx_messageInfo_Cluster.Merge(m, src) 203} 204func (m *Cluster) XXX_Size() int { 205 return xxx_messageInfo_Cluster.Size(m) 206} 207func (m *Cluster) XXX_DiscardUnknown() { 208 xxx_messageInfo_Cluster.DiscardUnknown(m) 209} 210 211var xxx_messageInfo_Cluster proto.InternalMessageInfo 212 213func (m *Cluster) GetProjectId() string { 214 if m != nil { 215 return m.ProjectId 216 } 217 return "" 218} 219 220func (m *Cluster) GetClusterName() string { 221 if m != nil { 222 return m.ClusterName 223 } 224 return "" 225} 226 227func (m *Cluster) GetConfig() *ClusterConfig { 228 if m != nil { 229 return m.Config 230 } 231 return nil 232} 233 234func (m *Cluster) GetLabels() map[string]string { 235 if m != nil { 236 return m.Labels 237 } 238 return nil 239} 240 241func (m *Cluster) GetStatus() *ClusterStatus { 242 if m != nil { 243 return m.Status 244 } 245 return nil 246} 247 248func (m *Cluster) GetStatusHistory() []*ClusterStatus { 249 if m != nil { 250 return m.StatusHistory 251 } 252 return nil 253} 254 255func (m *Cluster) GetClusterUuid() string { 256 if m != nil { 257 return m.ClusterUuid 258 } 259 return "" 260} 261 262func (m *Cluster) GetMetrics() *ClusterMetrics { 263 if m != nil { 264 return m.Metrics 265 } 266 return nil 267} 268 269// The cluster config. 270type ClusterConfig struct { 271 // Optional. A Cloud Storage bucket used to stage job 272 // dependencies, config files, and job driver console output. 273 // If you do not specify a staging bucket, Cloud 274 // Dataproc will determine a Cloud Storage location (US, 275 // ASIA, or EU) for your cluster's staging bucket according to the 276 // Compute Engine zone where your cluster is deployed, and then create 277 // and manage this project-level, per-location bucket (see 278 // [Dataproc staging 279 // bucket](/dataproc/docs/concepts/configuring-clusters/staging-bucket)). 280 ConfigBucket string `protobuf:"bytes,1,opt,name=config_bucket,json=configBucket,proto3" json:"config_bucket,omitempty"` 281 // Optional. The shared Compute Engine config settings for 282 // all instances in a cluster. 283 GceClusterConfig *GceClusterConfig `protobuf:"bytes,8,opt,name=gce_cluster_config,json=gceClusterConfig,proto3" json:"gce_cluster_config,omitempty"` 284 // Optional. The Compute Engine config settings for 285 // the master instance in a cluster. 286 MasterConfig *InstanceGroupConfig `protobuf:"bytes,9,opt,name=master_config,json=masterConfig,proto3" json:"master_config,omitempty"` 287 // Optional. The Compute Engine config settings for 288 // worker instances in a cluster. 289 WorkerConfig *InstanceGroupConfig `protobuf:"bytes,10,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"` 290 // Optional. The Compute Engine config settings for 291 // additional worker instances in a cluster. 292 SecondaryWorkerConfig *InstanceGroupConfig `protobuf:"bytes,12,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"` 293 // Optional. The config settings for software inside the cluster. 294 SoftwareConfig *SoftwareConfig `protobuf:"bytes,13,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"` 295 // Optional. The config setting for auto delete cluster schedule. 296 LifecycleConfig *LifecycleConfig `protobuf:"bytes,14,opt,name=lifecycle_config,json=lifecycleConfig,proto3" json:"lifecycle_config,omitempty"` 297 // Optional. Commands to execute on each node after config is 298 // completed. By default, executables are run on master and all worker nodes. 299 // You can test a node's <code>role</code> metadata to run an executable on 300 // a master or worker node, as shown below using `curl` (you can also use 301 // `wget`): 302 // 303 // ROLE=$(curl -H Metadata-Flavor:Google 304 // http://metadata/computeMetadata/v1beta2/instance/attributes/dataproc-role) 305 // if [[ "${ROLE}" == 'Master' ]]; then 306 // ... master specific actions ... 307 // else 308 // ... worker specific actions ... 309 // fi 310 InitializationActions []*NodeInitializationAction `protobuf:"bytes,11,rep,name=initialization_actions,json=initializationActions,proto3" json:"initialization_actions,omitempty"` 311 // Optional. Encryption settings for the cluster. 312 EncryptionConfig *EncryptionConfig `protobuf:"bytes,15,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"` 313 // Optional. Autoscaling config for the policy associated with the cluster. 314 // Cluster does not autoscale if this field is unset. 315 AutoscalingConfig *AutoscalingConfig `protobuf:"bytes,16,opt,name=autoscaling_config,json=autoscalingConfig,proto3" json:"autoscaling_config,omitempty"` 316 // Optional. Port/endpoint configuration for this cluster 317 EndpointConfig *EndpointConfig `protobuf:"bytes,17,opt,name=endpoint_config,json=endpointConfig,proto3" json:"endpoint_config,omitempty"` 318 // Optional. Security related configuration. 319 SecurityConfig *SecurityConfig `protobuf:"bytes,18,opt,name=security_config,json=securityConfig,proto3" json:"security_config,omitempty"` 320 XXX_NoUnkeyedLiteral struct{} `json:"-"` 321 XXX_unrecognized []byte `json:"-"` 322 XXX_sizecache int32 `json:"-"` 323} 324 325func (m *ClusterConfig) Reset() { *m = ClusterConfig{} } 326func (m *ClusterConfig) String() string { return proto.CompactTextString(m) } 327func (*ClusterConfig) ProtoMessage() {} 328func (*ClusterConfig) Descriptor() ([]byte, []int) { 329 return fileDescriptor_abc993f8d220b626, []int{1} 330} 331 332func (m *ClusterConfig) XXX_Unmarshal(b []byte) error { 333 return xxx_messageInfo_ClusterConfig.Unmarshal(m, b) 334} 335func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 336 return xxx_messageInfo_ClusterConfig.Marshal(b, m, deterministic) 337} 338func (m *ClusterConfig) XXX_Merge(src proto.Message) { 339 xxx_messageInfo_ClusterConfig.Merge(m, src) 340} 341func (m *ClusterConfig) XXX_Size() int { 342 return xxx_messageInfo_ClusterConfig.Size(m) 343} 344func (m *ClusterConfig) XXX_DiscardUnknown() { 345 xxx_messageInfo_ClusterConfig.DiscardUnknown(m) 346} 347 348var xxx_messageInfo_ClusterConfig proto.InternalMessageInfo 349 350func (m *ClusterConfig) GetConfigBucket() string { 351 if m != nil { 352 return m.ConfigBucket 353 } 354 return "" 355} 356 357func (m *ClusterConfig) GetGceClusterConfig() *GceClusterConfig { 358 if m != nil { 359 return m.GceClusterConfig 360 } 361 return nil 362} 363 364func (m *ClusterConfig) GetMasterConfig() *InstanceGroupConfig { 365 if m != nil { 366 return m.MasterConfig 367 } 368 return nil 369} 370 371func (m *ClusterConfig) GetWorkerConfig() *InstanceGroupConfig { 372 if m != nil { 373 return m.WorkerConfig 374 } 375 return nil 376} 377 378func (m *ClusterConfig) GetSecondaryWorkerConfig() *InstanceGroupConfig { 379 if m != nil { 380 return m.SecondaryWorkerConfig 381 } 382 return nil 383} 384 385func (m *ClusterConfig) GetSoftwareConfig() *SoftwareConfig { 386 if m != nil { 387 return m.SoftwareConfig 388 } 389 return nil 390} 391 392func (m *ClusterConfig) GetLifecycleConfig() *LifecycleConfig { 393 if m != nil { 394 return m.LifecycleConfig 395 } 396 return nil 397} 398 399func (m *ClusterConfig) GetInitializationActions() []*NodeInitializationAction { 400 if m != nil { 401 return m.InitializationActions 402 } 403 return nil 404} 405 406func (m *ClusterConfig) GetEncryptionConfig() *EncryptionConfig { 407 if m != nil { 408 return m.EncryptionConfig 409 } 410 return nil 411} 412 413func (m *ClusterConfig) GetAutoscalingConfig() *AutoscalingConfig { 414 if m != nil { 415 return m.AutoscalingConfig 416 } 417 return nil 418} 419 420func (m *ClusterConfig) GetEndpointConfig() *EndpointConfig { 421 if m != nil { 422 return m.EndpointConfig 423 } 424 return nil 425} 426 427func (m *ClusterConfig) GetSecurityConfig() *SecurityConfig { 428 if m != nil { 429 return m.SecurityConfig 430 } 431 return nil 432} 433 434// Endpoint config for this cluster 435type EndpointConfig struct { 436 // Output only. The map of port descriptions to URLs. Will only be populated 437 // if enable_http_port_access is true. 438 HttpPorts map[string]string `protobuf:"bytes,1,rep,name=http_ports,json=httpPorts,proto3" json:"http_ports,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 439 // Optional. If true, enable http access to specific ports on the cluster 440 // from external sources. Defaults to false. 441 EnableHttpPortAccess bool `protobuf:"varint,2,opt,name=enable_http_port_access,json=enableHttpPortAccess,proto3" json:"enable_http_port_access,omitempty"` 442 XXX_NoUnkeyedLiteral struct{} `json:"-"` 443 XXX_unrecognized []byte `json:"-"` 444 XXX_sizecache int32 `json:"-"` 445} 446 447func (m *EndpointConfig) Reset() { *m = EndpointConfig{} } 448func (m *EndpointConfig) String() string { return proto.CompactTextString(m) } 449func (*EndpointConfig) ProtoMessage() {} 450func (*EndpointConfig) Descriptor() ([]byte, []int) { 451 return fileDescriptor_abc993f8d220b626, []int{2} 452} 453 454func (m *EndpointConfig) XXX_Unmarshal(b []byte) error { 455 return xxx_messageInfo_EndpointConfig.Unmarshal(m, b) 456} 457func (m *EndpointConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 458 return xxx_messageInfo_EndpointConfig.Marshal(b, m, deterministic) 459} 460func (m *EndpointConfig) XXX_Merge(src proto.Message) { 461 xxx_messageInfo_EndpointConfig.Merge(m, src) 462} 463func (m *EndpointConfig) XXX_Size() int { 464 return xxx_messageInfo_EndpointConfig.Size(m) 465} 466func (m *EndpointConfig) XXX_DiscardUnknown() { 467 xxx_messageInfo_EndpointConfig.DiscardUnknown(m) 468} 469 470var xxx_messageInfo_EndpointConfig proto.InternalMessageInfo 471 472func (m *EndpointConfig) GetHttpPorts() map[string]string { 473 if m != nil { 474 return m.HttpPorts 475 } 476 return nil 477} 478 479func (m *EndpointConfig) GetEnableHttpPortAccess() bool { 480 if m != nil { 481 return m.EnableHttpPortAccess 482 } 483 return false 484} 485 486// Autoscaling Policy config associated with the cluster. 487type AutoscalingConfig struct { 488 // Optional. The autoscaling policy used by the cluster. 489 // 490 // Only resource names including projectid and location (region) are valid. 491 // Examples: 492 // 493 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]` 494 // * `projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]` 495 // 496 // Note that the policy must be in the same project and Dataproc region. 497 PolicyUri string `protobuf:"bytes,1,opt,name=policy_uri,json=policyUri,proto3" json:"policy_uri,omitempty"` 498 XXX_NoUnkeyedLiteral struct{} `json:"-"` 499 XXX_unrecognized []byte `json:"-"` 500 XXX_sizecache int32 `json:"-"` 501} 502 503func (m *AutoscalingConfig) Reset() { *m = AutoscalingConfig{} } 504func (m *AutoscalingConfig) String() string { return proto.CompactTextString(m) } 505func (*AutoscalingConfig) ProtoMessage() {} 506func (*AutoscalingConfig) Descriptor() ([]byte, []int) { 507 return fileDescriptor_abc993f8d220b626, []int{3} 508} 509 510func (m *AutoscalingConfig) XXX_Unmarshal(b []byte) error { 511 return xxx_messageInfo_AutoscalingConfig.Unmarshal(m, b) 512} 513func (m *AutoscalingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 514 return xxx_messageInfo_AutoscalingConfig.Marshal(b, m, deterministic) 515} 516func (m *AutoscalingConfig) XXX_Merge(src proto.Message) { 517 xxx_messageInfo_AutoscalingConfig.Merge(m, src) 518} 519func (m *AutoscalingConfig) XXX_Size() int { 520 return xxx_messageInfo_AutoscalingConfig.Size(m) 521} 522func (m *AutoscalingConfig) XXX_DiscardUnknown() { 523 xxx_messageInfo_AutoscalingConfig.DiscardUnknown(m) 524} 525 526var xxx_messageInfo_AutoscalingConfig proto.InternalMessageInfo 527 528func (m *AutoscalingConfig) GetPolicyUri() string { 529 if m != nil { 530 return m.PolicyUri 531 } 532 return "" 533} 534 535// Encryption settings for the cluster. 536type EncryptionConfig struct { 537 // Optional. The Cloud KMS key name to use for PD disk encryption for all 538 // instances in the cluster. 539 GcePdKmsKeyName string `protobuf:"bytes,1,opt,name=gce_pd_kms_key_name,json=gcePdKmsKeyName,proto3" json:"gce_pd_kms_key_name,omitempty"` 540 XXX_NoUnkeyedLiteral struct{} `json:"-"` 541 XXX_unrecognized []byte `json:"-"` 542 XXX_sizecache int32 `json:"-"` 543} 544 545func (m *EncryptionConfig) Reset() { *m = EncryptionConfig{} } 546func (m *EncryptionConfig) String() string { return proto.CompactTextString(m) } 547func (*EncryptionConfig) ProtoMessage() {} 548func (*EncryptionConfig) Descriptor() ([]byte, []int) { 549 return fileDescriptor_abc993f8d220b626, []int{4} 550} 551 552func (m *EncryptionConfig) XXX_Unmarshal(b []byte) error { 553 return xxx_messageInfo_EncryptionConfig.Unmarshal(m, b) 554} 555func (m *EncryptionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 556 return xxx_messageInfo_EncryptionConfig.Marshal(b, m, deterministic) 557} 558func (m *EncryptionConfig) XXX_Merge(src proto.Message) { 559 xxx_messageInfo_EncryptionConfig.Merge(m, src) 560} 561func (m *EncryptionConfig) XXX_Size() int { 562 return xxx_messageInfo_EncryptionConfig.Size(m) 563} 564func (m *EncryptionConfig) XXX_DiscardUnknown() { 565 xxx_messageInfo_EncryptionConfig.DiscardUnknown(m) 566} 567 568var xxx_messageInfo_EncryptionConfig proto.InternalMessageInfo 569 570func (m *EncryptionConfig) GetGcePdKmsKeyName() string { 571 if m != nil { 572 return m.GcePdKmsKeyName 573 } 574 return "" 575} 576 577// Common config settings for resources of Compute Engine cluster 578// instances, applicable to all instances in the cluster. 579type GceClusterConfig struct { 580 // Optional. The zone where the Compute Engine cluster will be located. 581 // On a create request, it is required in the "global" region. If omitted 582 // in a non-global Dataproc region, the service will pick a zone in the 583 // corresponding Compute Engine region. On a get request, zone will always be 584 // present. 585 // 586 // A full URL, partial URI, or short name are valid. Examples: 587 // 588 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]` 589 // * `projects/[project_id]/zones/[zone]` 590 // * `us-central1-f` 591 ZoneUri string `protobuf:"bytes,1,opt,name=zone_uri,json=zoneUri,proto3" json:"zone_uri,omitempty"` 592 // Optional. The Compute Engine network to be used for machine 593 // communications. Cannot be specified with subnetwork_uri. If neither 594 // `network_uri` nor `subnetwork_uri` is specified, the "default" network of 595 // the project is used, if it exists. Cannot be a "Custom Subnet Network" (see 596 // [Using Subnetworks](/compute/docs/subnetworks) for more information). 597 // 598 // A full URL, partial URI, or short name are valid. Examples: 599 // 600 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default` 601 // * `projects/[project_id]/regions/global/default` 602 // * `default` 603 NetworkUri string `protobuf:"bytes,2,opt,name=network_uri,json=networkUri,proto3" json:"network_uri,omitempty"` 604 // Optional. The Compute Engine subnetwork to be used for machine 605 // communications. Cannot be specified with network_uri. 606 // 607 // A full URL, partial URI, or short name are valid. Examples: 608 // 609 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/subnetworks/sub0` 610 // * `projects/[project_id]/regions/us-east1/subnetworks/sub0` 611 // * `sub0` 612 SubnetworkUri string `protobuf:"bytes,6,opt,name=subnetwork_uri,json=subnetworkUri,proto3" json:"subnetwork_uri,omitempty"` 613 // Optional. If true, all instances in the cluster will only have internal IP 614 // addresses. By default, clusters are not restricted to internal IP 615 // addresses, and will have ephemeral external IP addresses assigned to each 616 // instance. This `internal_ip_only` restriction can only be enabled for 617 // subnetwork enabled networks, and all off-cluster dependencies must be 618 // configured to be accessible without external IP addresses. 619 InternalIpOnly bool `protobuf:"varint,7,opt,name=internal_ip_only,json=internalIpOnly,proto3" json:"internal_ip_only,omitempty"` 620 // Optional. The [Dataproc service 621 // account](/dataproc/docs/concepts/configuring-clusters/service-accounts#service_accounts_in_cloud_dataproc) 622 // (also see [VM Data Plane 623 // identity](/dataproc/docs/concepts/iam/dataproc-principals#vm_service_account_data_plane_identity)) 624 // used by Dataproc cluster VM instances to access Google Cloud Platform 625 // services. 626 // 627 // If not specified, the 628 // [Compute Engine default service 629 // account](/compute/docs/access/service-accounts#default_service_account) 630 // is used. 631 ServiceAccount string `protobuf:"bytes,8,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` 632 // Optional. The URIs of service account scopes to be included in 633 // Compute Engine instances. The following base set of scopes is always 634 // included: 635 // 636 // * https://www.googleapis.com/auth/cloud.useraccounts.readonly 637 // * https://www.googleapis.com/auth/devstorage.read_write 638 // * https://www.googleapis.com/auth/logging.write 639 // 640 // If no scopes are specified, the following defaults are also provided: 641 // 642 // * https://www.googleapis.com/auth/bigquery 643 // * https://www.googleapis.com/auth/bigtable.admin.table 644 // * https://www.googleapis.com/auth/bigtable.data 645 // * https://www.googleapis.com/auth/devstorage.full_control 646 ServiceAccountScopes []string `protobuf:"bytes,3,rep,name=service_account_scopes,json=serviceAccountScopes,proto3" json:"service_account_scopes,omitempty"` 647 // The Compute Engine tags to add to all instances (see 648 // [Tagging instances](/compute/docs/label-or-tag-resources#tags)). 649 Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"` 650 // The Compute Engine metadata entries to add to all instances (see 651 // [Project and instance 652 // metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)). 653 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"` 654 // Optional. Reservation Affinity for consuming Zonal reservation. 655 ReservationAffinity *ReservationAffinity `protobuf:"bytes,11,opt,name=reservation_affinity,json=reservationAffinity,proto3" json:"reservation_affinity,omitempty"` 656 XXX_NoUnkeyedLiteral struct{} `json:"-"` 657 XXX_unrecognized []byte `json:"-"` 658 XXX_sizecache int32 `json:"-"` 659} 660 661func (m *GceClusterConfig) Reset() { *m = GceClusterConfig{} } 662func (m *GceClusterConfig) String() string { return proto.CompactTextString(m) } 663func (*GceClusterConfig) ProtoMessage() {} 664func (*GceClusterConfig) Descriptor() ([]byte, []int) { 665 return fileDescriptor_abc993f8d220b626, []int{5} 666} 667 668func (m *GceClusterConfig) XXX_Unmarshal(b []byte) error { 669 return xxx_messageInfo_GceClusterConfig.Unmarshal(m, b) 670} 671func (m *GceClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 672 return xxx_messageInfo_GceClusterConfig.Marshal(b, m, deterministic) 673} 674func (m *GceClusterConfig) XXX_Merge(src proto.Message) { 675 xxx_messageInfo_GceClusterConfig.Merge(m, src) 676} 677func (m *GceClusterConfig) XXX_Size() int { 678 return xxx_messageInfo_GceClusterConfig.Size(m) 679} 680func (m *GceClusterConfig) XXX_DiscardUnknown() { 681 xxx_messageInfo_GceClusterConfig.DiscardUnknown(m) 682} 683 684var xxx_messageInfo_GceClusterConfig proto.InternalMessageInfo 685 686func (m *GceClusterConfig) GetZoneUri() string { 687 if m != nil { 688 return m.ZoneUri 689 } 690 return "" 691} 692 693func (m *GceClusterConfig) GetNetworkUri() string { 694 if m != nil { 695 return m.NetworkUri 696 } 697 return "" 698} 699 700func (m *GceClusterConfig) GetSubnetworkUri() string { 701 if m != nil { 702 return m.SubnetworkUri 703 } 704 return "" 705} 706 707func (m *GceClusterConfig) GetInternalIpOnly() bool { 708 if m != nil { 709 return m.InternalIpOnly 710 } 711 return false 712} 713 714func (m *GceClusterConfig) GetServiceAccount() string { 715 if m != nil { 716 return m.ServiceAccount 717 } 718 return "" 719} 720 721func (m *GceClusterConfig) GetServiceAccountScopes() []string { 722 if m != nil { 723 return m.ServiceAccountScopes 724 } 725 return nil 726} 727 728func (m *GceClusterConfig) GetTags() []string { 729 if m != nil { 730 return m.Tags 731 } 732 return nil 733} 734 735func (m *GceClusterConfig) GetMetadata() map[string]string { 736 if m != nil { 737 return m.Metadata 738 } 739 return nil 740} 741 742func (m *GceClusterConfig) GetReservationAffinity() *ReservationAffinity { 743 if m != nil { 744 return m.ReservationAffinity 745 } 746 return nil 747} 748 749// The config settings for Compute Engine resources in 750// an instance group, such as a master or worker group. 751type InstanceGroupConfig struct { 752 // Optional. The number of VM instances in the instance group. 753 // For master instance groups, must be set to 1. 754 NumInstances int32 `protobuf:"varint,1,opt,name=num_instances,json=numInstances,proto3" json:"num_instances,omitempty"` 755 // Output only. The list of instance names. Dataproc derives the names 756 // from `cluster_name`, `num_instances`, and the instance group. 757 InstanceNames []string `protobuf:"bytes,2,rep,name=instance_names,json=instanceNames,proto3" json:"instance_names,omitempty"` 758 // Optional. The Compute Engine image resource used for cluster 759 // instances. It can be specified or may be inferred from 760 // `SoftwareConfig.image_version`. 761 ImageUri string `protobuf:"bytes,3,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"` 762 // Optional. The Compute Engine machine type used for cluster instances. 763 // 764 // A full URL, partial URI, or short name are valid. Examples: 765 // 766 // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` 767 // * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` 768 // * `n1-standard-2` 769 // 770 // **Auto Zone Exception**: If you are using the Dataproc 771 // [Auto Zone 772 // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement) 773 // feature, you must use the short name of the machine type 774 // resource, for example, `n1-standard-2`. 775 MachineTypeUri string `protobuf:"bytes,4,opt,name=machine_type_uri,json=machineTypeUri,proto3" json:"machine_type_uri,omitempty"` 776 // Optional. Disk option config settings. 777 DiskConfig *DiskConfig `protobuf:"bytes,5,opt,name=disk_config,json=diskConfig,proto3" json:"disk_config,omitempty"` 778 // Optional. Specifies that this instance group contains preemptible 779 // instances. 780 IsPreemptible bool `protobuf:"varint,6,opt,name=is_preemptible,json=isPreemptible,proto3" json:"is_preemptible,omitempty"` 781 // Output only. The config for Compute Engine Instance Group 782 // Manager that manages this group. 783 // This is only used for preemptible instance groups. 784 ManagedGroupConfig *ManagedGroupConfig `protobuf:"bytes,7,opt,name=managed_group_config,json=managedGroupConfig,proto3" json:"managed_group_config,omitempty"` 785 // Optional. The Compute Engine accelerator configuration for these 786 // instances. 787 Accelerators []*AcceleratorConfig `protobuf:"bytes,8,rep,name=accelerators,proto3" json:"accelerators,omitempty"` 788 // Specifies the minimum cpu platform for the Instance Group. 789 // See [Dataproc→Minimum CPU Platform] 790 // (/dataproc/docs/concepts/compute/dataproc-min-cpu). 791 MinCpuPlatform string `protobuf:"bytes,9,opt,name=min_cpu_platform,json=minCpuPlatform,proto3" json:"min_cpu_platform,omitempty"` 792 XXX_NoUnkeyedLiteral struct{} `json:"-"` 793 XXX_unrecognized []byte `json:"-"` 794 XXX_sizecache int32 `json:"-"` 795} 796 797func (m *InstanceGroupConfig) Reset() { *m = InstanceGroupConfig{} } 798func (m *InstanceGroupConfig) String() string { return proto.CompactTextString(m) } 799func (*InstanceGroupConfig) ProtoMessage() {} 800func (*InstanceGroupConfig) Descriptor() ([]byte, []int) { 801 return fileDescriptor_abc993f8d220b626, []int{6} 802} 803 804func (m *InstanceGroupConfig) XXX_Unmarshal(b []byte) error { 805 return xxx_messageInfo_InstanceGroupConfig.Unmarshal(m, b) 806} 807func (m *InstanceGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 808 return xxx_messageInfo_InstanceGroupConfig.Marshal(b, m, deterministic) 809} 810func (m *InstanceGroupConfig) XXX_Merge(src proto.Message) { 811 xxx_messageInfo_InstanceGroupConfig.Merge(m, src) 812} 813func (m *InstanceGroupConfig) XXX_Size() int { 814 return xxx_messageInfo_InstanceGroupConfig.Size(m) 815} 816func (m *InstanceGroupConfig) XXX_DiscardUnknown() { 817 xxx_messageInfo_InstanceGroupConfig.DiscardUnknown(m) 818} 819 820var xxx_messageInfo_InstanceGroupConfig proto.InternalMessageInfo 821 822func (m *InstanceGroupConfig) GetNumInstances() int32 { 823 if m != nil { 824 return m.NumInstances 825 } 826 return 0 827} 828 829func (m *InstanceGroupConfig) GetInstanceNames() []string { 830 if m != nil { 831 return m.InstanceNames 832 } 833 return nil 834} 835 836func (m *InstanceGroupConfig) GetImageUri() string { 837 if m != nil { 838 return m.ImageUri 839 } 840 return "" 841} 842 843func (m *InstanceGroupConfig) GetMachineTypeUri() string { 844 if m != nil { 845 return m.MachineTypeUri 846 } 847 return "" 848} 849 850func (m *InstanceGroupConfig) GetDiskConfig() *DiskConfig { 851 if m != nil { 852 return m.DiskConfig 853 } 854 return nil 855} 856 857func (m *InstanceGroupConfig) GetIsPreemptible() bool { 858 if m != nil { 859 return m.IsPreemptible 860 } 861 return false 862} 863 864func (m *InstanceGroupConfig) GetManagedGroupConfig() *ManagedGroupConfig { 865 if m != nil { 866 return m.ManagedGroupConfig 867 } 868 return nil 869} 870 871func (m *InstanceGroupConfig) GetAccelerators() []*AcceleratorConfig { 872 if m != nil { 873 return m.Accelerators 874 } 875 return nil 876} 877 878func (m *InstanceGroupConfig) GetMinCpuPlatform() string { 879 if m != nil { 880 return m.MinCpuPlatform 881 } 882 return "" 883} 884 885// Specifies the resources used to actively manage an instance group. 886type ManagedGroupConfig struct { 887 // Output only. The name of the Instance Template used for the Managed 888 // Instance Group. 889 InstanceTemplateName string `protobuf:"bytes,1,opt,name=instance_template_name,json=instanceTemplateName,proto3" json:"instance_template_name,omitempty"` 890 // Output only. The name of the Instance Group Manager for this group. 891 InstanceGroupManagerName string `protobuf:"bytes,2,opt,name=instance_group_manager_name,json=instanceGroupManagerName,proto3" json:"instance_group_manager_name,omitempty"` 892 XXX_NoUnkeyedLiteral struct{} `json:"-"` 893 XXX_unrecognized []byte `json:"-"` 894 XXX_sizecache int32 `json:"-"` 895} 896 897func (m *ManagedGroupConfig) Reset() { *m = ManagedGroupConfig{} } 898func (m *ManagedGroupConfig) String() string { return proto.CompactTextString(m) } 899func (*ManagedGroupConfig) ProtoMessage() {} 900func (*ManagedGroupConfig) Descriptor() ([]byte, []int) { 901 return fileDescriptor_abc993f8d220b626, []int{7} 902} 903 904func (m *ManagedGroupConfig) XXX_Unmarshal(b []byte) error { 905 return xxx_messageInfo_ManagedGroupConfig.Unmarshal(m, b) 906} 907func (m *ManagedGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 908 return xxx_messageInfo_ManagedGroupConfig.Marshal(b, m, deterministic) 909} 910func (m *ManagedGroupConfig) XXX_Merge(src proto.Message) { 911 xxx_messageInfo_ManagedGroupConfig.Merge(m, src) 912} 913func (m *ManagedGroupConfig) XXX_Size() int { 914 return xxx_messageInfo_ManagedGroupConfig.Size(m) 915} 916func (m *ManagedGroupConfig) XXX_DiscardUnknown() { 917 xxx_messageInfo_ManagedGroupConfig.DiscardUnknown(m) 918} 919 920var xxx_messageInfo_ManagedGroupConfig proto.InternalMessageInfo 921 922func (m *ManagedGroupConfig) GetInstanceTemplateName() string { 923 if m != nil { 924 return m.InstanceTemplateName 925 } 926 return "" 927} 928 929func (m *ManagedGroupConfig) GetInstanceGroupManagerName() string { 930 if m != nil { 931 return m.InstanceGroupManagerName 932 } 933 return "" 934} 935 936// Specifies the type and number of accelerator cards attached to the instances 937// of an instance group (see [GPUs on Compute Engine](/compute/docs/gpus/)). 938type AcceleratorConfig struct { 939 // Full URL, partial URI, or short name of the accelerator type resource to 940 // expose to this instance. See 941 // [Compute Engine 942 // AcceleratorTypes](/compute/docs/reference/beta/acceleratorTypes) 943 // 944 // Examples 945 // * `https://www.googleapis.com/compute/beta/projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` 946 // * `projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` 947 // * `nvidia-tesla-k80` 948 // 949 // **Auto Zone Exception**: If you are using the Dataproc 950 // [Auto Zone 951 // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement) 952 // feature, you must use the short name of the accelerator type 953 // resource, for example, `nvidia-tesla-k80`. 954 AcceleratorTypeUri string `protobuf:"bytes,1,opt,name=accelerator_type_uri,json=acceleratorTypeUri,proto3" json:"accelerator_type_uri,omitempty"` 955 // The number of the accelerator cards of this type exposed to this instance. 956 AcceleratorCount int32 `protobuf:"varint,2,opt,name=accelerator_count,json=acceleratorCount,proto3" json:"accelerator_count,omitempty"` 957 XXX_NoUnkeyedLiteral struct{} `json:"-"` 958 XXX_unrecognized []byte `json:"-"` 959 XXX_sizecache int32 `json:"-"` 960} 961 962func (m *AcceleratorConfig) Reset() { *m = AcceleratorConfig{} } 963func (m *AcceleratorConfig) String() string { return proto.CompactTextString(m) } 964func (*AcceleratorConfig) ProtoMessage() {} 965func (*AcceleratorConfig) Descriptor() ([]byte, []int) { 966 return fileDescriptor_abc993f8d220b626, []int{8} 967} 968 969func (m *AcceleratorConfig) XXX_Unmarshal(b []byte) error { 970 return xxx_messageInfo_AcceleratorConfig.Unmarshal(m, b) 971} 972func (m *AcceleratorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 973 return xxx_messageInfo_AcceleratorConfig.Marshal(b, m, deterministic) 974} 975func (m *AcceleratorConfig) XXX_Merge(src proto.Message) { 976 xxx_messageInfo_AcceleratorConfig.Merge(m, src) 977} 978func (m *AcceleratorConfig) XXX_Size() int { 979 return xxx_messageInfo_AcceleratorConfig.Size(m) 980} 981func (m *AcceleratorConfig) XXX_DiscardUnknown() { 982 xxx_messageInfo_AcceleratorConfig.DiscardUnknown(m) 983} 984 985var xxx_messageInfo_AcceleratorConfig proto.InternalMessageInfo 986 987func (m *AcceleratorConfig) GetAcceleratorTypeUri() string { 988 if m != nil { 989 return m.AcceleratorTypeUri 990 } 991 return "" 992} 993 994func (m *AcceleratorConfig) GetAcceleratorCount() int32 { 995 if m != nil { 996 return m.AcceleratorCount 997 } 998 return 0 999} 1000 1001// Specifies the config of disk options for a group of VM instances. 1002type DiskConfig struct { 1003 // Optional. Type of the boot disk (default is "pd-standard"). 1004 // Valid values: "pd-ssd" (Persistent Disk Solid State Drive) or 1005 // "pd-standard" (Persistent Disk Hard Disk Drive). 1006 BootDiskType string `protobuf:"bytes,3,opt,name=boot_disk_type,json=bootDiskType,proto3" json:"boot_disk_type,omitempty"` 1007 // Optional. Size in GB of the boot disk (default is 500GB). 1008 BootDiskSizeGb int32 `protobuf:"varint,1,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"` 1009 // Number of attached SSDs, from 0 to 4 (default is 0). 1010 // If SSDs are not attached, the boot disk is used to store runtime logs and 1011 // [HDFS](https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. 1012 // If one or more SSDs are attached, this runtime bulk 1013 // data is spread across them, and the boot disk contains only basic 1014 // config and installed binaries. 1015 NumLocalSsds int32 `protobuf:"varint,2,opt,name=num_local_ssds,json=numLocalSsds,proto3" json:"num_local_ssds,omitempty"` 1016 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1017 XXX_unrecognized []byte `json:"-"` 1018 XXX_sizecache int32 `json:"-"` 1019} 1020 1021func (m *DiskConfig) Reset() { *m = DiskConfig{} } 1022func (m *DiskConfig) String() string { return proto.CompactTextString(m) } 1023func (*DiskConfig) ProtoMessage() {} 1024func (*DiskConfig) Descriptor() ([]byte, []int) { 1025 return fileDescriptor_abc993f8d220b626, []int{9} 1026} 1027 1028func (m *DiskConfig) XXX_Unmarshal(b []byte) error { 1029 return xxx_messageInfo_DiskConfig.Unmarshal(m, b) 1030} 1031func (m *DiskConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1032 return xxx_messageInfo_DiskConfig.Marshal(b, m, deterministic) 1033} 1034func (m *DiskConfig) XXX_Merge(src proto.Message) { 1035 xxx_messageInfo_DiskConfig.Merge(m, src) 1036} 1037func (m *DiskConfig) XXX_Size() int { 1038 return xxx_messageInfo_DiskConfig.Size(m) 1039} 1040func (m *DiskConfig) XXX_DiscardUnknown() { 1041 xxx_messageInfo_DiskConfig.DiscardUnknown(m) 1042} 1043 1044var xxx_messageInfo_DiskConfig proto.InternalMessageInfo 1045 1046func (m *DiskConfig) GetBootDiskType() string { 1047 if m != nil { 1048 return m.BootDiskType 1049 } 1050 return "" 1051} 1052 1053func (m *DiskConfig) GetBootDiskSizeGb() int32 { 1054 if m != nil { 1055 return m.BootDiskSizeGb 1056 } 1057 return 0 1058} 1059 1060func (m *DiskConfig) GetNumLocalSsds() int32 { 1061 if m != nil { 1062 return m.NumLocalSsds 1063 } 1064 return 0 1065} 1066 1067// Specifies the cluster auto-delete schedule configuration. 1068type LifecycleConfig struct { 1069 // Optional. The duration to keep the cluster alive while idling (when no jobs 1070 // are running). Passing this threshold will cause the cluster to be 1071 // deleted. Minimum value is 10 minutes; maximum value is 14 days (see JSON 1072 // representation of 1073 // [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json). 1074 IdleDeleteTtl *duration.Duration `protobuf:"bytes,1,opt,name=idle_delete_ttl,json=idleDeleteTtl,proto3" json:"idle_delete_ttl,omitempty"` 1075 // Either the exact time the cluster should be deleted at or 1076 // the cluster maximum age. 1077 // 1078 // Types that are valid to be assigned to Ttl: 1079 // *LifecycleConfig_AutoDeleteTime 1080 // *LifecycleConfig_AutoDeleteTtl 1081 Ttl isLifecycleConfig_Ttl `protobuf_oneof:"ttl"` 1082 // Output only. The time when cluster became idle (most recent job finished) 1083 // and became eligible for deletion due to idleness (see JSON representation 1084 // of 1085 // [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). 1086 IdleStartTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=idle_start_time,json=idleStartTime,proto3" json:"idle_start_time,omitempty"` 1087 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1088 XXX_unrecognized []byte `json:"-"` 1089 XXX_sizecache int32 `json:"-"` 1090} 1091 1092func (m *LifecycleConfig) Reset() { *m = LifecycleConfig{} } 1093func (m *LifecycleConfig) String() string { return proto.CompactTextString(m) } 1094func (*LifecycleConfig) ProtoMessage() {} 1095func (*LifecycleConfig) Descriptor() ([]byte, []int) { 1096 return fileDescriptor_abc993f8d220b626, []int{10} 1097} 1098 1099func (m *LifecycleConfig) XXX_Unmarshal(b []byte) error { 1100 return xxx_messageInfo_LifecycleConfig.Unmarshal(m, b) 1101} 1102func (m *LifecycleConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1103 return xxx_messageInfo_LifecycleConfig.Marshal(b, m, deterministic) 1104} 1105func (m *LifecycleConfig) XXX_Merge(src proto.Message) { 1106 xxx_messageInfo_LifecycleConfig.Merge(m, src) 1107} 1108func (m *LifecycleConfig) XXX_Size() int { 1109 return xxx_messageInfo_LifecycleConfig.Size(m) 1110} 1111func (m *LifecycleConfig) XXX_DiscardUnknown() { 1112 xxx_messageInfo_LifecycleConfig.DiscardUnknown(m) 1113} 1114 1115var xxx_messageInfo_LifecycleConfig proto.InternalMessageInfo 1116 1117func (m *LifecycleConfig) GetIdleDeleteTtl() *duration.Duration { 1118 if m != nil { 1119 return m.IdleDeleteTtl 1120 } 1121 return nil 1122} 1123 1124type isLifecycleConfig_Ttl interface { 1125 isLifecycleConfig_Ttl() 1126} 1127 1128type LifecycleConfig_AutoDeleteTime struct { 1129 AutoDeleteTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=auto_delete_time,json=autoDeleteTime,proto3,oneof"` 1130} 1131 1132type LifecycleConfig_AutoDeleteTtl struct { 1133 AutoDeleteTtl *duration.Duration `protobuf:"bytes,3,opt,name=auto_delete_ttl,json=autoDeleteTtl,proto3,oneof"` 1134} 1135 1136func (*LifecycleConfig_AutoDeleteTime) isLifecycleConfig_Ttl() {} 1137 1138func (*LifecycleConfig_AutoDeleteTtl) isLifecycleConfig_Ttl() {} 1139 1140func (m *LifecycleConfig) GetTtl() isLifecycleConfig_Ttl { 1141 if m != nil { 1142 return m.Ttl 1143 } 1144 return nil 1145} 1146 1147func (m *LifecycleConfig) GetAutoDeleteTime() *timestamp.Timestamp { 1148 if x, ok := m.GetTtl().(*LifecycleConfig_AutoDeleteTime); ok { 1149 return x.AutoDeleteTime 1150 } 1151 return nil 1152} 1153 1154func (m *LifecycleConfig) GetAutoDeleteTtl() *duration.Duration { 1155 if x, ok := m.GetTtl().(*LifecycleConfig_AutoDeleteTtl); ok { 1156 return x.AutoDeleteTtl 1157 } 1158 return nil 1159} 1160 1161func (m *LifecycleConfig) GetIdleStartTime() *timestamp.Timestamp { 1162 if m != nil { 1163 return m.IdleStartTime 1164 } 1165 return nil 1166} 1167 1168// XXX_OneofWrappers is for the internal use of the proto package. 1169func (*LifecycleConfig) XXX_OneofWrappers() []interface{} { 1170 return []interface{}{ 1171 (*LifecycleConfig_AutoDeleteTime)(nil), 1172 (*LifecycleConfig_AutoDeleteTtl)(nil), 1173 } 1174} 1175 1176// Security related configuration, including encryption, Kerberos, etc. 1177type SecurityConfig struct { 1178 // Kerberos related configuration. 1179 KerberosConfig *KerberosConfig `protobuf:"bytes,1,opt,name=kerberos_config,json=kerberosConfig,proto3" json:"kerberos_config,omitempty"` 1180 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1181 XXX_unrecognized []byte `json:"-"` 1182 XXX_sizecache int32 `json:"-"` 1183} 1184 1185func (m *SecurityConfig) Reset() { *m = SecurityConfig{} } 1186func (m *SecurityConfig) String() string { return proto.CompactTextString(m) } 1187func (*SecurityConfig) ProtoMessage() {} 1188func (*SecurityConfig) Descriptor() ([]byte, []int) { 1189 return fileDescriptor_abc993f8d220b626, []int{11} 1190} 1191 1192func (m *SecurityConfig) XXX_Unmarshal(b []byte) error { 1193 return xxx_messageInfo_SecurityConfig.Unmarshal(m, b) 1194} 1195func (m *SecurityConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1196 return xxx_messageInfo_SecurityConfig.Marshal(b, m, deterministic) 1197} 1198func (m *SecurityConfig) XXX_Merge(src proto.Message) { 1199 xxx_messageInfo_SecurityConfig.Merge(m, src) 1200} 1201func (m *SecurityConfig) XXX_Size() int { 1202 return xxx_messageInfo_SecurityConfig.Size(m) 1203} 1204func (m *SecurityConfig) XXX_DiscardUnknown() { 1205 xxx_messageInfo_SecurityConfig.DiscardUnknown(m) 1206} 1207 1208var xxx_messageInfo_SecurityConfig proto.InternalMessageInfo 1209 1210func (m *SecurityConfig) GetKerberosConfig() *KerberosConfig { 1211 if m != nil { 1212 return m.KerberosConfig 1213 } 1214 return nil 1215} 1216 1217// Specifies Kerberos related configuration. 1218type KerberosConfig struct { 1219 // Optional. Flag to indicate whether to Kerberize the cluster. 1220 EnableKerberos bool `protobuf:"varint,1,opt,name=enable_kerberos,json=enableKerberos,proto3" json:"enable_kerberos,omitempty"` 1221 // Required. The Cloud Storage URI of a KMS encrypted file containing the root 1222 // principal password. 1223 RootPrincipalPasswordUri string `protobuf:"bytes,2,opt,name=root_principal_password_uri,json=rootPrincipalPasswordUri,proto3" json:"root_principal_password_uri,omitempty"` 1224 // Required. The uri of the KMS key used to encrypt various sensitive 1225 // files. 1226 KmsKeyUri string `protobuf:"bytes,3,opt,name=kms_key_uri,json=kmsKeyUri,proto3" json:"kms_key_uri,omitempty"` 1227 // Optional. The Cloud Storage URI of the keystore file used for SSL 1228 // encryption. If not provided, Dataproc will provide a self-signed 1229 // certificate. 1230 KeystoreUri string `protobuf:"bytes,4,opt,name=keystore_uri,json=keystoreUri,proto3" json:"keystore_uri,omitempty"` 1231 // Optional. The Cloud Storage URI of the truststore file used for SSL 1232 // encryption. If not provided, Dataproc will provide a self-signed 1233 // certificate. 1234 TruststoreUri string `protobuf:"bytes,5,opt,name=truststore_uri,json=truststoreUri,proto3" json:"truststore_uri,omitempty"` 1235 // Optional. The Cloud Storage URI of a KMS encrypted file containing the 1236 // password to the user provided keystore. For the self-signed certificate, 1237 // this password is generated by Dataproc. 1238 KeystorePasswordUri string `protobuf:"bytes,6,opt,name=keystore_password_uri,json=keystorePasswordUri,proto3" json:"keystore_password_uri,omitempty"` 1239 // Optional. The Cloud Storage URI of a KMS encrypted file containing the 1240 // password to the user provided key. For the self-signed certificate, this 1241 // password is generated by Dataproc. 1242 KeyPasswordUri string `protobuf:"bytes,7,opt,name=key_password_uri,json=keyPasswordUri,proto3" json:"key_password_uri,omitempty"` 1243 // Optional. The Cloud Storage URI of a KMS encrypted file containing the 1244 // password to the user provided truststore. For the self-signed certificate, 1245 // this password is generated by Dataproc. 1246 TruststorePasswordUri string `protobuf:"bytes,8,opt,name=truststore_password_uri,json=truststorePasswordUri,proto3" json:"truststore_password_uri,omitempty"` 1247 // Optional. The remote realm the Dataproc on-cluster KDC will trust, should 1248 // the user enable cross realm trust. 1249 CrossRealmTrustRealm string `protobuf:"bytes,9,opt,name=cross_realm_trust_realm,json=crossRealmTrustRealm,proto3" json:"cross_realm_trust_realm,omitempty"` 1250 // Optional. The KDC (IP or hostname) for the remote trusted realm in a cross 1251 // realm trust relationship. 1252 CrossRealmTrustKdc string `protobuf:"bytes,10,opt,name=cross_realm_trust_kdc,json=crossRealmTrustKdc,proto3" json:"cross_realm_trust_kdc,omitempty"` 1253 // Optional. The admin server (IP or hostname) for the remote trusted realm in 1254 // a cross realm trust relationship. 1255 CrossRealmTrustAdminServer string `protobuf:"bytes,11,opt,name=cross_realm_trust_admin_server,json=crossRealmTrustAdminServer,proto3" json:"cross_realm_trust_admin_server,omitempty"` 1256 // Optional. The Cloud Storage URI of a KMS encrypted file containing the 1257 // shared password between the on-cluster Kerberos realm and the remote 1258 // trusted realm, in a cross realm trust relationship. 1259 CrossRealmTrustSharedPasswordUri string `protobuf:"bytes,12,opt,name=cross_realm_trust_shared_password_uri,json=crossRealmTrustSharedPasswordUri,proto3" json:"cross_realm_trust_shared_password_uri,omitempty"` 1260 // Optional. The Cloud Storage URI of a KMS encrypted file containing the 1261 // master key of the KDC database. 1262 KdcDbKeyUri string `protobuf:"bytes,13,opt,name=kdc_db_key_uri,json=kdcDbKeyUri,proto3" json:"kdc_db_key_uri,omitempty"` 1263 // Optional. The lifetime of the ticket granting ticket, in hours. 1264 // If not specified, or user specifies 0, then default value 10 1265 // will be used. 1266 TgtLifetimeHours int32 `protobuf:"varint,14,opt,name=tgt_lifetime_hours,json=tgtLifetimeHours,proto3" json:"tgt_lifetime_hours,omitempty"` 1267 // Optional. The name of the on-cluster Kerberos realm. 1268 // If not specified, the uppercased domain of hostnames will be the realm. 1269 Realm string `protobuf:"bytes,15,opt,name=realm,proto3" json:"realm,omitempty"` 1270 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1271 XXX_unrecognized []byte `json:"-"` 1272 XXX_sizecache int32 `json:"-"` 1273} 1274 1275func (m *KerberosConfig) Reset() { *m = KerberosConfig{} } 1276func (m *KerberosConfig) String() string { return proto.CompactTextString(m) } 1277func (*KerberosConfig) ProtoMessage() {} 1278func (*KerberosConfig) Descriptor() ([]byte, []int) { 1279 return fileDescriptor_abc993f8d220b626, []int{12} 1280} 1281 1282func (m *KerberosConfig) XXX_Unmarshal(b []byte) error { 1283 return xxx_messageInfo_KerberosConfig.Unmarshal(m, b) 1284} 1285func (m *KerberosConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1286 return xxx_messageInfo_KerberosConfig.Marshal(b, m, deterministic) 1287} 1288func (m *KerberosConfig) XXX_Merge(src proto.Message) { 1289 xxx_messageInfo_KerberosConfig.Merge(m, src) 1290} 1291func (m *KerberosConfig) XXX_Size() int { 1292 return xxx_messageInfo_KerberosConfig.Size(m) 1293} 1294func (m *KerberosConfig) XXX_DiscardUnknown() { 1295 xxx_messageInfo_KerberosConfig.DiscardUnknown(m) 1296} 1297 1298var xxx_messageInfo_KerberosConfig proto.InternalMessageInfo 1299 1300func (m *KerberosConfig) GetEnableKerberos() bool { 1301 if m != nil { 1302 return m.EnableKerberos 1303 } 1304 return false 1305} 1306 1307func (m *KerberosConfig) GetRootPrincipalPasswordUri() string { 1308 if m != nil { 1309 return m.RootPrincipalPasswordUri 1310 } 1311 return "" 1312} 1313 1314func (m *KerberosConfig) GetKmsKeyUri() string { 1315 if m != nil { 1316 return m.KmsKeyUri 1317 } 1318 return "" 1319} 1320 1321func (m *KerberosConfig) GetKeystoreUri() string { 1322 if m != nil { 1323 return m.KeystoreUri 1324 } 1325 return "" 1326} 1327 1328func (m *KerberosConfig) GetTruststoreUri() string { 1329 if m != nil { 1330 return m.TruststoreUri 1331 } 1332 return "" 1333} 1334 1335func (m *KerberosConfig) GetKeystorePasswordUri() string { 1336 if m != nil { 1337 return m.KeystorePasswordUri 1338 } 1339 return "" 1340} 1341 1342func (m *KerberosConfig) GetKeyPasswordUri() string { 1343 if m != nil { 1344 return m.KeyPasswordUri 1345 } 1346 return "" 1347} 1348 1349func (m *KerberosConfig) GetTruststorePasswordUri() string { 1350 if m != nil { 1351 return m.TruststorePasswordUri 1352 } 1353 return "" 1354} 1355 1356func (m *KerberosConfig) GetCrossRealmTrustRealm() string { 1357 if m != nil { 1358 return m.CrossRealmTrustRealm 1359 } 1360 return "" 1361} 1362 1363func (m *KerberosConfig) GetCrossRealmTrustKdc() string { 1364 if m != nil { 1365 return m.CrossRealmTrustKdc 1366 } 1367 return "" 1368} 1369 1370func (m *KerberosConfig) GetCrossRealmTrustAdminServer() string { 1371 if m != nil { 1372 return m.CrossRealmTrustAdminServer 1373 } 1374 return "" 1375} 1376 1377func (m *KerberosConfig) GetCrossRealmTrustSharedPasswordUri() string { 1378 if m != nil { 1379 return m.CrossRealmTrustSharedPasswordUri 1380 } 1381 return "" 1382} 1383 1384func (m *KerberosConfig) GetKdcDbKeyUri() string { 1385 if m != nil { 1386 return m.KdcDbKeyUri 1387 } 1388 return "" 1389} 1390 1391func (m *KerberosConfig) GetTgtLifetimeHours() int32 { 1392 if m != nil { 1393 return m.TgtLifetimeHours 1394 } 1395 return 0 1396} 1397 1398func (m *KerberosConfig) GetRealm() string { 1399 if m != nil { 1400 return m.Realm 1401 } 1402 return "" 1403} 1404 1405// Specifies an executable to run on a fully configured node and a 1406// timeout period for executable completion. 1407type NodeInitializationAction struct { 1408 // Required. Cloud Storage URI of executable file. 1409 ExecutableFile string `protobuf:"bytes,1,opt,name=executable_file,json=executableFile,proto3" json:"executable_file,omitempty"` 1410 // Optional. Amount of time executable has to complete. Default is 1411 // 10 minutes (see JSON representation of 1412 // [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). 1413 // 1414 // Cluster creation fails with an explanatory error message (the 1415 // name of the executable that caused the error and the exceeded timeout 1416 // period) if the executable is not completed at end of the timeout period. 1417 ExecutionTimeout *duration.Duration `protobuf:"bytes,2,opt,name=execution_timeout,json=executionTimeout,proto3" json:"execution_timeout,omitempty"` 1418 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1419 XXX_unrecognized []byte `json:"-"` 1420 XXX_sizecache int32 `json:"-"` 1421} 1422 1423func (m *NodeInitializationAction) Reset() { *m = NodeInitializationAction{} } 1424func (m *NodeInitializationAction) String() string { return proto.CompactTextString(m) } 1425func (*NodeInitializationAction) ProtoMessage() {} 1426func (*NodeInitializationAction) Descriptor() ([]byte, []int) { 1427 return fileDescriptor_abc993f8d220b626, []int{13} 1428} 1429 1430func (m *NodeInitializationAction) XXX_Unmarshal(b []byte) error { 1431 return xxx_messageInfo_NodeInitializationAction.Unmarshal(m, b) 1432} 1433func (m *NodeInitializationAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1434 return xxx_messageInfo_NodeInitializationAction.Marshal(b, m, deterministic) 1435} 1436func (m *NodeInitializationAction) XXX_Merge(src proto.Message) { 1437 xxx_messageInfo_NodeInitializationAction.Merge(m, src) 1438} 1439func (m *NodeInitializationAction) XXX_Size() int { 1440 return xxx_messageInfo_NodeInitializationAction.Size(m) 1441} 1442func (m *NodeInitializationAction) XXX_DiscardUnknown() { 1443 xxx_messageInfo_NodeInitializationAction.DiscardUnknown(m) 1444} 1445 1446var xxx_messageInfo_NodeInitializationAction proto.InternalMessageInfo 1447 1448func (m *NodeInitializationAction) GetExecutableFile() string { 1449 if m != nil { 1450 return m.ExecutableFile 1451 } 1452 return "" 1453} 1454 1455func (m *NodeInitializationAction) GetExecutionTimeout() *duration.Duration { 1456 if m != nil { 1457 return m.ExecutionTimeout 1458 } 1459 return nil 1460} 1461 1462// The status of a cluster and its instances. 1463type ClusterStatus struct { 1464 // Output only. The cluster's state. 1465 State ClusterStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1beta2.ClusterStatus_State" json:"state,omitempty"` 1466 // Output only. Optional details of cluster's state. 1467 Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"` 1468 // Output only. Time when this state was entered (see JSON representation of 1469 // [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). 1470 StateStartTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"` 1471 // Output only. Additional state information that includes 1472 // status reported by the agent. 1473 Substate ClusterStatus_Substate `protobuf:"varint,4,opt,name=substate,proto3,enum=google.cloud.dataproc.v1beta2.ClusterStatus_Substate" json:"substate,omitempty"` 1474 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1475 XXX_unrecognized []byte `json:"-"` 1476 XXX_sizecache int32 `json:"-"` 1477} 1478 1479func (m *ClusterStatus) Reset() { *m = ClusterStatus{} } 1480func (m *ClusterStatus) String() string { return proto.CompactTextString(m) } 1481func (*ClusterStatus) ProtoMessage() {} 1482func (*ClusterStatus) Descriptor() ([]byte, []int) { 1483 return fileDescriptor_abc993f8d220b626, []int{14} 1484} 1485 1486func (m *ClusterStatus) XXX_Unmarshal(b []byte) error { 1487 return xxx_messageInfo_ClusterStatus.Unmarshal(m, b) 1488} 1489func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1490 return xxx_messageInfo_ClusterStatus.Marshal(b, m, deterministic) 1491} 1492func (m *ClusterStatus) XXX_Merge(src proto.Message) { 1493 xxx_messageInfo_ClusterStatus.Merge(m, src) 1494} 1495func (m *ClusterStatus) XXX_Size() int { 1496 return xxx_messageInfo_ClusterStatus.Size(m) 1497} 1498func (m *ClusterStatus) XXX_DiscardUnknown() { 1499 xxx_messageInfo_ClusterStatus.DiscardUnknown(m) 1500} 1501 1502var xxx_messageInfo_ClusterStatus proto.InternalMessageInfo 1503 1504func (m *ClusterStatus) GetState() ClusterStatus_State { 1505 if m != nil { 1506 return m.State 1507 } 1508 return ClusterStatus_UNKNOWN 1509} 1510 1511func (m *ClusterStatus) GetDetail() string { 1512 if m != nil { 1513 return m.Detail 1514 } 1515 return "" 1516} 1517 1518func (m *ClusterStatus) GetStateStartTime() *timestamp.Timestamp { 1519 if m != nil { 1520 return m.StateStartTime 1521 } 1522 return nil 1523} 1524 1525func (m *ClusterStatus) GetSubstate() ClusterStatus_Substate { 1526 if m != nil { 1527 return m.Substate 1528 } 1529 return ClusterStatus_UNSPECIFIED 1530} 1531 1532// Specifies the selection and config of software inside the cluster. 1533type SoftwareConfig struct { 1534 // Optional. The version of software inside the cluster. It must be one of the 1535 // supported [Dataproc 1536 // Versions](/dataproc/docs/concepts/versioning/dataproc-versions#supported_cloud_dataproc_versions), 1537 // such as "1.2" (including a subminor version, such as "1.2.29"), or the 1538 // ["preview" 1539 // version](/dataproc/docs/concepts/versioning/dataproc-versions#other_versions). 1540 // If unspecified, it defaults to the latest Debian version. 1541 ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"` 1542 // Optional. The properties to set on daemon config files. 1543 // 1544 // Property keys are specified in `prefix:property` format, for example 1545 // `core:hadoop.tmp.dir`. The following are supported prefixes 1546 // and their mappings: 1547 // 1548 // * capacity-scheduler: `capacity-scheduler.xml` 1549 // * core: `core-site.xml` 1550 // * distcp: `distcp-default.xml` 1551 // * hdfs: `hdfs-site.xml` 1552 // * hive: `hive-site.xml` 1553 // * mapred: `mapred-site.xml` 1554 // * pig: `pig.properties` 1555 // * spark: `spark-defaults.conf` 1556 // * yarn: `yarn-site.xml` 1557 // 1558 // For more information, see 1559 // [Cluster properties](/dataproc/docs/concepts/cluster-properties). 1560 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"` 1561 // The set of optional components to activate on the cluster. 1562 OptionalComponents []Component `protobuf:"varint,3,rep,packed,name=optional_components,json=optionalComponents,proto3,enum=google.cloud.dataproc.v1beta2.Component" json:"optional_components,omitempty"` 1563 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1564 XXX_unrecognized []byte `json:"-"` 1565 XXX_sizecache int32 `json:"-"` 1566} 1567 1568func (m *SoftwareConfig) Reset() { *m = SoftwareConfig{} } 1569func (m *SoftwareConfig) String() string { return proto.CompactTextString(m) } 1570func (*SoftwareConfig) ProtoMessage() {} 1571func (*SoftwareConfig) Descriptor() ([]byte, []int) { 1572 return fileDescriptor_abc993f8d220b626, []int{15} 1573} 1574 1575func (m *SoftwareConfig) XXX_Unmarshal(b []byte) error { 1576 return xxx_messageInfo_SoftwareConfig.Unmarshal(m, b) 1577} 1578func (m *SoftwareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1579 return xxx_messageInfo_SoftwareConfig.Marshal(b, m, deterministic) 1580} 1581func (m *SoftwareConfig) XXX_Merge(src proto.Message) { 1582 xxx_messageInfo_SoftwareConfig.Merge(m, src) 1583} 1584func (m *SoftwareConfig) XXX_Size() int { 1585 return xxx_messageInfo_SoftwareConfig.Size(m) 1586} 1587func (m *SoftwareConfig) XXX_DiscardUnknown() { 1588 xxx_messageInfo_SoftwareConfig.DiscardUnknown(m) 1589} 1590 1591var xxx_messageInfo_SoftwareConfig proto.InternalMessageInfo 1592 1593func (m *SoftwareConfig) GetImageVersion() string { 1594 if m != nil { 1595 return m.ImageVersion 1596 } 1597 return "" 1598} 1599 1600func (m *SoftwareConfig) GetProperties() map[string]string { 1601 if m != nil { 1602 return m.Properties 1603 } 1604 return nil 1605} 1606 1607func (m *SoftwareConfig) GetOptionalComponents() []Component { 1608 if m != nil { 1609 return m.OptionalComponents 1610 } 1611 return nil 1612} 1613 1614// Contains cluster daemon metrics, such as HDFS and YARN stats. 1615// 1616// **Beta Feature**: This report is available for testing purposes only. It may 1617// be changed before final release. 1618type ClusterMetrics struct { 1619 // The HDFS metrics. 1620 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"` 1621 // The YARN metrics. 1622 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"` 1623 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1624 XXX_unrecognized []byte `json:"-"` 1625 XXX_sizecache int32 `json:"-"` 1626} 1627 1628func (m *ClusterMetrics) Reset() { *m = ClusterMetrics{} } 1629func (m *ClusterMetrics) String() string { return proto.CompactTextString(m) } 1630func (*ClusterMetrics) ProtoMessage() {} 1631func (*ClusterMetrics) Descriptor() ([]byte, []int) { 1632 return fileDescriptor_abc993f8d220b626, []int{16} 1633} 1634 1635func (m *ClusterMetrics) XXX_Unmarshal(b []byte) error { 1636 return xxx_messageInfo_ClusterMetrics.Unmarshal(m, b) 1637} 1638func (m *ClusterMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1639 return xxx_messageInfo_ClusterMetrics.Marshal(b, m, deterministic) 1640} 1641func (m *ClusterMetrics) XXX_Merge(src proto.Message) { 1642 xxx_messageInfo_ClusterMetrics.Merge(m, src) 1643} 1644func (m *ClusterMetrics) XXX_Size() int { 1645 return xxx_messageInfo_ClusterMetrics.Size(m) 1646} 1647func (m *ClusterMetrics) XXX_DiscardUnknown() { 1648 xxx_messageInfo_ClusterMetrics.DiscardUnknown(m) 1649} 1650 1651var xxx_messageInfo_ClusterMetrics proto.InternalMessageInfo 1652 1653func (m *ClusterMetrics) GetHdfsMetrics() map[string]int64 { 1654 if m != nil { 1655 return m.HdfsMetrics 1656 } 1657 return nil 1658} 1659 1660func (m *ClusterMetrics) GetYarnMetrics() map[string]int64 { 1661 if m != nil { 1662 return m.YarnMetrics 1663 } 1664 return nil 1665} 1666 1667// A request to create a cluster. 1668type CreateClusterRequest struct { 1669 // Required. The ID of the Google Cloud Platform project that the cluster 1670 // belongs to. 1671 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1672 // Required. The Dataproc region in which to handle the request. 1673 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1674 // Required. The cluster to create. 1675 Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` 1676 // Optional. A unique id used to identify the request. If the server 1677 // receives two [CreateClusterRequest][google.cloud.dataproc.v1beta2.CreateClusterRequest] requests with the same 1678 // id, then the second request will be ignored and the 1679 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the backend 1680 // is returned. 1681 // 1682 // It is recommended to always set this value to a 1683 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1684 // 1685 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1686 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1687 RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1688 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1689 XXX_unrecognized []byte `json:"-"` 1690 XXX_sizecache int32 `json:"-"` 1691} 1692 1693func (m *CreateClusterRequest) Reset() { *m = CreateClusterRequest{} } 1694func (m *CreateClusterRequest) String() string { return proto.CompactTextString(m) } 1695func (*CreateClusterRequest) ProtoMessage() {} 1696func (*CreateClusterRequest) Descriptor() ([]byte, []int) { 1697 return fileDescriptor_abc993f8d220b626, []int{17} 1698} 1699 1700func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error { 1701 return xxx_messageInfo_CreateClusterRequest.Unmarshal(m, b) 1702} 1703func (m *CreateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1704 return xxx_messageInfo_CreateClusterRequest.Marshal(b, m, deterministic) 1705} 1706func (m *CreateClusterRequest) XXX_Merge(src proto.Message) { 1707 xxx_messageInfo_CreateClusterRequest.Merge(m, src) 1708} 1709func (m *CreateClusterRequest) XXX_Size() int { 1710 return xxx_messageInfo_CreateClusterRequest.Size(m) 1711} 1712func (m *CreateClusterRequest) XXX_DiscardUnknown() { 1713 xxx_messageInfo_CreateClusterRequest.DiscardUnknown(m) 1714} 1715 1716var xxx_messageInfo_CreateClusterRequest proto.InternalMessageInfo 1717 1718func (m *CreateClusterRequest) GetProjectId() string { 1719 if m != nil { 1720 return m.ProjectId 1721 } 1722 return "" 1723} 1724 1725func (m *CreateClusterRequest) GetRegion() string { 1726 if m != nil { 1727 return m.Region 1728 } 1729 return "" 1730} 1731 1732func (m *CreateClusterRequest) GetCluster() *Cluster { 1733 if m != nil { 1734 return m.Cluster 1735 } 1736 return nil 1737} 1738 1739func (m *CreateClusterRequest) GetRequestId() string { 1740 if m != nil { 1741 return m.RequestId 1742 } 1743 return "" 1744} 1745 1746// A request to update a cluster. 1747type UpdateClusterRequest struct { 1748 // Required. The ID of the Google Cloud Platform project the 1749 // cluster belongs to. 1750 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1751 // Required. The Dataproc region in which to handle the request. 1752 Region string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"` 1753 // Required. The cluster name. 1754 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1755 // Required. The changes to the cluster. 1756 Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"` 1757 // Optional. Timeout for graceful YARN decomissioning. Graceful 1758 // decommissioning allows removing nodes from the cluster without 1759 // interrupting jobs in progress. Timeout specifies how long to wait for jobs 1760 // in progress to finish before forcefully removing nodes (and potentially 1761 // interrupting jobs). Default timeout is 0 (for forceful decommission), and 1762 // the maximum allowed timeout is 1 day (see JSON representation of 1763 // [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). 1764 // 1765 // Only supported on Dataproc image versions 1.2 and higher. 1766 GracefulDecommissionTimeout *duration.Duration `protobuf:"bytes,6,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"` 1767 // Required. Specifies the path, relative to `Cluster`, of 1768 // the field to update. For example, to change the number of workers 1769 // in a cluster to 5, the `update_mask` parameter would be 1770 // specified as `config.worker_config.num_instances`, 1771 // and the `PATCH` request body would specify the new value, as follows: 1772 // 1773 // { 1774 // "config":{ 1775 // "workerConfig":{ 1776 // "numInstances":"5" 1777 // } 1778 // } 1779 // } 1780 // 1781 // Similarly, to change the number of preemptible workers in a cluster to 5, 1782 // the `update_mask` parameter would be 1783 // `config.secondary_worker_config.num_instances`, and the `PATCH` request 1784 // body would be set as follows: 1785 // 1786 // { 1787 // "config":{ 1788 // "secondaryWorkerConfig":{ 1789 // "numInstances":"5" 1790 // } 1791 // } 1792 // } 1793 // <strong>Note:</strong> currently only the following fields can be updated: 1794 // 1795 // <table> 1796 // <tr> 1797 // <td><strong>Mask</strong></td><td><strong>Purpose</strong></td> 1798 // </tr> 1799 // <tr> 1800 // <td>labels</td><td>Updates labels</td> 1801 // </tr> 1802 // <tr> 1803 // <td>config.worker_config.num_instances</td><td>Resize primary worker 1804 // group</td> 1805 // </tr> 1806 // <tr> 1807 // <td>config.secondary_worker_config.num_instances</td><td>Resize secondary 1808 // worker group</td> 1809 // </tr> 1810 // <tr> 1811 // <td>config.lifecycle_config.auto_delete_ttl</td><td>Reset MAX TTL 1812 // duration</td> 1813 // </tr> 1814 // <tr> 1815 // <td>config.lifecycle_config.auto_delete_time</td><td>Update MAX TTL 1816 // deletion timestamp</td> 1817 // </tr> 1818 // <tr> 1819 // <td>config.lifecycle_config.idle_delete_ttl</td><td>Update Idle TTL 1820 // duration</td> 1821 // </tr> 1822 // <tr> 1823 // <td>config.autoscaling_config.policy_uri</td><td>Use, stop using, or change 1824 // autoscaling policies</td> 1825 // </tr> 1826 // </table> 1827 UpdateMask *field_mask.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 1828 // Optional. A unique id used to identify the request. If the server 1829 // receives two [UpdateClusterRequest][google.cloud.dataproc.v1beta2.UpdateClusterRequest] requests with the same 1830 // id, then the second request will be ignored and the 1831 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the 1832 // backend is returned. 1833 // 1834 // It is recommended to always set this value to a 1835 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1836 // 1837 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1838 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1839 RequestId string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1840 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1841 XXX_unrecognized []byte `json:"-"` 1842 XXX_sizecache int32 `json:"-"` 1843} 1844 1845func (m *UpdateClusterRequest) Reset() { *m = UpdateClusterRequest{} } 1846func (m *UpdateClusterRequest) String() string { return proto.CompactTextString(m) } 1847func (*UpdateClusterRequest) ProtoMessage() {} 1848func (*UpdateClusterRequest) Descriptor() ([]byte, []int) { 1849 return fileDescriptor_abc993f8d220b626, []int{18} 1850} 1851 1852func (m *UpdateClusterRequest) XXX_Unmarshal(b []byte) error { 1853 return xxx_messageInfo_UpdateClusterRequest.Unmarshal(m, b) 1854} 1855func (m *UpdateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1856 return xxx_messageInfo_UpdateClusterRequest.Marshal(b, m, deterministic) 1857} 1858func (m *UpdateClusterRequest) XXX_Merge(src proto.Message) { 1859 xxx_messageInfo_UpdateClusterRequest.Merge(m, src) 1860} 1861func (m *UpdateClusterRequest) XXX_Size() int { 1862 return xxx_messageInfo_UpdateClusterRequest.Size(m) 1863} 1864func (m *UpdateClusterRequest) XXX_DiscardUnknown() { 1865 xxx_messageInfo_UpdateClusterRequest.DiscardUnknown(m) 1866} 1867 1868var xxx_messageInfo_UpdateClusterRequest proto.InternalMessageInfo 1869 1870func (m *UpdateClusterRequest) GetProjectId() string { 1871 if m != nil { 1872 return m.ProjectId 1873 } 1874 return "" 1875} 1876 1877func (m *UpdateClusterRequest) GetRegion() string { 1878 if m != nil { 1879 return m.Region 1880 } 1881 return "" 1882} 1883 1884func (m *UpdateClusterRequest) GetClusterName() string { 1885 if m != nil { 1886 return m.ClusterName 1887 } 1888 return "" 1889} 1890 1891func (m *UpdateClusterRequest) GetCluster() *Cluster { 1892 if m != nil { 1893 return m.Cluster 1894 } 1895 return nil 1896} 1897 1898func (m *UpdateClusterRequest) GetGracefulDecommissionTimeout() *duration.Duration { 1899 if m != nil { 1900 return m.GracefulDecommissionTimeout 1901 } 1902 return nil 1903} 1904 1905func (m *UpdateClusterRequest) GetUpdateMask() *field_mask.FieldMask { 1906 if m != nil { 1907 return m.UpdateMask 1908 } 1909 return nil 1910} 1911 1912func (m *UpdateClusterRequest) GetRequestId() string { 1913 if m != nil { 1914 return m.RequestId 1915 } 1916 return "" 1917} 1918 1919// A request to delete a cluster. 1920type DeleteClusterRequest struct { 1921 // Required. The ID of the Google Cloud Platform project that the cluster 1922 // belongs to. 1923 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 1924 // Required. The Dataproc region in which to handle the request. 1925 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 1926 // Required. The cluster name. 1927 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 1928 // Optional. Specifying the `cluster_uuid` means the RPC should fail 1929 // (with error NOT_FOUND) if cluster with specified UUID does not exist. 1930 ClusterUuid string `protobuf:"bytes,4,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"` 1931 // Optional. A unique id used to identify the request. If the server 1932 // receives two [DeleteClusterRequest][google.cloud.dataproc.v1beta2.DeleteClusterRequest] requests with the same 1933 // id, then the second request will be ignored and the 1934 // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the 1935 // backend is returned. 1936 // 1937 // It is recommended to always set this value to a 1938 // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier). 1939 // 1940 // The id must contain only letters (a-z, A-Z), numbers (0-9), 1941 // underscores (_), and hyphens (-). The maximum length is 40 characters. 1942 RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` 1943 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1944 XXX_unrecognized []byte `json:"-"` 1945 XXX_sizecache int32 `json:"-"` 1946} 1947 1948func (m *DeleteClusterRequest) Reset() { *m = DeleteClusterRequest{} } 1949func (m *DeleteClusterRequest) String() string { return proto.CompactTextString(m) } 1950func (*DeleteClusterRequest) ProtoMessage() {} 1951func (*DeleteClusterRequest) Descriptor() ([]byte, []int) { 1952 return fileDescriptor_abc993f8d220b626, []int{19} 1953} 1954 1955func (m *DeleteClusterRequest) XXX_Unmarshal(b []byte) error { 1956 return xxx_messageInfo_DeleteClusterRequest.Unmarshal(m, b) 1957} 1958func (m *DeleteClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1959 return xxx_messageInfo_DeleteClusterRequest.Marshal(b, m, deterministic) 1960} 1961func (m *DeleteClusterRequest) XXX_Merge(src proto.Message) { 1962 xxx_messageInfo_DeleteClusterRequest.Merge(m, src) 1963} 1964func (m *DeleteClusterRequest) XXX_Size() int { 1965 return xxx_messageInfo_DeleteClusterRequest.Size(m) 1966} 1967func (m *DeleteClusterRequest) XXX_DiscardUnknown() { 1968 xxx_messageInfo_DeleteClusterRequest.DiscardUnknown(m) 1969} 1970 1971var xxx_messageInfo_DeleteClusterRequest proto.InternalMessageInfo 1972 1973func (m *DeleteClusterRequest) GetProjectId() string { 1974 if m != nil { 1975 return m.ProjectId 1976 } 1977 return "" 1978} 1979 1980func (m *DeleteClusterRequest) GetRegion() string { 1981 if m != nil { 1982 return m.Region 1983 } 1984 return "" 1985} 1986 1987func (m *DeleteClusterRequest) GetClusterName() string { 1988 if m != nil { 1989 return m.ClusterName 1990 } 1991 return "" 1992} 1993 1994func (m *DeleteClusterRequest) GetClusterUuid() string { 1995 if m != nil { 1996 return m.ClusterUuid 1997 } 1998 return "" 1999} 2000 2001func (m *DeleteClusterRequest) GetRequestId() string { 2002 if m != nil { 2003 return m.RequestId 2004 } 2005 return "" 2006} 2007 2008// Request to get the resource representation for a cluster in a project. 2009type GetClusterRequest struct { 2010 // Required. The ID of the Google Cloud Platform project that the cluster 2011 // belongs to. 2012 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 2013 // Required. The Dataproc region in which to handle the request. 2014 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 2015 // Required. The cluster name. 2016 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 2017 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2018 XXX_unrecognized []byte `json:"-"` 2019 XXX_sizecache int32 `json:"-"` 2020} 2021 2022func (m *GetClusterRequest) Reset() { *m = GetClusterRequest{} } 2023func (m *GetClusterRequest) String() string { return proto.CompactTextString(m) } 2024func (*GetClusterRequest) ProtoMessage() {} 2025func (*GetClusterRequest) Descriptor() ([]byte, []int) { 2026 return fileDescriptor_abc993f8d220b626, []int{20} 2027} 2028 2029func (m *GetClusterRequest) XXX_Unmarshal(b []byte) error { 2030 return xxx_messageInfo_GetClusterRequest.Unmarshal(m, b) 2031} 2032func (m *GetClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2033 return xxx_messageInfo_GetClusterRequest.Marshal(b, m, deterministic) 2034} 2035func (m *GetClusterRequest) XXX_Merge(src proto.Message) { 2036 xxx_messageInfo_GetClusterRequest.Merge(m, src) 2037} 2038func (m *GetClusterRequest) XXX_Size() int { 2039 return xxx_messageInfo_GetClusterRequest.Size(m) 2040} 2041func (m *GetClusterRequest) XXX_DiscardUnknown() { 2042 xxx_messageInfo_GetClusterRequest.DiscardUnknown(m) 2043} 2044 2045var xxx_messageInfo_GetClusterRequest proto.InternalMessageInfo 2046 2047func (m *GetClusterRequest) GetProjectId() string { 2048 if m != nil { 2049 return m.ProjectId 2050 } 2051 return "" 2052} 2053 2054func (m *GetClusterRequest) GetRegion() string { 2055 if m != nil { 2056 return m.Region 2057 } 2058 return "" 2059} 2060 2061func (m *GetClusterRequest) GetClusterName() string { 2062 if m != nil { 2063 return m.ClusterName 2064 } 2065 return "" 2066} 2067 2068// A request to list the clusters in a project. 2069type ListClustersRequest struct { 2070 // Required. The ID of the Google Cloud Platform project that the cluster 2071 // belongs to. 2072 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 2073 // Required. The Dataproc region in which to handle the request. 2074 Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"` 2075 // Optional. A filter constraining the clusters to list. Filters are 2076 // case-sensitive and have the following syntax: 2077 // 2078 // field = value [AND [field = value]] ... 2079 // 2080 // where **field** is one of `status.state`, `clusterName`, or `labels.[KEY]`, 2081 // and `[KEY]` is a label key. **value** can be `*` to match all values. 2082 // `status.state` can be one of the following: `ACTIVE`, `INACTIVE`, 2083 // `CREATING`, `RUNNING`, `ERROR`, `DELETING`, or `UPDATING`. `ACTIVE` 2084 // contains the `CREATING`, `UPDATING`, and `RUNNING` states. `INACTIVE` 2085 // contains the `DELETING` and `ERROR` states. 2086 // `clusterName` is the name of the cluster provided at creation time. 2087 // Only the logical `AND` operator is supported; space-separated items are 2088 // treated as having an implicit `AND` operator. 2089 // 2090 // Example filter: 2091 // 2092 // status.state = ACTIVE AND clusterName = mycluster 2093 // AND labels.env = staging AND labels.starred = * 2094 Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"` 2095 // Optional. The standard List page size. 2096 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 2097 // Optional. The standard List page token. 2098 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 2099 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2100 XXX_unrecognized []byte `json:"-"` 2101 XXX_sizecache int32 `json:"-"` 2102} 2103 2104func (m *ListClustersRequest) Reset() { *m = ListClustersRequest{} } 2105func (m *ListClustersRequest) String() string { return proto.CompactTextString(m) } 2106func (*ListClustersRequest) ProtoMessage() {} 2107func (*ListClustersRequest) Descriptor() ([]byte, []int) { 2108 return fileDescriptor_abc993f8d220b626, []int{21} 2109} 2110 2111func (m *ListClustersRequest) XXX_Unmarshal(b []byte) error { 2112 return xxx_messageInfo_ListClustersRequest.Unmarshal(m, b) 2113} 2114func (m *ListClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2115 return xxx_messageInfo_ListClustersRequest.Marshal(b, m, deterministic) 2116} 2117func (m *ListClustersRequest) XXX_Merge(src proto.Message) { 2118 xxx_messageInfo_ListClustersRequest.Merge(m, src) 2119} 2120func (m *ListClustersRequest) XXX_Size() int { 2121 return xxx_messageInfo_ListClustersRequest.Size(m) 2122} 2123func (m *ListClustersRequest) XXX_DiscardUnknown() { 2124 xxx_messageInfo_ListClustersRequest.DiscardUnknown(m) 2125} 2126 2127var xxx_messageInfo_ListClustersRequest proto.InternalMessageInfo 2128 2129func (m *ListClustersRequest) GetProjectId() string { 2130 if m != nil { 2131 return m.ProjectId 2132 } 2133 return "" 2134} 2135 2136func (m *ListClustersRequest) GetRegion() string { 2137 if m != nil { 2138 return m.Region 2139 } 2140 return "" 2141} 2142 2143func (m *ListClustersRequest) GetFilter() string { 2144 if m != nil { 2145 return m.Filter 2146 } 2147 return "" 2148} 2149 2150func (m *ListClustersRequest) GetPageSize() int32 { 2151 if m != nil { 2152 return m.PageSize 2153 } 2154 return 0 2155} 2156 2157func (m *ListClustersRequest) GetPageToken() string { 2158 if m != nil { 2159 return m.PageToken 2160 } 2161 return "" 2162} 2163 2164// The list of all clusters in a project. 2165type ListClustersResponse struct { 2166 // Output only. The clusters in the project. 2167 Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` 2168 // Output only. This token is included in the response if there are more 2169 // results to fetch. To fetch additional results, provide this value as the 2170 // `page_token` in a subsequent <code>ListClustersRequest</code>. 2171 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 2172 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2173 XXX_unrecognized []byte `json:"-"` 2174 XXX_sizecache int32 `json:"-"` 2175} 2176 2177func (m *ListClustersResponse) Reset() { *m = ListClustersResponse{} } 2178func (m *ListClustersResponse) String() string { return proto.CompactTextString(m) } 2179func (*ListClustersResponse) ProtoMessage() {} 2180func (*ListClustersResponse) Descriptor() ([]byte, []int) { 2181 return fileDescriptor_abc993f8d220b626, []int{22} 2182} 2183 2184func (m *ListClustersResponse) XXX_Unmarshal(b []byte) error { 2185 return xxx_messageInfo_ListClustersResponse.Unmarshal(m, b) 2186} 2187func (m *ListClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2188 return xxx_messageInfo_ListClustersResponse.Marshal(b, m, deterministic) 2189} 2190func (m *ListClustersResponse) XXX_Merge(src proto.Message) { 2191 xxx_messageInfo_ListClustersResponse.Merge(m, src) 2192} 2193func (m *ListClustersResponse) XXX_Size() int { 2194 return xxx_messageInfo_ListClustersResponse.Size(m) 2195} 2196func (m *ListClustersResponse) XXX_DiscardUnknown() { 2197 xxx_messageInfo_ListClustersResponse.DiscardUnknown(m) 2198} 2199 2200var xxx_messageInfo_ListClustersResponse proto.InternalMessageInfo 2201 2202func (m *ListClustersResponse) GetClusters() []*Cluster { 2203 if m != nil { 2204 return m.Clusters 2205 } 2206 return nil 2207} 2208 2209func (m *ListClustersResponse) GetNextPageToken() string { 2210 if m != nil { 2211 return m.NextPageToken 2212 } 2213 return "" 2214} 2215 2216// A request to collect cluster diagnostic information. 2217type DiagnoseClusterRequest struct { 2218 // Required. The ID of the Google Cloud Platform project that the cluster 2219 // belongs to. 2220 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` 2221 // Required. The Dataproc region in which to handle the request. 2222 Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` 2223 // Required. The cluster name. 2224 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` 2225 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2226 XXX_unrecognized []byte `json:"-"` 2227 XXX_sizecache int32 `json:"-"` 2228} 2229 2230func (m *DiagnoseClusterRequest) Reset() { *m = DiagnoseClusterRequest{} } 2231func (m *DiagnoseClusterRequest) String() string { return proto.CompactTextString(m) } 2232func (*DiagnoseClusterRequest) ProtoMessage() {} 2233func (*DiagnoseClusterRequest) Descriptor() ([]byte, []int) { 2234 return fileDescriptor_abc993f8d220b626, []int{23} 2235} 2236 2237func (m *DiagnoseClusterRequest) XXX_Unmarshal(b []byte) error { 2238 return xxx_messageInfo_DiagnoseClusterRequest.Unmarshal(m, b) 2239} 2240func (m *DiagnoseClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2241 return xxx_messageInfo_DiagnoseClusterRequest.Marshal(b, m, deterministic) 2242} 2243func (m *DiagnoseClusterRequest) XXX_Merge(src proto.Message) { 2244 xxx_messageInfo_DiagnoseClusterRequest.Merge(m, src) 2245} 2246func (m *DiagnoseClusterRequest) XXX_Size() int { 2247 return xxx_messageInfo_DiagnoseClusterRequest.Size(m) 2248} 2249func (m *DiagnoseClusterRequest) XXX_DiscardUnknown() { 2250 xxx_messageInfo_DiagnoseClusterRequest.DiscardUnknown(m) 2251} 2252 2253var xxx_messageInfo_DiagnoseClusterRequest proto.InternalMessageInfo 2254 2255func (m *DiagnoseClusterRequest) GetProjectId() string { 2256 if m != nil { 2257 return m.ProjectId 2258 } 2259 return "" 2260} 2261 2262func (m *DiagnoseClusterRequest) GetRegion() string { 2263 if m != nil { 2264 return m.Region 2265 } 2266 return "" 2267} 2268 2269func (m *DiagnoseClusterRequest) GetClusterName() string { 2270 if m != nil { 2271 return m.ClusterName 2272 } 2273 return "" 2274} 2275 2276// The location of diagnostic output. 2277type DiagnoseClusterResults struct { 2278 // Output only. The Cloud Storage URI of the diagnostic output. 2279 // The output report is a plain text file with a summary of collected 2280 // diagnostics. 2281 OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"` 2282 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2283 XXX_unrecognized []byte `json:"-"` 2284 XXX_sizecache int32 `json:"-"` 2285} 2286 2287func (m *DiagnoseClusterResults) Reset() { *m = DiagnoseClusterResults{} } 2288func (m *DiagnoseClusterResults) String() string { return proto.CompactTextString(m) } 2289func (*DiagnoseClusterResults) ProtoMessage() {} 2290func (*DiagnoseClusterResults) Descriptor() ([]byte, []int) { 2291 return fileDescriptor_abc993f8d220b626, []int{24} 2292} 2293 2294func (m *DiagnoseClusterResults) XXX_Unmarshal(b []byte) error { 2295 return xxx_messageInfo_DiagnoseClusterResults.Unmarshal(m, b) 2296} 2297func (m *DiagnoseClusterResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2298 return xxx_messageInfo_DiagnoseClusterResults.Marshal(b, m, deterministic) 2299} 2300func (m *DiagnoseClusterResults) XXX_Merge(src proto.Message) { 2301 xxx_messageInfo_DiagnoseClusterResults.Merge(m, src) 2302} 2303func (m *DiagnoseClusterResults) XXX_Size() int { 2304 return xxx_messageInfo_DiagnoseClusterResults.Size(m) 2305} 2306func (m *DiagnoseClusterResults) XXX_DiscardUnknown() { 2307 xxx_messageInfo_DiagnoseClusterResults.DiscardUnknown(m) 2308} 2309 2310var xxx_messageInfo_DiagnoseClusterResults proto.InternalMessageInfo 2311 2312func (m *DiagnoseClusterResults) GetOutputUri() string { 2313 if m != nil { 2314 return m.OutputUri 2315 } 2316 return "" 2317} 2318 2319// Reservation Affinity for consuming Zonal reservation. 2320type ReservationAffinity struct { 2321 // Optional. Type of reservation to consume 2322 ConsumeReservationType ReservationAffinity_Type `protobuf:"varint,1,opt,name=consume_reservation_type,json=consumeReservationType,proto3,enum=google.cloud.dataproc.v1beta2.ReservationAffinity_Type" json:"consume_reservation_type,omitempty"` 2323 // Optional. Corresponds to the label key of reservation resource. 2324 Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` 2325 // Optional. Corresponds to the label values of reservation resource. 2326 Values []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` 2327 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2328 XXX_unrecognized []byte `json:"-"` 2329 XXX_sizecache int32 `json:"-"` 2330} 2331 2332func (m *ReservationAffinity) Reset() { *m = ReservationAffinity{} } 2333func (m *ReservationAffinity) String() string { return proto.CompactTextString(m) } 2334func (*ReservationAffinity) ProtoMessage() {} 2335func (*ReservationAffinity) Descriptor() ([]byte, []int) { 2336 return fileDescriptor_abc993f8d220b626, []int{25} 2337} 2338 2339func (m *ReservationAffinity) XXX_Unmarshal(b []byte) error { 2340 return xxx_messageInfo_ReservationAffinity.Unmarshal(m, b) 2341} 2342func (m *ReservationAffinity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2343 return xxx_messageInfo_ReservationAffinity.Marshal(b, m, deterministic) 2344} 2345func (m *ReservationAffinity) XXX_Merge(src proto.Message) { 2346 xxx_messageInfo_ReservationAffinity.Merge(m, src) 2347} 2348func (m *ReservationAffinity) XXX_Size() int { 2349 return xxx_messageInfo_ReservationAffinity.Size(m) 2350} 2351func (m *ReservationAffinity) XXX_DiscardUnknown() { 2352 xxx_messageInfo_ReservationAffinity.DiscardUnknown(m) 2353} 2354 2355var xxx_messageInfo_ReservationAffinity proto.InternalMessageInfo 2356 2357func (m *ReservationAffinity) GetConsumeReservationType() ReservationAffinity_Type { 2358 if m != nil { 2359 return m.ConsumeReservationType 2360 } 2361 return ReservationAffinity_TYPE_UNSPECIFIED 2362} 2363 2364func (m *ReservationAffinity) GetKey() string { 2365 if m != nil { 2366 return m.Key 2367 } 2368 return "" 2369} 2370 2371func (m *ReservationAffinity) GetValues() []string { 2372 if m != nil { 2373 return m.Values 2374 } 2375 return nil 2376} 2377 2378func init() { 2379 proto.RegisterEnum("google.cloud.dataproc.v1beta2.ClusterStatus_State", ClusterStatus_State_name, ClusterStatus_State_value) 2380 proto.RegisterEnum("google.cloud.dataproc.v1beta2.ClusterStatus_Substate", ClusterStatus_Substate_name, ClusterStatus_Substate_value) 2381 proto.RegisterEnum("google.cloud.dataproc.v1beta2.ReservationAffinity_Type", ReservationAffinity_Type_name, ReservationAffinity_Type_value) 2382 proto.RegisterType((*Cluster)(nil), "google.cloud.dataproc.v1beta2.Cluster") 2383 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1beta2.Cluster.LabelsEntry") 2384 proto.RegisterType((*ClusterConfig)(nil), "google.cloud.dataproc.v1beta2.ClusterConfig") 2385 proto.RegisterType((*EndpointConfig)(nil), "google.cloud.dataproc.v1beta2.EndpointConfig") 2386 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1beta2.EndpointConfig.HttpPortsEntry") 2387 proto.RegisterType((*AutoscalingConfig)(nil), "google.cloud.dataproc.v1beta2.AutoscalingConfig") 2388 proto.RegisterType((*EncryptionConfig)(nil), "google.cloud.dataproc.v1beta2.EncryptionConfig") 2389 proto.RegisterType((*GceClusterConfig)(nil), "google.cloud.dataproc.v1beta2.GceClusterConfig") 2390 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1beta2.GceClusterConfig.MetadataEntry") 2391 proto.RegisterType((*InstanceGroupConfig)(nil), "google.cloud.dataproc.v1beta2.InstanceGroupConfig") 2392 proto.RegisterType((*ManagedGroupConfig)(nil), "google.cloud.dataproc.v1beta2.ManagedGroupConfig") 2393 proto.RegisterType((*AcceleratorConfig)(nil), "google.cloud.dataproc.v1beta2.AcceleratorConfig") 2394 proto.RegisterType((*DiskConfig)(nil), "google.cloud.dataproc.v1beta2.DiskConfig") 2395 proto.RegisterType((*LifecycleConfig)(nil), "google.cloud.dataproc.v1beta2.LifecycleConfig") 2396 proto.RegisterType((*SecurityConfig)(nil), "google.cloud.dataproc.v1beta2.SecurityConfig") 2397 proto.RegisterType((*KerberosConfig)(nil), "google.cloud.dataproc.v1beta2.KerberosConfig") 2398 proto.RegisterType((*NodeInitializationAction)(nil), "google.cloud.dataproc.v1beta2.NodeInitializationAction") 2399 proto.RegisterType((*ClusterStatus)(nil), "google.cloud.dataproc.v1beta2.ClusterStatus") 2400 proto.RegisterType((*SoftwareConfig)(nil), "google.cloud.dataproc.v1beta2.SoftwareConfig") 2401 proto.RegisterMapType((map[string]string)(nil), "google.cloud.dataproc.v1beta2.SoftwareConfig.PropertiesEntry") 2402 proto.RegisterType((*ClusterMetrics)(nil), "google.cloud.dataproc.v1beta2.ClusterMetrics") 2403 proto.RegisterMapType((map[string]int64)(nil), "google.cloud.dataproc.v1beta2.ClusterMetrics.HdfsMetricsEntry") 2404 proto.RegisterMapType((map[string]int64)(nil), "google.cloud.dataproc.v1beta2.ClusterMetrics.YarnMetricsEntry") 2405 proto.RegisterType((*CreateClusterRequest)(nil), "google.cloud.dataproc.v1beta2.CreateClusterRequest") 2406 proto.RegisterType((*UpdateClusterRequest)(nil), "google.cloud.dataproc.v1beta2.UpdateClusterRequest") 2407 proto.RegisterType((*DeleteClusterRequest)(nil), "google.cloud.dataproc.v1beta2.DeleteClusterRequest") 2408 proto.RegisterType((*GetClusterRequest)(nil), "google.cloud.dataproc.v1beta2.GetClusterRequest") 2409 proto.RegisterType((*ListClustersRequest)(nil), "google.cloud.dataproc.v1beta2.ListClustersRequest") 2410 proto.RegisterType((*ListClustersResponse)(nil), "google.cloud.dataproc.v1beta2.ListClustersResponse") 2411 proto.RegisterType((*DiagnoseClusterRequest)(nil), "google.cloud.dataproc.v1beta2.DiagnoseClusterRequest") 2412 proto.RegisterType((*DiagnoseClusterResults)(nil), "google.cloud.dataproc.v1beta2.DiagnoseClusterResults") 2413 proto.RegisterType((*ReservationAffinity)(nil), "google.cloud.dataproc.v1beta2.ReservationAffinity") 2414} 2415 2416func init() { 2417 proto.RegisterFile("google/cloud/dataproc/v1beta2/clusters.proto", fileDescriptor_abc993f8d220b626) 2418} 2419 2420var fileDescriptor_abc993f8d220b626 = []byte{ 2421 // 3101 bytes of a gzipped FileDescriptorProto 2422 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x5a, 0xcd, 0x6f, 0x1b, 0xc7, 2423 0x15, 0x37, 0x49, 0x7d, 0x3e, 0x8a, 0x14, 0x35, 0x92, 0x6d, 0x46, 0x6e, 0x52, 0x95, 0x49, 0x03, 2424 0xc5, 0xb1, 0xc9, 0x58, 0x41, 0xe2, 0xc4, 0x71, 0x82, 0xd2, 0x12, 0x2d, 0x09, 0x92, 0x25, 0x61, 2425 0x45, 0x39, 0x75, 0x5b, 0x74, 0xbb, 0xdc, 0x1d, 0x51, 0x1b, 0xee, 0x57, 0x77, 0x66, 0xed, 0xd0, 2426 0x6e, 0x0e, 0xed, 0xb9, 0x05, 0x5a, 0x04, 0xfd, 0x07, 0x7a, 0x2a, 0x9a, 0x6b, 0x0e, 0xfd, 0xb8, 2427 0x14, 0x45, 0x81, 0x02, 0xe9, 0xa5, 0x68, 0xd1, 0x1e, 0x72, 0xea, 0xa1, 0x40, 0x0f, 0xed, 0xff, 2428 0xd0, 0x62, 0x3e, 0x76, 0x77, 0x96, 0x54, 0x4c, 0xca, 0x36, 0x90, 0x93, 0x96, 0xef, 0xe3, 0xf7, 2429 0xde, 0xbc, 0x79, 0xfb, 0xde, 0x9b, 0x59, 0xc1, 0x95, 0xae, 0xef, 0x77, 0x1d, 0xdc, 0x30, 0x1d, 2430 0x3f, 0xb2, 0x1a, 0x96, 0x41, 0x8d, 0x20, 0xf4, 0xcd, 0xc6, 0xfd, 0x6b, 0x1d, 0x4c, 0x8d, 0xb5, 2431 0x86, 0xe9, 0x44, 0x84, 0xe2, 0x90, 0xd4, 0x83, 0xd0, 0xa7, 0x3e, 0x7a, 0x5e, 0x48, 0xd7, 0xb9, 2432 0x74, 0x3d, 0x96, 0xae, 0x4b, 0xe9, 0xe5, 0xaf, 0x48, 0x30, 0x23, 0xb0, 0x1b, 0x86, 0xe7, 0xf9, 2433 0xd4, 0xa0, 0xb6, 0xef, 0x49, 0xe5, 0xe5, 0x8b, 0x0a, 0xd7, 0x74, 0x6c, 0xec, 0x51, 0xc9, 0xf8, 2434 0xaa, 0xc2, 0x38, 0xb6, 0xb1, 0x63, 0xe9, 0x1d, 0x7c, 0x62, 0xdc, 0xb7, 0xfd, 0x50, 0x0a, 0x3c, 2435 0xa7, 0x08, 0x84, 0x98, 0xf8, 0x51, 0x68, 0x62, 0xc9, 0xba, 0xfc, 0x78, 0xff, 0xc9, 0x89, 0x11, 2436 0x62, 0x4b, 0xca, 0xbe, 0x28, 0x65, 0x1d, 0xdf, 0xeb, 0x86, 0x91, 0xe7, 0xd9, 0x5e, 0xb7, 0xe1, 2437 0x07, 0x38, 0xcc, 0x78, 0xf9, 0x82, 0x14, 0xe2, 0xbf, 0x3a, 0xd1, 0x71, 0xc3, 0x8a, 0x84, 0x80, 2438 0xe4, 0xaf, 0x0c, 0xf2, 0x85, 0xc7, 0xae, 0x41, 0x7a, 0x03, 0xcb, 0x49, 0x24, 0xa8, 0xed, 0x62, 2439 0x42, 0x0d, 0x37, 0x10, 0x02, 0xb5, 0x3f, 0x4d, 0xc0, 0xf4, 0xba, 0x08, 0x2c, 0xaa, 0x01, 0x04, 2440 0xa1, 0xff, 0x01, 0x36, 0xa9, 0x6e, 0x5b, 0xd5, 0xdc, 0x4a, 0x6e, 0x75, 0xf6, 0x56, 0xe1, 0x9f, 2441 0xcd, 0xbc, 0x36, 0x2b, 0xc9, 0xdb, 0x16, 0x7a, 0x19, 0xe6, 0xe4, 0x3e, 0xe8, 0x9e, 0xe1, 0xe2, 2442 0x6a, 0x3e, 0x95, 0x2a, 0x4a, 0xc6, 0x9e, 0xe1, 0x62, 0xb4, 0x0d, 0x53, 0xa6, 0xef, 0x1d, 0xdb, 2443 0xdd, 0x6a, 0x61, 0x25, 0xb7, 0x5a, 0x5c, 0xbb, 0x52, 0x7f, 0xec, 0x76, 0xd5, 0xa5, 0x0f, 0xeb, 2444 0x5c, 0x47, 0xe0, 0x49, 0x00, 0xb4, 0x0f, 0x53, 0x8e, 0xd1, 0xc1, 0x0e, 0xa9, 0xce, 0xac, 0x14, 2445 0x56, 0x8b, 0x6b, 0x6b, 0xe3, 0x41, 0xd5, 0x77, 0xb9, 0x52, 0xcb, 0xa3, 0x61, 0x9f, 0x01, 0xe6, 2446 0x34, 0x09, 0xc3, 0x7c, 0x23, 0xd4, 0xa0, 0x11, 0xa9, 0x4e, 0x9c, 0xc5, 0xb7, 0x43, 0xae, 0xc3, 2447 0xa0, 0x0a, 0x9a, 0x04, 0x40, 0xdf, 0x84, 0xb2, 0x78, 0xd2, 0x4f, 0x6c, 0x42, 0xfd, 0xb0, 0x5f, 2448 0x9d, 0xe6, 0x3e, 0x3e, 0x01, 0x64, 0x49, 0x00, 0x6d, 0x09, 0x1c, 0x35, 0xd0, 0x51, 0x64, 0x5b, 2449 0xd5, 0xa9, 0x38, 0xd0, 0x85, 0x24, 0xd0, 0x47, 0x91, 0x6d, 0xa1, 0x5d, 0x98, 0x76, 0x31, 0x0d, 2450 0x6d, 0x93, 0x54, 0x67, 0xf9, 0x6a, 0xae, 0x8e, 0x67, 0xfa, 0x8e, 0x50, 0x12, 0x88, 0x31, 0xc4, 2451 0xf2, 0xdb, 0x50, 0x54, 0xc2, 0x86, 0x2a, 0x50, 0xe8, 0xe1, 0xbe, 0x48, 0x05, 0x8d, 0x3d, 0xa2, 2452 0x25, 0x98, 0xbc, 0x6f, 0x38, 0x91, 0xdc, 0x78, 0x4d, 0xfc, 0xb8, 0x91, 0x7f, 0x2b, 0x57, 0xfb, 2453 0xdf, 0x0c, 0x94, 0x32, 0xbb, 0x88, 0x56, 0xa1, 0x24, 0xb6, 0x50, 0xef, 0x44, 0x66, 0x0f, 0xd3, 2454 0x34, 0xa5, 0x72, 0xda, 0x9c, 0xe0, 0xdc, 0xe2, 0x0c, 0xd4, 0x01, 0xd4, 0x35, 0xb1, 0x1e, 0x2f, 2455 0x58, 0x66, 0xce, 0x0c, 0x5f, 0x4f, 0x63, 0xc4, 0x7a, 0x36, 0x4d, 0x3c, 0x94, 0x3c, 0x39, 0xad, 2456 0xd2, 0x1d, 0x20, 0xa3, 0xef, 0x40, 0xc9, 0x35, 0x54, 0x78, 0x11, 0xae, 0x51, 0xd9, 0xb4, 0xed, 2457 0x11, 0x6a, 0x78, 0x26, 0xde, 0x0c, 0xfd, 0x28, 0x50, 0x2d, 0xcc, 0x09, 0xb4, 0x14, 0xfd, 0x81, 2458 0x1f, 0xf6, 0x52, 0x74, 0x78, 0x4a, 0x74, 0x81, 0x26, 0xd1, 0x7d, 0xb8, 0x48, 0xb0, 0xe9, 0x7b, 2459 0x96, 0x11, 0xf6, 0xf5, 0xac, 0x9d, 0xb9, 0xa7, 0xb3, 0x73, 0x3e, 0xc1, 0x7d, 0x5f, 0x35, 0xf8, 2460 0x6d, 0x98, 0x27, 0xfe, 0x31, 0x7d, 0x60, 0x84, 0x38, 0x36, 0x54, 0x1a, 0x2b, 0xbb, 0x0e, 0xa5, 2461 0x96, 0x6a, 0xa3, 0x4c, 0x32, 0x44, 0xf4, 0x5d, 0xa8, 0x38, 0xf6, 0x31, 0x36, 0xfb, 0xa6, 0x93, 2462 0xa0, 0x97, 0x39, 0x7a, 0x7d, 0x04, 0xfa, 0x6e, 0xac, 0xa6, 0xc2, 0xcf, 0x3b, 0x59, 0x2a, 0x22, 2463 0x70, 0xc1, 0xf6, 0x6c, 0x6a, 0x1b, 0x8e, 0xfd, 0x90, 0x97, 0x4b, 0xdd, 0x30, 0x79, 0x59, 0xad, 2464 0x16, 0xf9, 0xcb, 0x79, 0x7d, 0x84, 0x95, 0x3d, 0xdf, 0xc2, 0xdb, 0x19, 0x80, 0x26, 0xd7, 0x97, 2465 0x11, 0xb3, 0x4f, 0x61, 0x11, 0x64, 0xc0, 0x02, 0xf6, 0xcc, 0xb0, 0x1f, 0x70, 0x83, 0x72, 0x55, 2466 0xf3, 0x63, 0x65, 0x70, 0x2b, 0xd1, 0xcb, 0x64, 0x30, 0x1e, 0x20, 0x23, 0x0b, 0x90, 0x11, 0x51, 2467 0x9f, 0x98, 0x86, 0x63, 0x7b, 0xdd, 0xd8, 0x46, 0x85, 0xdb, 0x78, 0x6d, 0x84, 0x8d, 0x66, 0xaa, 2468 0xa8, 0x1a, 0x59, 0x30, 0x06, 0xe9, 0x6c, 0xeb, 0xb1, 0x67, 0x05, 0xbe, 0xed, 0xd1, 0xd8, 0xc4, 2469 0xc2, 0x58, 0x5b, 0xdf, 0x92, 0x5a, 0x99, 0xad, 0xc7, 0x19, 0x22, 0xcf, 0x2b, 0x6c, 0x46, 0xa1, 2470 0x4d, 0xfb, 0x31, 0x38, 0x1a, 0x2f, 0xaf, 0xa4, 0x56, 0x36, 0xaf, 0x32, 0xc4, 0xda, 0x7f, 0x73, 2471 0x50, 0xce, 0x3a, 0x81, 0xbe, 0x07, 0x70, 0x42, 0x69, 0xa0, 0x07, 0x7e, 0x48, 0x49, 0x35, 0xc7, 2472 0xb7, 0xff, 0xe6, 0x99, 0xd6, 0x51, 0xdf, 0xa2, 0x34, 0x38, 0x60, 0xea, 0x49, 0x27, 0x29, 0x68, 2473 0xb3, 0x27, 0x31, 0x11, 0xdd, 0x80, 0x8b, 0xd8, 0x33, 0x3a, 0x0e, 0xd6, 0x13, 0x43, 0xba, 0x61, 2474 0x9a, 0x98, 0x10, 0x5e, 0x22, 0x67, 0x84, 0xab, 0x4b, 0x42, 0x26, 0xc6, 0x6a, 0x72, 0x81, 0xe5, 2475 0x9b, 0x50, 0xce, 0xa2, 0x9f, 0xa9, 0xe0, 0x5e, 0x87, 0x85, 0xa1, 0x5d, 0xe5, 0x3d, 0xdc, 0x77, 2476 0x6c, 0xb3, 0xaf, 0x47, 0xa1, 0xad, 0x16, 0xdc, 0x59, 0x41, 0x3e, 0x0a, 0xed, 0x5a, 0x0b, 0x2a, 2477 0x83, 0x29, 0x87, 0xae, 0xc1, 0x22, 0xab, 0xc0, 0x81, 0xa5, 0xf7, 0x5c, 0xa2, 0xf7, 0x70, 0x5f, 2478 0xb4, 0x77, 0x05, 0x60, 0xbe, 0x6b, 0xe2, 0x03, 0x6b, 0xc7, 0x25, 0x3b, 0xb8, 0xcf, 0x5a, 0x7c, 2479 0xed, 0xd3, 0x09, 0xa8, 0x0c, 0x16, 0x5f, 0xf4, 0x02, 0xcc, 0x3c, 0xf4, 0x3d, 0x3c, 0x68, 0x7d, 2480 0x9a, 0x11, 0x8f, 0x42, 0x1b, 0xbd, 0x04, 0x45, 0x0f, 0x53, 0x56, 0xc2, 0xb8, 0x48, 0x3e, 0x15, 2481 0x01, 0x49, 0x67, 0x52, 0x97, 0xa1, 0x4c, 0xa2, 0x8e, 0x2a, 0x38, 0x95, 0x0a, 0x96, 0x52, 0x16, 2482 0x93, 0xbd, 0x0a, 0x15, 0xdb, 0xa3, 0x38, 0xf4, 0x0c, 0x47, 0xb7, 0x03, 0xdd, 0xf7, 0x1c, 0xd6, 2483 0x84, 0x93, 0xc8, 0x97, 0x63, 0xe6, 0x76, 0xb0, 0xef, 0x39, 0x7d, 0x74, 0x85, 0x65, 0x60, 0x78, 2484 0xdf, 0x36, 0x31, 0xdb, 0x26, 0x3f, 0xf2, 0x28, 0xef, 0x33, 0xb3, 0x49, 0x4a, 0x71, 0x5e, 0x53, 2485 0xb0, 0xd0, 0xdb, 0x70, 0x61, 0x40, 0x5a, 0x27, 0xa6, 0x1f, 0x60, 0x52, 0x2d, 0xac, 0x14, 0x62, 2486 0xa5, 0xa5, 0xac, 0xd2, 0x21, 0x17, 0x40, 0x08, 0x26, 0xa8, 0xd1, 0x65, 0x33, 0x46, 0x61, 0x75, 2487 0x56, 0xe3, 0xcf, 0xe8, 0x1e, 0xcc, 0xb8, 0x98, 0x1a, 0x2c, 0xe5, 0xaa, 0x93, 0x3c, 0x19, 0xdf, 2488 0x3d, 0x63, 0x77, 0xab, 0xdf, 0x91, 0xfa, 0x3c, 0x5f, 0xb4, 0x04, 0x0e, 0x7d, 0x00, 0x4b, 0x21, 2489 0x66, 0x8e, 0xc8, 0x8a, 0x77, 0x7c, 0xcc, 0xea, 0x54, 0xbf, 0x5a, 0x1c, 0xab, 0x3f, 0x68, 0xa9, 2490 0x6a, 0x53, 0x6a, 0x8a, 0xb5, 0x2d, 0x86, 0xc3, 0x9c, 0xe5, 0x77, 0xa0, 0x94, 0x71, 0xe3, 0x4c, 2491 0x69, 0xfb, 0xcb, 0x09, 0x58, 0x3c, 0xa5, 0x1d, 0xb1, 0x69, 0xc1, 0x8b, 0x5c, 0xdd, 0x96, 0x2c, 2492 0xc2, 0xd1, 0x26, 0x65, 0x37, 0xf4, 0x22, 0x37, 0xd6, 0x21, 0x2c, 0x3b, 0x62, 0x29, 0x9e, 0xa5, 2493 0xec, 0x4d, 0x2b, 0xc4, 0xc3, 0x51, 0x29, 0x66, 0xb1, 0x1c, 0x25, 0x68, 0x05, 0x66, 0x6d, 0xd7, 2494 0xe8, 0x8a, 0x84, 0x2c, 0xa4, 0x1b, 0x3d, 0xc3, 0xa9, 0x32, 0x7f, 0x5c, 0xc3, 0x3c, 0xb1, 0x3d, 2495 0xac, 0xd3, 0x7e, 0x20, 0x04, 0x27, 0x94, 0x8c, 0x90, 0xcc, 0x76, 0x3f, 0xe0, 0xe2, 0xfb, 0x50, 2496 0xb4, 0x6c, 0xd2, 0x8b, 0xab, 0xd7, 0x24, 0x0f, 0xef, 0x2b, 0x23, 0xc2, 0xbb, 0x61, 0x93, 0x9e, 2497 0x5a, 0xb9, 0xc0, 0x4a, 0x08, 0x7c, 0x35, 0x44, 0x0f, 0x42, 0x8c, 0xdd, 0x80, 0xda, 0x1d, 0x07, 2498 0xf3, 0x5c, 0x97, 0xd9, 0x5b, 0xb2, 0xc9, 0x41, 0xca, 0x41, 0x27, 0xb0, 0xe4, 0x1a, 0x9e, 0xd1, 2499 0xc5, 0x96, 0xde, 0x65, 0xa1, 0x8b, 0xbd, 0x98, 0xe6, 0x5e, 0x5c, 0x1b, 0xe1, 0xc5, 0x1d, 0xa1, 2500 0x3a, 0x30, 0x03, 0x14, 0x34, 0xe4, 0x0e, 0x31, 0xd0, 0x3d, 0x98, 0x63, 0x55, 0xcc, 0x61, 0x27, 2501 0x12, 0x3f, 0x8c, 0x47, 0xef, 0x91, 0x5d, 0x26, 0x55, 0xc9, 0x0c, 0x33, 0x2a, 0x14, 0x5a, 0x85, 2502 0x8a, 0x6b, 0x7b, 0xba, 0x19, 0x44, 0x7a, 0xe0, 0x18, 0xf4, 0xd8, 0x0f, 0x5d, 0x3e, 0x8b, 0xcd, 2503 0x6a, 0x65, 0xd7, 0xf6, 0xd6, 0x83, 0xe8, 0x40, 0x52, 0x6b, 0x1f, 0xe7, 0x00, 0x0d, 0x3b, 0xcd, 2504 0x5e, 0xca, 0x64, 0xff, 0x29, 0x76, 0x19, 0x08, 0x1e, 0x28, 0x57, 0x05, 0x6d, 0x29, 0x16, 0x69, 2505 0x4b, 0x09, 0x7e, 0x2c, 0xb9, 0x05, 0x97, 0x12, 0x55, 0x11, 0x41, 0xb1, 0xf6, 0xc1, 0xd3, 0x4c, 2506 0x41, 0xab, 0xda, 0x6a, 0x8e, 0x0a, 0x2f, 0xf8, 0xd1, 0xa6, 0x16, 0xc2, 0xc2, 0xd0, 0x3a, 0xd1, 2507 0x6b, 0xb0, 0xa4, 0x2c, 0x32, 0xcd, 0x24, 0xf1, 0x4a, 0x20, 0x85, 0x17, 0x27, 0xd2, 0xab, 0xb0, 2508 0xa0, 0x6a, 0x88, 0x52, 0xc4, 0x1c, 0x98, 0xd4, 0x2a, 0x86, 0x8a, 0x1f, 0x79, 0xb4, 0xf6, 0x93, 2509 0x1c, 0x40, 0x9a, 0x44, 0xe8, 0x15, 0x28, 0x77, 0x7c, 0x9f, 0xea, 0x3c, 0x13, 0x99, 0x2d, 0x35, 2510 0xb5, 0xe7, 0x18, 0x8b, 0x09, 0x33, 0x4b, 0xa8, 0x0e, 0x0b, 0xa9, 0x28, 0xb1, 0x1f, 0x62, 0xbd, 2511 0xdb, 0x51, 0x5f, 0xad, 0x72, 0x2c, 0x7d, 0x68, 0x3f, 0xc4, 0x9b, 0x1d, 0xf4, 0x12, 0x94, 0xd9, 2512 0x6b, 0xe8, 0xf8, 0xa6, 0xe1, 0xe8, 0x84, 0x58, 0x44, 0xfa, 0xc4, 0x5e, 0xc1, 0x5d, 0x46, 0x3c, 2513 0x24, 0x16, 0xa9, 0xfd, 0x3e, 0x0f, 0xf3, 0x03, 0xc3, 0x18, 0xba, 0x0d, 0xf3, 0xb6, 0xe5, 0x60, 2514 0xdd, 0xc2, 0x0e, 0xa6, 0x58, 0xa7, 0xd4, 0xe1, 0x76, 0x8a, 0x6b, 0xcf, 0xc5, 0x59, 0x13, 0x9f, 2515 0x42, 0xeb, 0x1b, 0xf2, 0x1c, 0x1b, 0x27, 0xb9, 0xe5, 0xe0, 0x0d, 0xae, 0xd5, 0xa6, 0x0e, 0xda, 2516 0x81, 0x0a, 0x9b, 0x4a, 0x12, 0x1c, 0x5b, 0x6e, 0x4c, 0x71, 0x6d, 0x79, 0x08, 0xa8, 0x1d, 0x1f, 2517 0x67, 0x39, 0xd2, 0xd6, 0x39, 0xad, 0xcc, 0x54, 0x25, 0x96, 0xed, 0x62, 0xb4, 0x05, 0xf3, 0x19, 2518 0x30, 0xea, 0xc8, 0x03, 0xe9, 0x08, 0xa7, 0xb6, 0xce, 0x69, 0x25, 0x05, 0x8a, 0x3a, 0x68, 0x53, 2519 0x2e, 0x8f, 0x50, 0x23, 0xa4, 0xc2, 0xab, 0x89, 0x71, 0xbc, 0x2a, 0x88, 0xf5, 0x1d, 0x32, 0x35, 2520 0xc6, 0xb8, 0x35, 0x09, 0x05, 0x4a, 0x9d, 0xda, 0x09, 0x94, 0xb3, 0x43, 0x0d, 0xba, 0x0b, 0xf3, 2521 0x3d, 0x1c, 0x76, 0x70, 0xe8, 0x93, 0xf8, 0xc5, 0xce, 0x8d, 0x35, 0x1c, 0xed, 0x48, 0x2d, 0x81, 2522 0xa3, 0x95, 0x7b, 0x99, 0xdf, 0xb5, 0x4f, 0xa6, 0xa0, 0x9c, 0x15, 0x61, 0x5d, 0x50, 0x4e, 0x2d, 2523 0xb1, 0x2c, 0x37, 0x35, 0x93, 0x4c, 0x6d, 0x8c, 0x17, 0xeb, 0xb0, 0xb7, 0x26, 0x64, 0x39, 0x14, 2524 0x84, 0xb6, 0x67, 0xda, 0x81, 0xe1, 0xe8, 0x81, 0x41, 0xc8, 0x03, 0x3f, 0xb4, 0xb2, 0x4d, 0x3c, 2525 0xaf, 0x55, 0x99, 0xdc, 0x41, 0x2c, 0x76, 0x20, 0xa5, 0x58, 0xba, 0xbf, 0x08, 0xc5, 0x78, 0xb2, 2526 0xc8, 0x94, 0xe2, 0xbc, 0x36, 0xdb, 0xe3, 0x33, 0x05, 0x13, 0x7a, 0x19, 0xe6, 0x7a, 0xb8, 0xcf, 2527 0x0e, 0xc0, 0x43, 0x75, 0xb8, 0x18, 0x33, 0xe4, 0x7c, 0x40, 0xc3, 0x88, 0xd0, 0x54, 0x72, 0x52, 2528 0x99, 0x0f, 0x52, 0x16, 0x93, 0xbd, 0x0e, 0xe7, 0x13, 0xcc, 0x8c, 0xdb, 0xca, 0x48, 0xb1, 0x18, 2529 0x4b, 0xa8, 0x1e, 0x5f, 0x85, 0x0a, 0xf3, 0x36, 0xa3, 0x33, 0xad, 0x34, 0x86, 0x1e, 0xee, 0xab, 2530 0xe2, 0xef, 0xc0, 0x45, 0xc5, 0xa7, 0x8c, 0x96, 0x32, 0x60, 0x9c, 0x4f, 0x65, 0x54, 0xe5, 0x1b, 2531 0x70, 0xd1, 0x0c, 0x7d, 0x42, 0xf4, 0x10, 0x1b, 0x8e, 0xab, 0x73, 0x21, 0xf1, 0x2c, 0x4a, 0xa3, 2532 0x1c, 0x34, 0xb8, 0x8c, 0xc6, 0xc8, 0x6d, 0x26, 0xc1, 0x9f, 0xd0, 0x9b, 0x70, 0x7e, 0x58, 0xb7, 2533 0x67, 0x99, 0xfc, 0x08, 0x2a, 0x35, 0xd1, 0x80, 0xe6, 0x8e, 0x65, 0xa2, 0x4d, 0x78, 0x61, 0x58, 2534 0xcf, 0xb0, 0x58, 0x6d, 0x66, 0x2d, 0x1f, 0x87, 0x7c, 0x76, 0x90, 0x00, 0xcb, 0x03, 0x00, 0x4d, 2535 0x26, 0x77, 0xc8, 0xc5, 0x50, 0x1b, 0xbe, 0x3e, 0x0c, 0x24, 0x6e, 0xbb, 0xb2, 0x71, 0x98, 0x4b, 2536 0xf1, 0x56, 0x06, 0xf0, 0x0e, 0xb9, 0xb8, 0x1a, 0x92, 0x55, 0x28, 0xf7, 0x2c, 0x53, 0xb7, 0x3a, 2537 0x49, 0xce, 0x94, 0xd4, 0x6c, 0xb0, 0xcc, 0x8d, 0x8e, 0xcc, 0x9a, 0x6b, 0x80, 0x68, 0x97, 0xea, 2538 0xec, 0x18, 0xc8, 0x5e, 0x4b, 0xfd, 0xc4, 0x8f, 0x42, 0xc2, 0x4f, 0x94, 0xb2, 0xc6, 0x55, 0x68, 2539 0x97, 0xee, 0x4a, 0xee, 0x16, 0x63, 0xa2, 0xe7, 0x60, 0x52, 0x44, 0x77, 0x3e, 0xc5, 0x14, 0x94, 2540 0xda, 0xcf, 0x73, 0x50, 0xfd, 0xa2, 0x13, 0x20, 0x7f, 0x6f, 0x3e, 0xc4, 0x66, 0x44, 0xf9, 0xbb, 2541 0x73, 0x6c, 0x3b, 0x58, 0xbd, 0x27, 0x2b, 0xa7, 0xbc, 0xdb, 0xb6, 0x83, 0xd1, 0x0e, 0x2c, 0x08, 2542 0x0a, 0x9b, 0xc8, 0x98, 0x71, 0x3f, 0xa2, 0xb2, 0x94, 0x8d, 0xaa, 0x89, 0x95, 0x44, 0xb1, 0x2d, 2543 0xf4, 0x6a, 0x9f, 0x16, 0x92, 0xfb, 0x15, 0x71, 0x6d, 0x84, 0xee, 0xc0, 0x24, 0xa1, 0x06, 0x15, 2544 0x2e, 0x94, 0xc7, 0xbd, 0x17, 0x13, 0xca, 0x75, 0xf6, 0x07, 0x8b, 0xfa, 0x24, 0x50, 0xd0, 0x25, 2545 0x98, 0xb2, 0x30, 0x35, 0x6c, 0x47, 0x6d, 0x83, 0x92, 0x84, 0xb6, 0xa1, 0xc2, 0xa5, 0xd4, 0xf2, 2546 0x57, 0x18, 0xaf, 0xfc, 0xf1, 0x1b, 0xb2, 0xb4, 0xfe, 0xa1, 0xbb, 0x30, 0x43, 0xa2, 0x8e, 0xf0, 2547 0x7c, 0x82, 0x7b, 0xfe, 0xc6, 0xd9, 0x3c, 0x97, 0xca, 0x02, 0x3d, 0xc1, 0xaa, 0xdd, 0x85, 0x49, 2548 0xbe, 0x28, 0x54, 0x84, 0xe9, 0xa3, 0xbd, 0x9d, 0xbd, 0xfd, 0xf7, 0xf7, 0x2a, 0xe7, 0xd0, 0x1c, 2549 0xcc, 0xac, 0x6b, 0xad, 0x66, 0x7b, 0x7b, 0x6f, 0xb3, 0x92, 0x63, 0x2c, 0xed, 0x68, 0x6f, 0x8f, 2550 0xfd, 0xc8, 0xa3, 0x59, 0x98, 0x6c, 0x69, 0xda, 0xbe, 0x56, 0x29, 0x30, 0xa9, 0x8d, 0xd6, 0x6e, 2551 0x8b, 0x4b, 0x4d, 0xb0, 0x5f, 0x47, 0x07, 0x1b, 0x42, 0x67, 0xb2, 0x76, 0x13, 0x66, 0x62, 0x93, 2552 0x68, 0x1e, 0x8a, 0x47, 0x7b, 0x87, 0x07, 0xad, 0xf5, 0xed, 0xdb, 0xdb, 0xad, 0x8d, 0xca, 0x39, 2553 0x54, 0x82, 0xd9, 0xa3, 0xbd, 0xad, 0x56, 0x73, 0xb7, 0xbd, 0x75, 0xaf, 0x92, 0x43, 0x15, 0x98, 2554 0x3b, 0x6c, 0x37, 0x77, 0x5b, 0xfa, 0x61, 0xbb, 0xd9, 0x3e, 0x3a, 0xac, 0xe4, 0x6b, 0xbf, 0xce, 2555 0x43, 0x39, 0x7b, 0x29, 0xc2, 0x26, 0x5d, 0x31, 0x93, 0xde, 0xc7, 0x21, 0xb1, 0x7d, 0x2f, 0x73, 2556 0x2f, 0xc6, 0x39, 0x77, 0x05, 0x03, 0x75, 0xf8, 0x8d, 0x6c, 0x80, 0x43, 0x6a, 0xcb, 0x29, 0x77, 2557 0xf4, 0x89, 0x21, 0x6b, 0xac, 0x7e, 0x90, 0xe8, 0x2b, 0x37, 0xa1, 0x0a, 0x2a, 0xba, 0x07, 0x8b, 2558 0x3e, 0x3f, 0x09, 0x1a, 0x8e, 0x6e, 0xfa, 0x6e, 0xe0, 0x7b, 0xd8, 0xa3, 0xe2, 0x7c, 0x53, 0x5e, 2559 0x5b, 0x1d, 0xb5, 0x33, 0xb1, 0x82, 0x86, 0x62, 0x90, 0x84, 0x44, 0x96, 0xdf, 0x85, 0xf9, 0x01, 2560 0xf3, 0x67, 0x3a, 0x29, 0xfc, 0x23, 0x0f, 0xe5, 0xec, 0x6d, 0x25, 0x32, 0x60, 0xee, 0xc4, 0x3a, 2561 0x26, 0x7a, 0x7c, 0xe5, 0x29, 0x4e, 0xf4, 0xef, 0x9d, 0xe9, 0xca, 0xb3, 0xbe, 0x65, 0x1d, 0x13, 2562 0xf9, 0x2c, 0x4e, 0x51, 0xc5, 0x93, 0x94, 0xc2, 0x4c, 0xf4, 0x8d, 0xd0, 0x4b, 0x4c, 0xe4, 0x9f, 2563 0xc4, 0xc4, 0x3d, 0x23, 0xf4, 0xb2, 0x26, 0xfa, 0x29, 0x65, 0xf9, 0x3d, 0xa8, 0x0c, 0xfa, 0x30, 2564 0x2a, 0x30, 0x05, 0x25, 0x30, 0x4c, 0x7f, 0xd0, 0xc0, 0x59, 0xf4, 0x6b, 0x7f, 0xc8, 0xc1, 0xd2, 2565 0x7a, 0x88, 0x0d, 0x1a, 0x9f, 0x2d, 0x35, 0xfc, 0xfd, 0x08, 0x13, 0x3a, 0xd6, 0x17, 0x80, 0x4b, 2566 0x30, 0x15, 0xe2, 0x2e, 0x4b, 0x5b, 0xa5, 0x87, 0x4b, 0x12, 0x6a, 0xc1, 0xb4, 0xbc, 0xc4, 0x95, 2567 0x75, 0xee, 0xe5, 0xf1, 0xe2, 0x26, 0x50, 0x62, 0x5d, 0xe6, 0x47, 0x28, 0x5c, 0x62, 0x7e, 0x28, 2568 0x53, 0xc0, 0xac, 0x24, 0x6f, 0x5b, 0xb5, 0x9f, 0x16, 0x60, 0xe9, 0x28, 0xb0, 0x9e, 0x76, 0x11, 2569 0x93, 0xc3, 0x8b, 0x18, 0xf7, 0x1b, 0x87, 0xb2, 0xd8, 0xc2, 0x53, 0x2c, 0xb6, 0x03, 0xcf, 0x77, 2570 0x43, 0xc3, 0xc4, 0xc7, 0x91, 0xa3, 0x5b, 0xd8, 0xf4, 0x5d, 0xd7, 0x26, 0x44, 0xed, 0x18, 0x53, 2571 0x63, 0x75, 0x8c, 0x4b, 0x31, 0xc8, 0x86, 0x82, 0x21, 0x9b, 0x07, 0xfa, 0x06, 0x14, 0x23, 0x1e, 2572 0x2b, 0xfe, 0x71, 0xe8, 0x0b, 0x07, 0xd7, 0xdb, 0x36, 0x76, 0xac, 0x3b, 0x06, 0xe9, 0x09, 0x17, 2573 0x41, 0xe8, 0x30, 0xc2, 0xc0, 0x96, 0x4c, 0x9f, 0xba, 0x25, 0x7f, 0xce, 0xc1, 0x92, 0x18, 0x98, 2574 0x9f, 0x75, 0x5e, 0x8d, 0xbb, 0x25, 0x83, 0x5f, 0x4d, 0xd4, 0x01, 0x52, 0xfd, 0x6a, 0x92, 0x5d, 2575 0xcd, 0xe4, 0xa9, 0xab, 0xf9, 0x01, 0x2c, 0x6c, 0x62, 0xfa, 0x25, 0xad, 0xa4, 0xf6, 0x9b, 0x1c, 2576 0x2c, 0xee, 0xda, 0x24, 0xb6, 0x4f, 0x9e, 0xcc, 0x81, 0x89, 0x61, 0x07, 0x2e, 0xc1, 0xd4, 0xb1, 2577 0xed, 0xb0, 0xa4, 0x55, 0x96, 0x2d, 0x49, 0x68, 0x05, 0x66, 0x03, 0xd6, 0x99, 0xd8, 0x41, 0x51, 2578 0x1c, 0xfc, 0xe4, 0x75, 0x09, 0xa3, 0xb2, 0x13, 0x22, 0xb7, 0xcf, 0x24, 0xa8, 0xdf, 0xc3, 0x9e, 2579 0x7a, 0xec, 0xe4, 0x8a, 0x6d, 0x46, 0xad, 0xfd, 0x38, 0x07, 0x4b, 0x59, 0xdf, 0x49, 0xe0, 0x7b, 2580 0x04, 0xa3, 0x4d, 0x98, 0x89, 0xbf, 0xe2, 0xca, 0xd2, 0x7d, 0x86, 0x57, 0xa6, 0xa0, 0x25, 0xca, 2581 0xe8, 0x55, 0x98, 0xf7, 0xf0, 0x87, 0x54, 0x57, 0x5c, 0x51, 0x86, 0x96, 0x12, 0xe3, 0x1d, 0x24, 2582 0xee, 0xfc, 0x30, 0x07, 0x17, 0x36, 0x6c, 0xa3, 0xeb, 0xf9, 0xe4, 0xcb, 0x4a, 0xcc, 0xda, 0xcd, 2583 0x53, 0x5c, 0x20, 0x91, 0x43, 0x09, 0x73, 0xc1, 0x8f, 0x68, 0x10, 0xd1, 0xec, 0x9d, 0x69, 0x41, 2584 0x9b, 0x15, 0xe4, 0xa3, 0xd0, 0xae, 0xfd, 0x22, 0x0f, 0x8b, 0xa7, 0x5c, 0xd1, 0xa1, 0xfb, 0x50, 2585 0x35, 0x7d, 0x8f, 0x44, 0x2e, 0xd6, 0xd5, 0xcb, 0x3f, 0x7e, 0x23, 0x20, 0x86, 0xc2, 0xeb, 0x67, 2586 0xbf, 0xf8, 0xab, 0xb7, 0xfb, 0x01, 0x16, 0x7b, 0x7a, 0x41, 0xa2, 0x2b, 0x52, 0xfc, 0x52, 0xe1, 2587 0xbc, 0x68, 0x36, 0xca, 0xed, 0x2d, 0xef, 0x38, 0x97, 0x60, 0x8a, 0x37, 0x99, 0xcc, 0xed, 0xa8, 2588 0x24, 0xd5, 0x74, 0x98, 0xe0, 0xba, 0x4b, 0x50, 0x69, 0xdf, 0x3b, 0x68, 0xe9, 0xd9, 0x39, 0x0a, 2589 0x41, 0x79, 0x6f, 0x5f, 0xd7, 0x5a, 0x87, 0x2d, 0xed, 0x6e, 0xb3, 0xbd, 0xbd, 0xbf, 0x57, 0xc9, 2590 0xa1, 0x45, 0x98, 0x6f, 0xee, 0xdd, 0xcb, 0x10, 0xf3, 0xa8, 0x0a, 0x4b, 0x52, 0x6f, 0x3d, 0xc3, 2591 0x29, 0xac, 0xfd, 0xbb, 0x04, 0x0b, 0xe9, 0x5d, 0x29, 0x0d, 0x7d, 0xc7, 0xc1, 0x21, 0xfa, 0x59, 2592 0x1e, 0x4a, 0x99, 0x5e, 0x87, 0x5e, 0x1f, 0x95, 0x72, 0xa7, 0x74, 0xc6, 0xe5, 0xe7, 0x63, 0x25, 2593 0xe5, 0x83, 0x7d, 0x7d, 0x3f, 0xfe, 0x60, 0x5f, 0xfb, 0x24, 0xf7, 0x59, 0xb3, 0x99, 0x7e, 0x49, 2594 0x7f, 0x73, 0xac, 0xa4, 0x4e, 0xd4, 0xe3, 0xcb, 0xd4, 0xcf, 0x9b, 0x97, 0xd2, 0x6c, 0xbc, 0xb2, 2595 0x22, 0x52, 0xec, 0xca, 0x8a, 0xcc, 0xa3, 0x1f, 0xfd, 0xed, 0x5f, 0x1f, 0xe7, 0xd7, 0x6b, 0x6f, 2596 0x25, 0xff, 0x50, 0x20, 0x65, 0x49, 0xe3, 0x51, 0xaa, 0xf5, 0x51, 0x43, 0x68, 0x91, 0xc6, 0x23, 2597 0xf1, 0xf0, 0x51, 0xf2, 0x7f, 0x13, 0x37, 0x92, 0x8e, 0xf3, 0xbb, 0x3c, 0x94, 0x32, 0xad, 0x73, 2598 0x64, 0x4c, 0x4e, 0x6b, 0xb4, 0xa3, 0x62, 0xf2, 0xf7, 0x67, 0x14, 0x93, 0x37, 0x1f, 0x13, 0x13, 2599 0xfe, 0xd2, 0x25, 0xbf, 0xae, 0xac, 0x28, 0x4d, 0x8e, 0x87, 0x4b, 0x5b, 0xdb, 0x7c, 0xd2, 0x70, 2600 0x35, 0x1e, 0xa9, 0x36, 0x3e, 0x4a, 0xa3, 0xf7, 0xab, 0x3c, 0x94, 0x32, 0x5d, 0x6e, 0x64, 0xf4, 2601 0x4e, 0xeb, 0x89, 0xa3, 0xa2, 0xf7, 0xc7, 0xdc, 0x67, 0xcd, 0x7d, 0x38, 0x3f, 0xd8, 0xa1, 0x5b, 2602 0x6e, 0x40, 0xfb, 0x4f, 0x1e, 0xcb, 0x95, 0x51, 0xb1, 0xe4, 0x51, 0xdb, 0xbe, 0xfc, 0xac, 0xa2, 2603 0x86, 0x3e, 0xcf, 0x01, 0xa4, 0x5d, 0x14, 0x8d, 0xba, 0x40, 0x1e, 0x6a, 0xb8, 0xcb, 0x63, 0x36, 2604 0x88, 0x5a, 0x38, 0xf6, 0xe2, 0xd0, 0x33, 0x5b, 0xdc, 0x7f, 0x72, 0x30, 0xa7, 0xf6, 0x39, 0xb4, 2605 0x36, 0xf2, 0xfb, 0xf5, 0x50, 0x43, 0x5f, 0x7e, 0xfd, 0x4c, 0x3a, 0xa2, 0x91, 0xb2, 0xd5, 0xa2, 2606 0xe1, 0xd5, 0x7e, 0xde, 0x5c, 0x3e, 0x2d, 0x04, 0xa2, 0xb7, 0xf3, 0xc5, 0xdf, 0x40, 0x4f, 0x5c, 2607 0x3e, 0xd0, 0x6f, 0xf3, 0x30, 0x3f, 0xd0, 0xc3, 0xd0, 0x1b, 0x23, 0x3f, 0x7c, 0x9c, 0xd6, 0x76, 2608 0x47, 0xe5, 0xfe, 0x5f, 0xbe, 0xc4, 0xdc, 0x3f, 0xaa, 0x1d, 0x3c, 0xab, 0x8a, 0x61, 0xc9, 0xc5, 2609 0xdf, 0xc8, 0x5d, 0x5e, 0xde, 0xf9, 0xac, 0x79, 0x31, 0xf1, 0x55, 0xac, 0xc0, 0x08, 0x6c, 0x52, 2610 0x37, 0x7d, 0xf7, 0xaf, 0xcd, 0xfa, 0x09, 0xa5, 0x01, 0xb9, 0xd1, 0x68, 0x3c, 0x78, 0xf0, 0x60, 2611 0x80, 0xd9, 0x30, 0x22, 0x7a, 0x22, 0xfe, 0xa3, 0xec, 0x6a, 0xfc, 0xb5, 0xe4, 0xd6, 0x23, 0xf8, 2612 0x9a, 0xe9, 0xbb, 0x8f, 0x0f, 0xfd, 0xad, 0xf8, 0xb2, 0x88, 0x1c, 0xb0, 0xf8, 0x1d, 0xe4, 0xbe, 2613 0xd5, 0x92, 0xf2, 0x5d, 0xdf, 0x31, 0xbc, 0x6e, 0xdd, 0x0f, 0xbb, 0x8d, 0x2e, 0xf6, 0x78, 0x74, 2614 0x1b, 0xa9, 0xd1, 0x2f, 0xf8, 0xef, 0xb5, 0x77, 0x62, 0x42, 0x67, 0x8a, 0x6b, 0xbc, 0xfe, 0xff, 2615 0x00, 0x00, 0x00, 0xff, 0xff, 0x14, 0x77, 0x2a, 0xa9, 0xae, 0x27, 0x00, 0x00, 2616} 2617 2618// Reference imports to suppress errors if they are not otherwise used. 2619var _ context.Context 2620var _ grpc.ClientConnInterface 2621 2622// This is a compile-time assertion to ensure that this generated file 2623// is compatible with the grpc package it is being compiled against. 2624const _ = grpc.SupportPackageIsVersion6 2625 2626// ClusterControllerClient is the client API for ClusterController service. 2627// 2628// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2629type ClusterControllerClient interface { 2630 // Creates a cluster in a project. The returned 2631 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2632 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2633 CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 2634 // Updates a cluster in a project. The returned 2635 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2636 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2637 UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 2638 // Deletes a cluster in a project. The returned 2639 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2640 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2641 DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 2642 // Gets the resource representation for a cluster in a project. 2643 GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) 2644 // Lists all regions/{region}/clusters in a project. 2645 ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) 2646 // Gets cluster diagnostic information. The returned 2647 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2648 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2649 // After the operation completes, 2650 // [Operation.response][google.longrunning.Operation.response] 2651 // contains 2652 // [Empty][google.protobuf.Empty]. 2653 DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) 2654} 2655 2656type clusterControllerClient struct { 2657 cc grpc.ClientConnInterface 2658} 2659 2660func NewClusterControllerClient(cc grpc.ClientConnInterface) ClusterControllerClient { 2661 return &clusterControllerClient{cc} 2662} 2663 2664func (c *clusterControllerClient) CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2665 out := new(longrunning.Operation) 2666 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/CreateCluster", in, out, opts...) 2667 if err != nil { 2668 return nil, err 2669 } 2670 return out, nil 2671} 2672 2673func (c *clusterControllerClient) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2674 out := new(longrunning.Operation) 2675 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/UpdateCluster", in, out, opts...) 2676 if err != nil { 2677 return nil, err 2678 } 2679 return out, nil 2680} 2681 2682func (c *clusterControllerClient) DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2683 out := new(longrunning.Operation) 2684 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/DeleteCluster", in, out, opts...) 2685 if err != nil { 2686 return nil, err 2687 } 2688 return out, nil 2689} 2690 2691func (c *clusterControllerClient) GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) { 2692 out := new(Cluster) 2693 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/GetCluster", in, out, opts...) 2694 if err != nil { 2695 return nil, err 2696 } 2697 return out, nil 2698} 2699 2700func (c *clusterControllerClient) ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) { 2701 out := new(ListClustersResponse) 2702 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/ListClusters", in, out, opts...) 2703 if err != nil { 2704 return nil, err 2705 } 2706 return out, nil 2707} 2708 2709func (c *clusterControllerClient) DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) { 2710 out := new(longrunning.Operation) 2711 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1beta2.ClusterController/DiagnoseCluster", in, out, opts...) 2712 if err != nil { 2713 return nil, err 2714 } 2715 return out, nil 2716} 2717 2718// ClusterControllerServer is the server API for ClusterController service. 2719type ClusterControllerServer interface { 2720 // Creates a cluster in a project. The returned 2721 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2722 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2723 CreateCluster(context.Context, *CreateClusterRequest) (*longrunning.Operation, error) 2724 // Updates a cluster in a project. The returned 2725 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2726 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2727 UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunning.Operation, error) 2728 // Deletes a cluster in a project. The returned 2729 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2730 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2731 DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunning.Operation, error) 2732 // Gets the resource representation for a cluster in a project. 2733 GetCluster(context.Context, *GetClusterRequest) (*Cluster, error) 2734 // Lists all regions/{region}/clusters in a project. 2735 ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error) 2736 // Gets cluster diagnostic information. The returned 2737 // [Operation.metadata][google.longrunning.Operation.metadata] will be 2738 // [ClusterOperationMetadata](https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1beta2#clusteroperationmetadata). 2739 // After the operation completes, 2740 // [Operation.response][google.longrunning.Operation.response] 2741 // contains 2742 // [Empty][google.protobuf.Empty]. 2743 DiagnoseCluster(context.Context, *DiagnoseClusterRequest) (*longrunning.Operation, error) 2744} 2745 2746// UnimplementedClusterControllerServer can be embedded to have forward compatible implementations. 2747type UnimplementedClusterControllerServer struct { 2748} 2749 2750func (*UnimplementedClusterControllerServer) CreateCluster(ctx context.Context, req *CreateClusterRequest) (*longrunning.Operation, error) { 2751 return nil, status.Errorf(codes.Unimplemented, "method CreateCluster not implemented") 2752} 2753func (*UnimplementedClusterControllerServer) UpdateCluster(ctx context.Context, req *UpdateClusterRequest) (*longrunning.Operation, error) { 2754 return nil, status.Errorf(codes.Unimplemented, "method UpdateCluster not implemented") 2755} 2756func (*UnimplementedClusterControllerServer) DeleteCluster(ctx context.Context, req *DeleteClusterRequest) (*longrunning.Operation, error) { 2757 return nil, status.Errorf(codes.Unimplemented, "method DeleteCluster not implemented") 2758} 2759func (*UnimplementedClusterControllerServer) GetCluster(ctx context.Context, req *GetClusterRequest) (*Cluster, error) { 2760 return nil, status.Errorf(codes.Unimplemented, "method GetCluster not implemented") 2761} 2762func (*UnimplementedClusterControllerServer) ListClusters(ctx context.Context, req *ListClustersRequest) (*ListClustersResponse, error) { 2763 return nil, status.Errorf(codes.Unimplemented, "method ListClusters not implemented") 2764} 2765func (*UnimplementedClusterControllerServer) DiagnoseCluster(ctx context.Context, req *DiagnoseClusterRequest) (*longrunning.Operation, error) { 2766 return nil, status.Errorf(codes.Unimplemented, "method DiagnoseCluster not implemented") 2767} 2768 2769func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer) { 2770 s.RegisterService(&_ClusterController_serviceDesc, srv) 2771} 2772 2773func _ClusterController_CreateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2774 in := new(CreateClusterRequest) 2775 if err := dec(in); err != nil { 2776 return nil, err 2777 } 2778 if interceptor == nil { 2779 return srv.(ClusterControllerServer).CreateCluster(ctx, in) 2780 } 2781 info := &grpc.UnaryServerInfo{ 2782 Server: srv, 2783 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/CreateCluster", 2784 } 2785 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2786 return srv.(ClusterControllerServer).CreateCluster(ctx, req.(*CreateClusterRequest)) 2787 } 2788 return interceptor(ctx, in, info, handler) 2789} 2790 2791func _ClusterController_UpdateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2792 in := new(UpdateClusterRequest) 2793 if err := dec(in); err != nil { 2794 return nil, err 2795 } 2796 if interceptor == nil { 2797 return srv.(ClusterControllerServer).UpdateCluster(ctx, in) 2798 } 2799 info := &grpc.UnaryServerInfo{ 2800 Server: srv, 2801 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/UpdateCluster", 2802 } 2803 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2804 return srv.(ClusterControllerServer).UpdateCluster(ctx, req.(*UpdateClusterRequest)) 2805 } 2806 return interceptor(ctx, in, info, handler) 2807} 2808 2809func _ClusterController_DeleteCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2810 in := new(DeleteClusterRequest) 2811 if err := dec(in); err != nil { 2812 return nil, err 2813 } 2814 if interceptor == nil { 2815 return srv.(ClusterControllerServer).DeleteCluster(ctx, in) 2816 } 2817 info := &grpc.UnaryServerInfo{ 2818 Server: srv, 2819 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/DeleteCluster", 2820 } 2821 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2822 return srv.(ClusterControllerServer).DeleteCluster(ctx, req.(*DeleteClusterRequest)) 2823 } 2824 return interceptor(ctx, in, info, handler) 2825} 2826 2827func _ClusterController_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2828 in := new(GetClusterRequest) 2829 if err := dec(in); err != nil { 2830 return nil, err 2831 } 2832 if interceptor == nil { 2833 return srv.(ClusterControllerServer).GetCluster(ctx, in) 2834 } 2835 info := &grpc.UnaryServerInfo{ 2836 Server: srv, 2837 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/GetCluster", 2838 } 2839 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2840 return srv.(ClusterControllerServer).GetCluster(ctx, req.(*GetClusterRequest)) 2841 } 2842 return interceptor(ctx, in, info, handler) 2843} 2844 2845func _ClusterController_ListClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2846 in := new(ListClustersRequest) 2847 if err := dec(in); err != nil { 2848 return nil, err 2849 } 2850 if interceptor == nil { 2851 return srv.(ClusterControllerServer).ListClusters(ctx, in) 2852 } 2853 info := &grpc.UnaryServerInfo{ 2854 Server: srv, 2855 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/ListClusters", 2856 } 2857 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2858 return srv.(ClusterControllerServer).ListClusters(ctx, req.(*ListClustersRequest)) 2859 } 2860 return interceptor(ctx, in, info, handler) 2861} 2862 2863func _ClusterController_DiagnoseCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2864 in := new(DiagnoseClusterRequest) 2865 if err := dec(in); err != nil { 2866 return nil, err 2867 } 2868 if interceptor == nil { 2869 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, in) 2870 } 2871 info := &grpc.UnaryServerInfo{ 2872 Server: srv, 2873 FullMethod: "/google.cloud.dataproc.v1beta2.ClusterController/DiagnoseCluster", 2874 } 2875 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2876 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, req.(*DiagnoseClusterRequest)) 2877 } 2878 return interceptor(ctx, in, info, handler) 2879} 2880 2881var _ClusterController_serviceDesc = grpc.ServiceDesc{ 2882 ServiceName: "google.cloud.dataproc.v1beta2.ClusterController", 2883 HandlerType: (*ClusterControllerServer)(nil), 2884 Methods: []grpc.MethodDesc{ 2885 { 2886 MethodName: "CreateCluster", 2887 Handler: _ClusterController_CreateCluster_Handler, 2888 }, 2889 { 2890 MethodName: "UpdateCluster", 2891 Handler: _ClusterController_UpdateCluster_Handler, 2892 }, 2893 { 2894 MethodName: "DeleteCluster", 2895 Handler: _ClusterController_DeleteCluster_Handler, 2896 }, 2897 { 2898 MethodName: "GetCluster", 2899 Handler: _ClusterController_GetCluster_Handler, 2900 }, 2901 { 2902 MethodName: "ListClusters", 2903 Handler: _ClusterController_ListClusters_Handler, 2904 }, 2905 { 2906 MethodName: "DiagnoseCluster", 2907 Handler: _ClusterController_DiagnoseCluster_Handler, 2908 }, 2909 }, 2910 Streams: []grpc.StreamDesc{}, 2911 Metadata: "google/cloud/dataproc/v1beta2/clusters.proto", 2912} 2913