1 // Code generated by protoc-gen-go. DO NOT EDIT.
2 // source: google/cloud/dataproc/v1/clusters.proto
5 Package dataproc is a generated protocol buffer package.
7 It is generated from these files:
8 google/cloud/dataproc/v1/clusters.proto
9 google/cloud/dataproc/v1/jobs.proto
10 google/cloud/dataproc/v1/operations.proto
12 It has these top-level messages:
19 NodeInitializationAction
28 DiagnoseClusterRequest
29 DiagnoseClusterResults
48 ClusterOperationStatus
49 ClusterOperationMetadata
53 import proto "github.com/golang/protobuf/proto"
56 import _ "google.golang.org/genproto/googleapis/api/annotations"
57 import google_longrunning "google.golang.org/genproto/googleapis/longrunning"
58 import google_protobuf4 "github.com/golang/protobuf/ptypes/duration"
59 import google_protobuf5 "google.golang.org/genproto/protobuf/field_mask"
60 import google_protobuf3 "github.com/golang/protobuf/ptypes/timestamp"
63 context "golang.org/x/net/context"
64 grpc "google.golang.org/grpc"
67 // Reference imports to suppress errors if they are not otherwise used.
72 // This is a compile-time assertion to ensure that this generated file
73 // is compatible with the proto package it is being compiled against.
74 // A compilation error at this line likely means your copy of the
75 // proto package needs to be updated.
76 const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
79 type ClusterStatus_State int32
82 // The cluster state is unknown.
83 ClusterStatus_UNKNOWN ClusterStatus_State = 0
84 // The cluster is being created and set up. It is not ready for use.
85 ClusterStatus_CREATING ClusterStatus_State = 1
86 // The cluster is currently running and healthy. It is ready for use.
87 ClusterStatus_RUNNING ClusterStatus_State = 2
88 // The cluster encountered an error. It is not ready for use.
89 ClusterStatus_ERROR ClusterStatus_State = 3
90 // The cluster is being deleted. It cannot be used.
91 ClusterStatus_DELETING ClusterStatus_State = 4
92 // The cluster is being updated. It continues to accept and process jobs.
93 ClusterStatus_UPDATING ClusterStatus_State = 5
96 var ClusterStatus_State_name = map[int32]string{
104 var ClusterStatus_State_value = map[string]int32{
113 func (x ClusterStatus_State) String() string {
114 return proto.EnumName(ClusterStatus_State_name, int32(x))
116 func (ClusterStatus_State) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{7, 0} }
118 // Describes the identifying information, config, and status of
119 // a cluster of Google Compute Engine instances.
120 type Cluster struct {
121 // [Required] The Google Cloud Platform project ID that the cluster belongs to.
122 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
123 // [Required] The cluster name. Cluster names within a project must be
124 // unique. Names of deleted clusters can be reused.
125 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
126 // [Required] The cluster config. Note that Cloud Dataproc may set
127 // default values, and values may change when clusters are updated.
128 Config *ClusterConfig `protobuf:"bytes,3,opt,name=config" json:"config,omitempty"`
129 // [Output-only] Cluster status.
130 Status *ClusterStatus `protobuf:"bytes,4,opt,name=status" json:"status,omitempty"`
131 // [Output-only] The previous cluster status.
132 StatusHistory []*ClusterStatus `protobuf:"bytes,7,rep,name=status_history,json=statusHistory" json:"status_history,omitempty"`
133 // [Output-only] A cluster UUID (Unique Universal Identifier). Cloud Dataproc
134 // generates this value when it creates the cluster.
135 ClusterUuid string `protobuf:"bytes,6,opt,name=cluster_uuid,json=clusterUuid" json:"cluster_uuid,omitempty"`
138 func (m *Cluster) Reset() { *m = Cluster{} }
139 func (m *Cluster) String() string { return proto.CompactTextString(m) }
140 func (*Cluster) ProtoMessage() {}
141 func (*Cluster) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
143 func (m *Cluster) GetProjectId() string {
150 func (m *Cluster) GetClusterName() string {
157 func (m *Cluster) GetConfig() *ClusterConfig {
164 func (m *Cluster) GetStatus() *ClusterStatus {
171 func (m *Cluster) GetStatusHistory() []*ClusterStatus {
173 return m.StatusHistory
178 func (m *Cluster) GetClusterUuid() string {
185 // The cluster config.
186 type ClusterConfig struct {
187 // [Optional] A Google Cloud Storage staging bucket used for sharing generated
188 // SSH keys and config. If you do not specify a staging bucket, Cloud
189 // Dataproc will determine an appropriate Cloud Storage location (US,
190 // ASIA, or EU) for your cluster's staging bucket according to the Google
191 // Compute Engine zone where your cluster is deployed, and then it will create
192 // and manage this project-level, per-location bucket for you.
193 ConfigBucket string `protobuf:"bytes,1,opt,name=config_bucket,json=configBucket" json:"config_bucket,omitempty"`
194 // [Required] The shared Google Compute Engine config settings for
195 // all instances in a cluster.
196 GceClusterConfig *GceClusterConfig `protobuf:"bytes,8,opt,name=gce_cluster_config,json=gceClusterConfig" json:"gce_cluster_config,omitempty"`
197 // [Optional] The Google Compute Engine config settings for
198 // the master instance in a cluster.
199 MasterConfig *InstanceGroupConfig `protobuf:"bytes,9,opt,name=master_config,json=masterConfig" json:"master_config,omitempty"`
200 // [Optional] The Google Compute Engine config settings for
201 // worker instances in a cluster.
202 WorkerConfig *InstanceGroupConfig `protobuf:"bytes,10,opt,name=worker_config,json=workerConfig" json:"worker_config,omitempty"`
203 // [Optional] The Google Compute Engine config settings for
204 // additional worker instances in a cluster.
205 SecondaryWorkerConfig *InstanceGroupConfig `protobuf:"bytes,12,opt,name=secondary_worker_config,json=secondaryWorkerConfig" json:"secondary_worker_config,omitempty"`
206 // [Optional] The config settings for software inside the cluster.
207 SoftwareConfig *SoftwareConfig `protobuf:"bytes,13,opt,name=software_config,json=softwareConfig" json:"software_config,omitempty"`
208 // [Optional] Commands to execute on each node after config is
209 // completed. By default, executables are run on master and all worker nodes.
210 // You can test a node's <code>role</code> metadata to run an executable on
211 // a master or worker node, as shown below using `curl` (you can also use `wget`):
213 // ROLE=$(curl -H Metadata-Flavor:Google http://metadata/computeMetadata/v1/instance/attributes/dataproc-role)
214 // if [[ "${ROLE}" == 'Master' ]]; then
215 // ... master specific actions ...
217 // ... worker specific actions ...
219 InitializationActions []*NodeInitializationAction `protobuf:"bytes,11,rep,name=initialization_actions,json=initializationActions" json:"initialization_actions,omitempty"`
222 func (m *ClusterConfig) Reset() { *m = ClusterConfig{} }
223 func (m *ClusterConfig) String() string { return proto.CompactTextString(m) }
224 func (*ClusterConfig) ProtoMessage() {}
225 func (*ClusterConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
227 func (m *ClusterConfig) GetConfigBucket() string {
229 return m.ConfigBucket
234 func (m *ClusterConfig) GetGceClusterConfig() *GceClusterConfig {
236 return m.GceClusterConfig
241 func (m *ClusterConfig) GetMasterConfig() *InstanceGroupConfig {
243 return m.MasterConfig
248 func (m *ClusterConfig) GetWorkerConfig() *InstanceGroupConfig {
250 return m.WorkerConfig
255 func (m *ClusterConfig) GetSecondaryWorkerConfig() *InstanceGroupConfig {
257 return m.SecondaryWorkerConfig
262 func (m *ClusterConfig) GetSoftwareConfig() *SoftwareConfig {
264 return m.SoftwareConfig
269 func (m *ClusterConfig) GetInitializationActions() []*NodeInitializationAction {
271 return m.InitializationActions
276 // Common config settings for resources of Google Compute Engine cluster
277 // instances, applicable to all instances in the cluster.
278 type GceClusterConfig struct {
279 // [Required] The zone where the Google Compute Engine cluster will be located.
280 // Example: `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]`.
281 ZoneUri string `protobuf:"bytes,1,opt,name=zone_uri,json=zoneUri" json:"zone_uri,omitempty"`
282 // [Optional] The Google Compute Engine network to be used for machine
283 // communications. Cannot be specified with subnetwork_uri. If neither
284 // `network_uri` nor `subnetwork_uri` is specified, the "default" network of
285 // the project is used, if it exists. Cannot be a "Custom Subnet Network" (see
286 // [Using Subnetworks](/compute/docs/subnetworks) for more information).
287 // Example: `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default`.
288 NetworkUri string `protobuf:"bytes,2,opt,name=network_uri,json=networkUri" json:"network_uri,omitempty"`
289 // [Optional] The Google Compute Engine subnetwork to be used for machine
290 // communications. Cannot be specified with network_uri.
291 // Example: `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/sub0`.
292 SubnetworkUri string `protobuf:"bytes,6,opt,name=subnetwork_uri,json=subnetworkUri" json:"subnetwork_uri,omitempty"`
293 // [Optional] If true, all instances in the cluster will only have internal IP
294 // addresses. By default, clusters are not restricted to internal IP addresses,
295 // and will have ephemeral external IP addresses assigned to each instance.
296 // This `internal_ip_only` restriction can only be enabled for subnetwork
297 // enabled networks, and all off-cluster dependencies must be configured to be
298 // accessible without external IP addresses.
299 InternalIpOnly bool `protobuf:"varint,7,opt,name=internal_ip_only,json=internalIpOnly" json:"internal_ip_only,omitempty"`
300 // [Optional] The URIs of service account scopes to be included in Google
301 // Compute Engine instances. The following base set of scopes is always
304 // * https://www.googleapis.com/auth/cloud.useraccounts.readonly
305 // * https://www.googleapis.com/auth/devstorage.read_write
306 // * https://www.googleapis.com/auth/logging.write
308 // If no scopes are specified, the following defaults are also provided:
310 // * https://www.googleapis.com/auth/bigquery
311 // * https://www.googleapis.com/auth/bigtable.admin.table
312 // * https://www.googleapis.com/auth/bigtable.data
313 // * https://www.googleapis.com/auth/devstorage.full_control
314 ServiceAccountScopes []string `protobuf:"bytes,3,rep,name=service_account_scopes,json=serviceAccountScopes" json:"service_account_scopes,omitempty"`
315 // The Google Compute Engine tags to add to all instances (see
316 // [Labeling instances](/compute/docs/label-or-tag-resources#labeling_instances)).
317 Tags []string `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
318 // The Google Compute Engine metadata entries to add to all instances (see
319 // [Project and instance metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)).
320 Metadata map[string]string `protobuf:"bytes,5,rep,name=metadata" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
323 func (m *GceClusterConfig) Reset() { *m = GceClusterConfig{} }
324 func (m *GceClusterConfig) String() string { return proto.CompactTextString(m) }
325 func (*GceClusterConfig) ProtoMessage() {}
326 func (*GceClusterConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
328 func (m *GceClusterConfig) GetZoneUri() string {
335 func (m *GceClusterConfig) GetNetworkUri() string {
342 func (m *GceClusterConfig) GetSubnetworkUri() string {
344 return m.SubnetworkUri
349 func (m *GceClusterConfig) GetInternalIpOnly() bool {
351 return m.InternalIpOnly
356 func (m *GceClusterConfig) GetServiceAccountScopes() []string {
358 return m.ServiceAccountScopes
363 func (m *GceClusterConfig) GetTags() []string {
370 func (m *GceClusterConfig) GetMetadata() map[string]string {
377 // [Optional] The config settings for Google Compute Engine resources in
378 // an instance group, such as a master or worker group.
379 type InstanceGroupConfig struct {
380 // [Required] The number of VM instances in the instance group.
381 // For master instance groups, must be set to 1.
382 NumInstances int32 `protobuf:"varint,1,opt,name=num_instances,json=numInstances" json:"num_instances,omitempty"`
383 // [Optional] The list of instance names. Cloud Dataproc derives the names from
384 // `cluster_name`, `num_instances`, and the instance group if not set by user
385 // (recommended practice is to let Cloud Dataproc derive the name).
386 InstanceNames []string `protobuf:"bytes,2,rep,name=instance_names,json=instanceNames" json:"instance_names,omitempty"`
387 // [Output-only] The Google Compute Engine image resource used for cluster
388 // instances. Inferred from `SoftwareConfig.image_version`.
389 ImageUri string `protobuf:"bytes,3,opt,name=image_uri,json=imageUri" json:"image_uri,omitempty"`
390 // [Required] The Google Compute Engine machine type used for cluster instances.
391 // Example: `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2`.
392 MachineTypeUri string `protobuf:"bytes,4,opt,name=machine_type_uri,json=machineTypeUri" json:"machine_type_uri,omitempty"`
393 // [Optional] Disk option config settings.
394 DiskConfig *DiskConfig `protobuf:"bytes,5,opt,name=disk_config,json=diskConfig" json:"disk_config,omitempty"`
395 // [Optional] Specifies that this instance group contains preemptible instances.
396 IsPreemptible bool `protobuf:"varint,6,opt,name=is_preemptible,json=isPreemptible" json:"is_preemptible,omitempty"`
397 // [Output-only] The config for Google Compute Engine Instance Group
398 // Manager that manages this group.
399 // This is only used for preemptible instance groups.
400 ManagedGroupConfig *ManagedGroupConfig `protobuf:"bytes,7,opt,name=managed_group_config,json=managedGroupConfig" json:"managed_group_config,omitempty"`
403 func (m *InstanceGroupConfig) Reset() { *m = InstanceGroupConfig{} }
404 func (m *InstanceGroupConfig) String() string { return proto.CompactTextString(m) }
405 func (*InstanceGroupConfig) ProtoMessage() {}
406 func (*InstanceGroupConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
408 func (m *InstanceGroupConfig) GetNumInstances() int32 {
410 return m.NumInstances
415 func (m *InstanceGroupConfig) GetInstanceNames() []string {
417 return m.InstanceNames
422 func (m *InstanceGroupConfig) GetImageUri() string {
429 func (m *InstanceGroupConfig) GetMachineTypeUri() string {
431 return m.MachineTypeUri
436 func (m *InstanceGroupConfig) GetDiskConfig() *DiskConfig {
443 func (m *InstanceGroupConfig) GetIsPreemptible() bool {
445 return m.IsPreemptible
450 func (m *InstanceGroupConfig) GetManagedGroupConfig() *ManagedGroupConfig {
452 return m.ManagedGroupConfig
457 // Specifies the resources used to actively manage an instance group.
458 type ManagedGroupConfig struct {
459 // [Output-only] The name of the Instance Template used for the Managed
461 InstanceTemplateName string `protobuf:"bytes,1,opt,name=instance_template_name,json=instanceTemplateName" json:"instance_template_name,omitempty"`
462 // [Output-only] The name of the Instance Group Manager for this group.
463 InstanceGroupManagerName string `protobuf:"bytes,2,opt,name=instance_group_manager_name,json=instanceGroupManagerName" json:"instance_group_manager_name,omitempty"`
466 func (m *ManagedGroupConfig) Reset() { *m = ManagedGroupConfig{} }
467 func (m *ManagedGroupConfig) String() string { return proto.CompactTextString(m) }
468 func (*ManagedGroupConfig) ProtoMessage() {}
469 func (*ManagedGroupConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
471 func (m *ManagedGroupConfig) GetInstanceTemplateName() string {
473 return m.InstanceTemplateName
478 func (m *ManagedGroupConfig) GetInstanceGroupManagerName() string {
480 return m.InstanceGroupManagerName
485 // Specifies the config of disk options for a group of VM instances.
486 type DiskConfig struct {
487 // [Optional] Size in GB of the boot disk (default is 500GB).
488 BootDiskSizeGb int32 `protobuf:"varint,1,opt,name=boot_disk_size_gb,json=bootDiskSizeGb" json:"boot_disk_size_gb,omitempty"`
489 // [Optional] Number of attached SSDs, from 0 to 4 (default is 0).
490 // If SSDs are not attached, the boot disk is used to store runtime logs and
491 // [HDFS](https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data.
492 // If one or more SSDs are attached, this runtime bulk
493 // data is spread across them, and the boot disk contains only basic
494 // config and installed binaries.
495 NumLocalSsds int32 `protobuf:"varint,2,opt,name=num_local_ssds,json=numLocalSsds" json:"num_local_ssds,omitempty"`
498 func (m *DiskConfig) Reset() { *m = DiskConfig{} }
499 func (m *DiskConfig) String() string { return proto.CompactTextString(m) }
500 func (*DiskConfig) ProtoMessage() {}
501 func (*DiskConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
503 func (m *DiskConfig) GetBootDiskSizeGb() int32 {
505 return m.BootDiskSizeGb
510 func (m *DiskConfig) GetNumLocalSsds() int32 {
512 return m.NumLocalSsds
517 // Specifies an executable to run on a fully configured node and a
518 // timeout period for executable completion.
519 type NodeInitializationAction struct {
520 // [Required] Google Cloud Storage URI of executable file.
521 ExecutableFile string `protobuf:"bytes,1,opt,name=executable_file,json=executableFile" json:"executable_file,omitempty"`
522 // [Optional] Amount of time executable has to complete. Default is
523 // 10 minutes. Cluster creation fails with an explanatory error message (the
524 // name of the executable that caused the error and the exceeded timeout
525 // period) if the executable is not completed at end of the timeout period.
526 ExecutionTimeout *google_protobuf4.Duration `protobuf:"bytes,2,opt,name=execution_timeout,json=executionTimeout" json:"execution_timeout,omitempty"`
529 func (m *NodeInitializationAction) Reset() { *m = NodeInitializationAction{} }
530 func (m *NodeInitializationAction) String() string { return proto.CompactTextString(m) }
531 func (*NodeInitializationAction) ProtoMessage() {}
532 func (*NodeInitializationAction) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
534 func (m *NodeInitializationAction) GetExecutableFile() string {
536 return m.ExecutableFile
541 func (m *NodeInitializationAction) GetExecutionTimeout() *google_protobuf4.Duration {
543 return m.ExecutionTimeout
548 // The status of a cluster and its instances.
549 type ClusterStatus struct {
550 // [Output-only] The cluster's state.
551 State ClusterStatus_State `protobuf:"varint,1,opt,name=state,enum=google.cloud.dataproc.v1.ClusterStatus_State" json:"state,omitempty"`
552 // [Output-only] Optional details of cluster's state.
553 Detail string `protobuf:"bytes,2,opt,name=detail" json:"detail,omitempty"`
554 // [Output-only] Time when this state was entered.
555 StateStartTime *google_protobuf3.Timestamp `protobuf:"bytes,3,opt,name=state_start_time,json=stateStartTime" json:"state_start_time,omitempty"`
558 func (m *ClusterStatus) Reset() { *m = ClusterStatus{} }
559 func (m *ClusterStatus) String() string { return proto.CompactTextString(m) }
560 func (*ClusterStatus) ProtoMessage() {}
561 func (*ClusterStatus) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
563 func (m *ClusterStatus) GetState() ClusterStatus_State {
567 return ClusterStatus_UNKNOWN
570 func (m *ClusterStatus) GetDetail() string {
577 func (m *ClusterStatus) GetStateStartTime() *google_protobuf3.Timestamp {
579 return m.StateStartTime
584 // Specifies the selection and config of software inside the cluster.
585 type SoftwareConfig struct {
586 // [Optional] The version of software inside the cluster. It must match the
587 // regular expression `[0-9]+\.[0-9]+`. If unspecified, it defaults to the
588 // latest version (see [Cloud Dataproc Versioning](/dataproc/versioning)).
589 ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion" json:"image_version,omitempty"`
590 // [Optional] The properties to set on daemon config files.
592 // Property keys are specified in `prefix:property` format, such as
593 // `core:fs.defaultFS`. The following are supported prefixes
594 // and their mappings:
596 // * core: `core-site.xml`
597 // * hdfs: `hdfs-site.xml`
598 // * mapred: `mapred-site.xml`
599 // * yarn: `yarn-site.xml`
600 // * hive: `hive-site.xml`
601 // * pig: `pig.properties`
602 // * spark: `spark-defaults.conf`
603 Properties map[string]string `protobuf:"bytes,2,rep,name=properties" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
606 func (m *SoftwareConfig) Reset() { *m = SoftwareConfig{} }
607 func (m *SoftwareConfig) String() string { return proto.CompactTextString(m) }
608 func (*SoftwareConfig) ProtoMessage() {}
609 func (*SoftwareConfig) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
611 func (m *SoftwareConfig) GetImageVersion() string {
613 return m.ImageVersion
618 func (m *SoftwareConfig) GetProperties() map[string]string {
625 // A request to create a cluster.
626 type CreateClusterRequest struct {
627 // [Required] The ID of the Google Cloud Platform project that the cluster
629 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
630 // [Required] The Cloud Dataproc region in which to handle the request.
631 Region string `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
632 // [Required] The cluster to create.
633 Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
636 func (m *CreateClusterRequest) Reset() { *m = CreateClusterRequest{} }
637 func (m *CreateClusterRequest) String() string { return proto.CompactTextString(m) }
638 func (*CreateClusterRequest) ProtoMessage() {}
639 func (*CreateClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
641 func (m *CreateClusterRequest) GetProjectId() string {
648 func (m *CreateClusterRequest) GetRegion() string {
655 func (m *CreateClusterRequest) GetCluster() *Cluster {
662 // A request to update a cluster.
663 type UpdateClusterRequest struct {
664 // [Required] The ID of the Google Cloud Platform project the
665 // cluster belongs to.
666 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
667 // [Required] The Cloud Dataproc region in which to handle the request.
668 Region string `protobuf:"bytes,5,opt,name=region" json:"region,omitempty"`
669 // [Required] The cluster name.
670 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
671 // [Required] The changes to the cluster.
672 Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster" json:"cluster,omitempty"`
673 // [Required] Specifies the path, relative to <code>Cluster</code>, of
674 // the field to update. For example, to change the number of workers
675 // in a cluster to 5, the <code>update_mask</code> parameter would be
676 // specified as <code>config.worker_config.num_instances</code>,
677 // and the `PATCH` request body would specify the new value, as follows:
682 // "numInstances":"5"
686 // Similarly, to change the number of preemptible workers in a cluster to 5, the
687 // <code>update_mask</code> parameter would be <code>config.secondary_worker_config.num_instances</code>,
688 // and the `PATCH` request body would be set as follows:
692 // "secondaryWorkerConfig":{
693 // "numInstances":"5"
697 // <strong>Note:</strong> Currently, <code>config.worker_config.num_instances</code>
698 // and <code>config.secondary_worker_config.num_instances</code> are the only
699 // fields that can be updated.
700 UpdateMask *google_protobuf5.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask" json:"update_mask,omitempty"`
703 func (m *UpdateClusterRequest) Reset() { *m = UpdateClusterRequest{} }
704 func (m *UpdateClusterRequest) String() string { return proto.CompactTextString(m) }
705 func (*UpdateClusterRequest) ProtoMessage() {}
706 func (*UpdateClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
708 func (m *UpdateClusterRequest) GetProjectId() string {
715 func (m *UpdateClusterRequest) GetRegion() string {
722 func (m *UpdateClusterRequest) GetClusterName() string {
729 func (m *UpdateClusterRequest) GetCluster() *Cluster {
736 func (m *UpdateClusterRequest) GetUpdateMask() *google_protobuf5.FieldMask {
743 // A request to delete a cluster.
744 type DeleteClusterRequest struct {
745 // [Required] The ID of the Google Cloud Platform project that the cluster
747 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
748 // [Required] The Cloud Dataproc region in which to handle the request.
749 Region string `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
750 // [Required] The cluster name.
751 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
754 func (m *DeleteClusterRequest) Reset() { *m = DeleteClusterRequest{} }
755 func (m *DeleteClusterRequest) String() string { return proto.CompactTextString(m) }
756 func (*DeleteClusterRequest) ProtoMessage() {}
757 func (*DeleteClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
759 func (m *DeleteClusterRequest) GetProjectId() string {
766 func (m *DeleteClusterRequest) GetRegion() string {
773 func (m *DeleteClusterRequest) GetClusterName() string {
780 // Request to get the resource representation for a cluster in a project.
781 type GetClusterRequest struct {
782 // [Required] The ID of the Google Cloud Platform project that the cluster
784 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
785 // [Required] The Cloud Dataproc region in which to handle the request.
786 Region string `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
787 // [Required] The cluster name.
788 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
791 func (m *GetClusterRequest) Reset() { *m = GetClusterRequest{} }
792 func (m *GetClusterRequest) String() string { return proto.CompactTextString(m) }
793 func (*GetClusterRequest) ProtoMessage() {}
794 func (*GetClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
796 func (m *GetClusterRequest) GetProjectId() string {
803 func (m *GetClusterRequest) GetRegion() string {
810 func (m *GetClusterRequest) GetClusterName() string {
817 // A request to list the clusters in a project.
818 type ListClustersRequest struct {
819 // [Required] The ID of the Google Cloud Platform project that the cluster
821 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
822 // [Required] The Cloud Dataproc region in which to handle the request.
823 Region string `protobuf:"bytes,4,opt,name=region" json:"region,omitempty"`
824 // [Optional] The standard List page size.
825 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize" json:"page_size,omitempty"`
826 // [Optional] The standard List page token.
827 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken" json:"page_token,omitempty"`
830 func (m *ListClustersRequest) Reset() { *m = ListClustersRequest{} }
831 func (m *ListClustersRequest) String() string { return proto.CompactTextString(m) }
832 func (*ListClustersRequest) ProtoMessage() {}
833 func (*ListClustersRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
835 func (m *ListClustersRequest) GetProjectId() string {
842 func (m *ListClustersRequest) GetRegion() string {
849 func (m *ListClustersRequest) GetPageSize() int32 {
856 func (m *ListClustersRequest) GetPageToken() string {
863 // The list of all clusters in a project.
864 type ListClustersResponse struct {
865 // [Output-only] The clusters in the project.
866 Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters" json:"clusters,omitempty"`
867 // [Output-only] This token is included in the response if there are more
868 // results to fetch. To fetch additional results, provide this value as the
869 // `page_token` in a subsequent <code>ListClustersRequest</code>.
870 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
873 func (m *ListClustersResponse) Reset() { *m = ListClustersResponse{} }
874 func (m *ListClustersResponse) String() string { return proto.CompactTextString(m) }
875 func (*ListClustersResponse) ProtoMessage() {}
876 func (*ListClustersResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
878 func (m *ListClustersResponse) GetClusters() []*Cluster {
885 func (m *ListClustersResponse) GetNextPageToken() string {
887 return m.NextPageToken
892 // A request to collect cluster diagnostic information.
893 type DiagnoseClusterRequest struct {
894 // [Required] The ID of the Google Cloud Platform project that the cluster
896 ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
897 // [Required] The Cloud Dataproc region in which to handle the request.
898 Region string `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
899 // [Required] The cluster name.
900 ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
903 func (m *DiagnoseClusterRequest) Reset() { *m = DiagnoseClusterRequest{} }
904 func (m *DiagnoseClusterRequest) String() string { return proto.CompactTextString(m) }
905 func (*DiagnoseClusterRequest) ProtoMessage() {}
906 func (*DiagnoseClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
908 func (m *DiagnoseClusterRequest) GetProjectId() string {
915 func (m *DiagnoseClusterRequest) GetRegion() string {
922 func (m *DiagnoseClusterRequest) GetClusterName() string {
929 // The location of diagnostic output.
930 type DiagnoseClusterResults struct {
931 // [Output-only] The Google Cloud Storage URI of the diagnostic output.
932 // The output report is a plain text file with a summary of collected
934 OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri" json:"output_uri,omitempty"`
937 func (m *DiagnoseClusterResults) Reset() { *m = DiagnoseClusterResults{} }
938 func (m *DiagnoseClusterResults) String() string { return proto.CompactTextString(m) }
939 func (*DiagnoseClusterResults) ProtoMessage() {}
940 func (*DiagnoseClusterResults) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
942 func (m *DiagnoseClusterResults) GetOutputUri() string {
950 proto.RegisterType((*Cluster)(nil), "google.cloud.dataproc.v1.Cluster")
951 proto.RegisterType((*ClusterConfig)(nil), "google.cloud.dataproc.v1.ClusterConfig")
952 proto.RegisterType((*GceClusterConfig)(nil), "google.cloud.dataproc.v1.GceClusterConfig")
953 proto.RegisterType((*InstanceGroupConfig)(nil), "google.cloud.dataproc.v1.InstanceGroupConfig")
954 proto.RegisterType((*ManagedGroupConfig)(nil), "google.cloud.dataproc.v1.ManagedGroupConfig")
955 proto.RegisterType((*DiskConfig)(nil), "google.cloud.dataproc.v1.DiskConfig")
956 proto.RegisterType((*NodeInitializationAction)(nil), "google.cloud.dataproc.v1.NodeInitializationAction")
957 proto.RegisterType((*ClusterStatus)(nil), "google.cloud.dataproc.v1.ClusterStatus")
958 proto.RegisterType((*SoftwareConfig)(nil), "google.cloud.dataproc.v1.SoftwareConfig")
959 proto.RegisterType((*CreateClusterRequest)(nil), "google.cloud.dataproc.v1.CreateClusterRequest")
960 proto.RegisterType((*UpdateClusterRequest)(nil), "google.cloud.dataproc.v1.UpdateClusterRequest")
961 proto.RegisterType((*DeleteClusterRequest)(nil), "google.cloud.dataproc.v1.DeleteClusterRequest")
962 proto.RegisterType((*GetClusterRequest)(nil), "google.cloud.dataproc.v1.GetClusterRequest")
963 proto.RegisterType((*ListClustersRequest)(nil), "google.cloud.dataproc.v1.ListClustersRequest")
964 proto.RegisterType((*ListClustersResponse)(nil), "google.cloud.dataproc.v1.ListClustersResponse")
965 proto.RegisterType((*DiagnoseClusterRequest)(nil), "google.cloud.dataproc.v1.DiagnoseClusterRequest")
966 proto.RegisterType((*DiagnoseClusterResults)(nil), "google.cloud.dataproc.v1.DiagnoseClusterResults")
967 proto.RegisterEnum("google.cloud.dataproc.v1.ClusterStatus_State", ClusterStatus_State_name, ClusterStatus_State_value)
970 // Reference imports to suppress errors if they are not otherwise used.
971 var _ context.Context
972 var _ grpc.ClientConn
974 // This is a compile-time assertion to ensure that this generated file
975 // is compatible with the grpc package it is being compiled against.
976 const _ = grpc.SupportPackageIsVersion4
978 // Client API for ClusterController service
980 type ClusterControllerClient interface {
981 // Creates a cluster in a project.
982 CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error)
983 // Updates a cluster in a project.
984 UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error)
985 // Deletes a cluster in a project.
986 DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error)
987 // Gets the resource representation for a cluster in a project.
988 GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
989 // Lists all regions/{region}/clusters in a project.
990 ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
991 // Gets cluster diagnostic information.
992 // After the operation completes, the Operation.response field
993 // contains `DiagnoseClusterOutputLocation`.
994 DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error)
997 type clusterControllerClient struct {
1001 func NewClusterControllerClient(cc *grpc.ClientConn) ClusterControllerClient {
1002 return &clusterControllerClient{cc}
1005 func (c *clusterControllerClient) CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error) {
1006 out := new(google_longrunning.Operation)
1007 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/CreateCluster", in, out, c.cc, opts...)
1014 func (c *clusterControllerClient) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error) {
1015 out := new(google_longrunning.Operation)
1016 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/UpdateCluster", in, out, c.cc, opts...)
1023 func (c *clusterControllerClient) DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error) {
1024 out := new(google_longrunning.Operation)
1025 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/DeleteCluster", in, out, c.cc, opts...)
1032 func (c *clusterControllerClient) GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) {
1034 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/GetCluster", in, out, c.cc, opts...)
1041 func (c *clusterControllerClient) ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) {
1042 out := new(ListClustersResponse)
1043 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/ListClusters", in, out, c.cc, opts...)
1050 func (c *clusterControllerClient) DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*google_longrunning.Operation, error) {
1051 out := new(google_longrunning.Operation)
1052 err := grpc.Invoke(ctx, "/google.cloud.dataproc.v1.ClusterController/DiagnoseCluster", in, out, c.cc, opts...)
1059 // Server API for ClusterController service
1061 type ClusterControllerServer interface {
1062 // Creates a cluster in a project.
1063 CreateCluster(context.Context, *CreateClusterRequest) (*google_longrunning.Operation, error)
1064 // Updates a cluster in a project.
1065 UpdateCluster(context.Context, *UpdateClusterRequest) (*google_longrunning.Operation, error)
1066 // Deletes a cluster in a project.
1067 DeleteCluster(context.Context, *DeleteClusterRequest) (*google_longrunning.Operation, error)
1068 // Gets the resource representation for a cluster in a project.
1069 GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
1070 // Lists all regions/{region}/clusters in a project.
1071 ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
1072 // Gets cluster diagnostic information.
1073 // After the operation completes, the Operation.response field
1074 // contains `DiagnoseClusterOutputLocation`.
1075 DiagnoseCluster(context.Context, *DiagnoseClusterRequest) (*google_longrunning.Operation, error)
1078 func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer) {
1079 s.RegisterService(&_ClusterController_serviceDesc, srv)
1082 func _ClusterController_CreateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1083 in := new(CreateClusterRequest)
1084 if err := dec(in); err != nil {
1087 if interceptor == nil {
1088 return srv.(ClusterControllerServer).CreateCluster(ctx, in)
1090 info := &grpc.UnaryServerInfo{
1092 FullMethod: "/google.cloud.dataproc.v1.ClusterController/CreateCluster",
1094 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1095 return srv.(ClusterControllerServer).CreateCluster(ctx, req.(*CreateClusterRequest))
1097 return interceptor(ctx, in, info, handler)
1100 func _ClusterController_UpdateCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1101 in := new(UpdateClusterRequest)
1102 if err := dec(in); err != nil {
1105 if interceptor == nil {
1106 return srv.(ClusterControllerServer).UpdateCluster(ctx, in)
1108 info := &grpc.UnaryServerInfo{
1110 FullMethod: "/google.cloud.dataproc.v1.ClusterController/UpdateCluster",
1112 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1113 return srv.(ClusterControllerServer).UpdateCluster(ctx, req.(*UpdateClusterRequest))
1115 return interceptor(ctx, in, info, handler)
1118 func _ClusterController_DeleteCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1119 in := new(DeleteClusterRequest)
1120 if err := dec(in); err != nil {
1123 if interceptor == nil {
1124 return srv.(ClusterControllerServer).DeleteCluster(ctx, in)
1126 info := &grpc.UnaryServerInfo{
1128 FullMethod: "/google.cloud.dataproc.v1.ClusterController/DeleteCluster",
1130 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1131 return srv.(ClusterControllerServer).DeleteCluster(ctx, req.(*DeleteClusterRequest))
1133 return interceptor(ctx, in, info, handler)
1136 func _ClusterController_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1137 in := new(GetClusterRequest)
1138 if err := dec(in); err != nil {
1141 if interceptor == nil {
1142 return srv.(ClusterControllerServer).GetCluster(ctx, in)
1144 info := &grpc.UnaryServerInfo{
1146 FullMethod: "/google.cloud.dataproc.v1.ClusterController/GetCluster",
1148 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1149 return srv.(ClusterControllerServer).GetCluster(ctx, req.(*GetClusterRequest))
1151 return interceptor(ctx, in, info, handler)
1154 func _ClusterController_ListClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1155 in := new(ListClustersRequest)
1156 if err := dec(in); err != nil {
1159 if interceptor == nil {
1160 return srv.(ClusterControllerServer).ListClusters(ctx, in)
1162 info := &grpc.UnaryServerInfo{
1164 FullMethod: "/google.cloud.dataproc.v1.ClusterController/ListClusters",
1166 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1167 return srv.(ClusterControllerServer).ListClusters(ctx, req.(*ListClustersRequest))
1169 return interceptor(ctx, in, info, handler)
1172 func _ClusterController_DiagnoseCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1173 in := new(DiagnoseClusterRequest)
1174 if err := dec(in); err != nil {
1177 if interceptor == nil {
1178 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, in)
1180 info := &grpc.UnaryServerInfo{
1182 FullMethod: "/google.cloud.dataproc.v1.ClusterController/DiagnoseCluster",
1184 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1185 return srv.(ClusterControllerServer).DiagnoseCluster(ctx, req.(*DiagnoseClusterRequest))
1187 return interceptor(ctx, in, info, handler)
1190 var _ClusterController_serviceDesc = grpc.ServiceDesc{
1191 ServiceName: "google.cloud.dataproc.v1.ClusterController",
1192 HandlerType: (*ClusterControllerServer)(nil),
1193 Methods: []grpc.MethodDesc{
1195 MethodName: "CreateCluster",
1196 Handler: _ClusterController_CreateCluster_Handler,
1199 MethodName: "UpdateCluster",
1200 Handler: _ClusterController_UpdateCluster_Handler,
1203 MethodName: "DeleteCluster",
1204 Handler: _ClusterController_DeleteCluster_Handler,
1207 MethodName: "GetCluster",
1208 Handler: _ClusterController_GetCluster_Handler,
1211 MethodName: "ListClusters",
1212 Handler: _ClusterController_ListClusters_Handler,
1215 MethodName: "DiagnoseCluster",
1216 Handler: _ClusterController_DiagnoseCluster_Handler,
1219 Streams: []grpc.StreamDesc{},
1220 Metadata: "google/cloud/dataproc/v1/clusters.proto",
1223 func init() { proto.RegisterFile("google/cloud/dataproc/v1/clusters.proto", fileDescriptor0) }
1225 var fileDescriptor0 = []byte{
1226 // 1667 bytes of a gzipped FileDescriptorProto
1227 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4f, 0x73, 0x23, 0x47,
1228 0x15, 0x67, 0x64, 0xcb, 0x96, 0x9f, 0x2c, 0x59, 0xdb, 0x51, 0x8c, 0xa2, 0x4d, 0x88, 0x33, 0x09,
1229 0xac, 0xb3, 0x80, 0x44, 0x1c, 0x28, 0x52, 0xeb, 0x0a, 0xb0, 0x6b, 0x79, 0x8d, 0xc9, 0xae, 0xd6,
1230 0x8c, 0xed, 0x4d, 0x8a, 0x2a, 0x98, 0x6a, 0xcd, 0xb4, 0x27, 0x8d, 0x66, 0xa6, 0x27, 0xd3, 0x3d,
1231 0x4e, 0xbc, 0x5b, 0x7b, 0xe1, 0x04, 0xe1, 0xc8, 0x57, 0xe0, 0x40, 0xe5, 0x08, 0x37, 0x4e, 0x7c,
1232 0x02, 0x2e, 0x1c, 0xb9, 0x72, 0xe2, 0x03, 0x70, 0xe2, 0x40, 0xf5, 0x9f, 0x91, 0x34, 0xb6, 0x24,
1233 0x7b, 0x17, 0xd7, 0x9e, 0xd4, 0xfd, 0xde, 0xef, 0xfd, 0xe9, 0xd7, 0xef, 0xbd, 0x7e, 0x23, 0xb8,
1234 0x15, 0x30, 0x16, 0x84, 0xa4, 0xeb, 0x85, 0x2c, 0xf3, 0xbb, 0x3e, 0x16, 0x38, 0x49, 0x99, 0xd7,
1235 0x3d, 0x7d, 0xaf, 0xeb, 0x85, 0x19, 0x17, 0x24, 0xe5, 0x9d, 0x24, 0x65, 0x82, 0xa1, 0x96, 0x06,
1236 0x76, 0x14, 0xb0, 0x93, 0x03, 0x3b, 0xa7, 0xef, 0xb5, 0x5f, 0x37, 0x2a, 0x70, 0x42, 0xbb, 0x38,
1237 0x8e, 0x99, 0xc0, 0x82, 0xb2, 0xd8, 0xc8, 0xb5, 0xdf, 0x9d, 0x69, 0x80, 0x25, 0x24, 0x2d, 0x40,
1238 0xdf, 0x36, 0xd0, 0x90, 0xc5, 0x41, 0x9a, 0xc5, 0x31, 0x8d, 0x83, 0x8b, 0xa0, 0x6f, 0x18, 0x90,
1239 0xda, 0x0d, 0xb2, 0x93, 0xae, 0x9f, 0x69, 0x80, 0xe1, 0x6f, 0x9c, 0xe7, 0x9f, 0x50, 0x12, 0xfa,
1240 0x6e, 0x84, 0xf9, 0xd0, 0x20, 0xde, 0x3c, 0x8f, 0x10, 0x34, 0x22, 0x5c, 0xe0, 0x28, 0xd1, 0x00,
1241 0xfb, 0x6f, 0x25, 0x58, 0xde, 0xd1, 0xa7, 0x47, 0x6f, 0x00, 0x24, 0x29, 0xfb, 0x35, 0xf1, 0x84,
1242 0x4b, 0xfd, 0x96, 0xb5, 0x61, 0x6d, 0xae, 0x38, 0x2b, 0x86, 0xb2, 0xef, 0xa3, 0xb7, 0x60, 0xd5,
1243 0xc4, 0xc9, 0x8d, 0x71, 0x44, 0x5a, 0x25, 0x05, 0xa8, 0x1a, 0x5a, 0x1f, 0x47, 0x04, 0xfd, 0x18,
1244 0x96, 0x3c, 0x16, 0x9f, 0xd0, 0xa0, 0xb5, 0xb0, 0x61, 0x6d, 0x56, 0xb7, 0x6e, 0x75, 0x66, 0x45,
1245 0xb2, 0x63, 0x8c, 0xee, 0x28, 0xb8, 0x63, 0xc4, 0xa4, 0x02, 0x2e, 0xb0, 0xc8, 0x78, 0x6b, 0xf1,
1246 0x8a, 0x0a, 0x0e, 0x15, 0xdc, 0x31, 0x62, 0xa8, 0x0f, 0x75, 0xbd, 0x72, 0x3f, 0xa5, 0x5c, 0xb0,
1247 0xf4, 0xac, 0xb5, 0xbc, 0xb1, 0xf0, 0x3c, 0x8a, 0x6a, 0x5a, 0xfc, 0xa7, 0x5a, 0x7a, 0xf2, 0xd0,
1248 0x59, 0x46, 0xfd, 0xd6, 0x52, 0xe1, 0xd0, 0xc7, 0x19, 0xf5, 0xed, 0x7f, 0x2e, 0x42, 0xad, 0x70,
1249 0x1a, 0xf4, 0x36, 0xd4, 0xf4, 0x79, 0xdc, 0x41, 0xe6, 0x0d, 0x89, 0x30, 0xb1, 0x5c, 0xd5, 0xc4,
1250 0x7b, 0x8a, 0x86, 0x3e, 0x01, 0x14, 0x78, 0xc4, 0xcd, 0xb5, 0x9b, 0xb8, 0x55, 0xd4, 0xb1, 0x6f,
1251 0xcf, 0xf6, 0x76, 0xcf, 0x23, 0xc5, 0xd0, 0x35, 0x82, 0x73, 0x14, 0xe4, 0x40, 0x2d, 0xc2, 0x93,
1252 0x4a, 0x57, 0x94, 0xd2, 0xef, 0xce, 0x56, 0xba, 0x1f, 0x73, 0x81, 0x63, 0x8f, 0xec, 0xa5, 0x2c,
1253 0x4b, 0x8c, 0xde, 0x55, 0xad, 0x63, 0xac, 0xf3, 0x73, 0x96, 0x0e, 0xc7, 0x3a, 0xe1, 0x85, 0x74,
1254 0x6a, 0x1d, 0x46, 0x27, 0x81, 0xaf, 0x73, 0xe2, 0xb1, 0xd8, 0xc7, 0xe9, 0x99, 0x5b, 0xd4, 0xbe,
1255 0xfa, 0x22, 0xda, 0x5f, 0x1d, 0x69, 0xfb, 0x78, 0xd2, 0xcc, 0xcf, 0x61, 0x8d, 0xb3, 0x13, 0xf1,
1256 0x39, 0x4e, 0x49, 0xae, 0xbe, 0xa6, 0xd4, 0x6f, 0xce, 0x56, 0x7f, 0x68, 0x04, 0x8c, 0xe6, 0x3a,
1257 0x2f, 0xec, 0x11, 0x85, 0x75, 0x1a, 0x53, 0x41, 0x71, 0x48, 0x9f, 0xa8, 0x82, 0x74, 0xb1, 0xa7,
1258 0x0a, 0xb7, 0x55, 0x55, 0xd9, 0xb6, 0x35, 0x5b, 0x73, 0x9f, 0xf9, 0x64, 0xbf, 0x20, 0x7b, 0x57,
1259 0x89, 0x3a, 0xaf, 0xd2, 0x29, 0x54, 0x6e, 0xff, 0xb7, 0x04, 0x8d, 0xf3, 0x77, 0x8e, 0x5e, 0x83,
1260 0xca, 0x13, 0x16, 0x13, 0x37, 0x4b, 0xa9, 0xc9, 0xad, 0x65, 0xb9, 0x3f, 0x4e, 0x29, 0x7a, 0x13,
1261 0xaa, 0x31, 0x11, 0x32, 0x9a, 0x8a, 0xab, 0x8b, 0x14, 0x0c, 0x49, 0x02, 0xbe, 0x09, 0x75, 0x9e,
1262 0x0d, 0x26, 0x31, 0x3a, 0xa7, 0x6b, 0x63, 0xaa, 0x84, 0x6d, 0x42, 0x83, 0xc6, 0x82, 0xa4, 0x31,
1263 0x0e, 0x5d, 0x9a, 0xb8, 0x2c, 0x0e, 0x65, 0x29, 0x59, 0x9b, 0x15, 0xa7, 0x9e, 0xd3, 0xf7, 0x93,
1264 0x47, 0x71, 0x78, 0x86, 0xbe, 0x0f, 0xeb, 0x9c, 0xa4, 0xa7, 0xd4, 0x23, 0x2e, 0xf6, 0x3c, 0x96,
1265 0xc5, 0xc2, 0xe5, 0x1e, 0x4b, 0x08, 0x6f, 0x2d, 0x6c, 0x2c, 0x6c, 0xae, 0x38, 0x4d, 0xc3, 0xbd,
1266 0xab, 0x99, 0x87, 0x8a, 0x87, 0x10, 0x2c, 0x0a, 0x1c, 0xc8, 0x3a, 0x97, 0x18, 0xb5, 0x46, 0x47,
1267 0x50, 0x89, 0x88, 0xc0, 0x32, 0x5c, 0xad, 0xb2, 0x0a, 0xe4, 0x07, 0x57, 0x2f, 0x84, 0xce, 0x43,
1268 0x23, 0xba, 0x1b, 0x8b, 0xf4, 0xcc, 0x19, 0x69, 0x6a, 0x6f, 0x43, 0xad, 0xc0, 0x42, 0x0d, 0x58,
1269 0x18, 0x92, 0x33, 0x13, 0x38, 0xb9, 0x44, 0x4d, 0x28, 0x9f, 0xe2, 0x30, 0xcb, 0x7b, 0x9a, 0xde,
1270 0xdc, 0x29, 0x7d, 0x60, 0xd9, 0xff, 0x29, 0xc1, 0x2b, 0x53, 0x72, 0x4d, 0x96, 0x78, 0x9c, 0x45,
1271 0x2e, 0x35, 0x2c, 0xae, 0xb4, 0x95, 0x9d, 0xd5, 0x38, 0x8b, 0x72, 0x38, 0x97, 0xa1, 0xce, 0x01,
1272 0xaa, 0x65, 0xf2, 0x56, 0x49, 0x9d, 0xb6, 0x96, 0x53, 0x65, 0xd3, 0xe4, 0xe8, 0x26, 0xac, 0xd0,
1273 0x08, 0x07, 0xfa, 0x3a, 0x17, 0x94, 0x07, 0x15, 0x45, 0x30, 0xf7, 0x10, 0x61, 0xef, 0x53, 0x1a,
1274 0x13, 0x57, 0x9c, 0x25, 0x1a, 0xb3, 0xa8, 0x30, 0x75, 0x43, 0x3f, 0x3a, 0x4b, 0x14, 0x72, 0x17,
1275 0xaa, 0x3e, 0xe5, 0xc3, 0x3c, 0xc7, 0xcb, 0x2a, 0xc7, 0xdf, 0x99, 0x1d, 0xc0, 0x1e, 0xe5, 0x43,
1276 0x93, 0xdf, 0xe0, 0x8f, 0xd6, 0xca, 0x69, 0xee, 0x26, 0x29, 0x21, 0x51, 0x22, 0xe8, 0x20, 0x24,
1277 0x2a, 0x3f, 0x2a, 0x4e, 0x8d, 0xf2, 0x83, 0x31, 0x11, 0xfd, 0x0a, 0x9a, 0x11, 0x8e, 0x71, 0x40,
1278 0x7c, 0x37, 0x90, 0x71, 0xc9, 0xcd, 0x2e, 0x2b, 0xb3, 0xdf, 0x99, 0x6d, 0xf6, 0xa1, 0x96, 0x9a,
1279 0x2c, 0x5c, 0x14, 0x5d, 0xa0, 0xd9, 0xbf, 0xb3, 0x00, 0x5d, 0x84, 0xca, 0x64, 0x1b, 0x85, 0x54,
1280 0x90, 0x28, 0x09, 0xb1, 0xd0, 0xb1, 0x35, 0xd7, 0xd9, 0xcc, 0xb9, 0x47, 0x86, 0xa9, 0xde, 0xa5,
1281 0x0f, 0xe1, 0xe6, 0x48, 0x4a, 0x7b, 0xab, 0x2d, 0x16, 0x5e, 0xb2, 0x16, 0x9d, 0xbc, 0x67, 0x6d,
1282 0x5b, 0x3d, 0x6b, 0xf6, 0x2f, 0x01, 0xc6, 0xc1, 0x42, 0xef, 0xc2, 0x8d, 0x01, 0x63, 0xc2, 0x55,
1283 0xc1, 0xe6, 0xf4, 0x09, 0x71, 0x83, 0x81, 0xb9, 0xfe, 0xba, 0x64, 0x48, 0xe8, 0x21, 0x7d, 0x42,
1284 0xf6, 0x06, 0xe8, 0x1d, 0xa8, 0xcb, 0x2c, 0x09, 0x99, 0x87, 0x43, 0x97, 0x73, 0x9f, 0x2b, 0x53,
1285 0x3a, 0x4d, 0x1e, 0x48, 0xe2, 0x21, 0xf7, 0xb9, 0xfd, 0x7b, 0x0b, 0x5a, 0xb3, 0xda, 0x02, 0xba,
1286 0x05, 0x6b, 0xe4, 0x0b, 0xe2, 0x65, 0x02, 0x0f, 0x42, 0xe2, 0x9e, 0xd0, 0x30, 0x3f, 0x69, 0x7d,
1287 0x4c, 0xbe, 0x4f, 0x43, 0x82, 0xee, 0xc3, 0x0d, 0x4d, 0x91, 0xed, 0x48, 0x3e, 0xf3, 0x2c, 0x13,
1288 0xca, 0x5c, 0x75, 0xeb, 0xb5, 0xfc, 0x36, 0xf2, 0x31, 0xa0, 0xd3, 0x33, 0x83, 0x84, 0xd3, 0x18,
1289 0xc9, 0x1c, 0x69, 0x11, 0xfb, 0xcb, 0xd2, 0xe8, 0x39, 0xd3, 0x4f, 0x22, 0xda, 0x81, 0xb2, 0x7c,
1290 0x14, 0xb5, 0xe1, 0xfa, 0xbc, 0xae, 0x5c, 0x90, 0xeb, 0xc8, 0x1f, 0xe2, 0x68, 0x59, 0xb4, 0x0e,
1291 0x4b, 0x3e, 0x11, 0x98, 0x86, 0x26, 0xda, 0x66, 0x87, 0x7a, 0xd0, 0x50, 0x00, 0x97, 0x0b, 0x9c,
1292 0x0a, 0xe5, 0xb8, 0x19, 0x1e, 0xda, 0x17, 0xbc, 0x3e, 0xca, 0x87, 0x17, 0x47, 0x3d, 0xf2, 0xe4,
1293 0x50, 0x8a, 0x48, 0xa2, 0xfd, 0x18, 0xca, 0xca, 0x1a, 0xaa, 0xc2, 0xf2, 0x71, 0xff, 0xa3, 0xfe,
1294 0xa3, 0x8f, 0xfb, 0x8d, 0xaf, 0xa1, 0x55, 0xa8, 0xec, 0x38, 0xbb, 0x77, 0x8f, 0xf6, 0xfb, 0x7b,
1295 0x0d, 0x4b, 0xb2, 0x9c, 0xe3, 0x7e, 0x5f, 0x6e, 0x4a, 0x68, 0x05, 0xca, 0xbb, 0x8e, 0xf3, 0xc8,
1296 0x69, 0x2c, 0x48, 0x54, 0x6f, 0xf7, 0xc1, 0xae, 0x42, 0x2d, 0xca, 0xdd, 0xf1, 0x41, 0x4f, 0xcb,
1297 0x94, 0xed, 0xbf, 0x5b, 0x50, 0x2f, 0xbe, 0x05, 0xb2, 0xf2, 0x75, 0xb5, 0x9e, 0x92, 0x94, 0x53,
1298 0x16, 0xe7, 0x8f, 0xbb, 0x22, 0x3e, 0xd6, 0x34, 0xf4, 0x89, 0x1a, 0xa5, 0x12, 0x92, 0x0a, 0x6a,
1299 0xaa, 0x7e, 0x6e, 0x2f, 0x2b, 0x9a, 0xe8, 0x1c, 0x8c, 0x44, 0x75, 0x2f, 0x9b, 0xd0, 0xd5, 0xfe,
1300 0x10, 0xd6, 0xce, 0xb1, 0x9f, 0xab, 0x9f, 0x7d, 0x69, 0x41, 0x73, 0x27, 0x25, 0x58, 0xe4, 0xcd,
1301 0xd3, 0x21, 0x9f, 0x65, 0x84, 0x8b, 0xcb, 0x86, 0xbf, 0x75, 0x58, 0x4a, 0x49, 0x20, 0x8f, 0xab,
1302 0x1b, 0x94, 0xd9, 0xa1, 0x6d, 0x58, 0x36, 0x13, 0x8c, 0xc9, 0xb5, 0xb7, 0x2e, 0xcd, 0x0e, 0x27,
1303 0x97, 0xb0, 0xff, 0x6d, 0x41, 0xf3, 0x38, 0xf1, 0xff, 0x0f, 0x67, 0xca, 0x05, 0x67, 0xae, 0x30,
1304 0xa1, 0x4e, 0xf8, 0xbb, 0xf0, 0xbc, 0xfe, 0xa2, 0x6d, 0xa8, 0x66, 0xca, 0x5d, 0x35, 0x62, 0x9b,
1305 0x11, 0xf5, 0x62, 0x9a, 0xde, 0x97, 0x53, 0xf8, 0x43, 0xcc, 0x87, 0x0e, 0x68, 0xb8, 0x5c, 0xdb,
1306 0x09, 0x34, 0x7b, 0x24, 0x24, 0xd7, 0x15, 0xf8, 0xcb, 0xcf, 0x6a, 0x47, 0x70, 0x63, 0x8f, 0x88,
1307 0x97, 0x66, 0xee, 0xb7, 0x16, 0xbc, 0xf2, 0x80, 0xf2, 0xdc, 0x20, 0x7f, 0x6e, 0x8b, 0x8b, 0x05,
1308 0x8b, 0x37, 0x61, 0x25, 0x91, 0x65, 0x26, 0x3b, 0xac, 0x69, 0x9b, 0x15, 0x49, 0x90, 0xad, 0x55,
1309 0xe9, 0x94, 0x4c, 0xc1, 0x86, 0x24, 0x77, 0x55, 0xc1, 0x8f, 0x24, 0xc1, 0x7e, 0x06, 0xcd, 0xa2,
1310 0x27, 0x3c, 0x61, 0x31, 0x97, 0xef, 0x40, 0x25, 0xff, 0xd4, 0x6b, 0x59, 0xaa, 0x28, 0xaf, 0x70,
1311 0xfd, 0x23, 0x11, 0xf4, 0x2d, 0x58, 0x8b, 0xc9, 0x17, 0xc2, 0x9d, 0x30, 0xad, 0xe3, 0x50, 0x93,
1312 0xe4, 0x83, 0x91, 0xf9, 0x14, 0xd6, 0x7b, 0x14, 0x07, 0x31, 0xe3, 0x2f, 0xef, 0xb2, 0x7f, 0x38,
1313 0xc5, 0x26, 0xcf, 0x42, 0xc1, 0xa5, 0x4d, 0x96, 0x89, 0x24, 0x13, 0x13, 0xe3, 0xe2, 0x8a, 0xa6,
1314 0x1c, 0xa7, 0x74, 0xeb, 0xcf, 0x15, 0xb8, 0x31, 0x1e, 0xa4, 0x44, 0xca, 0xc2, 0x90, 0xa4, 0xe8,
1315 0x8f, 0x16, 0xd4, 0x0a, 0x7d, 0x02, 0x75, 0xe6, 0x44, 0x6a, 0x4a, 0x43, 0x69, 0xbf, 0x91, 0xe3,
1316 0x27, 0x3e, 0x71, 0x3b, 0x8f, 0xf2, 0x4f, 0x5c, 0xbb, 0xf7, 0x9b, 0x7f, 0xfc, 0xeb, 0x0f, 0xa5,
1317 0x1f, 0xd9, 0xef, 0xcb, 0xcf, 0x63, 0x13, 0x01, 0xde, 0x7d, 0x3a, 0x8e, 0xce, 0xb3, 0xae, 0x3e,
1318 0x3c, 0xef, 0x3e, 0xd5, 0x8b, 0x67, 0xa3, 0xcf, 0xf4, 0x3b, 0xa3, 0x8a, 0xfc, 0x8b, 0x05, 0xb5,
1319 0x42, 0x07, 0x99, 0xe7, 0xe6, 0xb4, 0x56, 0x73, 0x99, 0x9b, 0x87, 0xca, 0xcd, 0x87, 0x5b, 0xf7,
1320 0x5e, 0xc0, 0xcd, 0xee, 0xd3, 0xc9, 0x4b, 0x7b, 0x36, 0xf6, 0xfa, 0x2b, 0x0b, 0x6a, 0x85, 0x5e,
1321 0x30, 0xcf, 0xeb, 0x69, 0x4d, 0xe3, 0x32, 0xaf, 0x7f, 0xa6, 0xbc, 0xee, 0xdd, 0xbe, 0x06, 0xaf,
1322 0xd1, 0x9f, 0x2c, 0x80, 0x71, 0x1b, 0x41, 0xdf, 0x9e, 0x33, 0x91, 0x9f, 0x6f, 0x36, 0xed, 0xcb,
1323 0xab, 0x2b, 0x77, 0x15, 0x5d, 0x87, 0xab, 0x5f, 0x59, 0xb0, 0x3a, 0x59, 0xf7, 0x68, 0xce, 0xa8,
1324 0x32, 0xa5, 0x53, 0xb5, 0x3b, 0x57, 0x85, 0xeb, 0x76, 0x62, 0x6f, 0x2b, 0xdf, 0x7f, 0x80, 0x5e,
1325 0x24, 0x87, 0xd1, 0x5f, 0x2d, 0x58, 0x3b, 0x57, 0xb1, 0xe8, 0x7b, 0xf3, 0xa6, 0xf5, 0x69, 0x0d,
1326 0xe5, 0xb2, 0x44, 0x78, 0xac, 0x3c, 0x3c, 0xb0, 0x3f, 0xba, 0x86, 0xf4, 0xf5, 0x8d, 0x07, 0x77,
1327 0xac, 0xdb, 0xf7, 0x3e, 0x83, 0xd7, 0x3d, 0x16, 0xcd, 0xf4, 0xf6, 0x5e, 0x3e, 0x41, 0xf2, 0x03,
1328 0xf9, 0x28, 0x1e, 0x58, 0xbf, 0xf8, 0x89, 0x81, 0x06, 0x2c, 0xc4, 0x71, 0xd0, 0x61, 0x69, 0xd0,
1329 0x0d, 0x48, 0xac, 0x9e, 0xcc, 0xae, 0x66, 0xe1, 0x84, 0xf2, 0x8b, 0xff, 0x9c, 0x6d, 0xe7, 0xeb,
1330 0xc1, 0x92, 0x02, 0xbf, 0xff, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0x58, 0xab, 0x60, 0x26, 0xc6,