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

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 (
	AuthenticationConfig_AuthenticationType_name = map[int32]string{
		0: "AUTHENTICATION_TYPE_UNSPECIFIED",
		1: "SERVICE_ACCOUNT",
		2: "END_USER_CREDENTIALS",
	}
	AuthenticationConfig_AuthenticationType_value = map[string]int32{
		"AUTHENTICATION_TYPE_UNSPECIFIED": 0,
		"SERVICE_ACCOUNT":                 1,
		"END_USER_CREDENTIALS":            2,
	}
)

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 AuthenticationConfig struct {

	// Optional. Authentication type for the user workload running in containers.
	UserWorkloadAuthenticationType AuthenticationConfig_AuthenticationType `protobuf:"varint,1,opt,name=user_workload_authentication_type,json=userWorkloadAuthenticationType,proto3,enum=google.cloud.dataproc.v1.AuthenticationConfig_AuthenticationType" json:"user_workload_authentication_type,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *AuthenticationConfig) GetUserWorkloadAuthenticationType() AuthenticationConfig_AuthenticationType

func (*AuthenticationConfig) ProtoMessage()

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

func (x *AuthenticationConfig) Reset()

func (x *AuthenticationConfig) String() string

type AuthenticationConfig_AuthenticationType int32

const (
	// If AuthenticationType is unspecified then END_USER_CREDENTIALS is used
	// for 3.0 and newer runtimes, and SERVICE_ACCOUNT is used for older
	// runtimes.
	AuthenticationConfig_AUTHENTICATION_TYPE_UNSPECIFIED AuthenticationConfig_AuthenticationType = 0
	// Use service account credentials for authenticating to other services.
	AuthenticationConfig_SERVICE_ACCOUNT AuthenticationConfig_AuthenticationType = 1
	// Use OAuth credentials associated with the workload creator/user for
	// authenticating to other services.
	AuthenticationConfig_END_USER_CREDENTIALS AuthenticationConfig_AuthenticationType = 2
)

func (AuthenticationConfig_AuthenticationType) Descriptor() protoreflect.EnumDescriptor

func (x AuthenticationConfig_AuthenticationType) Enum() *AuthenticationConfig_AuthenticationType

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

func (x AuthenticationConfig_AuthenticationType) Number() protoreflect.EnumNumber

func (x AuthenticationConfig_AuthenticationType) String() string

func (AuthenticationConfig_AuthenticationType) Type() protoreflect.EnumType

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 {

	// Required. The policy id.
	//
	// 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 between 3 and 50 characters.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Output only. The "resource name" of the autoscaling policy, as described
	// in https://cloud.google.com/apis/design/resource_names.
	//
	//   - For `projects.regions.autoscalingPolicies`, the resource name of the
	//     policy has the following format:
	//     `projects/{project_id}/regions/{region}/autoscalingPolicies/{policy_id}`
	//
	//   - For `projects.locations.autoscalingPolicies`, the resource name of the
	//     policy has the following format:
	//     `projects/{project_id}/locations/{location}/autoscalingPolicies/{policy_id}`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Autoscaling algorithm for policy.
	//
	// Types that are assignable to Algorithm:
	//
	//	*AutoscalingPolicy_BasicAlgorithm
	Algorithm isAutoscalingPolicy_Algorithm `protobuf_oneof:"algorithm"`
	// Required. Describes how the autoscaler will operate for primary workers.
	WorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,4,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"`
	// Optional. Describes how the autoscaler will operate for secondary workers.
	SecondaryWorkerConfig *InstanceGroupAutoscalingPolicyConfig `protobuf:"bytes,5,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"`
	// Optional. The labels to associate with this autoscaling policy.
	// Label **keys** must contain 1 to 63 characters, and must conform to
	// [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt).
	// Label **values** may be empty, but, if present, must contain 1 to 63
	// characters, and must conform to [RFC
	// 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be
	// associated with an autoscaling policy.
	Labels map[string]string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

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 {

	// Optional. Scenarios for which tunings are applied.
	Scenarios []AutotuningConfig_Scenario `protobuf:"varint,2,rep,packed,name=scenarios,proto3,enum=google.cloud.dataproc.v1.AutotuningConfig_Scenario" json:"scenarios,omitempty"`
	// contains filtered or unexported fields
}

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 {

	// Optional. The Hive Metastore configuration for this workload.
	MetastoreConfig *MetastoreConfig `protobuf:"bytes,1,opt,name=metastore_config,json=metastoreConfig,proto3" json:"metastore_config,omitempty"`
	// Optional. The Spark History Server configuration for the workload.
	SparkHistoryServerConfig *SparkHistoryServerConfig `protobuf:"bytes,2,opt,name=spark_history_server_config,json=sparkHistoryServerConfig,proto3" json:"spark_history_server_config,omitempty"`
	// contains filtered or unexported fields
}

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 {

	// Required. Timeout for YARN graceful decommissioning of Node Managers.
	// Specifies the duration to wait for jobs to complete before forcefully
	// removing workers (and potentially interrupting jobs). Only applicable to
	// downscaling operations.
	//
	// Bounds: [0s, 1d].
	GracefulDecommissionTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"`
	// Required. Fraction of average YARN pending memory in the last cooldown
	// period for which to add workers. A scale-up factor of 1.0 will result in
	// scaling up so that there is no pending memory remaining after the update
	// (more aggressive scaling). A scale-up factor closer to 0 will result in a
	// smaller magnitude of scaling up (less aggressive scaling). See [How
	// autoscaling
	// works](https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/autoscaling#how_autoscaling_works)
	// for more information.
	//
	// Bounds: [0.0, 1.0].
	ScaleUpFactor float64 `protobuf:"fixed64,1,opt,name=scale_up_factor,json=scaleUpFactor,proto3" json:"scale_up_factor,omitempty"`
	// Required. Fraction of average YARN pending memory in the last cooldown
	// period for which to remove workers. A scale-down factor of 1 will result in
	// scaling down so that there is no available memory remaining after the
	// update (more aggressive scaling). A scale-down factor of 0 disables
	// removing workers, which can be beneficial for autoscaling a single job.
	// See [How autoscaling
	// works](https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/autoscaling#how_autoscaling_works)
	// for more information.
	//
	// Bounds: [0.0, 1.0].
	ScaleDownFactor float64 `protobuf:"fixed64,2,opt,name=scale_down_factor,json=scaleDownFactor,proto3" json:"scale_down_factor,omitempty"`
	// Optional. Minimum scale-up threshold as a fraction of total cluster size
	// before scaling occurs. For example, in a 20-worker cluster, a threshold of
	// 0.1 means the autoscaler must recommend at least a 2-worker scale-up for
	// the cluster to scale. A threshold of 0 means the autoscaler will scale up
	// on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	ScaleUpMinWorkerFraction float64 `protobuf:"fixed64,3,opt,name=scale_up_min_worker_fraction,json=scaleUpMinWorkerFraction,proto3" json:"scale_up_min_worker_fraction,omitempty"`
	// Optional. Minimum scale-down threshold as a fraction of total cluster size
	// before scaling occurs. For example, in a 20-worker cluster, a threshold of
	// 0.1 means the autoscaler must recommend at least a 2 worker scale-down for
	// the cluster to scale. A threshold of 0 means the autoscaler will scale down
	// on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	ScaleDownMinWorkerFraction float64 `protobuf:"fixed64,4,opt,name=scale_down_min_worker_fraction,json=scaleDownMinWorkerFraction,proto3" json:"scale_down_min_worker_fraction,omitempty"`
	// contains filtered or unexported fields
}

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 {

	// Output only. The resource name of the batch.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. A batch UUID (Unique Universal Identifier). The service
	// generates this value when it creates the batch.
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Output only. The time when the batch was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The application/framework-specific portion of the batch configuration.
	//
	// Types that are assignable to BatchConfig:
	//
	//	*Batch_PysparkBatch
	//	*Batch_SparkBatch
	//	*Batch_SparkRBatch
	//	*Batch_SparkSqlBatch
	BatchConfig isBatch_BatchConfig `protobuf_oneof:"batch_config"`
	// Output only. Runtime information about batch execution.
	RuntimeInfo *RuntimeInfo `protobuf:"bytes,8,opt,name=runtime_info,json=runtimeInfo,proto3" json:"runtime_info,omitempty"`
	// Output only. The state of the batch.
	State Batch_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.dataproc.v1.Batch_State" json:"state,omitempty"`
	// Output only. Batch state details, such as a failure
	// description if the state is `FAILED`.
	StateMessage string `protobuf:"bytes,10,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	// Output only. The time when the batch entered a current state.
	StateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=state_time,json=stateTime,proto3" json:"state_time,omitempty"`
	// Output only. The email address of the user who created the batch.
	Creator string `protobuf:"bytes,12,opt,name=creator,proto3" json:"creator,omitempty"`
	// Optional. The labels to associate with this batch.
	// Label **keys** must contain 1 to 63 characters, and must conform to
	// [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt).
	// Label **values** may be empty, but, if present, must contain 1 to 63
	// characters, and must conform to [RFC
	// 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be
	// associated with a batch.
	Labels map[string]string `protobuf:"bytes,13,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Runtime configuration for the batch execution.
	RuntimeConfig *RuntimeConfig `protobuf:"bytes,14,opt,name=runtime_config,json=runtimeConfig,proto3" json:"runtime_config,omitempty"`
	// Optional. Environment configuration for the batch execution.
	EnvironmentConfig *EnvironmentConfig `protobuf:"bytes,15,opt,name=environment_config,json=environmentConfig,proto3" json:"environment_config,omitempty"`
	// Output only. The resource name of the operation associated with this batch.
	Operation string `protobuf:"bytes,16,opt,name=operation,proto3" json:"operation,omitempty"`
	// Output only. Historical state information for the batch.
	StateHistory []*Batch_StateHistory `protobuf:"bytes,17,rep,name=state_history,json=stateHistory,proto3" json:"state_history,omitempty"`
	// contains filtered or unexported fields
}

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 {

	// Name of the batch for the operation.
	Batch string `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// Batch UUID for the operation.
	BatchUuid string `protobuf:"bytes,2,opt,name=batch_uuid,json=batchUuid,proto3" json:"batch_uuid,omitempty"`
	// The time when the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The time when the operation finished.
	DoneTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=done_time,json=doneTime,proto3" json:"done_time,omitempty"`
	// The operation type.
	OperationType BatchOperationMetadata_BatchOperationType `protobuf:"varint,6,opt,name=operation_type,json=operationType,proto3,enum=google.cloud.dataproc.v1.BatchOperationMetadata_BatchOperationType" json:"operation_type,omitempty"`
	// Short description of the operation.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Labels associated with the operation.
	Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Warnings encountered during operation execution.
	Warnings []string `protobuf:"bytes,9,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

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