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