Source file src/google.golang.org/genproto/googleapis/cloud/dataproc/logging/autoscaler_log.pb.go

Documentation: google.golang.org/genproto/googleapis/cloud/dataproc/logging

     1  // Copyright 2020 Google LLC
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.26.0
    18  // 	protoc        v3.12.2
    19  // source: google/cloud/dataproc/logging/autoscaler_log.proto
    20  
    21  package logging
    22  
    23  import (
    24  	reflect "reflect"
    25  	sync "sync"
    26  
    27  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    28  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    29  	durationpb "google.golang.org/protobuf/types/known/durationpb"
    30  )
    31  
    32  const (
    33  	// Verify that this generated code is sufficiently up-to-date.
    34  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    35  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    36  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    37  )
    38  
    39  // The Autoscaler state.
    40  type AutoscalerState int32
    41  
    42  const (
    43  	AutoscalerState_AUTOSCALER_STATE_UNSPECIFIED AutoscalerState = 0
    44  	// The Autoscaler is sleeping and waiting for the next update.
    45  	AutoscalerState_COOLDOWN AutoscalerState = 1
    46  	// The Autoscaler is in the process of calculating its recommendation on
    47  	// whether to scale the cluster, and if so, how to autoscale.
    48  	AutoscalerState_RECOMMENDING AutoscalerState = 6
    49  	// The Autoscaler is scaling the cluster.
    50  	AutoscalerState_SCALING AutoscalerState = 2
    51  	// The Autoscaler has stopped.
    52  	AutoscalerState_STOPPED AutoscalerState = 3
    53  	// The Autoscaler has failed.
    54  	AutoscalerState_FAILED AutoscalerState = 4
    55  	// The Autoscaler is initializing.
    56  	AutoscalerState_INITIALIZING AutoscalerState = 5
    57  )
    58  
    59  // Enum value maps for AutoscalerState.
    60  var (
    61  	AutoscalerState_name = map[int32]string{
    62  		0: "AUTOSCALER_STATE_UNSPECIFIED",
    63  		1: "COOLDOWN",
    64  		6: "RECOMMENDING",
    65  		2: "SCALING",
    66  		3: "STOPPED",
    67  		4: "FAILED",
    68  		5: "INITIALIZING",
    69  	}
    70  	AutoscalerState_value = map[string]int32{
    71  		"AUTOSCALER_STATE_UNSPECIFIED": 0,
    72  		"COOLDOWN":                     1,
    73  		"RECOMMENDING":                 6,
    74  		"SCALING":                      2,
    75  		"STOPPED":                      3,
    76  		"FAILED":                       4,
    77  		"INITIALIZING":                 5,
    78  	}
    79  )
    80  
    81  func (x AutoscalerState) Enum() *AutoscalerState {
    82  	p := new(AutoscalerState)
    83  	*p = x
    84  	return p
    85  }
    86  
    87  func (x AutoscalerState) String() string {
    88  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    89  }
    90  
    91  func (AutoscalerState) Descriptor() protoreflect.EnumDescriptor {
    92  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[0].Descriptor()
    93  }
    94  
    95  func (AutoscalerState) Type() protoreflect.EnumType {
    96  	return &file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[0]
    97  }
    98  
    99  func (x AutoscalerState) Number() protoreflect.EnumNumber {
   100  	return protoreflect.EnumNumber(x)
   101  }
   102  
   103  // Deprecated: Use AutoscalerState.Descriptor instead.
   104  func (AutoscalerState) EnumDescriptor() ([]byte, []int) {
   105  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{0}
   106  }
   107  
   108  // The Autoscaling decision type.
   109  type ScalingDecisionType int32
   110  
   111  const (
   112  	ScalingDecisionType_SCALING_DECISION_TYPE_UNSPECIFIED ScalingDecisionType = 0
   113  	// Increase the number of primary and/or secondary workers.
   114  	ScalingDecisionType_SCALE_UP ScalingDecisionType = 1
   115  	// Decrease the number of primary and/or secondary workers.
   116  	ScalingDecisionType_SCALE_DOWN ScalingDecisionType = 2
   117  	// Not changing the number of primary or secondary workers.
   118  	ScalingDecisionType_NO_SCALE ScalingDecisionType = 3
   119  	// Scale the primary and secondary worker groups in different directions.
   120  	ScalingDecisionType_MIXED ScalingDecisionType = 4
   121  )
   122  
   123  // Enum value maps for ScalingDecisionType.
   124  var (
   125  	ScalingDecisionType_name = map[int32]string{
   126  		0: "SCALING_DECISION_TYPE_UNSPECIFIED",
   127  		1: "SCALE_UP",
   128  		2: "SCALE_DOWN",
   129  		3: "NO_SCALE",
   130  		4: "MIXED",
   131  	}
   132  	ScalingDecisionType_value = map[string]int32{
   133  		"SCALING_DECISION_TYPE_UNSPECIFIED": 0,
   134  		"SCALE_UP":                          1,
   135  		"SCALE_DOWN":                        2,
   136  		"NO_SCALE":                          3,
   137  		"MIXED":                             4,
   138  	}
   139  )
   140  
   141  func (x ScalingDecisionType) Enum() *ScalingDecisionType {
   142  	p := new(ScalingDecisionType)
   143  	*p = x
   144  	return p
   145  }
   146  
   147  func (x ScalingDecisionType) String() string {
   148  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   149  }
   150  
   151  func (ScalingDecisionType) Descriptor() protoreflect.EnumDescriptor {
   152  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[1].Descriptor()
   153  }
   154  
   155  func (ScalingDecisionType) Type() protoreflect.EnumType {
   156  	return &file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[1]
   157  }
   158  
   159  func (x ScalingDecisionType) Number() protoreflect.EnumNumber {
   160  	return protoreflect.EnumNumber(x)
   161  }
   162  
   163  // Deprecated: Use ScalingDecisionType.Descriptor instead.
   164  func (ScalingDecisionType) EnumDescriptor() ([]byte, []int) {
   165  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{1}
   166  }
   167  
   168  type ConstrainingFactor int32
   169  
   170  const (
   171  	ConstrainingFactor_CONSTRAINING_FACTOR_UNSPECIFIED ConstrainingFactor = 0
   172  	// The project does not have sufficient regional, global, and or preemptible
   173  	// quota to allocate a new VM.
   174  	ConstrainingFactor_SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA ConstrainingFactor = 1
   175  	// All worker groups have reached maximum size. This message will not be
   176  	// issued if one group reached maximum size, but workers were able to be
   177  	// allocated to another group.
   178  	ConstrainingFactor_REACHED_MAXIMUM_CLUSTER_SIZE ConstrainingFactor = 2
   179  	// All worker groups have reached minimum size. This message will not be
   180  	// issued if workers were able to be removed from another group that had not
   181  	// reached minimum size.
   182  	ConstrainingFactor_REACHED_MINIMUM_CLUSTER_SIZE ConstrainingFactor = 3
   183  )
   184  
   185  // Enum value maps for ConstrainingFactor.
   186  var (
   187  	ConstrainingFactor_name = map[int32]string{
   188  		0: "CONSTRAINING_FACTOR_UNSPECIFIED",
   189  		1: "SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA",
   190  		2: "REACHED_MAXIMUM_CLUSTER_SIZE",
   191  		3: "REACHED_MINIMUM_CLUSTER_SIZE",
   192  	}
   193  	ConstrainingFactor_value = map[string]int32{
   194  		"CONSTRAINING_FACTOR_UNSPECIFIED":     0,
   195  		"SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA": 1,
   196  		"REACHED_MAXIMUM_CLUSTER_SIZE":        2,
   197  		"REACHED_MINIMUM_CLUSTER_SIZE":        3,
   198  	}
   199  )
   200  
   201  func (x ConstrainingFactor) Enum() *ConstrainingFactor {
   202  	p := new(ConstrainingFactor)
   203  	*p = x
   204  	return p
   205  }
   206  
   207  func (x ConstrainingFactor) String() string {
   208  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   209  }
   210  
   211  func (ConstrainingFactor) Descriptor() protoreflect.EnumDescriptor {
   212  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[2].Descriptor()
   213  }
   214  
   215  func (ConstrainingFactor) Type() protoreflect.EnumType {
   216  	return &file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes[2]
   217  }
   218  
   219  func (x ConstrainingFactor) Number() protoreflect.EnumNumber {
   220  	return protoreflect.EnumNumber(x)
   221  }
   222  
   223  // Deprecated: Use ConstrainingFactor.Descriptor instead.
   224  func (ConstrainingFactor) EnumDescriptor() ([]byte, []int) {
   225  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{2}
   226  }
   227  
   228  // The short version of cluster configuration for Cloud logging.
   229  type ClusterSize struct {
   230  	state         protoimpl.MessageState
   231  	sizeCache     protoimpl.SizeCache
   232  	unknownFields protoimpl.UnknownFields
   233  
   234  	// The number of primary workers in the cluster.
   235  	PrimaryWorkerCount int32 `protobuf:"varint,1,opt,name=primary_worker_count,json=primaryWorkerCount,proto3" json:"primary_worker_count,omitempty"`
   236  	// The number of secondary workers in the cluster.
   237  	SecondaryWorkerCount int32 `protobuf:"varint,2,opt,name=secondary_worker_count,json=secondaryWorkerCount,proto3" json:"secondary_worker_count,omitempty"`
   238  }
   239  
   240  func (x *ClusterSize) Reset() {
   241  	*x = ClusterSize{}
   242  	if protoimpl.UnsafeEnabled {
   243  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[0]
   244  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   245  		ms.StoreMessageInfo(mi)
   246  	}
   247  }
   248  
   249  func (x *ClusterSize) String() string {
   250  	return protoimpl.X.MessageStringOf(x)
   251  }
   252  
   253  func (*ClusterSize) ProtoMessage() {}
   254  
   255  func (x *ClusterSize) ProtoReflect() protoreflect.Message {
   256  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[0]
   257  	if protoimpl.UnsafeEnabled && x != nil {
   258  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   259  		if ms.LoadMessageInfo() == nil {
   260  			ms.StoreMessageInfo(mi)
   261  		}
   262  		return ms
   263  	}
   264  	return mi.MessageOf(x)
   265  }
   266  
   267  // Deprecated: Use ClusterSize.ProtoReflect.Descriptor instead.
   268  func (*ClusterSize) Descriptor() ([]byte, []int) {
   269  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{0}
   270  }
   271  
   272  func (x *ClusterSize) GetPrimaryWorkerCount() int32 {
   273  	if x != nil {
   274  		return x.PrimaryWorkerCount
   275  	}
   276  	return 0
   277  }
   278  
   279  func (x *ClusterSize) GetSecondaryWorkerCount() int32 {
   280  	if x != nil {
   281  		return x.SecondaryWorkerCount
   282  	}
   283  	return 0
   284  }
   285  
   286  // The main proto that will be converted to JSON format and then written to
   287  // Logging.
   288  type AutoscalerLog struct {
   289  	state         protoimpl.MessageState
   290  	sizeCache     protoimpl.SizeCache
   291  	unknownFields protoimpl.UnknownFields
   292  
   293  	// The current Autoscaler status.
   294  	Status *AutoscalerStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
   295  	// Optional. The autoscaling recommendation including its inputs, outputs,
   296  	// scaling decision, and detailed explanation.
   297  	Recommendation *AutoscalerRecommendation `protobuf:"bytes,2,opt,name=recommendation,proto3" json:"recommendation,omitempty"`
   298  }
   299  
   300  func (x *AutoscalerLog) Reset() {
   301  	*x = AutoscalerLog{}
   302  	if protoimpl.UnsafeEnabled {
   303  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[1]
   304  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   305  		ms.StoreMessageInfo(mi)
   306  	}
   307  }
   308  
   309  func (x *AutoscalerLog) String() string {
   310  	return protoimpl.X.MessageStringOf(x)
   311  }
   312  
   313  func (*AutoscalerLog) ProtoMessage() {}
   314  
   315  func (x *AutoscalerLog) ProtoReflect() protoreflect.Message {
   316  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[1]
   317  	if protoimpl.UnsafeEnabled && x != nil {
   318  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   319  		if ms.LoadMessageInfo() == nil {
   320  			ms.StoreMessageInfo(mi)
   321  		}
   322  		return ms
   323  	}
   324  	return mi.MessageOf(x)
   325  }
   326  
   327  // Deprecated: Use AutoscalerLog.ProtoReflect.Descriptor instead.
   328  func (*AutoscalerLog) Descriptor() ([]byte, []int) {
   329  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{1}
   330  }
   331  
   332  func (x *AutoscalerLog) GetStatus() *AutoscalerStatus {
   333  	if x != nil {
   334  		return x.Status
   335  	}
   336  	return nil
   337  }
   338  
   339  func (x *AutoscalerLog) GetRecommendation() *AutoscalerRecommendation {
   340  	if x != nil {
   341  		return x.Recommendation
   342  	}
   343  	return nil
   344  }
   345  
   346  // The Autoscaler's status, including its state and other details.
   347  type AutoscalerStatus struct {
   348  	state         protoimpl.MessageState
   349  	sizeCache     protoimpl.SizeCache
   350  	unknownFields protoimpl.UnknownFields
   351  
   352  	// The high-level Autoscaler state.
   353  	State AutoscalerState `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.logging.AutoscalerState" json:"state,omitempty"`
   354  	// The detailed description of Autoscaler status.
   355  	Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
   356  	// The cluster update operation ID.
   357  	UpdateClusterOperationId string `protobuf:"bytes,3,opt,name=update_cluster_operation_id,json=updateClusterOperationId,proto3" json:"update_cluster_operation_id,omitempty"`
   358  	// Error message from an Autoscaler exception, if any.
   359  	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
   360  }
   361  
   362  func (x *AutoscalerStatus) Reset() {
   363  	*x = AutoscalerStatus{}
   364  	if protoimpl.UnsafeEnabled {
   365  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[2]
   366  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   367  		ms.StoreMessageInfo(mi)
   368  	}
   369  }
   370  
   371  func (x *AutoscalerStatus) String() string {
   372  	return protoimpl.X.MessageStringOf(x)
   373  }
   374  
   375  func (*AutoscalerStatus) ProtoMessage() {}
   376  
   377  func (x *AutoscalerStatus) ProtoReflect() protoreflect.Message {
   378  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[2]
   379  	if protoimpl.UnsafeEnabled && x != nil {
   380  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   381  		if ms.LoadMessageInfo() == nil {
   382  			ms.StoreMessageInfo(mi)
   383  		}
   384  		return ms
   385  	}
   386  	return mi.MessageOf(x)
   387  }
   388  
   389  // Deprecated: Use AutoscalerStatus.ProtoReflect.Descriptor instead.
   390  func (*AutoscalerStatus) Descriptor() ([]byte, []int) {
   391  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{2}
   392  }
   393  
   394  func (x *AutoscalerStatus) GetState() AutoscalerState {
   395  	if x != nil {
   396  		return x.State
   397  	}
   398  	return AutoscalerState_AUTOSCALER_STATE_UNSPECIFIED
   399  }
   400  
   401  func (x *AutoscalerStatus) GetDetails() string {
   402  	if x != nil {
   403  		return x.Details
   404  	}
   405  	return ""
   406  }
   407  
   408  func (x *AutoscalerStatus) GetUpdateClusterOperationId() string {
   409  	if x != nil {
   410  		return x.UpdateClusterOperationId
   411  	}
   412  	return ""
   413  }
   414  
   415  func (x *AutoscalerStatus) GetError() string {
   416  	if x != nil {
   417  		return x.Error
   418  	}
   419  	return ""
   420  }
   421  
   422  // The inputs, outputs, and detailed explanation of the Autoscaling
   423  // recommendation.
   424  type AutoscalerRecommendation struct {
   425  	state         protoimpl.MessageState
   426  	sizeCache     protoimpl.SizeCache
   427  	unknownFields protoimpl.UnknownFields
   428  
   429  	// The autoscaling algorithm inputs.
   430  	Inputs *AutoscalerRecommendation_Inputs `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
   431  	// The algorithm outputs for the recommended cluster size.
   432  	Outputs *AutoscalerRecommendation_Outputs `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
   433  }
   434  
   435  func (x *AutoscalerRecommendation) Reset() {
   436  	*x = AutoscalerRecommendation{}
   437  	if protoimpl.UnsafeEnabled {
   438  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[3]
   439  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   440  		ms.StoreMessageInfo(mi)
   441  	}
   442  }
   443  
   444  func (x *AutoscalerRecommendation) String() string {
   445  	return protoimpl.X.MessageStringOf(x)
   446  }
   447  
   448  func (*AutoscalerRecommendation) ProtoMessage() {}
   449  
   450  func (x *AutoscalerRecommendation) ProtoReflect() protoreflect.Message {
   451  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[3]
   452  	if protoimpl.UnsafeEnabled && x != nil {
   453  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   454  		if ms.LoadMessageInfo() == nil {
   455  			ms.StoreMessageInfo(mi)
   456  		}
   457  		return ms
   458  	}
   459  	return mi.MessageOf(x)
   460  }
   461  
   462  // Deprecated: Use AutoscalerRecommendation.ProtoReflect.Descriptor instead.
   463  func (*AutoscalerRecommendation) Descriptor() ([]byte, []int) {
   464  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{3}
   465  }
   466  
   467  func (x *AutoscalerRecommendation) GetInputs() *AutoscalerRecommendation_Inputs {
   468  	if x != nil {
   469  		return x.Inputs
   470  	}
   471  	return nil
   472  }
   473  
   474  func (x *AutoscalerRecommendation) GetOutputs() *AutoscalerRecommendation_Outputs {
   475  	if x != nil {
   476  		return x.Outputs
   477  	}
   478  	return nil
   479  }
   480  
   481  // The input values for the Autoscaling recommendation alogirthm.
   482  type AutoscalerRecommendation_Inputs struct {
   483  	state         protoimpl.MessageState
   484  	sizeCache     protoimpl.SizeCache
   485  	unknownFields protoimpl.UnknownFields
   486  
   487  	// The metrics collected by the Dataproc agent running on the cluster.
   488  	// For example, {"avg-yarn-pending-memory": "1040 MB"}
   489  	ClusterMetrics map[string]string `protobuf:"bytes,1,rep,name=cluster_metrics,json=clusterMetrics,proto3" json:"cluster_metrics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
   490  	// The cluster configuration before updating the cluster.
   491  	CurrentClusterSize *ClusterSize `protobuf:"bytes,2,opt,name=current_cluster_size,json=currentClusterSize,proto3" json:"current_cluster_size,omitempty"`
   492  	// The minimum worker counts for each instance group.
   493  	MinWorkerCounts *ClusterSize `protobuf:"bytes,3,opt,name=min_worker_counts,json=minWorkerCounts,proto3" json:"min_worker_counts,omitempty"`
   494  	// The maximum worker counts for each instance group.
   495  	MaxWorkerCounts *ClusterSize `protobuf:"bytes,4,opt,name=max_worker_counts,json=maxWorkerCounts,proto3" json:"max_worker_counts,omitempty"`
   496  }
   497  
   498  func (x *AutoscalerRecommendation_Inputs) Reset() {
   499  	*x = AutoscalerRecommendation_Inputs{}
   500  	if protoimpl.UnsafeEnabled {
   501  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[4]
   502  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   503  		ms.StoreMessageInfo(mi)
   504  	}
   505  }
   506  
   507  func (x *AutoscalerRecommendation_Inputs) String() string {
   508  	return protoimpl.X.MessageStringOf(x)
   509  }
   510  
   511  func (*AutoscalerRecommendation_Inputs) ProtoMessage() {}
   512  
   513  func (x *AutoscalerRecommendation_Inputs) ProtoReflect() protoreflect.Message {
   514  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[4]
   515  	if protoimpl.UnsafeEnabled && x != nil {
   516  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   517  		if ms.LoadMessageInfo() == nil {
   518  			ms.StoreMessageInfo(mi)
   519  		}
   520  		return ms
   521  	}
   522  	return mi.MessageOf(x)
   523  }
   524  
   525  // Deprecated: Use AutoscalerRecommendation_Inputs.ProtoReflect.Descriptor instead.
   526  func (*AutoscalerRecommendation_Inputs) Descriptor() ([]byte, []int) {
   527  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{3, 0}
   528  }
   529  
   530  func (x *AutoscalerRecommendation_Inputs) GetClusterMetrics() map[string]string {
   531  	if x != nil {
   532  		return x.ClusterMetrics
   533  	}
   534  	return nil
   535  }
   536  
   537  func (x *AutoscalerRecommendation_Inputs) GetCurrentClusterSize() *ClusterSize {
   538  	if x != nil {
   539  		return x.CurrentClusterSize
   540  	}
   541  	return nil
   542  }
   543  
   544  func (x *AutoscalerRecommendation_Inputs) GetMinWorkerCounts() *ClusterSize {
   545  	if x != nil {
   546  		return x.MinWorkerCounts
   547  	}
   548  	return nil
   549  }
   550  
   551  func (x *AutoscalerRecommendation_Inputs) GetMaxWorkerCounts() *ClusterSize {
   552  	if x != nil {
   553  		return x.MaxWorkerCounts
   554  	}
   555  	return nil
   556  }
   557  
   558  // Autoscaler recommendations.
   559  type AutoscalerRecommendation_Outputs struct {
   560  	state         protoimpl.MessageState
   561  	sizeCache     protoimpl.SizeCache
   562  	unknownFields protoimpl.UnknownFields
   563  
   564  	// The high-level autoscaling decision, such as SCALE_UP, SCALE_DOWN,
   565  	// NO_OP.
   566  	Decision ScalingDecisionType `protobuf:"varint,1,opt,name=decision,proto3,enum=google.cloud.dataproc.logging.ScalingDecisionType" json:"decision,omitempty"`
   567  	// The recommended cluster size.
   568  	RecommendedClusterSize *ClusterSize `protobuf:"bytes,2,opt,name=recommended_cluster_size,json=recommendedClusterSize,proto3" json:"recommended_cluster_size,omitempty"`
   569  	// The graceful decommission timeout for downscaling operations.
   570  	GracefulDecommissionTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"`
   571  	// Reasons why the Autoscaler didn't add or remove more workers.
   572  	ConstraintsReached []ConstrainingFactor `protobuf:"varint,4,rep,packed,name=constraints_reached,json=constraintsReached,proto3,enum=google.cloud.dataproc.logging.ConstrainingFactor" json:"constraints_reached,omitempty"`
   573  	// Less significant recommendations that are not included in the
   574  	// `AutoscalerStatus.details` message.
   575  	AdditionalRecommendationDetails []string `protobuf:"bytes,5,rep,name=additional_recommendation_details,json=additionalRecommendationDetails,proto3" json:"additional_recommendation_details,omitempty"`
   576  	// A unique id for this recommendation that should be included when opening
   577  	// a support ticket.
   578  	RecommendationId string `protobuf:"bytes,6,opt,name=recommendation_id,json=recommendationId,proto3" json:"recommendation_id,omitempty"`
   579  }
   580  
   581  func (x *AutoscalerRecommendation_Outputs) Reset() {
   582  	*x = AutoscalerRecommendation_Outputs{}
   583  	if protoimpl.UnsafeEnabled {
   584  		mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[5]
   585  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   586  		ms.StoreMessageInfo(mi)
   587  	}
   588  }
   589  
   590  func (x *AutoscalerRecommendation_Outputs) String() string {
   591  	return protoimpl.X.MessageStringOf(x)
   592  }
   593  
   594  func (*AutoscalerRecommendation_Outputs) ProtoMessage() {}
   595  
   596  func (x *AutoscalerRecommendation_Outputs) ProtoReflect() protoreflect.Message {
   597  	mi := &file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[5]
   598  	if protoimpl.UnsafeEnabled && x != nil {
   599  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   600  		if ms.LoadMessageInfo() == nil {
   601  			ms.StoreMessageInfo(mi)
   602  		}
   603  		return ms
   604  	}
   605  	return mi.MessageOf(x)
   606  }
   607  
   608  // Deprecated: Use AutoscalerRecommendation_Outputs.ProtoReflect.Descriptor instead.
   609  func (*AutoscalerRecommendation_Outputs) Descriptor() ([]byte, []int) {
   610  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP(), []int{3, 1}
   611  }
   612  
   613  func (x *AutoscalerRecommendation_Outputs) GetDecision() ScalingDecisionType {
   614  	if x != nil {
   615  		return x.Decision
   616  	}
   617  	return ScalingDecisionType_SCALING_DECISION_TYPE_UNSPECIFIED
   618  }
   619  
   620  func (x *AutoscalerRecommendation_Outputs) GetRecommendedClusterSize() *ClusterSize {
   621  	if x != nil {
   622  		return x.RecommendedClusterSize
   623  	}
   624  	return nil
   625  }
   626  
   627  func (x *AutoscalerRecommendation_Outputs) GetGracefulDecommissionTimeout() *durationpb.Duration {
   628  	if x != nil {
   629  		return x.GracefulDecommissionTimeout
   630  	}
   631  	return nil
   632  }
   633  
   634  func (x *AutoscalerRecommendation_Outputs) GetConstraintsReached() []ConstrainingFactor {
   635  	if x != nil {
   636  		return x.ConstraintsReached
   637  	}
   638  	return nil
   639  }
   640  
   641  func (x *AutoscalerRecommendation_Outputs) GetAdditionalRecommendationDetails() []string {
   642  	if x != nil {
   643  		return x.AdditionalRecommendationDetails
   644  	}
   645  	return nil
   646  }
   647  
   648  func (x *AutoscalerRecommendation_Outputs) GetRecommendationId() string {
   649  	if x != nil {
   650  		return x.RecommendationId
   651  	}
   652  	return ""
   653  }
   654  
   655  var File_google_cloud_dataproc_logging_autoscaler_log_proto protoreflect.FileDescriptor
   656  
   657  var file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDesc = []byte{
   658  	0x0a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64,
   659  	0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2f, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2f,
   660  	0x61, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x5f, 0x6c, 0x6f, 0x67, 0x2e, 0x70,
   661  	0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   662  	0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67,
   663  	0x69, 0x6e, 0x67, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
   664  	0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
   665  	0x6f, 0x74, 0x6f, 0x22, 0x75, 0x0a, 0x0b, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x69,
   666  	0x7a, 0x65, 0x12, 0x30, 0x0a, 0x14, 0x70, 0x72, 0x69, 0x6d, 0x61, 0x72, 0x79, 0x5f, 0x77, 0x6f,
   667  	0x72, 0x6b, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05,
   668  	0x52, 0x12, 0x70, 0x72, 0x69, 0x6d, 0x61, 0x72, 0x79, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x43,
   669  	0x6f, 0x75, 0x6e, 0x74, 0x12, 0x34, 0x0a, 0x16, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x61, 0x72,
   670  	0x79, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02,
   671  	0x20, 0x01, 0x28, 0x05, 0x52, 0x14, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x61, 0x72, 0x79, 0x57,
   672  	0x6f, 0x72, 0x6b, 0x65, 0x72, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0xb9, 0x01, 0x0a, 0x0d, 0x41,
   673  	0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x4c, 0x6f, 0x67, 0x12, 0x47, 0x0a, 0x06,
   674  	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67,
   675  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61,
   676  	0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75, 0x74,
   677  	0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73,
   678  	0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x5f, 0x0a, 0x0e, 0x72, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65,
   679  	0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e,
   680  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
   681  	0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75,
   682  	0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e,
   683  	0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0e, 0x72, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e,
   684  	0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xc7, 0x01, 0x0a, 0x10, 0x41, 0x75, 0x74, 0x6f, 0x73,
   685  	0x63, 0x61, 0x6c, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x44, 0x0a, 0x05, 0x73,
   686  	0x74, 0x61, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2e, 0x2e, 0x67, 0x6f, 0x6f,
   687  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72,
   688  	0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x73,
   689  	0x63, 0x61, 0x6c, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74, 0x61, 0x74,
   690  	0x65, 0x12, 0x18, 0x0a, 0x07, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x18, 0x02, 0x20, 0x01,
   691  	0x28, 0x09, 0x52, 0x07, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x12, 0x3d, 0x0a, 0x1b, 0x75,
   692  	0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6f, 0x70,
   693  	0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
   694  	0x52, 0x18, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4f,
   695  	0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72,
   696  	0x72, 0x6f, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72,
   697  	0x22, 0xa4, 0x09, 0x0a, 0x18, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52,
   698  	0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x56, 0x0a,
   699  	0x06, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3e, 0x2e,
   700  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74,
   701  	0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75,
   702  	0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e,
   703  	0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x52, 0x06, 0x69,
   704  	0x6e, 0x70, 0x75, 0x74, 0x73, 0x12, 0x59, 0x0a, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73,
   705  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
   706  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c,
   707  	0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65,
   708  	0x72, 0x52, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e,
   709  	0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x52, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73,
   710  	0x1a, 0xd6, 0x03, 0x0a, 0x06, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x12, 0x7b, 0x0a, 0x0f, 0x63,
   711  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x18, 0x01,
   712  	0x20, 0x03, 0x28, 0x0b, 0x32, 0x52, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   713  	0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67,
   714  	0x67, 0x69, 0x6e, 0x67, 0x2e, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52,
   715  	0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x49, 0x6e,
   716  	0x70, 0x75, 0x74, 0x73, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x72,
   717  	0x69, 0x63, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0e, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65,
   718  	0x72, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x12, 0x5c, 0x0a, 0x14, 0x63, 0x75, 0x72, 0x72,
   719  	0x65, 0x6e, 0x74, 0x5f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x73, 0x69, 0x7a, 0x65,
   720  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
   721  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c,
   722  	0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x69,
   723  	0x7a, 0x65, 0x52, 0x12, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74,
   724  	0x65, 0x72, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x56, 0x0a, 0x11, 0x6d, 0x69, 0x6e, 0x5f, 0x77, 0x6f,
   725  	0x72, 0x6b, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28,
   726  	0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
   727  	0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e,
   728  	0x67, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x69, 0x7a, 0x65, 0x52, 0x0f, 0x6d,
   729  	0x69, 0x6e, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x12, 0x56,
   730  	0x0a, 0x11, 0x6d, 0x61, 0x78, 0x5f, 0x77, 0x6f, 0x72, 0x6b, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x75,
   731  	0x6e, 0x74, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   732  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f,
   733  	0x63, 0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
   734  	0x72, 0x53, 0x69, 0x7a, 0x65, 0x52, 0x0f, 0x6d, 0x61, 0x78, 0x57, 0x6f, 0x72, 0x6b, 0x65, 0x72,
   735  	0x43, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x1a, 0x41, 0x0a, 0x13, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65,
   736  	0x72, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a,
   737  	0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12,
   738  	0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
   739  	0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0xfb, 0x03, 0x0a, 0x07, 0x4f, 0x75,
   740  	0x74, 0x70, 0x75, 0x74, 0x73, 0x12, 0x4e, 0x0a, 0x08, 0x64, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f,
   741  	0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   742  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e,
   743  	0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x53, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67, 0x44,
   744  	0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x08, 0x64, 0x65, 0x63,
   745  	0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x64, 0x0a, 0x18, 0x72, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65,
   746  	0x6e, 0x64, 0x65, 0x64, 0x5f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x73, 0x69, 0x7a,
   747  	0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   748  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e,
   749  	0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53,
   750  	0x69, 0x7a, 0x65, 0x52, 0x16, 0x72, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x65, 0x64,
   751  	0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x5d, 0x0a, 0x1d, 0x67,
   752  	0x72, 0x61, 0x63, 0x65, 0x66, 0x75, 0x6c, 0x5f, 0x64, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x73,
   753  	0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x03, 0x20, 0x01,
   754  	0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   755  	0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x1b, 0x67,
   756  	0x72, 0x61, 0x63, 0x65, 0x66, 0x75, 0x6c, 0x44, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x73, 0x73,
   757  	0x69, 0x6f, 0x6e, 0x54, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x12, 0x62, 0x0a, 0x13, 0x63, 0x6f,
   758  	0x6e, 0x73, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x74, 0x73, 0x5f, 0x72, 0x65, 0x61, 0x63, 0x68, 0x65,
   759  	0x64, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0e, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   760  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63, 0x2e,
   761  	0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x2e, 0x43, 0x6f, 0x6e, 0x73, 0x74, 0x72, 0x61, 0x69,
   762  	0x6e, 0x69, 0x6e, 0x67, 0x46, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x52, 0x12, 0x63, 0x6f, 0x6e, 0x73,
   763  	0x74, 0x72, 0x61, 0x69, 0x6e, 0x74, 0x73, 0x52, 0x65, 0x61, 0x63, 0x68, 0x65, 0x64, 0x12, 0x4a,
   764  	0x0a, 0x21, 0x61, 0x64, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x5f, 0x72, 0x65, 0x63,
   765  	0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x64, 0x65, 0x74, 0x61,
   766  	0x69, 0x6c, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x09, 0x52, 0x1f, 0x61, 0x64, 0x64, 0x69, 0x74,
   767  	0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x52, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74,
   768  	0x69, 0x6f, 0x6e, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x72, 0x65,
   769  	0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18,
   770  	0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x72, 0x65, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x64,
   771  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x2a, 0x8b, 0x01, 0x0a, 0x0f, 0x41, 0x75, 0x74, 0x6f,
   772  	0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x20, 0x0a, 0x1c, 0x41,
   773  	0x55, 0x54, 0x4f, 0x53, 0x43, 0x41, 0x4c, 0x45, 0x52, 0x5f, 0x53, 0x54, 0x41, 0x54, 0x45, 0x5f,
   774  	0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0c, 0x0a,
   775  	0x08, 0x43, 0x4f, 0x4f, 0x4c, 0x44, 0x4f, 0x57, 0x4e, 0x10, 0x01, 0x12, 0x10, 0x0a, 0x0c, 0x52,
   776  	0x45, 0x43, 0x4f, 0x4d, 0x4d, 0x45, 0x4e, 0x44, 0x49, 0x4e, 0x47, 0x10, 0x06, 0x12, 0x0b, 0x0a,
   777  	0x07, 0x53, 0x43, 0x41, 0x4c, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x0b, 0x0a, 0x07, 0x53, 0x54,
   778  	0x4f, 0x50, 0x50, 0x45, 0x44, 0x10, 0x03, 0x12, 0x0a, 0x0a, 0x06, 0x46, 0x41, 0x49, 0x4c, 0x45,
   779  	0x44, 0x10, 0x04, 0x12, 0x10, 0x0a, 0x0c, 0x49, 0x4e, 0x49, 0x54, 0x49, 0x41, 0x4c, 0x49, 0x5a,
   780  	0x49, 0x4e, 0x47, 0x10, 0x05, 0x2a, 0x73, 0x0a, 0x13, 0x53, 0x63, 0x61, 0x6c, 0x69, 0x6e, 0x67,
   781  	0x44, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a, 0x21,
   782  	0x53, 0x43, 0x41, 0x4c, 0x49, 0x4e, 0x47, 0x5f, 0x44, 0x45, 0x43, 0x49, 0x53, 0x49, 0x4f, 0x4e,
   783  	0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45,
   784  	0x44, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x53, 0x43, 0x41, 0x4c, 0x45, 0x5f, 0x55, 0x50, 0x10,
   785  	0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x53, 0x43, 0x41, 0x4c, 0x45, 0x5f, 0x44, 0x4f, 0x57, 0x4e, 0x10,
   786  	0x02, 0x12, 0x0c, 0x0a, 0x08, 0x4e, 0x4f, 0x5f, 0x53, 0x43, 0x41, 0x4c, 0x45, 0x10, 0x03, 0x12,
   787  	0x09, 0x0a, 0x05, 0x4d, 0x49, 0x58, 0x45, 0x44, 0x10, 0x04, 0x2a, 0xa6, 0x01, 0x0a, 0x12, 0x43,
   788  	0x6f, 0x6e, 0x73, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x69, 0x6e, 0x67, 0x46, 0x61, 0x63, 0x74, 0x6f,
   789  	0x72, 0x12, 0x23, 0x0a, 0x1f, 0x43, 0x4f, 0x4e, 0x53, 0x54, 0x52, 0x41, 0x49, 0x4e, 0x49, 0x4e,
   790  	0x47, 0x5f, 0x46, 0x41, 0x43, 0x54, 0x4f, 0x52, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49,
   791  	0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x27, 0x0a, 0x23, 0x53, 0x43, 0x41, 0x4c, 0x49, 0x4e,
   792  	0x47, 0x5f, 0x43, 0x41, 0x50, 0x50, 0x45, 0x44, 0x5f, 0x44, 0x55, 0x45, 0x5f, 0x54, 0x4f, 0x5f,
   793  	0x4c, 0x41, 0x43, 0x4b, 0x5f, 0x4f, 0x46, 0x5f, 0x51, 0x55, 0x4f, 0x54, 0x41, 0x10, 0x01, 0x12,
   794  	0x20, 0x0a, 0x1c, 0x52, 0x45, 0x41, 0x43, 0x48, 0x45, 0x44, 0x5f, 0x4d, 0x41, 0x58, 0x49, 0x4d,
   795  	0x55, 0x4d, 0x5f, 0x43, 0x4c, 0x55, 0x53, 0x54, 0x45, 0x52, 0x5f, 0x53, 0x49, 0x5a, 0x45, 0x10,
   796  	0x02, 0x12, 0x20, 0x0a, 0x1c, 0x52, 0x45, 0x41, 0x43, 0x48, 0x45, 0x44, 0x5f, 0x4d, 0x49, 0x4e,
   797  	0x49, 0x4d, 0x55, 0x4d, 0x5f, 0x43, 0x4c, 0x55, 0x53, 0x54, 0x45, 0x52, 0x5f, 0x53, 0x49, 0x5a,
   798  	0x45, 0x10, 0x03, 0x42, 0x6b, 0x0a, 0x21, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   799  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
   800  	0x2e, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x50, 0x01, 0x5a, 0x44, 0x67, 0x6f, 0x6f, 0x67,
   801  	0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65,
   802  	0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
   803  	0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x70, 0x72, 0x6f, 0x63,
   804  	0x2f, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67, 0x3b, 0x6c, 0x6f, 0x67, 0x67, 0x69, 0x6e, 0x67,
   805  	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   806  }
   807  
   808  var (
   809  	file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescOnce sync.Once
   810  	file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescData = file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDesc
   811  )
   812  
   813  func file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescGZIP() []byte {
   814  	file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescOnce.Do(func() {
   815  		file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescData)
   816  	})
   817  	return file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDescData
   818  }
   819  
   820  var file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
   821  var file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
   822  var file_google_cloud_dataproc_logging_autoscaler_log_proto_goTypes = []interface{}{
   823  	(AutoscalerState)(0),                     // 0: google.cloud.dataproc.logging.AutoscalerState
   824  	(ScalingDecisionType)(0),                 // 1: google.cloud.dataproc.logging.ScalingDecisionType
   825  	(ConstrainingFactor)(0),                  // 2: google.cloud.dataproc.logging.ConstrainingFactor
   826  	(*ClusterSize)(nil),                      // 3: google.cloud.dataproc.logging.ClusterSize
   827  	(*AutoscalerLog)(nil),                    // 4: google.cloud.dataproc.logging.AutoscalerLog
   828  	(*AutoscalerStatus)(nil),                 // 5: google.cloud.dataproc.logging.AutoscalerStatus
   829  	(*AutoscalerRecommendation)(nil),         // 6: google.cloud.dataproc.logging.AutoscalerRecommendation
   830  	(*AutoscalerRecommendation_Inputs)(nil),  // 7: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs
   831  	(*AutoscalerRecommendation_Outputs)(nil), // 8: google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs
   832  	nil,                                      // 9: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.ClusterMetricsEntry
   833  	(*durationpb.Duration)(nil),              // 10: google.protobuf.Duration
   834  }
   835  var file_google_cloud_dataproc_logging_autoscaler_log_proto_depIdxs = []int32{
   836  	5,  // 0: google.cloud.dataproc.logging.AutoscalerLog.status:type_name -> google.cloud.dataproc.logging.AutoscalerStatus
   837  	6,  // 1: google.cloud.dataproc.logging.AutoscalerLog.recommendation:type_name -> google.cloud.dataproc.logging.AutoscalerRecommendation
   838  	0,  // 2: google.cloud.dataproc.logging.AutoscalerStatus.state:type_name -> google.cloud.dataproc.logging.AutoscalerState
   839  	7,  // 3: google.cloud.dataproc.logging.AutoscalerRecommendation.inputs:type_name -> google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs
   840  	8,  // 4: google.cloud.dataproc.logging.AutoscalerRecommendation.outputs:type_name -> google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs
   841  	9,  // 5: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.cluster_metrics:type_name -> google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.ClusterMetricsEntry
   842  	3,  // 6: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.current_cluster_size:type_name -> google.cloud.dataproc.logging.ClusterSize
   843  	3,  // 7: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.min_worker_counts:type_name -> google.cloud.dataproc.logging.ClusterSize
   844  	3,  // 8: google.cloud.dataproc.logging.AutoscalerRecommendation.Inputs.max_worker_counts:type_name -> google.cloud.dataproc.logging.ClusterSize
   845  	1,  // 9: google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs.decision:type_name -> google.cloud.dataproc.logging.ScalingDecisionType
   846  	3,  // 10: google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs.recommended_cluster_size:type_name -> google.cloud.dataproc.logging.ClusterSize
   847  	10, // 11: google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs.graceful_decommission_timeout:type_name -> google.protobuf.Duration
   848  	2,  // 12: google.cloud.dataproc.logging.AutoscalerRecommendation.Outputs.constraints_reached:type_name -> google.cloud.dataproc.logging.ConstrainingFactor
   849  	13, // [13:13] is the sub-list for method output_type
   850  	13, // [13:13] is the sub-list for method input_type
   851  	13, // [13:13] is the sub-list for extension type_name
   852  	13, // [13:13] is the sub-list for extension extendee
   853  	0,  // [0:13] is the sub-list for field type_name
   854  }
   855  
   856  func init() { file_google_cloud_dataproc_logging_autoscaler_log_proto_init() }
   857  func file_google_cloud_dataproc_logging_autoscaler_log_proto_init() {
   858  	if File_google_cloud_dataproc_logging_autoscaler_log_proto != nil {
   859  		return
   860  	}
   861  	if !protoimpl.UnsafeEnabled {
   862  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   863  			switch v := v.(*ClusterSize); i {
   864  			case 0:
   865  				return &v.state
   866  			case 1:
   867  				return &v.sizeCache
   868  			case 2:
   869  				return &v.unknownFields
   870  			default:
   871  				return nil
   872  			}
   873  		}
   874  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   875  			switch v := v.(*AutoscalerLog); i {
   876  			case 0:
   877  				return &v.state
   878  			case 1:
   879  				return &v.sizeCache
   880  			case 2:
   881  				return &v.unknownFields
   882  			default:
   883  				return nil
   884  			}
   885  		}
   886  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   887  			switch v := v.(*AutoscalerStatus); i {
   888  			case 0:
   889  				return &v.state
   890  			case 1:
   891  				return &v.sizeCache
   892  			case 2:
   893  				return &v.unknownFields
   894  			default:
   895  				return nil
   896  			}
   897  		}
   898  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   899  			switch v := v.(*AutoscalerRecommendation); i {
   900  			case 0:
   901  				return &v.state
   902  			case 1:
   903  				return &v.sizeCache
   904  			case 2:
   905  				return &v.unknownFields
   906  			default:
   907  				return nil
   908  			}
   909  		}
   910  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
   911  			switch v := v.(*AutoscalerRecommendation_Inputs); i {
   912  			case 0:
   913  				return &v.state
   914  			case 1:
   915  				return &v.sizeCache
   916  			case 2:
   917  				return &v.unknownFields
   918  			default:
   919  				return nil
   920  			}
   921  		}
   922  		file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
   923  			switch v := v.(*AutoscalerRecommendation_Outputs); i {
   924  			case 0:
   925  				return &v.state
   926  			case 1:
   927  				return &v.sizeCache
   928  			case 2:
   929  				return &v.unknownFields
   930  			default:
   931  				return nil
   932  			}
   933  		}
   934  	}
   935  	type x struct{}
   936  	out := protoimpl.TypeBuilder{
   937  		File: protoimpl.DescBuilder{
   938  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   939  			RawDescriptor: file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDesc,
   940  			NumEnums:      3,
   941  			NumMessages:   7,
   942  			NumExtensions: 0,
   943  			NumServices:   0,
   944  		},
   945  		GoTypes:           file_google_cloud_dataproc_logging_autoscaler_log_proto_goTypes,
   946  		DependencyIndexes: file_google_cloud_dataproc_logging_autoscaler_log_proto_depIdxs,
   947  		EnumInfos:         file_google_cloud_dataproc_logging_autoscaler_log_proto_enumTypes,
   948  		MessageInfos:      file_google_cloud_dataproc_logging_autoscaler_log_proto_msgTypes,
   949  	}.Build()
   950  	File_google_cloud_dataproc_logging_autoscaler_log_proto = out.File
   951  	file_google_cloud_dataproc_logging_autoscaler_log_proto_rawDesc = nil
   952  	file_google_cloud_dataproc_logging_autoscaler_log_proto_goTypes = nil
   953  	file_google_cloud_dataproc_logging_autoscaler_log_proto_depIdxs = nil
   954  }
   955  

View as plain text