Enum value maps for AutoscalerState.
var (
AutoscalerState_name = map[int32]string{
0: "AUTOSCALER_STATE_UNSPECIFIED",
1: "COOLDOWN",
6: "RECOMMENDING",
2: "SCALING",
3: "STOPPED",
4: "FAILED",
5: "INITIALIZING",
}
AutoscalerState_value = map[string]int32{
"AUTOSCALER_STATE_UNSPECIFIED": 0,
"COOLDOWN": 1,
"RECOMMENDING": 6,
"SCALING": 2,
"STOPPED": 3,
"FAILED": 4,
"INITIALIZING": 5,
}
)
Enum value maps for ScalingDecisionType.
var (
ScalingDecisionType_name = map[int32]string{
0: "SCALING_DECISION_TYPE_UNSPECIFIED",
1: "SCALE_UP",
2: "SCALE_DOWN",
3: "NO_SCALE",
4: "MIXED",
}
ScalingDecisionType_value = map[string]int32{
"SCALING_DECISION_TYPE_UNSPECIFIED": 0,
"SCALE_UP": 1,
"SCALE_DOWN": 2,
"NO_SCALE": 3,
"MIXED": 4,
}
)
Enum value maps for ConstrainingFactor.
var (
ConstrainingFactor_name = map[int32]string{
0: "CONSTRAINING_FACTOR_UNSPECIFIED",
1: "SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA",
2: "REACHED_MAXIMUM_CLUSTER_SIZE",
3: "REACHED_MINIMUM_CLUSTER_SIZE",
}
ConstrainingFactor_value = map[string]int32{
"CONSTRAINING_FACTOR_UNSPECIFIED": 0,
"SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA": 1,
"REACHED_MAXIMUM_CLUSTER_SIZE": 2,
"REACHED_MINIMUM_CLUSTER_SIZE": 3,
}
)
var File_google_cloud_dataproc_logging_autoscaler_log_proto protoreflect.FileDescriptor
The main proto that will be converted to JSON format and then written to Logging.
type AutoscalerLog struct {
// The current Autoscaler status.
Status *AutoscalerStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
// Optional. The autoscaling recommendation including its inputs, outputs,
// scaling decision, and detailed explanation.
Recommendation *AutoscalerRecommendation `protobuf:"bytes,2,opt,name=recommendation,proto3" json:"recommendation,omitempty"`
// contains filtered or unexported fields
}
func (*AutoscalerLog) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalerLog.ProtoReflect.Descriptor instead.
func (x *AutoscalerLog) GetRecommendation() *AutoscalerRecommendation
func (x *AutoscalerLog) GetStatus() *AutoscalerStatus
func (*AutoscalerLog) ProtoMessage()
func (x *AutoscalerLog) ProtoReflect() protoreflect.Message
func (x *AutoscalerLog) Reset()
func (x *AutoscalerLog) String() string
The inputs, outputs, and detailed explanation of the Autoscaling recommendation.
type AutoscalerRecommendation struct {
// The autoscaling algorithm inputs.
Inputs *AutoscalerRecommendation_Inputs `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
// The algorithm outputs for the recommended cluster size.
Outputs *AutoscalerRecommendation_Outputs `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
// contains filtered or unexported fields
}
func (*AutoscalerRecommendation) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalerRecommendation.ProtoReflect.Descriptor instead.
func (x *AutoscalerRecommendation) GetInputs() *AutoscalerRecommendation_Inputs
func (x *AutoscalerRecommendation) GetOutputs() *AutoscalerRecommendation_Outputs
func (*AutoscalerRecommendation) ProtoMessage()
func (x *AutoscalerRecommendation) ProtoReflect() protoreflect.Message
func (x *AutoscalerRecommendation) Reset()
func (x *AutoscalerRecommendation) String() string
The input values for the Autoscaling recommendation alogirthm.
type AutoscalerRecommendation_Inputs struct {
// The metrics collected by the Dataproc agent running on the cluster.
// For example, {"avg-yarn-pending-memory": "1040 MB"}
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"`
// The cluster configuration before updating the cluster.
CurrentClusterSize *ClusterSize `protobuf:"bytes,2,opt,name=current_cluster_size,json=currentClusterSize,proto3" json:"current_cluster_size,omitempty"`
// The minimum worker counts for each instance group.
MinWorkerCounts *ClusterSize `protobuf:"bytes,3,opt,name=min_worker_counts,json=minWorkerCounts,proto3" json:"min_worker_counts,omitempty"`
// The maximum worker counts for each instance group.
MaxWorkerCounts *ClusterSize `protobuf:"bytes,4,opt,name=max_worker_counts,json=maxWorkerCounts,proto3" json:"max_worker_counts,omitempty"`
// contains filtered or unexported fields
}
func (*AutoscalerRecommendation_Inputs) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalerRecommendation_Inputs.ProtoReflect.Descriptor instead.
func (x *AutoscalerRecommendation_Inputs) GetClusterMetrics() map[string]string
func (x *AutoscalerRecommendation_Inputs) GetCurrentClusterSize() *ClusterSize
func (x *AutoscalerRecommendation_Inputs) GetMaxWorkerCounts() *ClusterSize
func (x *AutoscalerRecommendation_Inputs) GetMinWorkerCounts() *ClusterSize
func (*AutoscalerRecommendation_Inputs) ProtoMessage()
func (x *AutoscalerRecommendation_Inputs) ProtoReflect() protoreflect.Message
func (x *AutoscalerRecommendation_Inputs) Reset()
func (x *AutoscalerRecommendation_Inputs) String() string
Autoscaler recommendations.
type AutoscalerRecommendation_Outputs struct {
// The high-level autoscaling decision, such as SCALE_UP, SCALE_DOWN,
// NO_OP.
Decision ScalingDecisionType `protobuf:"varint,1,opt,name=decision,proto3,enum=google.cloud.dataproc.logging.ScalingDecisionType" json:"decision,omitempty"`
// The recommended cluster size.
RecommendedClusterSize *ClusterSize `protobuf:"bytes,2,opt,name=recommended_cluster_size,json=recommendedClusterSize,proto3" json:"recommended_cluster_size,omitempty"`
// The graceful decommission timeout for downscaling operations.
GracefulDecommissionTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"`
// Reasons why the Autoscaler didn't add or remove more workers.
ConstraintsReached []ConstrainingFactor `protobuf:"varint,4,rep,packed,name=constraints_reached,json=constraintsReached,proto3,enum=google.cloud.dataproc.logging.ConstrainingFactor" json:"constraints_reached,omitempty"`
// Less significant recommendations that are not included in the
// `AutoscalerStatus.details` message.
AdditionalRecommendationDetails []string `protobuf:"bytes,5,rep,name=additional_recommendation_details,json=additionalRecommendationDetails,proto3" json:"additional_recommendation_details,omitempty"`
// A unique id for this recommendation that should be included when opening
// a support ticket.
RecommendationId string `protobuf:"bytes,6,opt,name=recommendation_id,json=recommendationId,proto3" json:"recommendation_id,omitempty"`
// contains filtered or unexported fields
}
func (*AutoscalerRecommendation_Outputs) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalerRecommendation_Outputs.ProtoReflect.Descriptor instead.
func (x *AutoscalerRecommendation_Outputs) GetAdditionalRecommendationDetails() []string
func (x *AutoscalerRecommendation_Outputs) GetConstraintsReached() []ConstrainingFactor
func (x *AutoscalerRecommendation_Outputs) GetDecision() ScalingDecisionType
func (x *AutoscalerRecommendation_Outputs) GetGracefulDecommissionTimeout() *durationpb.Duration
func (x *AutoscalerRecommendation_Outputs) GetRecommendationId() string
func (x *AutoscalerRecommendation_Outputs) GetRecommendedClusterSize() *ClusterSize
func (*AutoscalerRecommendation_Outputs) ProtoMessage()
func (x *AutoscalerRecommendation_Outputs) ProtoReflect() protoreflect.Message
func (x *AutoscalerRecommendation_Outputs) Reset()
func (x *AutoscalerRecommendation_Outputs) String() string
The Autoscaler state.
type AutoscalerState int32
const (
AutoscalerState_AUTOSCALER_STATE_UNSPECIFIED AutoscalerState = 0
// The Autoscaler is sleeping and waiting for the next update.
AutoscalerState_COOLDOWN AutoscalerState = 1
// The Autoscaler is in the process of calculating its recommendation on
// whether to scale the cluster, and if so, how to autoscale.
AutoscalerState_RECOMMENDING AutoscalerState = 6
// The Autoscaler is scaling the cluster.
AutoscalerState_SCALING AutoscalerState = 2
// The Autoscaler has stopped.
AutoscalerState_STOPPED AutoscalerState = 3
// The Autoscaler has failed.
AutoscalerState_FAILED AutoscalerState = 4
// The Autoscaler is initializing.
AutoscalerState_INITIALIZING AutoscalerState = 5
)
func (AutoscalerState) Descriptor() protoreflect.EnumDescriptor
func (x AutoscalerState) Enum() *AutoscalerState
func (AutoscalerState) EnumDescriptor() ([]byte, []int)
Deprecated: Use AutoscalerState.Descriptor instead.
func (x AutoscalerState) Number() protoreflect.EnumNumber
func (x AutoscalerState) String() string
func (AutoscalerState) Type() protoreflect.EnumType
The Autoscaler's status, including its state and other details.
type AutoscalerStatus struct {
// The high-level Autoscaler state.
State AutoscalerState `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.logging.AutoscalerState" json:"state,omitempty"`
// The detailed description of Autoscaler status.
Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
// The cluster update operation ID.
UpdateClusterOperationId string `protobuf:"bytes,3,opt,name=update_cluster_operation_id,json=updateClusterOperationId,proto3" json:"update_cluster_operation_id,omitempty"`
// Error message from an Autoscaler exception, if any.
Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*AutoscalerStatus) Descriptor() ([]byte, []int)
Deprecated: Use AutoscalerStatus.ProtoReflect.Descriptor instead.
func (x *AutoscalerStatus) GetDetails() string
func (x *AutoscalerStatus) GetError() string
func (x *AutoscalerStatus) GetState() AutoscalerState
func (x *AutoscalerStatus) GetUpdateClusterOperationId() string
func (*AutoscalerStatus) ProtoMessage()
func (x *AutoscalerStatus) ProtoReflect() protoreflect.Message
func (x *AutoscalerStatus) Reset()
func (x *AutoscalerStatus) String() string
The short version of cluster configuration for Cloud logging.
type ClusterSize struct {
// The number of primary workers in the cluster.
PrimaryWorkerCount int32 `protobuf:"varint,1,opt,name=primary_worker_count,json=primaryWorkerCount,proto3" json:"primary_worker_count,omitempty"`
// The number of secondary workers in the cluster.
SecondaryWorkerCount int32 `protobuf:"varint,2,opt,name=secondary_worker_count,json=secondaryWorkerCount,proto3" json:"secondary_worker_count,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterSize) Descriptor() ([]byte, []int)
Deprecated: Use ClusterSize.ProtoReflect.Descriptor instead.
func (x *ClusterSize) GetPrimaryWorkerCount() int32
func (x *ClusterSize) GetSecondaryWorkerCount() int32
func (*ClusterSize) ProtoMessage()
func (x *ClusterSize) ProtoReflect() protoreflect.Message
func (x *ClusterSize) Reset()
func (x *ClusterSize) String() string
type ConstrainingFactor int32
const (
ConstrainingFactor_CONSTRAINING_FACTOR_UNSPECIFIED ConstrainingFactor = 0
// The project does not have sufficient regional, global, and or preemptible
// quota to allocate a new VM.
ConstrainingFactor_SCALING_CAPPED_DUE_TO_LACK_OF_QUOTA ConstrainingFactor = 1
// All worker groups have reached maximum size. This message will not be
// issued if one group reached maximum size, but workers were able to be
// allocated to another group.
ConstrainingFactor_REACHED_MAXIMUM_CLUSTER_SIZE ConstrainingFactor = 2
// All worker groups have reached minimum size. This message will not be
// issued if workers were able to be removed from another group that had not
// reached minimum size.
ConstrainingFactor_REACHED_MINIMUM_CLUSTER_SIZE ConstrainingFactor = 3
)
func (ConstrainingFactor) Descriptor() protoreflect.EnumDescriptor
func (x ConstrainingFactor) Enum() *ConstrainingFactor
func (ConstrainingFactor) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConstrainingFactor.Descriptor instead.
func (x ConstrainingFactor) Number() protoreflect.EnumNumber
func (x ConstrainingFactor) String() string
func (ConstrainingFactor) Type() protoreflect.EnumType
The Autoscaling decision type.
type ScalingDecisionType int32
const (
ScalingDecisionType_SCALING_DECISION_TYPE_UNSPECIFIED ScalingDecisionType = 0
// Increase the number of primary and/or secondary workers.
ScalingDecisionType_SCALE_UP ScalingDecisionType = 1
// Decrease the number of primary and/or secondary workers.
ScalingDecisionType_SCALE_DOWN ScalingDecisionType = 2
// Not changing the number of primary or secondary workers.
ScalingDecisionType_NO_SCALE ScalingDecisionType = 3
// Scale the primary and secondary worker groups in different directions.
ScalingDecisionType_MIXED ScalingDecisionType = 4
)
func (ScalingDecisionType) Descriptor() protoreflect.EnumDescriptor
func (x ScalingDecisionType) Enum() *ScalingDecisionType
func (ScalingDecisionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ScalingDecisionType.Descriptor instead.
func (x ScalingDecisionType) Number() protoreflect.EnumNumber
func (x ScalingDecisionType) String() string
func (ScalingDecisionType) Type() protoreflect.EnumType