Package cloud.google.com/go/dataproc/v2/apiv1/dataprocpb (v2.10.1)

var (
	Batch_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "CANCELLING",
		4: "CANCELLED",
		5: "SUCCEEDED",
		6: "FAILED",
	}
	Batch_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"RUNNING":           2,
		"CANCELLING":        3,
		"CANCELLED":         4,
		"SUCCEEDED":         5,
		"FAILED":            6,
	}
)

var (
	GceClusterConfig_PrivateIpv6GoogleAccess_name = map[int32]string{
		0: "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED",
		1: "INHERIT_FROM_SUBNETWORK",
		2: "OUTBOUND",
		3: "BIDIRECTIONAL",
	}
	GceClusterConfig_PrivateIpv6GoogleAccess_value = map[string]int32{
		"PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED": 0,
		"INHERIT_FROM_SUBNETWORK":                1,
		"OUTBOUND":                               2,
		"BIDIRECTIONAL":                          3,
	}
)

var (
	InstanceGroupConfig_Preemptibility_name = map[int32]string{
		0: "PREEMPTIBILITY_UNSPECIFIED",
		1: "NON_PREEMPTIBLE",
		2: "PREEMPTIBLE",
		3: "SPOT",
	}
	InstanceGroupConfig_Preemptibility_value = map[string]int32{
		"PREEMPTIBILITY_UNSPECIFIED": 0,
		"NON_PREEMPTIBLE":            1,
		"PREEMPTIBLE":                2,
		"SPOT":                       3,
	}
)

var (
	NodeGroup_Role_name = map[int32]string{
		0: "ROLE_UNSPECIFIED",
		1: "DRIVER",
	}
	NodeGroup_Role_value = map[string]int32{
		"ROLE_UNSPECIFIED": 0,
		"DRIVER":           1,
	}
)

var (
	ClusterStatus_State_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "CREATING",
		2:  "RUNNING",
		3:  "ERROR",
		9:  "ERROR_DUE_TO_UPDATE",
		4:  "DELETING",
		5:  "UPDATING",
		6:  "STOPPING",
		7:  "STOPPED",
		8:  "STARTING",
		10: "REPAIRING",
	}
	ClusterStatus_State_value = map[string]int32{
		"UNKNOWN":             0,
		"CREATING":            1,
		"RUNNING":             2,
		"ERROR":               3,
		"ERROR_DUE_TO_UPDATE": 9,
		"DELETING":            4,
		"UPDATING":            5,
		"STOPPING":            6,
		"STOPPED":             7,
		"STARTING":            8,
		"REPAIRING":           10,
	}
)

var (
	ClusterStatus_Substate_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "UNHEALTHY",
		2: "STALE_STATUS",
	}
	ClusterStatus_Substate_value = map[string]int32{
		"UNSPECIFIED":  0,
		"UNHEALTHY":    1,
		"STALE_STATUS": 2,
	}
)

var (
	DataprocMetricConfig_MetricSource_name = map[int32]string{
		0: "METRIC_SOURCE_UNSPECIFIED",
		1: "MONITORING_AGENT_DEFAULTS",
		2: "HDFS",
		3: "SPARK",
		4: "YARN",
		5: "SPARK_HISTORY_SERVER",
		6: "HIVESERVER2",
		7: "HIVEMETASTORE",
		8: "FLINK",
	}
	DataprocMetricConfig_MetricSource_value = map[string]int32{
		"METRIC_SOURCE_UNSPECIFIED": 0,
		"MONITORING_AGENT_DEFAULTS": 1,
		"HDFS":                      2,
		"SPARK":                     3,
		"YARN":                      4,
		"SPARK_HISTORY_SERVER":      5,
		"HIVESERVER2":               6,
		"HIVEMETASTORE":             7,
		"FLINK":                     8,
	}
)

var (
	DiagnoseClusterRequest_TarballAccess_name = map[int32]string{
		0: "TARBALL_ACCESS_UNSPECIFIED",
		1: "GOOGLE_CLOUD_SUPPORT",
		2: "GOOGLE_DATAPROC_DIAGNOSE",
	}
	DiagnoseClusterRequest_TarballAccess_value = map[string]int32{
		"TARBALL_ACCESS_UNSPECIFIED": 0,
		"GOOGLE_CLOUD_SUPPORT":       1,
		"GOOGLE_DATAPROC_DIAGNOSE":   2,
	}
)

var (
	ReservationAffinity_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "NO_RESERVATION",
		2: "ANY_RESERVATION",
		3: "SPECIFIC_RESERVATION",
	}
	ReservationAffinity_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":     0,
		"NO_RESERVATION":       1,
		"ANY_RESERVATION":      2,
		"SPECIFIC_RESERVATION": 3,
	}
)

var (
	LoggingConfig_Level_name = map[int32]string{
		0: "LEVEL_UNSPECIFIED",
		1: "ALL",
		2: "TRACE",
		3: "DEBUG",
		4: "INFO",
		5: "WARN",
		6: "ERROR",
		7: "FATAL",
		8: "OFF",
	}
	LoggingConfig_Level_value = map[string]int32{
		"LEVEL_UNSPECIFIED": 0,
		"ALL":               1,
		"TRACE":             2,
		"DEBUG":             3,
		"INFO":              4,
		"WARN":              5,
		"ERROR":             6,
		"FATAL":             7,
		"OFF":               8,
	}
)

var (
	JobStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		8: "SETUP_DONE",
		2: "RUNNING",
		3: "CANCEL_PENDING",
		7: "CANCEL_STARTED",
		4: "CANCELLED",
		5: "DONE",
		6: "ERROR",
		9: "ATTEMPT_FAILURE",
	}
	JobStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"SETUP_DONE":        8,
		"RUNNING":           2,
		"CANCEL_PENDING":    3,
		"CANCEL_STARTED":    7,
		"CANCELLED":         4,
		"DONE":              5,
		"ERROR":             6,
		"ATTEMPT_FAILURE":   9,
	}
)

var (
	JobStatus_Substate_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUBMITTED",
		2: "QUEUED",
		3: "STALE_STATUS",
	}
	JobStatus_Substate_value = map[string]int32{
		"UNSPECIFIED":  0,
		"SUBMITTED":    1,
		"QUEUED":       2,
		"STALE_STATUS": 3,
	}
)

var (
	YarnApplication_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "NEW",
		2: "NEW_SAVING",
		3: "SUBMITTED",
		4: "ACCEPTED",
		5: "RUNNING",
		6: "FINISHED",
		7: "FAILED",
		8: "KILLED",
	}
	YarnApplication_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"NEW":               1,
		"NEW_SAVING":        2,
		"SUBMITTED":         3,
		"ACCEPTED":          4,
		"RUNNING":           5,
		"FINISHED":          6,
		"FAILED":            7,
		"KILLED":            8,
	}
)

var (
	ListJobsRequest_JobStateMatcher_name = map[int32]string{
		0: "ALL",
		1: "ACTIVE",
		2: "NON_ACTIVE",
	}
	ListJobsRequest_JobStateMatcher_value = map[string]int32{
		"ALL":        0,
		"ACTIVE":     1,
		"NON_ACTIVE": 2,
	}
)

var (
	BatchOperationMetadata_BatchOperationType_name = map[int32]string{
		0: "BATCH_OPERATION_TYPE_UNSPECIFIED",
		1: "BATCH",
	}
	BatchOperationMetadata_BatchOperationType_value = map[string]int32{
		"BATCH_OPERATION_TYPE_UNSPECIFIED": 0,
		"BATCH":                            1,
	}
)

var (
	SessionOperationMetadata_SessionOperationType_name = map[int32]string{
		0: "SESSION_OPERATION_TYPE_UNSPECIFIED",
		1: "CREATE",
		2: "TERMINATE",
		3: "DELETE",
	}
	SessionOperationMetadata_SessionOperationType_value = map[string]int32{
		"SESSION_OPERATION_TYPE_UNSPECIFIED": 0,
		"CREATE":                             1,
		"TERMINATE":                          2,
		"DELETE":                             3,
	}
)

var (
	ClusterOperationStatus_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "RUNNING",
		3: "DONE",
	}
	ClusterOperationStatus_State_value = map[string]int32{
		"UNKNOWN": 0,
		"PENDING": 1,
		"RUNNING": 2,
		"DONE":    3,
	}
)

var (
	NodeGroupOperationMetadata_NodeGroupOperationType_name = map[int32]string{
		0: "NODE_GROUP_OPERATION_TYPE_UNSPECIFIED",
		1: "CREATE",
		2: "UPDATE",
		3: "DELETE",
		4: "RESIZE",
	}
	NodeGroupOperationMetadata_NodeGroupOperationType_value = map[string]int32{
		"NODE_GROUP_OPERATION_TYPE_UNSPECIFIED": 0,
		"CREATE":                                1,
		"UPDATE":                                2,
		"DELETE":                                3,
		"RESIZE":                                4,
	}
)

var (
	Session_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "TERMINATING",
		4: "TERMINATED",
		5: "FAILED",
	}
	Session_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"TERMINATING":       3,
		"TERMINATED":        4,
		"FAILED":            5,
	}
)

var (
	JupyterConfig_Kernel_name = map[int32]string{
		0: "KERNEL_UNSPECIFIED",
		1: "PYTHON",
		2: "SCALA",
	}
	JupyterConfig_Kernel_value = map[string]int32{
		"KERNEL_UNSPECIFIED": 0,
		"PYTHON":             1,
		"SCALA":              2,
	}
)

var (
	Component_name = map[int32]string{
		0:  "COMPONENT_UNSPECIFIED",
		5:  "ANACONDA",
		13: "DOCKER",
		9:  "DRUID",
		14: "FLINK",
		11: "HBASE",
		3:  "HIVE_WEBHCAT",
		18: "HUDI",
		1:  "JUPYTER",
		6:  "PRESTO",
		17: "TRINO",
		12: "RANGER",
		10: "SOLR",
		4:  "ZEPPELIN",
		8:  "ZOOKEEPER",
	}
	Component_value = map[string]int32{
		"COMPONENT_UNSPECIFIED": 0,
		"ANACONDA":              5,
		"DOCKER":                13,
		"DRUID":                 9,
		"FLINK":                 14,
		"HBASE":                 11,
		"HIVE_WEBHCAT":          3,
		"HUDI":                  18,
		"JUPYTER":               1,
		"PRESTO":                6,
		"TRINO":                 17,
		"RANGER":                12,
		"SOLR":                  10,
		"ZEPPELIN":              4,
		"ZOOKEEPER":             8,
	}
)

var (
	FailureAction_name = map[int32]string{
		0: "FAILURE_ACTION_UNSPECIFIED",
		1: "NO_ACTION",
		2: "DELETE",
	}
	FailureAction_value = map[string]int32{
		"FAILURE_ACTION_UNSPECIFIED": 0,
		"NO_ACTION":                  1,
		"DELETE":                     2,
	}
)

var (
	GkeNodePoolTarget_Role_name = map[int32]string{
		0: "ROLE_UNSPECIFIED",
		1: "DEFAULT",
		2: "CONTROLLER",
		3: "SPARK_DRIVER",
		4: "SPARK_EXECUTOR",
	}
	GkeNodePoolTarget_Role_value = map[string]int32{
		"ROLE_UNSPECIFIED": 0,
		"DEFAULT":          1,
		"CONTROLLER":       2,
		"SPARK_DRIVER":     3,
		"SPARK_EXECUTOR":   4,
	}
)

var (
	AutotuningConfig_Scenario_name = map[int32]string{
		0: "SCENARIO_UNSPECIFIED",
		2: "SCALING",
		3: "BROADCAST_HASH_JOIN",
		4: "MEMORY",
	}
	AutotuningConfig_Scenario_value = map[string]int32{
		"SCENARIO_UNSPECIFIED": 0,
		"SCALING":              2,
		"BROADCAST_HASH_JOIN":  3,
		"MEMORY":               4,
	}
)

var (
	WorkflowMetadata_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "RUNNING",
		3: "DONE",
	}
	WorkflowMetadata_State_value = map[string]int32{
		"UNKNOWN": 0,
		"PENDING": 1,
		"RUNNING": 2,
		"DONE":    3,
	}
)

var (
	WorkflowNode_NodeState_name = map[int32]string{
		0: "NODE_STATE_UNSPECIFIED",
		1: "BLOCKED",
		2: "RUNNABLE",
		3: "RUNNING",
		4: "COMPLETED",
		5: "FAILED",
	}
	WorkflowNode_NodeState_value = map[string]int32{
		"NODE_STATE_UNSPECIFIED": 0,
		"BLOCKED":                1,
		"RUNNABLE":               2,
		"RUNNING":                3,
		"COMPLETED":              4,
		"FAILED":                 5,
	}
)

var File_google_cloud_dataproc_v1_autoscaling_policies_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_batches_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_clusters_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_jobs_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_node_groups_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_operations_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_session_templates_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_sessions_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_shared_proto protoreflect.FileDescriptor

var File_google_cloud_dataproc_v1_workflow_templates_proto protoreflect.FileDescriptor

func RegisterAutoscalingPolicyServiceServer(s *grpc.Server, srv AutoscalingPolicyServiceServer)

func RegisterBatchControllerServer(s *grpc.Server, srv BatchControllerServer)

func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer)

func RegisterJobControllerServer(s *grpc.Server, srv JobControllerServer)

func RegisterNodeGroupControllerServer(s *grpc.Server, srv NodeGroupControllerServer)

func RegisterSessionControllerServer(s *grpc.Server, srv SessionControllerServer)

func RegisterSessionTemplateControllerServer(s *grpc.Server, srv SessionTemplateControllerServer)

func RegisterWorkflowTemplateServiceServer(s *grpc.Server, srv WorkflowTemplateServiceServer)

type AcceleratorConfig struct {

	// Full URL, partial URI, or short name of the accelerator type resource to
	// expose to this instance. See
	// [Compute Engine
	// AcceleratorTypes](https://cloud.google.com/compute/docs/reference/v1/acceleratorTypes).
	//
	// Examples:
	//
	// * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]/acceleratorTypes/nvidia-tesla-t4`
	// * `projects/[project_id]/zones/[zone]/acceleratorTypes/nvidia-tesla-t4`
	// * `nvidia-tesla-t4`
	//
	// **Auto Zone Exception**: If you are using the Dataproc
	// [Auto Zone
	// Placement](https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement)
	// feature, you must use the short name of the accelerator type
	// resource, for example, `nvidia-tesla-t4`.
	AcceleratorTypeUri string `protobuf:"bytes,1,opt,name=accelerator_type_uri,json=acceleratorTypeUri,proto3" json:"accelerator_type_uri,omitempty"`
	// The number of the accelerator cards of this type exposed to this instance.
	AcceleratorCount int32 `protobuf:"varint,2,opt,name=accelerator_count,json=acceleratorCount,proto3" json:"accelerator_count,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *AcceleratorConfig) GetAcceleratorCount() int32

func (x *AcceleratorConfig) GetAcceleratorTypeUri() string

func (*AcceleratorConfig) ProtoMessage()

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

func (x *AcceleratorConfig) Reset()

func (x *AcceleratorConfig) String() string

type AutoscalingConfig struct {

	// Optional. The autoscaling policy used by the cluster.
	//
	// Only resource names including projectid and location (region) are valid.
	// Examples:
	//
	// * `https://www.googleapis.com/compute/v1/projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]`
	// * `projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]`
	//
	// Note that the policy must be in the same project and Dataproc region.
	PolicyUri string `protobuf:"bytes,1,opt,name=policy_uri,json=policyUri,proto3" json:"policy_uri,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *AutoscalingConfig) GetPolicyUri() string

func (*AutoscalingConfig) ProtoMessage()

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

func (x *AutoscalingConfig) Reset()

func (x *AutoscalingConfig) String() string

type AutoscalingPolicy struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`

	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`

	Algorithm isAutoscalingPolicy_Algorithm `protobuf_oneof:"algorithm"`

	WorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,4,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"`

	SecondaryWorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,5,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

}

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

func (m *AutoscalingPolicy) GetAlgorithm() isAutoscalingPolicy_Algorithm

func (x *AutoscalingPolicy) GetBasicAlgorithm() *BasicAutoscalingAlgorithm

func (x *AutoscalingPolicy) GetId() string

func (x *AutoscalingPolicy) GetLabels() map[string]string

func (x *AutoscalingPolicy) GetName() string

func (x *AutoscalingPolicy) GetSecondaryWorkerConfig() *InstanceGroupAutoscalingPolicyConfig

func (x *AutoscalingPolicy) GetWorkerConfig() *InstanceGroupAutoscalingPolicyConfig

func (*AutoscalingPolicy) ProtoMessage()

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

func (x *AutoscalingPolicy) Reset()

func (x *AutoscalingPolicy) String() string

type AutoscalingPolicyServiceClient interface {
	// Creates new autoscaling policy.
	CreateAutoscalingPolicy(ctx context.Context, in *CreateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error)
	// Updates (replaces) autoscaling policy.
	//
	// Disabled check for update_mask, because all updates will be full
	// replacements.
	UpdateAutoscalingPolicy(ctx context.Context, in *UpdateAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error)
	// Retrieves autoscaling policy.
	GetAutoscalingPolicy(ctx context.Context, in *GetAutoscalingPolicyRequest, opts ...grpc.CallOption) (*AutoscalingPolicy, error)
	// Lists autoscaling policies in the project.
	ListAutoscalingPolicies(ctx context.Context, in *ListAutoscalingPoliciesRequest, opts ...grpc.CallOption) (*ListAutoscalingPoliciesResponse, error)
	// Deletes an autoscaling policy. It is an error to delete an autoscaling
	// policy that is in use by one or more clusters.
	DeleteAutoscalingPolicy(ctx context.Context, in *DeleteAutoscalingPolicyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

func NewAutoscalingPolicyServiceClient(cc grpc.ClientConnInterface) AutoscalingPolicyServiceClient

type AutoscalingPolicyServiceServer interface {
	// Creates new autoscaling policy.
	CreateAutoscalingPolicy(context.Context, *CreateAutoscalingPolicyRequest) (*AutoscalingPolicy, error)
	// Updates (replaces) autoscaling policy.
	//
	// Disabled check for update_mask, because all updates will be full
	// replacements.
	UpdateAutoscalingPolicy(context.Context, *UpdateAutoscalingPolicyRequest) (*AutoscalingPolicy, error)
	// Retrieves autoscaling policy.
	GetAutoscalingPolicy(context.Context, *GetAutoscalingPolicyRequest) (*AutoscalingPolicy, error)
	// Lists autoscaling policies in the project.
	ListAutoscalingPolicies(context.Context, *ListAutoscalingPoliciesRequest) (*ListAutoscalingPoliciesResponse, error)
	// Deletes an autoscaling policy. It is an error to delete an autoscaling
	// policy that is in use by one or more clusters.
	DeleteAutoscalingPolicy(context.Context, *DeleteAutoscalingPolicyRequest) (*emptypb.Empty, error)
}

type AutoscalingPolicy_BasicAlgorithm struct {
	BasicAlgorithm *BasicAutoscalingAlgorithm `protobuf:"bytes,3,opt,name=basic_algorithm,json=basicAlgorithm,proto3,oneof"`
}

type AutotuningConfig struct {
	Scenarios []AutotuningConfig_Scenario "" /* 135 byte string literal not displayed */

}

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

func (x *AutotuningConfig) GetScenarios() []AutotuningConfig_Scenario

func (*AutotuningConfig) ProtoMessage()

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

func (x *AutotuningConfig) Reset()

func (x *AutotuningConfig) String() string

type AutotuningConfig_Scenario int32

const (
	// Default value.
	AutotuningConfig_SCENARIO_UNSPECIFIED AutotuningConfig_Scenario = 0
	// Scaling recommendations such as initialExecutors.
	AutotuningConfig_SCALING AutotuningConfig_Scenario = 2
	// Adding hints for potential relation broadcasts.
	AutotuningConfig_BROADCAST_HASH_JOIN AutotuningConfig_Scenario = 3
	// Memory management for workloads.
	AutotuningConfig_MEMORY AutotuningConfig_Scenario = 4
)

func (AutotuningConfig_Scenario) Descriptor() protoreflect.EnumDescriptor

func (x AutotuningConfig_Scenario) Enum() *AutotuningConfig_Scenario

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

func (x AutotuningConfig_Scenario) Number() protoreflect.EnumNumber

func (x AutotuningConfig_Scenario) String() string

func (AutotuningConfig_Scenario) Type() protoreflect.EnumType

type AuxiliaryNodeGroup struct {

	// Required. Node group configuration.
	NodeGroup *NodeGroup `protobuf:"bytes,1,opt,name=node_group,json=nodeGroup,proto3" json:"node_group,omitempty"`
	// Optional. A node group ID. Generated if not specified.
	//
	// The ID must contain only letters (a-z, A-Z), numbers (0-9),
	// underscores (_), and hyphens (-). Cannot begin or end with underscore
	// or hyphen. Must consist of from 3 to 33 characters.
	NodeGroupId string `protobuf:"bytes,2,opt,name=node_group_id,json=nodeGroupId,proto3" json:"node_group_id,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *AuxiliaryNodeGroup) GetNodeGroup() *NodeGroup

func (x *AuxiliaryNodeGroup) GetNodeGroupId() string

func (*AuxiliaryNodeGroup) ProtoMessage()

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

func (x *AuxiliaryNodeGroup) Reset()

func (x *AuxiliaryNodeGroup) String() string

type AuxiliaryServicesConfig struct {
	MetastoreConfig *MetastoreConfig `protobuf:"bytes,1,opt,name=metastore_config,json=metastoreConfig,proto3" json:"metastore_config,omitempty"`

	SparkHistoryServerConfig *SparkHistoryServerConfig "" /* 137 byte string literal not displayed */

}

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

func (x *AuxiliaryServicesConfig) GetMetastoreConfig() *MetastoreConfig

func (x *AuxiliaryServicesConfig) GetSparkHistoryServerConfig() *SparkHistoryServerConfig

func (*AuxiliaryServicesConfig) ProtoMessage()

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

func (x *AuxiliaryServicesConfig) Reset()

func (x *AuxiliaryServicesConfig) String() string

type BasicAutoscalingAlgorithm struct {

	// Types that are assignable to Config:
	//
	//	*BasicAutoscalingAlgorithm_YarnConfig
	Config isBasicAutoscalingAlgorithm_Config `protobuf_oneof:"config"`
	// Optional. Duration between scaling events. A scaling period starts after
	// the update operation from the previous event has completed.
	//
	// Bounds: [2m, 1d]. Default: 2m.
	CooldownPeriod *durationpb.Duration `protobuf:"bytes,2,opt,name=cooldown_period,json=cooldownPeriod,proto3" json:"cooldown_period,omitempty"`
	// contains filtered or unexported fields
}

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

func (m *BasicAutoscalingAlgorithm) GetConfig() isBasicAutoscalingAlgorithm_Config

func (x *BasicAutoscalingAlgorithm) GetCooldownPeriod() *durationpb.Duration

func (x *BasicAutoscalingAlgorithm) GetYarnConfig() *BasicYarnAutoscalingConfig

func (*BasicAutoscalingAlgorithm) ProtoMessage()

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

func (x *BasicAutoscalingAlgorithm) Reset()

func (x *BasicAutoscalingAlgorithm) String() string

type BasicAutoscalingAlgorithm_YarnConfig struct {
	// Required. YARN autoscaling configuration.
	YarnConfig *BasicYarnAutoscalingConfig `protobuf:"bytes,1,opt,name=yarn_config,json=yarnConfig,proto3,oneof"`
}

type BasicYarnAutoscalingConfig struct {
	GracefulDecommissionTimeout *durationpb.Duration "" /* 144 byte string literal not displayed */

	ScaleUpFactor float64 `protobuf:"fixed64,1,opt,name=scale_up_factor,json=scaleUpFactor,proto3" json:"scale_up_factor,omitempty"`

	ScaleDownFactor float64 `protobuf:"fixed64,2,opt,name=scale_down_factor,json=scaleDownFactor,proto3" json:"scale_down_factor,omitempty"`

	ScaleUpMinWorkerFraction float64 "" /* 141 byte string literal not displayed */

	ScaleDownMinWorkerFraction float64 "" /* 147 byte string literal not displayed */

}

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

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

func (x *BasicYarnAutoscalingConfig) GetScaleDownFactor() float64

func (x *BasicYarnAutoscalingConfig) GetScaleDownMinWorkerFraction() float64

func (x *BasicYarnAutoscalingConfig) GetScaleUpFactor() float64

func (x *BasicYarnAutoscalingConfig) GetScaleUpMinWorkerFraction() float64

func (*BasicYarnAutoscalingConfig) ProtoMessage()

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

func (x *BasicYarnAutoscalingConfig) Reset()

func (x *BasicYarnAutoscalingConfig) String() string

type Batch struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	BatchConfig isBatch_BatchConfig `protobuf_oneof:"batch_config"`

	RuntimeInfo *RuntimeInfo `protobuf:"bytes,8,opt,name=runtime_info,json=runtimeInfo,proto3" json:"runtime_info,omitempty"`

	State Batch_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.dataproc.v1.Batch_State" json:"state,omitempty"`

	StateMessage string `protobuf:"bytes,10,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`

	StateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=state_time,json=stateTime,proto3" json:"state_time,omitempty"`

	Creator string `protobuf:"bytes,12,opt,name=creator,proto3" json:"creator,omitempty"`

	Labels map[string]string "" /* 154 byte string literal not displayed */

	RuntimeConfig *RuntimeConfig `protobuf:"bytes,14,opt,name=runtime_config,json=runtimeConfig,proto3" json:"runtime_config,omitempty"`

	EnvironmentConfig *EnvironmentConfig `protobuf:"bytes,15,opt,name=environment_config,json=environmentConfig,proto3" json:"environment_config,omitempty"`

	Operation string `protobuf:"bytes,16,opt,name=operation,proto3" json:"operation,omitempty"`

	StateHistory []*Batch_StateHistory `protobuf:"bytes,17,rep,name=state_history,json=stateHistory,proto3" json:"state_history,omitempty"`

}

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

func (m *Batch) GetBatchConfig() isBatch_BatchConfig

func (x *Batch) GetCreateTime() *timestamppb.Timestamp

func (x *Batch) GetCreator() string

func (x *Batch) GetEnvironmentConfig() *EnvironmentConfig

func (x *Batch) GetLabels() map[string]string

func (x *Batch) GetName() string

func (x *Batch) GetOperation() string

func (x *Batch) GetPysparkBatch() *PySparkBatch

func (x *Batch) GetRuntimeConfig() *RuntimeConfig

func (x *Batch) GetRuntimeInfo() *RuntimeInfo

func (x *Batch) GetSparkBatch() *SparkBatch

func (x *Batch) GetSparkRBatch() *SparkRBatch

func (x *Batch) GetSparkSqlBatch() *SparkSqlBatch

func (x *Batch) GetState() Batch_State

func (x *Batch) GetStateHistory() []*Batch_StateHistory

func (x *Batch) GetStateMessage() string

func (x *Batch) GetStateTime() *timestamppb.Timestamp

func (x *Batch) GetUuid() string

func (*Batch) ProtoMessage()

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

func (x *Batch) Reset()

func (x *Batch) String() string

type BatchControllerClient interface {
	// Creates a batch workload that executes asynchronously.
	CreateBatch(ctx context.Context, in *CreateBatchRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets the batch workload resource representation.
	GetBatch(ctx context.Context, in *GetBatchRequest, opts ...grpc.CallOption) (*Batch, error)
	// Lists batch workloads.
	ListBatches(ctx context.Context, in *ListBatchesRequest, opts ...grpc.CallOption) (*ListBatchesResponse, error)
	// Deletes the batch workload resource. If the batch is not in terminal state,
	// the delete fails and the response returns `FAILED_PRECONDITION`.
	DeleteBatch(ctx context.Context, in *DeleteBatchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

func NewBatchControllerClient(cc grpc.ClientConnInterface) BatchControllerClient

type BatchControllerServer interface {
	// Creates a batch workload that executes asynchronously.
	CreateBatch(context.Context, *CreateBatchRequest) (*longrunningpb.Operation, error)
	// Gets the batch workload resource representation.
	GetBatch(context.Context, *GetBatchRequest) (*Batch, error)
	// Lists batch workloads.
	ListBatches(context.Context, *ListBatchesRequest) (*ListBatchesResponse, error)
	// Deletes the batch workload resource. If the batch is not in terminal state,
	// the delete fails and the response returns `FAILED_PRECONDITION`.
	DeleteBatch(context.Context, *DeleteBatchRequest) (*emptypb.Empty, error)
}

type BatchOperationMetadata struct {
	Batch string `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`

	BatchUuid string `protobuf:"bytes,2,opt,name=batch_uuid,json=batchUuid,proto3" json:"batch_uuid,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	DoneTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=done_time,json=doneTime,proto3" json:"done_time,omitempty"`

	OperationType BatchOperationMetadata_BatchOperationType "" /* 173 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Warnings []string `protobuf:"bytes,9,rep,name=warnings,proto3" json:"warnings,omitempty"`

}

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

func (x *BatchOperationMetadata) GetBatch() string

func (x *BatchOperationMetadata) GetBatchUuid() string

func (x *BatchOperationMetadata) GetCreateTime() *timestamppb.Timestamp

func (x *BatchOperationMetadata) GetDescription() string

func (x *BatchOperationMetadata) GetDoneTime() *timestamppb.Timestamp

func (x *BatchOperationMetadata) GetLabels() map[string]string

func (x *BatchOperationMetadata) GetOperationType() BatchOperationMetadata_BatchOperationType

func (x *BatchOperationMetadata) GetWarnings() []string

func (*BatchOperationMetadata) ProtoMessage()

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

func (x *BatchOperationMetadata) Reset()

func (x *BatchOperationMetadata) String() string

type BatchOperationMetadata_BatchOperationType int32

const (
	// Batch operation type is unknown.
	BatchOperationMetadata_BATCH_OPERATION_TYPE_UNSPECIFIED BatchOperationMetadata_BatchOperationType = 0
	// Batch operation type.
	BatchOperationMetadata_BATCH BatchOperationMetadata_BatchOperationType = 1
)

func (BatchOperationMetadata_BatchOperationType) Descriptor() protoreflect.EnumDescriptor

func (x BatchOperationMetadata_BatchOperationType) Enum() *BatchOperationMetadata_BatchOperationType

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

func (x BatchOperationMetadata_BatchOperationType) Number() protoreflect.EnumNumber

func (x BatchOperationMetadata_BatchOperationType) String() string

func (BatchOperationMetadata_BatchOperationType) Type() protoreflect.EnumType

type Batch_PysparkBatch struct {
	// Optional. PySpark batch config.
	PysparkBatch *PySparkBatch `protobuf:"bytes,4,opt,name=pyspark_batch,json=pysparkBatch,proto3,oneof"`
}

type Batch_SparkBatch struct {
	// Optional. Spark batch config.
	SparkBatch *SparkBatch `protobuf:"bytes,5,opt,name=spark_batch,json=sparkBatch,proto3,oneof"`
}

type Batch_SparkRBatch struct {
	// Optional. SparkR batch config.
	SparkRBatch *SparkRBatch `protobuf:"bytes,6,opt,name=spark_r_batch,json=sparkRBatch,proto3,oneof"`
}

type Batch_SparkSqlBatch struct {
	// Optional. SparkSql batch config.
	SparkSqlBatch *SparkSqlBatch `protobuf:"bytes,7,opt,name=spark_sql_batch,json=sparkSqlBatch,proto3,oneof"`
}

type Batch_State int32

const (
	// The batch state is unknown.
	Batch_STATE_UNSPECIFIED Batch_State = 0
	// The batch is created before running.
	Batch_PENDING Batch_State = 1
	// The batch is running.
	Batch_RUNNING Batch_State = 2
	// The batch is cancelling.
	Batch_CANCELLING Batch_State = 3
	// The batch cancellation was successful.
	Batch_CANCELLED Batch_State = 4
	// The batch completed successfully.
	Batch_SUCCEEDED Batch_State = 5
	// The batch is no longer running due to an error.
	Batch_FAILED Batch_State = 6
)

func (Batch_State) Descriptor() protoreflect.EnumDescriptor

func (x Batch_State) Enum() *Batch_State

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

func (x Batch_State) Number() protoreflect.EnumNumber

func (x Batch_State) String() string

func (Batch_State) Type() protoreflect.EnumType

type Batch_StateHistory struct {

	// Output only. The state of the batch at this point in history.
	State Batch_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1.Batch_State" json:"state,omitempty"`
	// Output only. Details about the state at this point in history.
	StateMessage string `protobuf:"bytes,2,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	// Output only. The time when the batch entered the historical state.
	StateStartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *Batch_StateHistory) GetState() Batch_State

func (x *Batch_StateHistory) GetStateMessage() string

func (x *Batch_StateHistory) GetStateStartTime() *timestamppb.Timestamp

func (*Batch_StateHistory) ProtoMessage()

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

func (x *Batch_StateHistory) Reset()