genproto: google.golang.org/genproto/googleapis/cloud/dataproc/logging Index | Files

package logging

import "google.golang.org/genproto/googleapis/cloud/dataproc/logging"

Index

Package Files

autoscaler_log.pb.go

Variables

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 AutoscalerState.

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 ScalingDecisionType.

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,
    }
)

Enum value maps for ConstrainingFactor.

var File_google_cloud_dataproc_logging_autoscaler_log_proto protoreflect.FileDescriptor

type AutoscalerLog Uses

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
}

The main proto that will be converted to JSON format and then written to Logging.

func (*AutoscalerLog) Descriptor Uses

func (*AutoscalerLog) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerLog.ProtoReflect.Descriptor instead.

func (*AutoscalerLog) GetRecommendation Uses

func (x *AutoscalerLog) GetRecommendation() *AutoscalerRecommendation

func (*AutoscalerLog) GetStatus Uses

func (x *AutoscalerLog) GetStatus() *AutoscalerStatus

func (*AutoscalerLog) ProtoMessage Uses

func (*AutoscalerLog) ProtoMessage()

func (*AutoscalerLog) ProtoReflect Uses

func (x *AutoscalerLog) ProtoReflect() protoreflect.Message

func (*AutoscalerLog) Reset Uses

func (x *AutoscalerLog) Reset()

func (*AutoscalerLog) String Uses

func (x *AutoscalerLog) String() string

type AutoscalerRecommendation Uses

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
}

The inputs, outputs, and detailed explanation of the Autoscaling recommendation.

func (*AutoscalerRecommendation) Descriptor Uses

func (*AutoscalerRecommendation) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerRecommendation.ProtoReflect.Descriptor instead.

func (*AutoscalerRecommendation) GetInputs Uses

func (x *AutoscalerRecommendation) GetInputs() *AutoscalerRecommendation_Inputs

func (*AutoscalerRecommendation) GetOutputs Uses

func (x *AutoscalerRecommendation) GetOutputs() *AutoscalerRecommendation_Outputs

func (*AutoscalerRecommendation) ProtoMessage Uses

func (*AutoscalerRecommendation) ProtoMessage()

func (*AutoscalerRecommendation) ProtoReflect Uses

func (x *AutoscalerRecommendation) ProtoReflect() protoreflect.Message

func (*AutoscalerRecommendation) Reset Uses

func (x *AutoscalerRecommendation) Reset()

func (*AutoscalerRecommendation) String Uses

func (x *AutoscalerRecommendation) String() string

type AutoscalerRecommendation_Inputs Uses

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
}

The input values for the Autoscaling recommendation alogirthm.

func (*AutoscalerRecommendation_Inputs) Descriptor Uses

func (*AutoscalerRecommendation_Inputs) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerRecommendation_Inputs.ProtoReflect.Descriptor instead.

func (*AutoscalerRecommendation_Inputs) GetClusterMetrics Uses

func (x *AutoscalerRecommendation_Inputs) GetClusterMetrics() map[string]string

func (*AutoscalerRecommendation_Inputs) GetCurrentClusterSize Uses

func (x *AutoscalerRecommendation_Inputs) GetCurrentClusterSize() *ClusterSize

func (*AutoscalerRecommendation_Inputs) GetMaxWorkerCounts Uses

func (x *AutoscalerRecommendation_Inputs) GetMaxWorkerCounts() *ClusterSize

func (*AutoscalerRecommendation_Inputs) GetMinWorkerCounts Uses

func (x *AutoscalerRecommendation_Inputs) GetMinWorkerCounts() *ClusterSize

func (*AutoscalerRecommendation_Inputs) ProtoMessage Uses

func (*AutoscalerRecommendation_Inputs) ProtoMessage()

func (*AutoscalerRecommendation_Inputs) ProtoReflect Uses

func (x *AutoscalerRecommendation_Inputs) ProtoReflect() protoreflect.Message

func (*AutoscalerRecommendation_Inputs) Reset Uses

func (x *AutoscalerRecommendation_Inputs) Reset()

func (*AutoscalerRecommendation_Inputs) String Uses

func (x *AutoscalerRecommendation_Inputs) String() string

type AutoscalerRecommendation_Outputs Uses

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
}

Autoscaler recommendations.

func (*AutoscalerRecommendation_Outputs) Descriptor Uses

func (*AutoscalerRecommendation_Outputs) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerRecommendation_Outputs.ProtoReflect.Descriptor instead.

func (*AutoscalerRecommendation_Outputs) GetAdditionalRecommendationDetails Uses

func (x *AutoscalerRecommendation_Outputs) GetAdditionalRecommendationDetails() []string

func (*AutoscalerRecommendation_Outputs) GetConstraintsReached Uses

func (x *AutoscalerRecommendation_Outputs) GetConstraintsReached() []ConstrainingFactor

func (*AutoscalerRecommendation_Outputs) GetDecision Uses

func (x *AutoscalerRecommendation_Outputs) GetDecision() ScalingDecisionType

func (*AutoscalerRecommendation_Outputs) GetGracefulDecommissionTimeout Uses

func (x *AutoscalerRecommendation_Outputs) GetGracefulDecommissionTimeout() *durationpb.Duration

func (*AutoscalerRecommendation_Outputs) GetRecommendationId Uses

func (x *AutoscalerRecommendation_Outputs) GetRecommendationId() string

func (*AutoscalerRecommendation_Outputs) GetRecommendedClusterSize Uses

func (x *AutoscalerRecommendation_Outputs) GetRecommendedClusterSize() *ClusterSize

func (*AutoscalerRecommendation_Outputs) ProtoMessage Uses

func (*AutoscalerRecommendation_Outputs) ProtoMessage()

func (*AutoscalerRecommendation_Outputs) ProtoReflect Uses

func (x *AutoscalerRecommendation_Outputs) ProtoReflect() protoreflect.Message

func (*AutoscalerRecommendation_Outputs) Reset Uses

func (x *AutoscalerRecommendation_Outputs) Reset()

func (*AutoscalerRecommendation_Outputs) String Uses

func (x *AutoscalerRecommendation_Outputs) String() string

type AutoscalerState Uses

type AutoscalerState int32

The Autoscaler state.

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 Uses

func (AutoscalerState) Descriptor() protoreflect.EnumDescriptor

func (AutoscalerState) Enum Uses

func (x AutoscalerState) Enum() *AutoscalerState

func (AutoscalerState) EnumDescriptor Uses

func (AutoscalerState) EnumDescriptor() ([]byte, []int)

Deprecated: Use AutoscalerState.Descriptor instead.

func (AutoscalerState) Number Uses

func (x AutoscalerState) Number() protoreflect.EnumNumber

func (AutoscalerState) String Uses

func (x AutoscalerState) String() string

func (AutoscalerState) Type Uses

func (AutoscalerState) Type() protoreflect.EnumType

type AutoscalerStatus Uses

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
}

The Autoscaler's status, including its state and other details.

func (*AutoscalerStatus) Descriptor Uses

func (*AutoscalerStatus) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerStatus.ProtoReflect.Descriptor instead.

func (*AutoscalerStatus) GetDetails Uses

func (x *AutoscalerStatus) GetDetails() string

func (*AutoscalerStatus) GetError Uses

func (x *AutoscalerStatus) GetError() string

func (*AutoscalerStatus) GetState Uses

func (x *AutoscalerStatus) GetState() AutoscalerState

func (*AutoscalerStatus) GetUpdateClusterOperationId Uses

func (x *AutoscalerStatus) GetUpdateClusterOperationId() string

func (*AutoscalerStatus) ProtoMessage Uses

func (*AutoscalerStatus) ProtoMessage()

func (*AutoscalerStatus) ProtoReflect Uses

func (x *AutoscalerStatus) ProtoReflect() protoreflect.Message

func (*AutoscalerStatus) Reset Uses

func (x *AutoscalerStatus) Reset()

func (*AutoscalerStatus) String Uses

func (x *AutoscalerStatus) String() string

type ClusterSize Uses

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
}

The short version of cluster configuration for Cloud logging.

func (*ClusterSize) Descriptor Uses

func (*ClusterSize) Descriptor() ([]byte, []int)

Deprecated: Use ClusterSize.ProtoReflect.Descriptor instead.

func (*ClusterSize) GetPrimaryWorkerCount Uses

func (x *ClusterSize) GetPrimaryWorkerCount() int32

func (*ClusterSize) GetSecondaryWorkerCount Uses

func (x *ClusterSize) GetSecondaryWorkerCount() int32

func (*ClusterSize) ProtoMessage Uses

func (*ClusterSize) ProtoMessage()

func (*ClusterSize) ProtoReflect Uses

func (x *ClusterSize) ProtoReflect() protoreflect.Message

func (*ClusterSize) Reset Uses

func (x *ClusterSize) Reset()

func (*ClusterSize) String Uses

func (x *ClusterSize) String() string

type ConstrainingFactor Uses

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 Uses

func (ConstrainingFactor) Descriptor() protoreflect.EnumDescriptor

func (ConstrainingFactor) Enum Uses

func (x ConstrainingFactor) Enum() *ConstrainingFactor

func (ConstrainingFactor) EnumDescriptor Uses

func (ConstrainingFactor) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConstrainingFactor.Descriptor instead.

func (ConstrainingFactor) Number Uses

func (x ConstrainingFactor) Number() protoreflect.EnumNumber

func (ConstrainingFactor) String Uses

func (x ConstrainingFactor) String() string

func (ConstrainingFactor) Type Uses

func (ConstrainingFactor) Type() protoreflect.EnumType

type ScalingDecisionType Uses

type ScalingDecisionType int32

The Autoscaling decision type.

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 Uses

func (ScalingDecisionType) Descriptor() protoreflect.EnumDescriptor

func (ScalingDecisionType) Enum Uses

func (x ScalingDecisionType) Enum() *ScalingDecisionType

func (ScalingDecisionType) EnumDescriptor Uses

func (ScalingDecisionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ScalingDecisionType.Descriptor instead.

func (ScalingDecisionType) Number Uses

func (x ScalingDecisionType) Number() protoreflect.EnumNumber

func (ScalingDecisionType) String Uses

func (x ScalingDecisionType) String() string

func (ScalingDecisionType) Type Uses

func (ScalingDecisionType) Type() protoreflect.EnumType

Package logging imports 6 packages (graph). Updated 2020-10-13. Refresh now. Tools for package owners.