1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/cloud/dataproc/v1/autoscaling_policies.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 empty "github.com/golang/protobuf/ptypes/empty" 14 _ "google.golang.org/genproto/googleapis/api/annotations" 15 grpc "google.golang.org/grpc" 16 codes "google.golang.org/grpc/codes" 17 status "google.golang.org/grpc/status" 18) 19 20// Reference imports to suppress errors if they are not otherwise used. 21var _ = proto.Marshal 22var _ = fmt.Errorf 23var _ = math.Inf 24 25// This is a compile-time assertion to ensure that this generated file 26// is compatible with the proto package it is being compiled against. 27// A compilation error at this line likely means your copy of the 28// proto package needs to be updated. 29const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 30 31// Describes an autoscaling policy for Dataproc cluster autoscaler. 32type AutoscalingPolicy struct { 33 // Required. The policy id. 34 // 35 // The id must contain only letters (a-z, A-Z), numbers (0-9), 36 // underscores (_), and hyphens (-). Cannot begin or end with underscore 37 // or hyphen. Must consist of between 3 and 50 characters. 38 // 39 Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` 40 // Output only. The "resource name" of the autoscaling policy, as described 41 // in https://cloud.google.com/apis/design/resource_names. 42 // 43 // * For `projects.regions.autoscalingPolicies`, the resource name of the 44 // policy has the following format: 45 // `projects/{project_id}/regions/{region}/autoscalingPolicies/{policy_id}` 46 // 47 // * For `projects.locations.autoscalingPolicies`, the resource name of the 48 // policy has the following format: 49 // `projects/{project_id}/locations/{location}/autoscalingPolicies/{policy_id}` 50 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` 51 // Autoscaling algorithm for policy. 52 // 53 // Types that are valid to be assigned to Algorithm: 54 // *AutoscalingPolicy_BasicAlgorithm 55 Algorithm isAutoscalingPolicy_Algorithm `protobuf_oneof:"algorithm"` 56 // Required. Describes how the autoscaler will operate for primary workers. 57 WorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,4,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"` 58 // Optional. Describes how the autoscaler will operate for secondary workers. 59 SecondaryWorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,5,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"` 60 XXX_NoUnkeyedLiteral struct{} `json:"-"` 61 XXX_unrecognized []byte `json:"-"` 62 XXX_sizecache int32 `json:"-"` 63} 64 65func (m *AutoscalingPolicy) Reset() { *m = AutoscalingPolicy{} } 66func (m *AutoscalingPolicy) String() string { return proto.CompactTextString(m) } 67func (*AutoscalingPolicy) ProtoMessage() {} 68func (*AutoscalingPolicy) Descriptor() ([]byte, []int) { 69 return fileDescriptor_e49a4a9859d08ad9, []int{0} 70} 71 72func (m *AutoscalingPolicy) XXX_Unmarshal(b []byte) error { 73 return xxx_messageInfo_AutoscalingPolicy.Unmarshal(m, b) 74} 75func (m *AutoscalingPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 76 return xxx_messageInfo_AutoscalingPolicy.Marshal(b, m, deterministic) 77} 78func (m *AutoscalingPolicy) XXX_Merge(src proto.Message) { 79 xxx_messageInfo_AutoscalingPolicy.Merge(m, src) 80} 81func (m *AutoscalingPolicy) XXX_Size() int { 82 return xxx_messageInfo_AutoscalingPolicy.Size(m) 83} 84func (m *AutoscalingPolicy) XXX_DiscardUnknown() { 85 xxx_messageInfo_AutoscalingPolicy.DiscardUnknown(m) 86} 87 88var xxx_messageInfo_AutoscalingPolicy proto.InternalMessageInfo 89 90func (m *AutoscalingPolicy) GetId() string { 91 if m != nil { 92 return m.Id 93 } 94 return "" 95} 96 97func (m *AutoscalingPolicy) GetName() string { 98 if m != nil { 99 return m.Name 100 } 101 return "" 102} 103 104type isAutoscalingPolicy_Algorithm interface { 105 isAutoscalingPolicy_Algorithm() 106} 107 108type AutoscalingPolicy_BasicAlgorithm struct { 109 BasicAlgorithm *BasicAutoscalingAlgorithm `protobuf:"bytes,3,opt,name=basic_algorithm,json=basicAlgorithm,proto3,oneof"` 110} 111 112func (*AutoscalingPolicy_BasicAlgorithm) isAutoscalingPolicy_Algorithm() {} 113 114func (m *AutoscalingPolicy) GetAlgorithm() isAutoscalingPolicy_Algorithm { 115 if m != nil { 116 return m.Algorithm 117 } 118 return nil 119} 120 121func (m *AutoscalingPolicy) GetBasicAlgorithm() *BasicAutoscalingAlgorithm { 122 if x, ok := m.GetAlgorithm().(*AutoscalingPolicy_BasicAlgorithm); ok { 123 return x.BasicAlgorithm 124 } 125 return nil 126} 127 128func (m *AutoscalingPolicy) GetWorkerConfig() *InstanceGroupAutoscalingPolicyConfig { 129 if m != nil { 130 return m.WorkerConfig 131 } 132 return nil 133} 134 135func (m *AutoscalingPolicy) GetSecondaryWorkerConfig() *InstanceGroupAutoscalingPolicyConfig { 136 if m != nil { 137 return m.SecondaryWorkerConfig 138 } 139 return nil 140} 141 142// XXX_OneofWrappers is for the internal use of the proto package. 143func (*AutoscalingPolicy) XXX_OneofWrappers() []interface{} { 144 return []interface{}{ 145 (*AutoscalingPolicy_BasicAlgorithm)(nil), 146 } 147} 148 149// Basic algorithm for autoscaling. 150type BasicAutoscalingAlgorithm struct { 151 // Required. YARN autoscaling configuration. 152 YarnConfig *BasicYarnAutoscalingConfig `protobuf:"bytes,1,opt,name=yarn_config,json=yarnConfig,proto3" json:"yarn_config,omitempty"` 153 // Optional. Duration between scaling events. A scaling period starts after 154 // the update operation from the previous event has completed. 155 // 156 // Bounds: [2m, 1d]. Default: 2m. 157 CooldownPeriod *duration.Duration `protobuf:"bytes,2,opt,name=cooldown_period,json=cooldownPeriod,proto3" json:"cooldown_period,omitempty"` 158 XXX_NoUnkeyedLiteral struct{} `json:"-"` 159 XXX_unrecognized []byte `json:"-"` 160 XXX_sizecache int32 `json:"-"` 161} 162 163func (m *BasicAutoscalingAlgorithm) Reset() { *m = BasicAutoscalingAlgorithm{} } 164func (m *BasicAutoscalingAlgorithm) String() string { return proto.CompactTextString(m) } 165func (*BasicAutoscalingAlgorithm) ProtoMessage() {} 166func (*BasicAutoscalingAlgorithm) Descriptor() ([]byte, []int) { 167 return fileDescriptor_e49a4a9859d08ad9, []int{1} 168} 169 170func (m *BasicAutoscalingAlgorithm) XXX_Unmarshal(b []byte) error { 171 return xxx_messageInfo_BasicAutoscalingAlgorithm.Unmarshal(m, b) 172} 173func (m *BasicAutoscalingAlgorithm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 174 return xxx_messageInfo_BasicAutoscalingAlgorithm.Marshal(b, m, deterministic) 175} 176func (m *BasicAutoscalingAlgorithm) XXX_Merge(src proto.Message) { 177 xxx_messageInfo_BasicAutoscalingAlgorithm.Merge(m, src) 178} 179func (m *BasicAutoscalingAlgorithm) XXX_Size() int { 180 return xxx_messageInfo_BasicAutoscalingAlgorithm.Size(m) 181} 182func (m *BasicAutoscalingAlgorithm) XXX_DiscardUnknown() { 183 xxx_messageInfo_BasicAutoscalingAlgorithm.DiscardUnknown(m) 184} 185 186var xxx_messageInfo_BasicAutoscalingAlgorithm proto.InternalMessageInfo 187 188func (m *BasicAutoscalingAlgorithm) GetYarnConfig() *BasicYarnAutoscalingConfig { 189 if m != nil { 190 return m.YarnConfig 191 } 192 return nil 193} 194 195func (m *BasicAutoscalingAlgorithm) GetCooldownPeriod() *duration.Duration { 196 if m != nil { 197 return m.CooldownPeriod 198 } 199 return nil 200} 201 202// Basic autoscaling configurations for YARN. 203type BasicYarnAutoscalingConfig struct { 204 // Required. Timeout for YARN graceful decommissioning of Node Managers. 205 // Specifies the duration to wait for jobs to complete before forcefully 206 // removing workers (and potentially interrupting jobs). Only applicable to 207 // downscaling operations. 208 // 209 // Bounds: [0s, 1d]. 210 GracefulDecommissionTimeout *duration.Duration `protobuf:"bytes,5,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"` 211 // Required. Fraction of average pending memory in the last cooldown period 212 // for which to add workers. A scale-up factor of 1.0 will result in scaling 213 // up so that there is no pending memory remaining after the update (more 214 // aggressive scaling). A scale-up factor closer to 0 will result in a smaller 215 // magnitude of scaling up (less aggressive scaling). 216 // 217 // Bounds: [0.0, 1.0]. 218 ScaleUpFactor float64 `protobuf:"fixed64,1,opt,name=scale_up_factor,json=scaleUpFactor,proto3" json:"scale_up_factor,omitempty"` 219 // Required. Fraction of average pending memory in the last cooldown period 220 // for which to remove workers. A scale-down factor of 1 will result in 221 // scaling down so that there is no available memory remaining after the 222 // update (more aggressive scaling). A scale-down factor of 0 disables 223 // removing workers, which can be beneficial for autoscaling a single job. 224 // 225 // Bounds: [0.0, 1.0]. 226 ScaleDownFactor float64 `protobuf:"fixed64,2,opt,name=scale_down_factor,json=scaleDownFactor,proto3" json:"scale_down_factor,omitempty"` 227 // Optional. Minimum scale-up threshold as a fraction of total cluster size 228 // before scaling occurs. For example, in a 20-worker cluster, a threshold of 229 // 0.1 means the autoscaler must recommend at least a 2-worker scale-up for 230 // the cluster to scale. A threshold of 0 means the autoscaler will scale up 231 // on any recommended change. 232 // 233 // Bounds: [0.0, 1.0]. Default: 0.0. 234 ScaleUpMinWorkerFraction float64 `protobuf:"fixed64,3,opt,name=scale_up_min_worker_fraction,json=scaleUpMinWorkerFraction,proto3" json:"scale_up_min_worker_fraction,omitempty"` 235 // Optional. Minimum scale-down threshold as a fraction of total cluster size 236 // before scaling occurs. For example, in a 20-worker cluster, a threshold of 237 // 0.1 means the autoscaler must recommend at least a 2 worker scale-down for 238 // the cluster to scale. A threshold of 0 means the autoscaler will scale down 239 // on any recommended change. 240 // 241 // Bounds: [0.0, 1.0]. Default: 0.0. 242 ScaleDownMinWorkerFraction float64 `protobuf:"fixed64,4,opt,name=scale_down_min_worker_fraction,json=scaleDownMinWorkerFraction,proto3" json:"scale_down_min_worker_fraction,omitempty"` 243 XXX_NoUnkeyedLiteral struct{} `json:"-"` 244 XXX_unrecognized []byte `json:"-"` 245 XXX_sizecache int32 `json:"-"` 246} 247 248func (m *BasicYarnAutoscalingConfig) Reset() { *m = BasicYarnAutoscalingConfig{} } 249func (m *BasicYarnAutoscalingConfig) String() string { return proto.CompactTextString(m) } 250func (*BasicYarnAutoscalingConfig) ProtoMessage() {} 251func (*BasicYarnAutoscalingConfig) Descriptor() ([]byte, []int) { 252 return fileDescriptor_e49a4a9859d08ad9, []int{2} 253} 254 255func (m *BasicYarnAutoscalingConfig) XXX_Unmarshal(b []byte) error { 256 return xxx_messageInfo_BasicYarnAutoscalingConfig.Unmarshal(m, b) 257} 258func (m *BasicYarnAutoscalingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 259 return xxx_messageInfo_BasicYarnAutoscalingConfig.Marshal(b, m, deterministic) 260} 261func (m *BasicYarnAutoscalingConfig) XXX_Merge(src proto.Message) { 262 xxx_messageInfo_BasicYarnAutoscalingConfig.Merge(m, src) 263} 264func (m *BasicYarnAutoscalingConfig) XXX_Size() int { 265 return xxx_messageInfo_BasicYarnAutoscalingConfig.Size(m) 266} 267func (m *BasicYarnAutoscalingConfig) XXX_DiscardUnknown() { 268 xxx_messageInfo_BasicYarnAutoscalingConfig.DiscardUnknown(m) 269} 270 271var xxx_messageInfo_BasicYarnAutoscalingConfig proto.InternalMessageInfo 272 273func (m *BasicYarnAutoscalingConfig) GetGracefulDecommissionTimeout() *duration.Duration { 274 if m != nil { 275 return m.GracefulDecommissionTimeout 276 } 277 return nil 278} 279 280func (m *BasicYarnAutoscalingConfig) GetScaleUpFactor() float64 { 281 if m != nil { 282 return m.ScaleUpFactor 283 } 284 return 0 285} 286 287func (m *BasicYarnAutoscalingConfig) GetScaleDownFactor() float64 { 288 if m != nil { 289 return m.ScaleDownFactor 290 } 291 return 0 292} 293 294func (m *BasicYarnAutoscalingConfig) GetScaleUpMinWorkerFraction() float64 { 295 if m != nil { 296 return m.ScaleUpMinWorkerFraction 297 } 298 return 0 299} 300 301func (m *BasicYarnAutoscalingConfig) GetScaleDownMinWorkerFraction() float64 { 302 if m != nil { 303 return m.ScaleDownMinWorkerFraction 304 } 305 return 0 306} 307 308// Configuration for the size bounds of an instance group, including its 309// proportional size to other groups. 310type InstanceGroupAutoscalingPolicyConfig struct { 311 // Optional. Minimum number of instances for this group. 312 // 313 // Primary workers - Bounds: [2, max_instances]. Default: 2. 314 // Secondary workers - Bounds: [0, max_instances]. Default: 0. 315 MinInstances int32 `protobuf:"varint,1,opt,name=min_instances,json=minInstances,proto3" json:"min_instances,omitempty"` 316 // Required. Maximum number of instances for this group. Required for primary 317 // workers. Note that by default, clusters will not use secondary workers. 318 // Required for secondary workers if the minimum secondary instances is set. 319 // 320 // Primary workers - Bounds: [min_instances, ). 321 // Secondary workers - Bounds: [min_instances, ). Default: 0. 322 MaxInstances int32 `protobuf:"varint,2,opt,name=max_instances,json=maxInstances,proto3" json:"max_instances,omitempty"` 323 // Optional. Weight for the instance group, which is used to determine the 324 // fraction of total workers in the cluster from this instance group. 325 // For example, if primary workers have weight 2, and secondary workers have 326 // weight 1, the cluster will have approximately 2 primary workers for each 327 // secondary worker. 328 // 329 // The cluster may not reach the specified balance if constrained 330 // by min/max bounds or other autoscaling settings. For example, if 331 // `max_instances` for secondary workers is 0, then only primary workers will 332 // be added. The cluster can also be out of balance when created. 333 // 334 // If weight is not set on any instance group, the cluster will default to 335 // equal weight for all groups: the cluster will attempt to maintain an equal 336 // number of workers in each group within the configured size bounds for each 337 // group. If weight is set for one group only, the cluster will default to 338 // zero weight on the unset group. For example if weight is set only on 339 // primary workers, the cluster will use primary workers only and no 340 // secondary workers. 341 Weight int32 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"` 342 XXX_NoUnkeyedLiteral struct{} `json:"-"` 343 XXX_unrecognized []byte `json:"-"` 344 XXX_sizecache int32 `json:"-"` 345} 346 347func (m *InstanceGroupAutoscalingPolicyConfig) Reset() { *m = InstanceGroupAutoscalingPolicyConfig{} } 348func (m *InstanceGroupAutoscalingPolicyConfig) String() string { return proto.CompactTextString(m) } 349func (*InstanceGroupAutoscalingPolicyConfig) ProtoMessage() {} 350func (*InstanceGroupAutoscalingPolicyConfig) Descriptor() ([]byte, []int) { 351 return fileDescriptor_e49a4a9859d08ad9, []int{3} 352} 353 354func (m *InstanceGroupAutoscalingPolicyConfig) XXX_Unmarshal(b []byte) error { 355 return xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig.Unmarshal(m, b) 356} 357func (m *InstanceGroupAutoscalingPolicyConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 358 return xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig.Marshal(b, m, deterministic) 359} 360func (m *InstanceGroupAutoscalingPolicyConfig) XXX_Merge(src proto.Message) { 361 xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig.Merge(m, src) 362} 363func (m *InstanceGroupAutoscalingPolicyConfig) XXX_Size() int { 364 return xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig.Size(m) 365} 366func (m *InstanceGroupAutoscalingPolicyConfig) XXX_DiscardUnknown() { 367 xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig.DiscardUnknown(m) 368} 369 370var xxx_messageInfo_InstanceGroupAutoscalingPolicyConfig proto.InternalMessageInfo 371 372func (m *InstanceGroupAutoscalingPolicyConfig) GetMinInstances() int32 { 373 if m != nil { 374 return m.MinInstances 375 } 376 return 0 377} 378 379func (m *InstanceGroupAutoscalingPolicyConfig) GetMaxInstances() int32 { 380 if m != nil { 381 return m.MaxInstances 382 } 383 return 0 384} 385 386func (m *InstanceGroupAutoscalingPolicyConfig) GetWeight() int32 { 387 if m != nil { 388 return m.Weight 389 } 390 return 0 391} 392 393// A request to create an autoscaling policy. 394type CreateAutoscalingPolicyRequest struct { 395 // Required. The "resource name" of the region or location, as described 396 // in https://cloud.google.com/apis/design/resource_names. 397 // 398 // * For `projects.regions.autoscalingPolicies.create`, the resource name 399 // of the region has the following format: 400 // `projects/{project_id}/regions/{region}` 401 // 402 // * For `projects.locations.autoscalingPolicies.create`, the resource name 403 // of the location has the following format: 404 // `projects/{project_id}/locations/{location}` 405 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 406 // The autoscaling policy to create. 407 Policy *AutoscalingPolicy `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"` 408 XXX_NoUnkeyedLiteral struct{} `json:"-"` 409 XXX_unrecognized []byte `json:"-"` 410 XXX_sizecache int32 `json:"-"` 411} 412 413func (m *CreateAutoscalingPolicyRequest) Reset() { *m = CreateAutoscalingPolicyRequest{} } 414func (m *CreateAutoscalingPolicyRequest) String() string { return proto.CompactTextString(m) } 415func (*CreateAutoscalingPolicyRequest) ProtoMessage() {} 416func (*CreateAutoscalingPolicyRequest) Descriptor() ([]byte, []int) { 417 return fileDescriptor_e49a4a9859d08ad9, []int{4} 418} 419 420func (m *CreateAutoscalingPolicyRequest) XXX_Unmarshal(b []byte) error { 421 return xxx_messageInfo_CreateAutoscalingPolicyRequest.Unmarshal(m, b) 422} 423func (m *CreateAutoscalingPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 424 return xxx_messageInfo_CreateAutoscalingPolicyRequest.Marshal(b, m, deterministic) 425} 426func (m *CreateAutoscalingPolicyRequest) XXX_Merge(src proto.Message) { 427 xxx_messageInfo_CreateAutoscalingPolicyRequest.Merge(m, src) 428} 429func (m *CreateAutoscalingPolicyRequest) XXX_Size() int { 430 return xxx_messageInfo_CreateAutoscalingPolicyRequest.Size(m) 431} 432func (m *CreateAutoscalingPolicyRequest) XXX_DiscardUnknown() { 433 xxx_messageInfo_CreateAutoscalingPolicyRequest.DiscardUnknown(m) 434} 435 436var xxx_messageInfo_CreateAutoscalingPolicyRequest proto.InternalMessageInfo 437 438func (m *CreateAutoscalingPolicyRequest) GetParent() string { 439 if m != nil { 440 return m.Parent 441 } 442 return "" 443} 444 445func (m *CreateAutoscalingPolicyRequest) GetPolicy() *AutoscalingPolicy { 446 if m != nil { 447 return m.Policy 448 } 449 return nil 450} 451 452// A request to fetch an autoscaling policy. 453type GetAutoscalingPolicyRequest struct { 454 // Required. The "resource name" of the autoscaling policy, as described 455 // in https://cloud.google.com/apis/design/resource_names. 456 // 457 // * For `projects.regions.autoscalingPolicies.get`, the resource name 458 // of the policy has the following format: 459 // `projects/{project_id}/regions/{region}/autoscalingPolicies/{policy_id}` 460 // 461 // * For `projects.locations.autoscalingPolicies.get`, the resource name 462 // of the policy has the following format: 463 // `projects/{project_id}/locations/{location}/autoscalingPolicies/{policy_id}` 464 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 465 XXX_NoUnkeyedLiteral struct{} `json:"-"` 466 XXX_unrecognized []byte `json:"-"` 467 XXX_sizecache int32 `json:"-"` 468} 469 470func (m *GetAutoscalingPolicyRequest) Reset() { *m = GetAutoscalingPolicyRequest{} } 471func (m *GetAutoscalingPolicyRequest) String() string { return proto.CompactTextString(m) } 472func (*GetAutoscalingPolicyRequest) ProtoMessage() {} 473func (*GetAutoscalingPolicyRequest) Descriptor() ([]byte, []int) { 474 return fileDescriptor_e49a4a9859d08ad9, []int{5} 475} 476 477func (m *GetAutoscalingPolicyRequest) XXX_Unmarshal(b []byte) error { 478 return xxx_messageInfo_GetAutoscalingPolicyRequest.Unmarshal(m, b) 479} 480func (m *GetAutoscalingPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 481 return xxx_messageInfo_GetAutoscalingPolicyRequest.Marshal(b, m, deterministic) 482} 483func (m *GetAutoscalingPolicyRequest) XXX_Merge(src proto.Message) { 484 xxx_messageInfo_GetAutoscalingPolicyRequest.Merge(m, src) 485} 486func (m *GetAutoscalingPolicyRequest) XXX_Size() int { 487 return xxx_messageInfo_GetAutoscalingPolicyRequest.Size(m) 488} 489func (m *GetAutoscalingPolicyRequest) XXX_DiscardUnknown() { 490 xxx_messageInfo_GetAutoscalingPolicyRequest.DiscardUnknown(m) 491} 492 493var xxx_messageInfo_GetAutoscalingPolicyRequest proto.InternalMessageInfo 494 495func (m *GetAutoscalingPolicyRequest) GetName() string { 496 if m != nil { 497 return m.Name 498 } 499 return "" 500} 501 502// A request to update an autoscaling policy. 503type UpdateAutoscalingPolicyRequest struct { 504 // Required. The updated autoscaling policy. 505 Policy *AutoscalingPolicy `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"` 506 XXX_NoUnkeyedLiteral struct{} `json:"-"` 507 XXX_unrecognized []byte `json:"-"` 508 XXX_sizecache int32 `json:"-"` 509} 510 511func (m *UpdateAutoscalingPolicyRequest) Reset() { *m = UpdateAutoscalingPolicyRequest{} } 512func (m *UpdateAutoscalingPolicyRequest) String() string { return proto.CompactTextString(m) } 513func (*UpdateAutoscalingPolicyRequest) ProtoMessage() {} 514func (*UpdateAutoscalingPolicyRequest) Descriptor() ([]byte, []int) { 515 return fileDescriptor_e49a4a9859d08ad9, []int{6} 516} 517 518func (m *UpdateAutoscalingPolicyRequest) XXX_Unmarshal(b []byte) error { 519 return xxx_messageInfo_UpdateAutoscalingPolicyRequest.Unmarshal(m, b) 520} 521func (m *UpdateAutoscalingPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 522 return xxx_messageInfo_UpdateAutoscalingPolicyRequest.Marshal(b, m, deterministic) 523} 524func (m *UpdateAutoscalingPolicyRequest) XXX_Merge(src proto.Message) { 525 xxx_messageInfo_UpdateAutoscalingPolicyRequest.Merge(m, src) 526} 527func (m *UpdateAutoscalingPolicyRequest) XXX_Size() int { 528 return xxx_messageInfo_UpdateAutoscalingPolicyRequest.Size(m) 529} 530func (m *UpdateAutoscalingPolicyRequest) XXX_DiscardUnknown() { 531 xxx_messageInfo_UpdateAutoscalingPolicyRequest.DiscardUnknown(m) 532} 533 534var xxx_messageInfo_UpdateAutoscalingPolicyRequest proto.InternalMessageInfo 535 536func (m *UpdateAutoscalingPolicyRequest) GetPolicy() *AutoscalingPolicy { 537 if m != nil { 538 return m.Policy 539 } 540 return nil 541} 542 543// A request to delete an autoscaling policy. 544// 545// Autoscaling policies in use by one or more clusters will not be deleted. 546type DeleteAutoscalingPolicyRequest struct { 547 // Required. The "resource name" of the autoscaling policy, as described 548 // in https://cloud.google.com/apis/design/resource_names. 549 // 550 // * For `projects.regions.autoscalingPolicies.delete`, the resource name 551 // of the policy has the following format: 552 // `projects/{project_id}/regions/{region}/autoscalingPolicies/{policy_id}` 553 // 554 // * For `projects.locations.autoscalingPolicies.delete`, the resource name 555 // of the policy has the following format: 556 // `projects/{project_id}/locations/{location}/autoscalingPolicies/{policy_id}` 557 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 558 XXX_NoUnkeyedLiteral struct{} `json:"-"` 559 XXX_unrecognized []byte `json:"-"` 560 XXX_sizecache int32 `json:"-"` 561} 562 563func (m *DeleteAutoscalingPolicyRequest) Reset() { *m = DeleteAutoscalingPolicyRequest{} } 564func (m *DeleteAutoscalingPolicyRequest) String() string { return proto.CompactTextString(m) } 565func (*DeleteAutoscalingPolicyRequest) ProtoMessage() {} 566func (*DeleteAutoscalingPolicyRequest) Descriptor() ([]byte, []int) { 567 return fileDescriptor_e49a4a9859d08ad9, []int{7} 568} 569 570func (m *DeleteAutoscalingPolicyRequest) XXX_Unmarshal(b []byte) error { 571 return xxx_messageInfo_DeleteAutoscalingPolicyRequest.Unmarshal(m, b) 572} 573func (m *DeleteAutoscalingPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 574 return xxx_messageInfo_DeleteAutoscalingPolicyRequest.Marshal(b, m, deterministic) 575} 576func (m *DeleteAutoscalingPolicyRequest) XXX_Merge(src proto.Message) { 577 xxx_messageInfo_DeleteAutoscalingPolicyRequest.Merge(m, src) 578} 579func (m *DeleteAutoscalingPolicyRequest) XXX_Size() int { 580 return xxx_messageInfo_DeleteAutoscalingPolicyRequest.Size(m) 581} 582func (m *DeleteAutoscalingPolicyRequest) XXX_DiscardUnknown() { 583 xxx_messageInfo_DeleteAutoscalingPolicyRequest.DiscardUnknown(m) 584} 585 586var xxx_messageInfo_DeleteAutoscalingPolicyRequest proto.InternalMessageInfo 587 588func (m *DeleteAutoscalingPolicyRequest) GetName() string { 589 if m != nil { 590 return m.Name 591 } 592 return "" 593} 594 595// A request to list autoscaling policies in a project. 596type ListAutoscalingPoliciesRequest struct { 597 // Required. The "resource name" of the region or location, as described 598 // in https://cloud.google.com/apis/design/resource_names. 599 // 600 // * For `projects.regions.autoscalingPolicies.list`, the resource name 601 // of the region has the following format: 602 // `projects/{project_id}/regions/{region}` 603 // 604 // * For `projects.locations.autoscalingPolicies.list`, the resource name 605 // of the location has the following format: 606 // `projects/{project_id}/locations/{location}` 607 Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` 608 // Optional. The maximum number of results to return in each response. 609 // Must be less than or equal to 1000. Defaults to 100. 610 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 611 // Optional. The page token, returned by a previous call, to request the 612 // next page of results. 613 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 614 XXX_NoUnkeyedLiteral struct{} `json:"-"` 615 XXX_unrecognized []byte `json:"-"` 616 XXX_sizecache int32 `json:"-"` 617} 618 619func (m *ListAutoscalingPoliciesRequest) Reset() { *m = ListAutoscalingPoliciesRequest{} } 620func (m *ListAutoscalingPoliciesRequest) String() string { return proto.CompactTextString(m) } 621func (*ListAutoscalingPoliciesRequest) ProtoMessage() {} 622func (*ListAutoscalingPoliciesRequest) Descriptor() ([]byte, []int) { 623 return fileDescriptor_e49a4a9859d08ad9, []int{8} 624} 625 626func (m *ListAutoscalingPoliciesRequest) XXX_Unmarshal(b []byte) error { 627 return xxx_messageInfo_ListAutoscalingPoliciesRequest.Unmarshal(m, b) 628} 629func (m *ListAutoscalingPoliciesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 630 return xxx_messageInfo_ListAutoscalingPoliciesRequest.Marshal(b, m, deterministic) 631} 632func (m *ListAutoscalingPoliciesRequest) XXX_Merge(src proto.Message) { 633 xxx_messageInfo_ListAutoscalingPoliciesRequest.Merge(m, src) 634} 635func (m *ListAutoscalingPoliciesRequest) XXX_Size() int { 636 return xxx_messageInfo_ListAutoscalingPoliciesRequest.Size(m) 637} 638func (m *ListAutoscalingPoliciesRequest) XXX_DiscardUnknown() { 639 xxx_messageInfo_ListAutoscalingPoliciesRequest.DiscardUnknown(m) 640} 641 642var xxx_messageInfo_ListAutoscalingPoliciesRequest proto.InternalMessageInfo 643 644func (m *ListAutoscalingPoliciesRequest) GetParent() string { 645 if m != nil { 646 return m.Parent 647 } 648 return "" 649} 650 651func (m *ListAutoscalingPoliciesRequest) GetPageSize() int32 { 652 if m != nil { 653 return m.PageSize 654 } 655 return 0 656} 657 658func (m *ListAutoscalingPoliciesRequest) GetPageToken() string { 659 if m != nil { 660 return m.PageToken 661 } 662 return "" 663} 664 665// A response to a request to list autoscaling policies in a project. 666type ListAutoscalingPoliciesResponse struct { 667 // Output only. Autoscaling policies list. 668 Policies []*AutoscalingPolicy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"` 669 // Output only. This token is included in the response if there are more 670 // results to fetch. 671 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 672 XXX_NoUnkeyedLiteral struct{} `json:"-"` 673 XXX_unrecognized []byte `json:"-"` 674 XXX_sizecache int32 `json:"-"` 675} 676 677func (m *ListAutoscalingPoliciesResponse) Reset() { *m = ListAutoscalingPoliciesResponse{} } 678func (m *ListAutoscalingPoliciesResponse) String() string { return proto.CompactTextString(m) } 679func (*ListAutoscalingPoliciesResponse) ProtoMessage() {} 680func (*ListAutoscalingPoliciesResponse) Descriptor() ([]byte, []int) { 681 return fileDescriptor_e49a4a9859d08ad9, []int{9} 682} 683 684func (m *ListAutoscalingPoliciesResponse) XXX_Unmarshal(b []byte) error { 685 return xxx_messageInfo_ListAutoscalingPoliciesResponse.Unmarshal(m, b) 686} 687func (m *ListAutoscalingPoliciesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 688 return xxx_messageInfo_ListAutoscalingPoliciesResponse.Marshal(b, m, deterministic) 689} 690func (m *ListAutoscalingPoliciesResponse) XXX_Merge(src proto.Message) { 691 xxx_messageInfo_ListAutoscalingPoliciesResponse.Merge(m, src) 692} 693func (m *ListAutoscalingPoliciesResponse) XXX_Size() int { 694 return xxx_messageInfo_ListAutoscalingPoliciesResponse.Size(m) 695} 696func (m *ListAutoscalingPoliciesResponse) XXX_DiscardUnknown() { 697 xxx_messageInfo_ListAutoscalingPoliciesResponse.DiscardUnknown(m) 698} 699 700var xxx_messageInfo_ListAutoscalingPoliciesResponse proto.InternalMessageInfo 701 702func (m *ListAutoscalingPoliciesResponse) GetPolicies() []*AutoscalingPolicy { 703 if m != nil { 704 return m.Policies 705 } 706 return nil 707} 708 709func (m *ListAutoscalingPoliciesResponse) GetNextPageToken() string { 710 if m != nil { 711 return m.NextPageToken 712 } 713 return "" 714} 715 716func init() { 717 proto.RegisterType((*AutoscalingPolicy)(nil), "google.cloud.dataproc.v1.AutoscalingPolicy") 718 proto.RegisterType((*BasicAutoscalingAlgorithm)(nil), "google.cloud.dataproc.v1.BasicAutoscalingAlgorithm") 719 proto.RegisterType((*BasicYarnAutoscalingConfig)(nil), "google.cloud.dataproc.v1.BasicYarnAutoscalingConfig") 720 proto.RegisterType((*InstanceGroupAutoscalingPolicyConfig)(nil), "google.cloud.dataproc.v1.InstanceGroupAutoscalingPolicyConfig") 721 proto.RegisterType((*CreateAutoscalingPolicyRequest)(nil), "google.cloud.dataproc.v1.CreateAutoscalingPolicyRequest") 722 proto.RegisterType((*GetAutoscalingPolicyRequest)(nil), "google.cloud.dataproc.v1.GetAutoscalingPolicyRequest") 723 proto.RegisterType((*UpdateAutoscalingPolicyRequest)(nil), "google.cloud.dataproc.v1.UpdateAutoscalingPolicyRequest") 724 proto.RegisterType((*DeleteAutoscalingPolicyRequest)(nil), "google.cloud.dataproc.v1.DeleteAutoscalingPolicyRequest") 725 proto.RegisterType((*ListAutoscalingPoliciesRequest)(nil), "google.cloud.dataproc.v1.ListAutoscalingPoliciesRequest") 726 proto.RegisterType((*ListAutoscalingPoliciesResponse)(nil), "google.cloud.dataproc.v1.ListAutoscalingPoliciesResponse") 727} 728 729func init() { 730 proto.RegisterFile("google/cloud/dataproc/v1/autoscaling_policies.proto", fileDescriptor_e49a4a9859d08ad9) 731} 732 733var fileDescriptor_e49a4a9859d08ad9 = []byte{ 734 // 1241 bytes of a gzipped FileDescriptorProto 735 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x57, 0x41, 0x6f, 0xdc, 0x44, 736 0x14, 0x66, 0x9c, 0x34, 0x6a, 0x26, 0x4d, 0xab, 0x8e, 0x80, 0xdd, 0x6e, 0xca, 0x36, 0x32, 0x1c, 737 0x4a, 0x0a, 0x6b, 0xb5, 0xa5, 0x2a, 0x14, 0x28, 0x38, 0x49, 0x9b, 0x56, 0x14, 0x69, 0xe5, 0xb6, 738 0x42, 0xe4, 0x62, 0x4d, 0xec, 0x59, 0x67, 0x5a, 0xdb, 0x63, 0xc6, 0xb3, 0xd9, 0xa6, 0x51, 0x84, 739 0xe8, 0x2f, 0x40, 0x70, 0x40, 0x48, 0x3d, 0x20, 0x71, 0x47, 0xf0, 0x0f, 0x38, 0x70, 0x82, 0x03, 740 0x12, 0xdc, 0x7a, 0xea, 0x01, 0x09, 0xa9, 0xea, 0x2f, 0x80, 0x0b, 0xf2, 0xcc, 0xd8, 0xeb, 0x76, 741 0xd7, 0x6e, 0x36, 0x2a, 0xa7, 0xf5, 0xce, 0x7b, 0xef, 0x7b, 0xef, 0x7d, 0xf3, 0xbd, 0x19, 0x1b, 742 0x9e, 0x0d, 0x18, 0x0b, 0x42, 0x62, 0x79, 0x21, 0xeb, 0xfb, 0x96, 0x8f, 0x05, 0x4e, 0x38, 0xf3, 743 0xac, 0xad, 0xd3, 0x16, 0xee, 0x0b, 0x96, 0x7a, 0x38, 0xa4, 0x71, 0xe0, 0x26, 0x2c, 0xa4, 0x1e, 744 0x25, 0x69, 0x27, 0xe1, 0x4c, 0x30, 0xd4, 0x54, 0x41, 0x1d, 0x19, 0xd4, 0xc9, 0x83, 0x3a, 0x5b, 745 0xa7, 0x5b, 0xc7, 0x35, 0x1c, 0x4e, 0xa8, 0x85, 0xe3, 0x98, 0x09, 0x2c, 0x28, 0x8b, 0x75, 0x5c, 746 0xab, 0x51, 0xb2, 0x7a, 0x21, 0x25, 0xb1, 0xd0, 0x86, 0x13, 0x25, 0x43, 0x8f, 0x92, 0xd0, 0x77, 747 0x37, 0xc8, 0x26, 0xde, 0xa2, 0x8c, 0x6b, 0x87, 0x63, 0x25, 0x07, 0x4e, 0x52, 0xd6, 0xe7, 0x1e, 748 0xd1, 0xa6, 0xb6, 0x36, 0xc9, 0x7f, 0x1b, 0xfd, 0x9e, 0xe5, 0xf7, 0xb9, 0xcc, 0xaa, 0xed, 0x0b, 749 0x4f, 0xdb, 0x49, 0x94, 0x88, 0x6d, 0x65, 0x34, 0xff, 0x9e, 0x86, 0x47, 0xed, 0x61, 0xa3, 0xdd, 750 0xac, 0xcf, 0x6d, 0x74, 0x18, 0x1a, 0xd4, 0x6f, 0x82, 0x45, 0x70, 0x72, 0xd6, 0x31, 0xa8, 0x8f, 751 0x1a, 0x70, 0x3a, 0xc6, 0x11, 0x69, 0x1a, 0xd9, 0xca, 0xf2, 0xd4, 0x43, 0x7b, 0xca, 0x91, 0x0b, 752 0xc8, 0x83, 0x47, 0x36, 0x70, 0x4a, 0x3d, 0x17, 0x87, 0x01, 0xe3, 0x54, 0x6c, 0x46, 0xcd, 0xa9, 753 0x45, 0x70, 0x72, 0xee, 0xcc, 0xd9, 0x4e, 0x15, 0x45, 0x9d, 0xe5, 0x2c, 0xa0, 0x94, 0xd3, 0xce, 754 0x43, 0x33, 0x60, 0xe3, 0xca, 0x0b, 0xce, 0x61, 0x09, 0x59, 0x2c, 0xa3, 0x4d, 0x38, 0x3f, 0x60, 755 0xfc, 0x36, 0xe1, 0xae, 0xc7, 0xe2, 0x1e, 0x0d, 0x9a, 0xd3, 0x32, 0xc5, 0xc5, 0xea, 0x14, 0x57, 756 0xe3, 0x54, 0xe0, 0xd8, 0x23, 0x6b, 0x9c, 0xf5, 0x93, 0x91, 0xf6, 0x56, 0x24, 0x8a, 0xcc, 0xe6, 757 0x1c, 0x52, 0xc8, 0x6a, 0x09, 0xed, 0xc0, 0x46, 0x4a, 0x3c, 0x16, 0xfb, 0x98, 0x6f, 0xbb, 0x4f, 758 0xe6, 0x3c, 0xf0, 0xbc, 0x72, 0x02, 0xe7, 0xa5, 0x22, 0xc7, 0x27, 0xa5, 0xe4, 0x17, 0x7e, 0x07, 759 0x8f, 0xec, 0xdf, 0x00, 0x7c, 0xbd, 0x00, 0x55, 0xa9, 0x70, 0x42, 0xd3, 0x8e, 0xc7, 0x22, 0x6b, 760 0x74, 0x9b, 0xba, 0x09, 0x67, 0xb7, 0x88, 0x27, 0x52, 0x6b, 0x47, 0x3f, 0xed, 0x5a, 0x21, 0xf3, 761 0x94, 0xe4, 0xac, 0x9d, 0xfc, 0x71, 0xb7, 0x2c, 0xe5, 0xae, 0x56, 0xb2, 0xb5, 0x33, 0xa2, 0xef, 762 0xed, 0x5d, 0x74, 0x6d, 0x0c, 0x22, 0x27, 0x81, 0xc2, 0x53, 0x0f, 0x7b, 0x47, 0x5b, 0x9e, 0x83, 763 0xb3, 0x85, 0x2e, 0xcc, 0x9f, 0x01, 0x3c, 0x56, 0xb9, 0xf5, 0x68, 0x1d, 0xce, 0x6d, 0x63, 0x1e, 764 0xe7, 0x6c, 0x03, 0xc9, 0xf6, 0x5b, 0xcf, 0x10, 0xd1, 0xa7, 0x98, 0xc7, 0x25, 0xb4, 0xf2, 0xbe, 765 0xc2, 0x0c, 0x4d, 0xef, 0xea, 0x1a, 0x3c, 0xe2, 0x31, 0x16, 0xfa, 0x6c, 0x10, 0xbb, 0x09, 0xe1, 766 0x94, 0xf9, 0x52, 0xc8, 0x73, 0x67, 0x8e, 0xe5, 0xf8, 0xf9, 0x68, 0x74, 0x56, 0xf5, 0xe8, 0xa8, 767 0x8d, 0x3a, 0x9c, 0x87, 0x75, 0x65, 0x94, 0xf9, 0xd8, 0x80, 0xad, 0xea, 0xc4, 0x68, 0x03, 0xbe, 768 0x12, 0x70, 0xec, 0x91, 0x5e, 0x3f, 0x74, 0x7d, 0xe2, 0xb1, 0x28, 0xa2, 0x69, 0x4a, 0x59, 0xec, 769 0x0a, 0x1a, 0x11, 0xd6, 0x17, 0x5a, 0x43, 0xf5, 0x59, 0x0d, 0x67, 0x21, 0x07, 0x59, 0x2d, 0x61, 770 0xdc, 0x50, 0x10, 0xe8, 0x14, 0x3c, 0x92, 0x25, 0x25, 0x6e, 0x3f, 0x71, 0x7b, 0xd8, 0x13, 0x8c, 771 0x4b, 0xae, 0x80, 0x0a, 0x9d, 0x97, 0xb6, 0x9b, 0xc9, 0x65, 0x69, 0x41, 0x16, 0x3c, 0xaa, 0x9c, 772 0x65, 0xeb, 0xda, 0xdd, 0x18, 0xba, 0x2b, 0xa8, 0x55, 0x36, 0x88, 0x75, 0xc0, 0x0a, 0x3c, 0x5e, 773 0xa0, 0x47, 0x34, 0xce, 0x47, 0xa0, 0xc7, 0xb1, 0x97, 0xd5, 0x27, 0x67, 0x1b, 0x28, 0x6e, 0x9a, 774 0x3a, 0xd5, 0xc7, 0x34, 0x56, 0x2a, 0xbe, 0xac, 0x9d, 0xd0, 0x1a, 0x6c, 0x97, 0xb2, 0x8e, 0x83, 775 0x99, 0x1e, 0xc2, 0xb4, 0x8a, 0x12, 0x46, 0x80, 0xcc, 0x6f, 0x00, 0x7c, 0x6d, 0x2f, 0x53, 0x85, 776 0x4e, 0xc2, 0xf9, 0x2c, 0x0d, 0xd5, 0xbe, 0xa9, 0xa4, 0xe4, 0x80, 0x4a, 0x70, 0x28, 0xa2, 0x71, 777 0x0e, 0x92, 0x4a, 0x4f, 0x7c, 0xa7, 0xe4, 0x69, 0xe4, 0x9e, 0x86, 0x73, 0x28, 0xc2, 0x77, 0x86, 778 0x9e, 0x0b, 0x70, 0x66, 0x40, 0x68, 0xb0, 0x29, 0x64, 0xd3, 0x1a, 0x4c, 0x2f, 0x99, 0x3f, 0x02, 779 0xd8, 0x5e, 0xe1, 0x04, 0x0b, 0x32, 0x52, 0x92, 0x43, 0x3e, 0xeb, 0x93, 0x54, 0xa0, 0xab, 0x70, 780 0x26, 0xc1, 0x9c, 0xc4, 0x42, 0x1d, 0xa3, 0xcb, 0xa7, 0x1f, 0xda, 0xc6, 0x3f, 0xf6, 0x29, 0xb4, 781 0xf7, 0xf1, 0x76, 0x34, 0x00, 0x5a, 0x81, 0x33, 0x6a, 0xa2, 0xb4, 0x6c, 0x4f, 0x55, 0x8f, 0xc5, 782 0x38, 0x10, 0xf9, 0x6b, 0xfa, 0x70, 0x61, 0x8d, 0x88, 0xca, 0x72, 0x2f, 0xe9, 0x13, 0xfe, 0x89, 783 0x62, 0x27, 0x38, 0x8b, 0xd4, 0x7d, 0x60, 0xde, 0x82, 0xed, 0x9b, 0x89, 0x5f, 0xc7, 0xcb, 0x95, 784 0xa2, 0x19, 0x30, 0x71, 0x33, 0x6a, 0x9f, 0xf2, 0x8e, 0x02, 0xd8, 0x5e, 0x25, 0x21, 0xa9, 0xc9, 785 0xf5, 0x9c, 0x9a, 0xfa, 0x09, 0xc0, 0xf6, 0x35, 0x9a, 0x8e, 0x90, 0x47, 0x49, 0xfa, 0x3f, 0xec, 786 0xf6, 0x22, 0x9c, 0x4d, 0x70, 0x40, 0xdc, 0x94, 0xde, 0x25, 0x43, 0x79, 0x02, 0xe7, 0x60, 0xb6, 787 0x7a, 0x9d, 0xde, 0x25, 0xc8, 0x84, 0x50, 0x7a, 0x08, 0x76, 0x9b, 0xa8, 0x99, 0x9c, 0x55, 0x2e, 788 0x32, 0xf0, 0x46, 0xb6, 0x6a, 0xde, 0x07, 0xf0, 0x44, 0x65, 0xcd, 0x69, 0xc2, 0xe2, 0x94, 0xa0, 789 0x6b, 0xf0, 0x60, 0xfe, 0x5e, 0xd3, 0x04, 0x8b, 0x53, 0xfb, 0xd8, 0x8c, 0x29, 0xa7, 0x40, 0xc8, 790 0x4e, 0xa6, 0x98, 0xdc, 0x11, 0x6e, 0xa9, 0xb4, 0xd2, 0xeb, 0xc2, 0x7c, 0x66, 0xeb, 0xe6, 0xe5, 791 0x9d, 0xf9, 0x61, 0x0e, 0x36, 0x47, 0x10, 0xaf, 0x13, 0xbe, 0x45, 0x3d, 0x82, 0xee, 0x1b, 0xb0, 792 0x51, 0x31, 0x5d, 0xe8, 0xed, 0xea, 0x0a, 0xeb, 0x07, 0xb2, 0x35, 0x49, 0x6f, 0xe6, 0xb7, 0xe0, 793 0x81, 0x3d, 0xaf, 0x36, 0xe4, 0x0d, 0x25, 0xb7, 0x7b, 0x7f, 0xfe, 0xf5, 0xb5, 0x71, 0x0f, 0x98, 794 0xe7, 0xb3, 0x57, 0xc3, 0x1d, 0x65, 0x7a, 0xbf, 0xb8, 0x2d, 0x97, 0x4a, 0xf7, 0xee, 0xd2, 0xd8, 795 0x1b, 0xf2, 0x82, 0x96, 0xed, 0xfa, 0x07, 0xe6, 0xb9, 0x0a, 0x88, 0xfc, 0xa2, 0xad, 0x07, 0x40, 796 0xdf, 0x1b, 0xb0, 0x51, 0x31, 0x64, 0x75, 0xf4, 0xd4, 0xcf, 0xe5, 0x64, 0xf4, 0x7c, 0x07, 0x1e, 797 0xd8, 0x33, 0x25, 0x5e, 0xbe, 0x04, 0xad, 0x8b, 0xaa, 0x29, 0xb9, 0xd6, 0xc9, 0xc6, 0xa6, 0x82, 798 0x9c, 0xb1, 0x6f, 0x0f, 0x4b, 0xbb, 0x05, 0x3d, 0x97, 0x5b, 0xef, 0xd5, 0x21, 0x15, 0x1c, 0x3d, 799 0x03, 0x07, 0xfd, 0x0b, 0xe0, 0x8b, 0xe3, 0x0e, 0x3c, 0x74, 0xae, 0xba, 0xd1, 0x9a, 0x03, 0x72, 800 0x32, 0x7e, 0x3e, 0x7f, 0x60, 0xcb, 0xa3, 0x43, 0x92, 0xc3, 0x91, 0xd2, 0xcc, 0xe4, 0xa4, 0xac, 801 0x9f, 0x47, 0xe7, 0xc6, 0x86, 0x3e, 0x8b, 0x05, 0xf4, 0x95, 0x01, 0x1b, 0x15, 0xe3, 0x5f, 0xa7, 802 0x91, 0xfa, 0x53, 0xae, 0xf5, 0xce, 0x3e, 0x22, 0xd5, 0x59, 0x63, 0x7e, 0x21, 0x15, 0x23, 0x25, 803 0xff, 0x04, 0x29, 0x93, 0x0f, 0x52, 0x41, 0xca, 0xa4, 0x03, 0x84, 0x1e, 0x03, 0xd8, 0xa8, 0xb8, 804 0x31, 0xea, 0x48, 0xa9, 0xbf, 0x64, 0x5a, 0x2f, 0x8f, 0xbc, 0xce, 0x5d, 0xca, 0xbe, 0xaf, 0x9e, 805 0xd2, 0xc0, 0xd2, 0xfe, 0x35, 0xb0, 0xb4, 0x3f, 0x0d, 0xb4, 0x3e, 0xfa, 0xd5, 0x6e, 0x54, 0x5c, 806 0x3f, 0x7f, 0xd8, 0x9d, 0x4d, 0x21, 0x92, 0xf4, 0x82, 0x65, 0x0d, 0x06, 0x83, 0xa7, 0xef, 0x26, 807 0xdc, 0x17, 0x9b, 0xea, 0x7b, 0xf8, 0xcd, 0x24, 0xc4, 0xa2, 0xc7, 0x78, 0xb4, 0xfc, 0x0b, 0x78, 808 0x64, 0x5f, 0x82, 0xed, 0xaa, 0xeb, 0xcc, 0x91, 0xc5, 0xa0, 0x57, 0xf7, 0xf0, 0xf9, 0x00, 0x8f, 809 0x7b, 0x2c, 0xaa, 0x64, 0x7b, 0xb9, 0x39, 0x46, 0x45, 0xdd, 0x8c, 0xd9, 0x2e, 0x58, 0xff, 0x50, 810 0x47, 0x05, 0x2c, 0xc4, 0x71, 0xd0, 0x61, 0x3c, 0xb0, 0x02, 0x12, 0x4b, 0xde, 0xad, 0x61, 0x41, 811 0xa3, 0x9f, 0xf2, 0xef, 0xe6, 0xcf, 0x1b, 0x33, 0xd2, 0xf9, 0xec, 0x7f, 0x01, 0x00, 0x00, 0xff, 812 0xff, 0x36, 0x83, 0xe7, 0x94, 0xf6, 0x0f, 0x00, 0x00, 813} 814 815// Reference imports to suppress errors if they are not otherwise used. 816var _ context.Context 817var _ grpc.ClientConnInterface 818 819// This is a compile-time assertion to ensure that this generated file 820// is compatible with the grpc package it is being compiled against. 821const _ = grpc.SupportPackageIsVersion6 822 823// AutoscalingPolicyServiceClient is the client API for AutoscalingPolicyService service. 824// 825// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 826type AutoscalingPolicyServiceClient interface { 827 // Creates new autoscaling policy. 828 CreateAutoscalingPolicy(ctx context.Context, in *CreateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) 829 // Updates (replaces) autoscaling policy. 830 // 831 // Disabled check for update_mask, because all updates will be full 832 // replacements. 833 UpdateAutoscalingPolicy(ctx context.Context, in *UpdateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) 834 // Retrieves autoscaling policy. 835 GetAutoscalingPolicy(ctx context.Context, in *GetAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) 836 // Lists autoscaling policies in the project. 837 ListAutoscalingPolicies(ctx context.Context, in *ListAutoscalingPoliciesRequest, opts ...grpc.CallOption) (*ListAutoscalingPoliciesResponse, error) 838 // Deletes an autoscaling policy. It is an error to delete an autoscaling 839 // policy that is in use by one or more clusters. 840 DeleteAutoscalingPolicy(ctx context.Context, in *DeleteAutoscalingPolicyRequest, opts ...grpc.CallOption) (*empty.Empty, error) 841} 842 843type autoscalingPolicyServiceClient struct { 844 cc grpc.ClientConnInterface 845} 846 847func NewAutoscalingPolicyServiceClient(cc grpc.ClientConnInterface) AutoscalingPolicyServiceClient { 848 return &autoscalingPolicyServiceClient{cc} 849} 850 851func (c *autoscalingPolicyServiceClient) CreateAutoscalingPolicy(ctx context.Context, in *CreateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) { 852 out := new(AutoscalingPolicy) 853 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.AutoscalingPolicyService/CreateAutoscalingPolicy", in, out, opts...) 854 if err != nil { 855 return nil, err 856 } 857 return out, nil 858} 859 860func (c *autoscalingPolicyServiceClient) UpdateAutoscalingPolicy(ctx context.Context, in *UpdateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) { 861 out := new(AutoscalingPolicy) 862 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.AutoscalingPolicyService/UpdateAutoscalingPolicy", in, out, opts...) 863 if err != nil { 864 return nil, err 865 } 866 return out, nil 867} 868 869func (c *autoscalingPolicyServiceClient) GetAutoscalingPolicy(ctx context.Context, in *GetAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error) { 870 out := new(AutoscalingPolicy) 871 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.AutoscalingPolicyService/GetAutoscalingPolicy", in, out, opts...) 872 if err != nil { 873 return nil, err 874 } 875 return out, nil 876} 877 878func (c *autoscalingPolicyServiceClient) ListAutoscalingPolicies(ctx context.Context, in *ListAutoscalingPoliciesRequest, opts ...grpc.CallOption) (*ListAutoscalingPoliciesResponse, error) { 879 out := new(ListAutoscalingPoliciesResponse) 880 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.AutoscalingPolicyService/ListAutoscalingPolicies", in, out, opts...) 881 if err != nil { 882 return nil, err 883 } 884 return out, nil 885} 886 887func (c *autoscalingPolicyServiceClient) DeleteAutoscalingPolicy(ctx context.Context, in *DeleteAutoscalingPolicyRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 888 out := new(empty.Empty) 889 err := c.cc.Invoke(ctx, "/google.cloud.dataproc.v1.AutoscalingPolicyService/DeleteAutoscalingPolicy", in, out, opts...) 890 if err != nil { 891 return nil, err 892 } 893 return out, nil 894} 895 896// AutoscalingPolicyServiceServer is the server API for AutoscalingPolicyService service. 897type AutoscalingPolicyServiceServer interface { 898 // Creates new autoscaling policy. 899 CreateAutoscalingPolicy(context.Context, *CreateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) 900 // Updates (replaces) autoscaling policy. 901 // 902 // Disabled check for update_mask, because all updates will be full 903 // replacements. 904 UpdateAutoscalingPolicy(context.Context, *UpdateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) 905 // Retrieves autoscaling policy. 906 GetAutoscalingPolicy(context.Context, *GetAutoscalingPolicyRequest) (*AutoscalingPolicy, error) 907 // Lists autoscaling policies in the project. 908 ListAutoscalingPolicies(context.Context, *ListAutoscalingPoliciesRequest) (*ListAutoscalingPoliciesResponse, error) 909 // Deletes an autoscaling policy. It is an error to delete an autoscaling 910 // policy that is in use by one or more clusters. 911 DeleteAutoscalingPolicy(context.Context, *DeleteAutoscalingPolicyRequest) (*empty.Empty, error) 912} 913 914// UnimplementedAutoscalingPolicyServiceServer can be embedded to have forward compatible implementations. 915type UnimplementedAutoscalingPolicyServiceServer struct { 916} 917 918func (*UnimplementedAutoscalingPolicyServiceServer) CreateAutoscalingPolicy(ctx context.Context, req *CreateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) { 919 return nil, status.Errorf(codes.Unimplemented, "method CreateAutoscalingPolicy not implemented") 920} 921func (*UnimplementedAutoscalingPolicyServiceServer) UpdateAutoscalingPolicy(ctx context.Context, req *UpdateAutoscalingPolicyRequest) (*AutoscalingPolicy, error) { 922 return nil, status.Errorf(codes.Unimplemented, "method UpdateAutoscalingPolicy not implemented") 923} 924func (*UnimplementedAutoscalingPolicyServiceServer) GetAutoscalingPolicy(ctx context.Context, req *GetAutoscalingPolicyRequest) (*AutoscalingPolicy, error) { 925 return nil, status.Errorf(codes.Unimplemented, "method GetAutoscalingPolicy not implemented") 926} 927func (*UnimplementedAutoscalingPolicyServiceServer) ListAutoscalingPolicies(ctx context.Context, req *ListAutoscalingPoliciesRequest) (*ListAutoscalingPoliciesResponse, error) { 928 return nil, status.Errorf(codes.Unimplemented, "method ListAutoscalingPolicies not implemented") 929} 930func (*UnimplementedAutoscalingPolicyServiceServer) DeleteAutoscalingPolicy(ctx context.Context, req *DeleteAutoscalingPolicyRequest) (*empty.Empty, error) { 931 return nil, status.Errorf(codes.Unimplemented, "method DeleteAutoscalingPolicy not implemented") 932} 933 934func RegisterAutoscalingPolicyServiceServer(s *grpc.Server, srv AutoscalingPolicyServiceServer) { 935 s.RegisterService(&_AutoscalingPolicyService_serviceDesc, srv) 936} 937 938func _AutoscalingPolicyService_CreateAutoscalingPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 939 in := new(CreateAutoscalingPolicyRequest) 940 if err := dec(in); err != nil { 941 return nil, err 942 } 943 if interceptor == nil { 944 return srv.(AutoscalingPolicyServiceServer).CreateAutoscalingPolicy(ctx, in) 945 } 946 info := &grpc.UnaryServerInfo{ 947 Server: srv, 948 FullMethod: "/google.cloud.dataproc.v1.AutoscalingPolicyService/CreateAutoscalingPolicy", 949 } 950 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 951 return srv.(AutoscalingPolicyServiceServer).CreateAutoscalingPolicy(ctx, req.(*CreateAutoscalingPolicyRequest)) 952 } 953 return interceptor(ctx, in, info, handler) 954} 955 956func _AutoscalingPolicyService_UpdateAutoscalingPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 957 in := new(UpdateAutoscalingPolicyRequest) 958 if err := dec(in); err != nil { 959 return nil, err 960 } 961 if interceptor == nil { 962 return srv.(AutoscalingPolicyServiceServer).UpdateAutoscalingPolicy(ctx, in) 963 } 964 info := &grpc.UnaryServerInfo{ 965 Server: srv, 966 FullMethod: "/google.cloud.dataproc.v1.AutoscalingPolicyService/UpdateAutoscalingPolicy", 967 } 968 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 969 return srv.(AutoscalingPolicyServiceServer).UpdateAutoscalingPolicy(ctx, req.(*UpdateAutoscalingPolicyRequest)) 970 } 971 return interceptor(ctx, in, info, handler) 972} 973 974func _AutoscalingPolicyService_GetAutoscalingPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 975 in := new(GetAutoscalingPolicyRequest) 976 if err := dec(in); err != nil { 977 return nil, err 978 } 979 if interceptor == nil { 980 return srv.(AutoscalingPolicyServiceServer).GetAutoscalingPolicy(ctx, in) 981 } 982 info := &grpc.UnaryServerInfo{ 983 Server: srv, 984 FullMethod: "/google.cloud.dataproc.v1.AutoscalingPolicyService/GetAutoscalingPolicy", 985 } 986 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 987 return srv.(AutoscalingPolicyServiceServer).GetAutoscalingPolicy(ctx, req.(*GetAutoscalingPolicyRequest)) 988 } 989 return interceptor(ctx, in, info, handler) 990} 991 992func _AutoscalingPolicyService_ListAutoscalingPolicies_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 993 in := new(ListAutoscalingPoliciesRequest) 994 if err := dec(in); err != nil { 995 return nil, err 996 } 997 if interceptor == nil { 998 return srv.(AutoscalingPolicyServiceServer).ListAutoscalingPolicies(ctx, in) 999 } 1000 info := &grpc.UnaryServerInfo{ 1001 Server: srv, 1002 FullMethod: "/google.cloud.dataproc.v1.AutoscalingPolicyService/ListAutoscalingPolicies", 1003 } 1004 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1005 return srv.(AutoscalingPolicyServiceServer).ListAutoscalingPolicies(ctx, req.(*ListAutoscalingPoliciesRequest)) 1006 } 1007 return interceptor(ctx, in, info, handler) 1008} 1009 1010func _AutoscalingPolicyService_DeleteAutoscalingPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1011 in := new(DeleteAutoscalingPolicyRequest) 1012 if err := dec(in); err != nil { 1013 return nil, err 1014 } 1015 if interceptor == nil { 1016 return srv.(AutoscalingPolicyServiceServer).DeleteAutoscalingPolicy(ctx, in) 1017 } 1018 info := &grpc.UnaryServerInfo{ 1019 Server: srv, 1020 FullMethod: "/google.cloud.dataproc.v1.AutoscalingPolicyService/DeleteAutoscalingPolicy", 1021 } 1022 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1023 return srv.(AutoscalingPolicyServiceServer).DeleteAutoscalingPolicy(ctx, req.(*DeleteAutoscalingPolicyRequest)) 1024 } 1025 return interceptor(ctx, in, info, handler) 1026} 1027 1028var _AutoscalingPolicyService_serviceDesc = grpc.ServiceDesc{ 1029 ServiceName: "google.cloud.dataproc.v1.AutoscalingPolicyService", 1030 HandlerType: (*AutoscalingPolicyServiceServer)(nil), 1031 Methods: []grpc.MethodDesc{ 1032 { 1033 MethodName: "CreateAutoscalingPolicy", 1034 Handler: _AutoscalingPolicyService_CreateAutoscalingPolicy_Handler, 1035 }, 1036 { 1037 MethodName: "UpdateAutoscalingPolicy", 1038 Handler: _AutoscalingPolicyService_UpdateAutoscalingPolicy_Handler, 1039 }, 1040 { 1041 MethodName: "GetAutoscalingPolicy", 1042 Handler: _AutoscalingPolicyService_GetAutoscalingPolicy_Handler, 1043 }, 1044 { 1045 MethodName: "ListAutoscalingPolicies", 1046 Handler: _AutoscalingPolicyService_ListAutoscalingPolicies_Handler, 1047 }, 1048 { 1049 MethodName: "DeleteAutoscalingPolicy", 1050 Handler: _AutoscalingPolicyService_DeleteAutoscalingPolicy_Handler, 1051 }, 1052 }, 1053 Streams: []grpc.StreamDesc{}, 1054 Metadata: "google/cloud/dataproc/v1/autoscaling_policies.proto", 1055} 1056