v1beta1

package
v1.107.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Generate deepcopy object for dataproc/v1beta1 API group

Package v1beta1 contains API Schema definitions for the dataproc v1beta1 API group. +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/pkg/apis/dataproc +k8s:defaulter-gen=TypeMeta +groupName=dataproc.cnrm.cloud.google.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is the group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "dataproc.cnrm.cloud.google.com", Version: "v1beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}

	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme

	DataprocAutoscalingPolicyGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DataprocAutoscalingPolicy{}).Name(),
	}

	DataprocClusterGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DataprocCluster{}).Name(),
	}

	DataprocWorkflowTemplateGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DataprocWorkflowTemplate{}).Name(),
	}
)

Functions

This section is empty.

Types

type AutoscalingpolicyBasicAlgorithm 

type AutoscalingpolicyBasicAlgorithm struct {
	/* Optional. Duration between scaling events. A scaling period starts after the update operation from the previous event has completed. Bounds: . Default: 2m. */
	// +optional
	CooldownPeriod *string `json:"cooldownPeriod,omitempty"`

	/* Required. YARN autoscaling configuration. */
	YarnConfig AutoscalingpolicyYarnConfig `json:"yarnConfig"`
}

func (*AutoscalingpolicyBasicAlgorithm) DeepCopy 

func (in *AutoscalingpolicyBasicAlgorithm) DeepCopy() *AutoscalingpolicyBasicAlgorithm

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AutoscalingpolicyBasicAlgorithm.

func (*AutoscalingpolicyBasicAlgorithm) DeepCopyInto 

func (in *AutoscalingpolicyBasicAlgorithm) DeepCopyInto(out *AutoscalingpolicyBasicAlgorithm)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AutoscalingpolicySecondaryWorkerConfig 

type AutoscalingpolicySecondaryWorkerConfig struct {
	/* Optional. Maximum number of instances for this group. Note that by default, clusters will not use secondary workers. Required for secondary workers if the minimum secondary instances is set. Primary workers - Bounds: [min_instances, ). Secondary workers - Bounds: [min_instances, ). Default: 0. */
	// +optional
	MaxInstances *int `json:"maxInstances,omitempty"`

	/* Optional. Minimum number of instances for this group. Primary workers - Bounds: . Default: 0. */
	// +optional
	MinInstances *int `json:"minInstances,omitempty"`

	/* Optional. Weight for the instance group, which is used to determine the fraction of total workers in the cluster from this instance group. For example, if primary workers have weight 2, and secondary workers have weight 1, the cluster will have approximately 2 primary workers for each secondary worker. The cluster may not reach the specified balance if constrained by min/max bounds or other autoscaling settings. For example, if `max_instances` for secondary workers is 0, then only primary workers will be added. The cluster can also be out of balance when created. If weight is not set on any instance group, the cluster will default to equal weight for all groups: the cluster will attempt to maintain an equal number of workers in each group within the configured size bounds for each group. If weight is set for one group only, the cluster will default to zero weight on the unset group. For example if weight is set only on primary workers, the cluster will use primary workers only and no secondary workers. */
	// +optional
	Weight *int `json:"weight,omitempty"`
}

func (*AutoscalingpolicySecondaryWorkerConfig) DeepCopy 

func (in *AutoscalingpolicySecondaryWorkerConfig) DeepCopy() *AutoscalingpolicySecondaryWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AutoscalingpolicySecondaryWorkerConfig.

func (*AutoscalingpolicySecondaryWorkerConfig) DeepCopyInto 

func (in *AutoscalingpolicySecondaryWorkerConfig) DeepCopyInto(out *AutoscalingpolicySecondaryWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AutoscalingpolicyWorkerConfig 

type AutoscalingpolicyWorkerConfig struct {
	/* Required. Maximum number of instances for this group. Required for primary workers. Note that by default, clusters will not use secondary workers. Required for secondary workers if the minimum secondary instances is set. Primary workers - Bounds: [min_instances, ). Secondary workers - Bounds: [min_instances, ). Default: 0. */
	MaxInstances int `json:"maxInstances"`

	/* Optional. Minimum number of instances for this group. Primary workers - Bounds: . Default: 0. */
	// +optional
	MinInstances *int `json:"minInstances,omitempty"`

	/* Optional. Weight for the instance group, which is used to determine the fraction of total workers in the cluster from this instance group. For example, if primary workers have weight 2, and secondary workers have weight 1, the cluster will have approximately 2 primary workers for each secondary worker. The cluster may not reach the specified balance if constrained by min/max bounds or other autoscaling settings. For example, if `max_instances` for secondary workers is 0, then only primary workers will be added. The cluster can also be out of balance when created. If weight is not set on any instance group, the cluster will default to equal weight for all groups: the cluster will attempt to maintain an equal number of workers in each group within the configured size bounds for each group. If weight is set for one group only, the cluster will default to zero weight on the unset group. For example if weight is set only on primary workers, the cluster will use primary workers only and no secondary workers. */
	// +optional
	Weight *int `json:"weight,omitempty"`
}

func (*AutoscalingpolicyWorkerConfig) DeepCopy 

func (in *AutoscalingpolicyWorkerConfig) DeepCopy() *AutoscalingpolicyWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AutoscalingpolicyWorkerConfig.

func (*AutoscalingpolicyWorkerConfig) DeepCopyInto 

func (in *AutoscalingpolicyWorkerConfig) DeepCopyInto(out *AutoscalingpolicyWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AutoscalingpolicyYarnConfig 

type AutoscalingpolicyYarnConfig 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. */
	GracefulDecommissionTimeout string `json:"gracefulDecommissionTimeout"`

	/* 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 . */
	ScaleDownFactor float64 `json:"scaleDownFactor"`

	/* 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: . Default: 0.0. */
	// +optional
	ScaleDownMinWorkerFraction *float64 `json:"scaleDownMinWorkerFraction,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 . */
	ScaleUpFactor float64 `json:"scaleUpFactor"`

	/* 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: . Default: 0.0. */
	// +optional
	ScaleUpMinWorkerFraction *float64 `json:"scaleUpMinWorkerFraction,omitempty"`
}

func (*AutoscalingpolicyYarnConfig) DeepCopy 

func (in *AutoscalingpolicyYarnConfig) DeepCopy() *AutoscalingpolicyYarnConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AutoscalingpolicyYarnConfig.

func (*AutoscalingpolicyYarnConfig) DeepCopyInto 

func (in *AutoscalingpolicyYarnConfig) DeepCopyInto(out *AutoscalingpolicyYarnConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterAccelerators 

type ClusterAccelerators struct {
	/* Immutable. The number of accelerator cards exposed to an instance. */
	// +optional
	AcceleratorCount *int `json:"acceleratorCount,omitempty"`

	/* Immutable. The accelerator type resource namename (see GPUs on Compute Engine). */
	// +optional
	AcceleratorType *string `json:"acceleratorType,omitempty"`

	/* Immutable. Size of partitions to create on the GPU. Valid values are described in the NVIDIA [mig user guide](https://docs.nvidia.com/datacenter/tesla/mig-user-guide/#partitioning). */
	// +optional
	GpuPartitionSize *string `json:"gpuPartitionSize,omitempty"`
}

func (*ClusterAccelerators) DeepCopy 

func (in *ClusterAccelerators) DeepCopy() *ClusterAccelerators

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterAccelerators.

func (*ClusterAccelerators) DeepCopyInto 

func (in *ClusterAccelerators) DeepCopyInto(out *ClusterAccelerators)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterAutoscaling added in v1.97.0 

type ClusterAutoscaling struct {
	/* Immutable. The maximum number of nodes in the node pool. Must be >= min_node_count, and must be > 0. **Note:** Quota must be sufficient to scale up the cluster. */
	// +optional
	MaxNodeCount *int `json:"maxNodeCount,omitempty"`

	/* Immutable. The minimum number of nodes in the node pool. Must be >= 0 and <= max_node_count. */
	// +optional
	MinNodeCount *int `json:"minNodeCount,omitempty"`
}

func (*ClusterAutoscaling) DeepCopy added in v1.97.0 

func (in *ClusterAutoscaling) DeepCopy() *ClusterAutoscaling

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterAutoscaling.

func (*ClusterAutoscaling) DeepCopyInto added in v1.97.0 

func (in *ClusterAutoscaling) DeepCopyInto(out *ClusterAutoscaling)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterAutoscalingConfig 

type ClusterAutoscalingConfig struct {
	/* Immutable. */
	// +optional
	PolicyRef *v1alpha1.ResourceRef `json:"policyRef,omitempty"`
}

func (*ClusterAutoscalingConfig) DeepCopy 

func (in *ClusterAutoscalingConfig) DeepCopy() *ClusterAutoscalingConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterAutoscalingConfig.

func (*ClusterAutoscalingConfig) DeepCopyInto 

func (in *ClusterAutoscalingConfig) DeepCopyInto(out *ClusterAutoscalingConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterAuxiliaryServicesConfig added in v1.97.0 

type ClusterAuxiliaryServicesConfig struct {
	/* Immutable. Optional. The Hive Metastore configuration for this workload. */
	// +optional
	MetastoreConfig *ClusterMetastoreConfig `json:"metastoreConfig,omitempty"`

	/* Immutable. Optional. The Spark History Server configuration for the workload. */
	// +optional
	SparkHistoryServerConfig *ClusterSparkHistoryServerConfig `json:"sparkHistoryServerConfig,omitempty"`
}

func (*ClusterAuxiliaryServicesConfig) DeepCopy added in v1.97.0 

func (in *ClusterAuxiliaryServicesConfig) DeepCopy() *ClusterAuxiliaryServicesConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterAuxiliaryServicesConfig.

func (*ClusterAuxiliaryServicesConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterAuxiliaryServicesConfig) DeepCopyInto(out *ClusterAuxiliaryServicesConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterConfidentialInstanceConfig added in v1.97.0 

type ClusterConfidentialInstanceConfig struct {
	/* Immutable. Optional. Defines whether the instance should have confidential compute enabled. */
	// +optional
	EnableConfidentialCompute *bool `json:"enableConfidentialCompute,omitempty"`
}

func (*ClusterConfidentialInstanceConfig) DeepCopy added in v1.97.0 

func (in *ClusterConfidentialInstanceConfig) DeepCopy() *ClusterConfidentialInstanceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterConfidentialInstanceConfig.

func (*ClusterConfidentialInstanceConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterConfidentialInstanceConfig) DeepCopyInto(out *ClusterConfidentialInstanceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterConfig 

type ClusterConfig struct {
	/* Immutable. Optional. A list of [hardware accelerators](https://cloud.google.com/compute/docs/gpus) to attach to each node. */
	// +optional
	Accelerators []ClusterAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. The [Customer Managed Encryption Key (CMEK)] (https://cloud.google.com/kubernetes-engine/docs/how-to/using-cmek) used to encrypt the boot disk attached to each node in the node pool. Specify the key using the following format: `projects/KEY_PROJECT_ID/locations/LOCATION/keyRings/RING_NAME/cryptoKeys/KEY_NAME`. */
	// +optional
	BootDiskKmsKey *string `json:"bootDiskKmsKey,omitempty"`

	/* Immutable. Optional. Parameters for the ephemeral storage filesystem. If unspecified, ephemeral storage is backed by the boot disk. */
	// +optional
	EphemeralStorageConfig *ClusterEphemeralStorageConfig `json:"ephemeralStorageConfig,omitempty"`

	/* Immutable. Optional. The number of local SSD disks to attach to the node, which is limited by the maximum number of disks allowable per zone (see [Adding Local SSDs](https://cloud.google.com/compute/docs/disks/local-ssd)). */
	// +optional
	LocalSsdCount *int `json:"localSsdCount,omitempty"`

	/* Immutable. Optional. The name of a Compute Engine [machine type](https://cloud.google.com/compute/docs/machine-types). */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. [Minimum CPU platform](https://cloud.google.com/compute/docs/instances/specify-min-cpu-platform) to be used by this instance. The instance may be scheduled on the specified or a newer CPU platform. Specify the friendly names of CPU platforms, such as "Intel Haswell"` or Intel Sandy Bridge". */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. Whether the nodes are created as legacy [preemptible VM instances] (https://cloud.google.com/compute/docs/instances/preemptible). Also see Spot VMs, preemptible VM instances without a maximum lifetime. Legacy and Spot preemptible nodes cannot be used in a node pool with the `CONTROLLER` [role] (/dataproc/docs/reference/rest/v1/projects.regions.clusters#role) or in the DEFAULT node pool if the CONTROLLER role is not assigned (the DEFAULT node pool will assume the CONTROLLER role). */
	// +optional
	Preemptible *bool `json:"preemptible,omitempty"`

	/* Immutable. Optional. Whether the nodes are created as [Spot VM instances] (https://cloud.google.com/compute/docs/instances/spot). Spot VMs are the latest update to legacy preemptible VMs. Spot VMs do not have a maximum lifetime. Legacy and Spot preemptible nodes cannot be used in a node pool with the `CONTROLLER` [role](/dataproc/docs/reference/rest/v1/projects.regions.clusters#role) or in the DEFAULT node pool if the CONTROLLER role is not assigned (the DEFAULT node pool will assume the CONTROLLER role). */
	// +optional
	Spot *bool `json:"spot,omitempty"`
}

func (*ClusterConfig) DeepCopy 

func (in *ClusterConfig) DeepCopy() *ClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterConfig.

func (*ClusterConfig) DeepCopyInto 

func (in *ClusterConfig) DeepCopyInto(out *ClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterConfigStatus 

type ClusterConfigStatus struct {
	// +optional
	EndpointConfig *ClusterEndpointConfigStatus `json:"endpointConfig,omitempty"`

	// +optional
	LifecycleConfig *ClusterLifecycleConfigStatus `json:"lifecycleConfig,omitempty"`

	// +optional
	MasterConfig *ClusterMasterConfigStatus `json:"masterConfig,omitempty"`

	// +optional
	SecondaryWorkerConfig *ClusterSecondaryWorkerConfigStatus `json:"secondaryWorkerConfig,omitempty"`

	// +optional
	WorkerConfig *ClusterWorkerConfigStatus `json:"workerConfig,omitempty"`
}

func (*ClusterConfigStatus) DeepCopy 

func (in *ClusterConfigStatus) DeepCopy() *ClusterConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterConfigStatus.

func (*ClusterConfigStatus) DeepCopyInto 

func (in *ClusterConfigStatus) DeepCopyInto(out *ClusterConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterDataprocMetricConfig added in v1.97.0 

type ClusterDataprocMetricConfig struct {
	/* Immutable. Required. Metrics sources to enable. */
	Metrics []ClusterMetrics `json:"metrics"`
}

func (*ClusterDataprocMetricConfig) DeepCopy added in v1.97.0 

func (in *ClusterDataprocMetricConfig) DeepCopy() *ClusterDataprocMetricConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterDataprocMetricConfig.

func (*ClusterDataprocMetricConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterDataprocMetricConfig) DeepCopyInto(out *ClusterDataprocMetricConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterDiskConfig 

type ClusterDiskConfig struct {
	/* Immutable. Optional. Size in GB of the boot disk (default is 500GB). */
	// +optional
	BootDiskSizeGb *int `json:"bootDiskSizeGb,omitempty"`

	/* Immutable. Optional. Type of the boot disk (default is "pd-standard"). Valid values: "pd-balanced" (Persistent Disk Balanced Solid State Drive), "pd-ssd" (Persistent Disk Solid State Drive), or "pd-standard" (Persistent Disk Hard Disk Drive). See [Disk types](https://cloud.google.com/compute/docs/disks#disk-types). */
	// +optional
	BootDiskType *string `json:"bootDiskType,omitempty"`

	/* Immutable. Optional. Interface type of local SSDs (default is "scsi"). Valid values: "scsi" (Small Computer System Interface), "nvme" (Non-Volatile Memory Express). See [local SSD performance](https://cloud.google.com/compute/docs/disks/local-ssd#performance). */
	// +optional
	LocalSsdInterface *string `json:"localSsdInterface,omitempty"`

	/* Immutable. Optional. Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are not attached, the boot disk is used to store runtime logs and [HDFS](https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. If one or more SSDs are attached, this runtime bulk data is spread across them, and the boot disk contains only basic config and installed binaries. */
	// +optional
	NumLocalSsds *int `json:"numLocalSsds,omitempty"`
}

func (*ClusterDiskConfig) DeepCopy 

func (in *ClusterDiskConfig) DeepCopy() *ClusterDiskConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterDiskConfig.

func (*ClusterDiskConfig) DeepCopyInto 

func (in *ClusterDiskConfig) DeepCopyInto(out *ClusterDiskConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterEncryptionConfig 

type ClusterEncryptionConfig struct {
	/* Immutable. */
	// +optional
	GcePdKmsKeyRef *v1alpha1.ResourceRef `json:"gcePdKmsKeyRef,omitempty"`
}

func (*ClusterEncryptionConfig) DeepCopy 

func (in *ClusterEncryptionConfig) DeepCopy() *ClusterEncryptionConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEncryptionConfig.

func (*ClusterEncryptionConfig) DeepCopyInto 

func (in *ClusterEncryptionConfig) DeepCopyInto(out *ClusterEncryptionConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterEndpointConfig 

type ClusterEndpointConfig struct {
	/* Immutable. Optional. If true, enable http access to specific ports on the cluster from external sources. Defaults to false. */
	// +optional
	EnableHttpPortAccess *bool `json:"enableHttpPortAccess,omitempty"`
}

func (*ClusterEndpointConfig) DeepCopy 

func (in *ClusterEndpointConfig) DeepCopy() *ClusterEndpointConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpointConfig.

func (*ClusterEndpointConfig) DeepCopyInto 

func (in *ClusterEndpointConfig) DeepCopyInto(out *ClusterEndpointConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterEndpointConfigStatus 

type ClusterEndpointConfigStatus struct {
	/* Output only. The map of port descriptions to URLs. Will only be populated if enable_http_port_access is true. */
	// +optional
	HttpPorts map[string]string `json:"httpPorts,omitempty"`
}

func (*ClusterEndpointConfigStatus) DeepCopy 

func (in *ClusterEndpointConfigStatus) DeepCopy() *ClusterEndpointConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEndpointConfigStatus.

func (*ClusterEndpointConfigStatus) DeepCopyInto 

func (in *ClusterEndpointConfigStatus) DeepCopyInto(out *ClusterEndpointConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterEphemeralStorageConfig added in v1.97.0 

type ClusterEphemeralStorageConfig struct {
	/* Immutable. Number of local SSDs to use to back ephemeral storage. Uses NVMe interfaces. Each local SSD is 375 GB in size. If zero, it means to disable using local SSDs as ephemeral storage. */
	// +optional
	LocalSsdCount *int `json:"localSsdCount,omitempty"`
}

func (*ClusterEphemeralStorageConfig) DeepCopy added in v1.97.0 

func (in *ClusterEphemeralStorageConfig) DeepCopy() *ClusterEphemeralStorageConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterEphemeralStorageConfig.

func (*ClusterEphemeralStorageConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterEphemeralStorageConfig) DeepCopyInto(out *ClusterEphemeralStorageConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterGceClusterConfig 

type ClusterGceClusterConfig struct {
	/* Immutable. Optional. Confidential Instance Config for clusters using [Confidential VMs](https://cloud.google.com/compute/confidential-vm/docs). */
	// +optional
	ConfidentialInstanceConfig *ClusterConfidentialInstanceConfig `json:"confidentialInstanceConfig,omitempty"`

	/* Immutable. Optional. If true, all instances in the cluster will only have internal IP addresses. By default, clusters are not restricted to internal IP addresses, and will have ephemeral external IP addresses assigned to each instance. This `internal_ip_only` restriction can only be enabled for subnetwork enabled networks, and all off-cluster dependencies must be configured to be accessible without external IP addresses. */
	// +optional
	InternalIPOnly *bool `json:"internalIPOnly,omitempty"`

	/* Immutable. The Compute Engine metadata entries to add to all instances (see [Project and instance metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)). */
	// +optional
	Metadata map[string]string `json:"metadata,omitempty"`

	/* Immutable. */
	// +optional
	NetworkRef *v1alpha1.ResourceRef `json:"networkRef,omitempty"`

	/* Immutable. Optional. Node Group Affinity for sole-tenant clusters. */
	// +optional
	NodeGroupAffinity *ClusterNodeGroupAffinity `json:"nodeGroupAffinity,omitempty"`

	/* Immutable. Optional. The type of IPv6 access for a cluster. Possible values: PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED, INHERIT_FROM_SUBNETWORK, OUTBOUND, BIDIRECTIONAL */
	// +optional
	PrivateIPv6GoogleAccess *string `json:"privateIPv6GoogleAccess,omitempty"`

	/* Immutable. Optional. Reservation Affinity for consuming Zonal reservation. */
	// +optional
	ReservationAffinity *ClusterReservationAffinity `json:"reservationAffinity,omitempty"`

	/* Immutable. */
	// +optional
	ServiceAccountRef *v1alpha1.ResourceRef `json:"serviceAccountRef,omitempty"`

	/* Immutable. Optional. The URIs of service account scopes to be included in Compute Engine instances. The following base set of scopes is always included: * https://www.googleapis.com/auth/cloud.useraccounts.readonly * https://www.googleapis.com/auth/devstorage.read_write * https://www.googleapis.com/auth/logging.write If no scopes are specified, the following defaults are also provided: * https://www.googleapis.com/auth/bigquery * https://www.googleapis.com/auth/bigtable.admin.table * https://www.googleapis.com/auth/bigtable.data * https://www.googleapis.com/auth/devstorage.full_control */
	// +optional
	ServiceAccountScopes []string `json:"serviceAccountScopes,omitempty"`

	/* Immutable. Optional. Shielded Instance Config for clusters using [Compute Engine Shielded VMs](https://cloud.google.com/security/shielded-cloud/shielded-vm). */
	// +optional
	ShieldedInstanceConfig *ClusterShieldedInstanceConfig `json:"shieldedInstanceConfig,omitempty"`

	/* Immutable. */
	// +optional
	SubnetworkRef *v1alpha1.ResourceRef `json:"subnetworkRef,omitempty"`

	/* Immutable. The Compute Engine tags to add to all instances (see [Tagging instances](https://cloud.google.com/compute/docs/label-or-tag-resources#tags)). */
	// +optional
	Tags []string `json:"tags,omitempty"`

	/* Immutable. Optional. The zone where the Compute Engine cluster will be located. On a create request, it is required in the "global" region. If omitted in a non-global Dataproc region, the service will pick a zone in the corresponding Compute Engine region. On a get request, zone will always be present. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]` * `projects/[project_id]/zones/[zone]` * `us-central1-f` */
	// +optional
	Zone *string `json:"zone,omitempty"`
}

func (*ClusterGceClusterConfig) DeepCopy 

func (in *ClusterGceClusterConfig) DeepCopy() *ClusterGceClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterGceClusterConfig.

func (*ClusterGceClusterConfig) DeepCopyInto 

func (in *ClusterGceClusterConfig) DeepCopyInto(out *ClusterGceClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterGkeClusterConfig added in v1.97.0 

type ClusterGkeClusterConfig struct {
	/* Immutable. */
	// +optional
	GkeClusterTargetRef *v1alpha1.ResourceRef `json:"gkeClusterTargetRef,omitempty"`

	/* Immutable. Optional. GKE node pools where workloads will be scheduled. At least one node pool must be assigned the `DEFAULT` GkeNodePoolTarget.Role. If a `GkeNodePoolTarget` is not specified, Dataproc constructs a `DEFAULT` `GkeNodePoolTarget`. Each role can be given to only one `GkeNodePoolTarget`. All node pools must have the same location settings. */
	// +optional
	NodePoolTarget []ClusterNodePoolTarget `json:"nodePoolTarget,omitempty"`
}

func (*ClusterGkeClusterConfig) DeepCopy added in v1.97.0 

func (in *ClusterGkeClusterConfig) DeepCopy() *ClusterGkeClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterGkeClusterConfig.

func (*ClusterGkeClusterConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterGkeClusterConfig) DeepCopyInto(out *ClusterGkeClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterIdentityConfig added in v1.97.0 

type ClusterIdentityConfig struct {
	/* Immutable. Required. Map of user to service account. */
	UserServiceAccountMapping map[string]string `json:"userServiceAccountMapping"`
}

func (*ClusterIdentityConfig) DeepCopy added in v1.97.0 

func (in *ClusterIdentityConfig) DeepCopy() *ClusterIdentityConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterIdentityConfig.

func (*ClusterIdentityConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterIdentityConfig) DeepCopyInto(out *ClusterIdentityConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterInitializationActions 

type ClusterInitializationActions struct {
	/* Immutable. Required. Cloud Storage URI of executable file. */
	ExecutableFile string `json:"executableFile"`

	/* Immutable. Optional. Amount of time executable has to complete. Default is 10 minutes (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). Cluster creation fails with an explanatory error message (the name of the executable that caused the error and the exceeded timeout period) if the executable is not completed at end of the timeout period. */
	// +optional
	ExecutionTimeout *string `json:"executionTimeout,omitempty"`
}

func (*ClusterInitializationActions) DeepCopy 

func (in *ClusterInitializationActions) DeepCopy() *ClusterInitializationActions

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInitializationActions.

func (*ClusterInitializationActions) DeepCopyInto 

func (in *ClusterInitializationActions) DeepCopyInto(out *ClusterInitializationActions)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterInstanceReferencesStatus added in v1.97.0 

type ClusterInstanceReferencesStatus struct {
	/* The unique identifier of the Compute Engine instance. */
	// +optional
	InstanceId *string `json:"instanceId,omitempty"`

	/* The user-friendly name of the Compute Engine instance. */
	// +optional
	InstanceName *string `json:"instanceName,omitempty"`

	/* The public ECIES key used for sharing data with this instance. */
	// +optional
	PublicEciesKey *string `json:"publicEciesKey,omitempty"`

	/* The public RSA key used for sharing data with this instance. */
	// +optional
	PublicKey *string `json:"publicKey,omitempty"`
}

func (*ClusterInstanceReferencesStatus) DeepCopy added in v1.97.0 

func (in *ClusterInstanceReferencesStatus) DeepCopy() *ClusterInstanceReferencesStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInstanceReferencesStatus.

func (*ClusterInstanceReferencesStatus) DeepCopyInto added in v1.97.0 

func (in *ClusterInstanceReferencesStatus) DeepCopyInto(out *ClusterInstanceReferencesStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterKerberosConfig 

type ClusterKerberosConfig struct {
	/* Immutable. Optional. The admin server (IP or hostname) for the remote trusted realm in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustAdminServer *string `json:"crossRealmTrustAdminServer,omitempty"`

	/* Immutable. Optional. The KDC (IP or hostname) for the remote trusted realm in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustKdc *string `json:"crossRealmTrustKdc,omitempty"`

	/* Immutable. Optional. The remote realm the Dataproc on-cluster KDC will trust, should the user enable cross realm trust. */
	// +optional
	CrossRealmTrustRealm *string `json:"crossRealmTrustRealm,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the shared password between the on-cluster Kerberos realm and the remote trusted realm, in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustSharedPassword *string `json:"crossRealmTrustSharedPassword,omitempty"`

	/* Immutable. Optional. Flag to indicate whether to Kerberize the cluster (default: false). Set this field to true to enable Kerberos on a cluster. */
	// +optional
	EnableKerberos *bool `json:"enableKerberos,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the master key of the KDC database. */
	// +optional
	KdcDbKey *string `json:"kdcDbKey,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided key. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	KeyPassword *string `json:"keyPassword,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of the keystore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate. */
	// +optional
	Keystore *string `json:"keystore,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided keystore. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	KeystorePassword *string `json:"keystorePassword,omitempty"`

	/* Immutable. */
	// +optional
	KmsKeyRef *v1alpha1.ResourceRef `json:"kmsKeyRef,omitempty"`

	/* Immutable. Optional. The name of the on-cluster Kerberos realm. If not specified, the uppercased domain of hostnames will be the realm. */
	// +optional
	Realm *string `json:"realm,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the root principal password. */
	// +optional
	RootPrincipalPassword *string `json:"rootPrincipalPassword,omitempty"`

	/* Immutable. Optional. The lifetime of the ticket granting ticket, in hours. If not specified, or user specifies 0, then default value 10 will be used. */
	// +optional
	TgtLifetimeHours *int `json:"tgtLifetimeHours,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of the truststore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate. */
	// +optional
	Truststore *string `json:"truststore,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided truststore. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	TruststorePassword *string `json:"truststorePassword,omitempty"`
}

func (*ClusterKerberosConfig) DeepCopy 

func (in *ClusterKerberosConfig) DeepCopy() *ClusterKerberosConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterKerberosConfig.

func (*ClusterKerberosConfig) DeepCopyInto 

func (in *ClusterKerberosConfig) DeepCopyInto(out *ClusterKerberosConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterKubernetesClusterConfig added in v1.97.0 

type ClusterKubernetesClusterConfig struct {
	/* Immutable. Required. The configuration for running the Dataproc cluster on GKE. */
	GkeClusterConfig ClusterGkeClusterConfig `json:"gkeClusterConfig"`

	/* Immutable. Optional. A namespace within the Kubernetes cluster to deploy into. If this namespace does not exist, it is created. If it exists, Dataproc verifies that another Dataproc VirtualCluster is not installed into it. If not specified, the name of the Dataproc Cluster is used. */
	// +optional
	KubernetesNamespace *string `json:"kubernetesNamespace,omitempty"`

	/* Immutable. Optional. The software configuration for this Dataproc cluster running on Kubernetes. */
	// +optional
	KubernetesSoftwareConfig *ClusterKubernetesSoftwareConfig `json:"kubernetesSoftwareConfig,omitempty"`
}

func (*ClusterKubernetesClusterConfig) DeepCopy added in v1.97.0 

func (in *ClusterKubernetesClusterConfig) DeepCopy() *ClusterKubernetesClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterKubernetesClusterConfig.

func (*ClusterKubernetesClusterConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterKubernetesClusterConfig) DeepCopyInto(out *ClusterKubernetesClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterKubernetesSoftwareConfig added in v1.97.0 

type ClusterKubernetesSoftwareConfig struct {
	/* Immutable. The components that should be installed in this Dataproc cluster. The key must be a string from the KubernetesComponent enumeration. The value is the version of the software to be installed. At least one entry must be specified. */
	// +optional
	ComponentVersion map[string]string `json:"componentVersion,omitempty"`

	/* Immutable. The properties to set on daemon config files. Property keys are specified in `prefix:property` format, for example `spark:spark.kubernetes.container.image`. The following are supported prefixes and their mappings: * spark: `spark-defaults.conf` For more information, see [Cluster properties](https://cloud.google.com/dataproc/docs/concepts/cluster-properties). */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*ClusterKubernetesSoftwareConfig) DeepCopy added in v1.97.0 

func (in *ClusterKubernetesSoftwareConfig) DeepCopy() *ClusterKubernetesSoftwareConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterKubernetesSoftwareConfig.

func (*ClusterKubernetesSoftwareConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterKubernetesSoftwareConfig) DeepCopyInto(out *ClusterKubernetesSoftwareConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterLifecycleConfig 

type ClusterLifecycleConfig struct {
	/* Immutable. Optional. The time when cluster will be auto-deleted (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	AutoDeleteTime *string `json:"autoDeleteTime,omitempty"`

	/* Immutable. Optional. The lifetime duration of cluster. The cluster will be auto-deleted at the end of this period. Minimum value is 10 minutes; maximum value is 14 days (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	AutoDeleteTtl *string `json:"autoDeleteTtl,omitempty"`

	/* Immutable. Optional. The duration to keep the cluster alive while idling (when no jobs are running). Passing this threshold will cause the cluster to be deleted. Minimum value is 5 minutes; maximum value is 14 days (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	IdleDeleteTtl *string `json:"idleDeleteTtl,omitempty"`
}

func (*ClusterLifecycleConfig) DeepCopy 

func (in *ClusterLifecycleConfig) DeepCopy() *ClusterLifecycleConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterLifecycleConfig.

func (*ClusterLifecycleConfig) DeepCopyInto 

func (in *ClusterLifecycleConfig) DeepCopyInto(out *ClusterLifecycleConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterLifecycleConfigStatus 

type ClusterLifecycleConfigStatus struct {
	/* Output only. The time when cluster became idle (most recent job finished) and became eligible for deletion due to idleness (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	IdleStartTime *string `json:"idleStartTime,omitempty"`
}

func (*ClusterLifecycleConfigStatus) DeepCopy 

func (in *ClusterLifecycleConfigStatus) DeepCopy() *ClusterLifecycleConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterLifecycleConfigStatus.

func (*ClusterLifecycleConfigStatus) DeepCopyInto 

func (in *ClusterLifecycleConfigStatus) DeepCopyInto(out *ClusterLifecycleConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterManagedGroupConfigStatus 

type ClusterManagedGroupConfigStatus struct {
	/* Output only. The name of the Instance Group Manager for this group. */
	// +optional
	InstanceGroupManagerName *string `json:"instanceGroupManagerName,omitempty"`

	/* Output only. The name of the Instance Template used for the Managed Instance Group. */
	// +optional
	InstanceTemplateName *string `json:"instanceTemplateName,omitempty"`
}

func (*ClusterManagedGroupConfigStatus) DeepCopy 

func (in *ClusterManagedGroupConfigStatus) DeepCopy() *ClusterManagedGroupConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterManagedGroupConfigStatus.

func (*ClusterManagedGroupConfigStatus) DeepCopyInto 

func (in *ClusterManagedGroupConfigStatus) DeepCopyInto(out *ClusterManagedGroupConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterMasterConfig 

type ClusterMasterConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []ClusterAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *ClusterDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*ClusterMasterConfig) DeepCopy 

func (in *ClusterMasterConfig) DeepCopy() *ClusterMasterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMasterConfig.

func (*ClusterMasterConfig) DeepCopyInto 

func (in *ClusterMasterConfig) DeepCopyInto(out *ClusterMasterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterMasterConfigStatus 

type ClusterMasterConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. List of references to Compute Engine instances. */
	// +optional
	InstanceReferences []ClusterInstanceReferencesStatus `json:"instanceReferences,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *ClusterManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*ClusterMasterConfigStatus) DeepCopy 

func (in *ClusterMasterConfigStatus) DeepCopy() *ClusterMasterConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMasterConfigStatus.

func (*ClusterMasterConfigStatus) DeepCopyInto 

func (in *ClusterMasterConfigStatus) DeepCopyInto(out *ClusterMasterConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterMetastoreConfig added in v1.97.0 

type ClusterMetastoreConfig struct {
	/* Immutable. */
	DataprocMetastoreServiceRef v1alpha1.ResourceRef `json:"dataprocMetastoreServiceRef"`
}

func (*ClusterMetastoreConfig) DeepCopy added in v1.97.0 

func (in *ClusterMetastoreConfig) DeepCopy() *ClusterMetastoreConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMetastoreConfig.

func (*ClusterMetastoreConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterMetastoreConfig) DeepCopyInto(out *ClusterMetastoreConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterMetrics added in v1.97.0 

type ClusterMetrics struct {
	/* Immutable. Optional. Specify one or more [available OSS metrics] (https://cloud.google.com/dataproc/docs/guides/monitoring#available_oss_metrics) to collect for the metric course (for the `SPARK` metric source, any [Spark metric] (https://spark.apache.org/docs/latest/monitoring.html#metrics) can be specified). Provide metrics in the following format: `METRIC_SOURCE:INSTANCE:GROUP:METRIC` Use camelcase as appropriate. Examples: “` yarn:ResourceManager:QueueMetrics:AppsCompleted spark:driver:DAGScheduler:job.allJobs sparkHistoryServer:JVM:Memory:NonHeapMemoryUsage.committed hiveserver2:JVM:Memory:NonHeapMemoryUsage.used “` Notes: * Only the specified overridden metrics will be collected for the metric source. For example, if one or more `spark:executive` metrics are listed as metric overrides, other `SPARK` metrics will not be collected. The collection of the default metrics for other OSS metric sources is unaffected. For example, if both `SPARK` andd `YARN` metric sources are enabled, and overrides are provided for Spark metrics only, all default YARN metrics will be collected. */
	// +optional
	MetricOverrides []string `json:"metricOverrides,omitempty"`

	/* Immutable. Required. Default metrics are collected unless `metricOverrides` are specified for the metric source (see [Available OSS metrics] (https://cloud.google.com/dataproc/docs/guides/monitoring#available_oss_metrics) for more information). Possible values: METRIC_SOURCE_UNSPECIFIED, MONITORING_AGENT_DEFAULTS, HDFS, SPARK, YARN, SPARK_HISTORY_SERVER, HIVESERVER2 */
	MetricSource string `json:"metricSource"`
}

func (*ClusterMetrics) DeepCopy added in v1.97.0 

func (in *ClusterMetrics) DeepCopy() *ClusterMetrics

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMetrics.

func (*ClusterMetrics) DeepCopyInto added in v1.97.0 

func (in *ClusterMetrics) DeepCopyInto(out *ClusterMetrics)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterMetricsStatus 

type ClusterMetricsStatus struct {
	/* The HDFS metrics. */
	// +optional
	HdfsMetrics map[string]string `json:"hdfsMetrics,omitempty"`

	/* The YARN metrics. */
	// +optional
	YarnMetrics map[string]string `json:"yarnMetrics,omitempty"`
}

func (*ClusterMetricsStatus) DeepCopy 

func (in *ClusterMetricsStatus) DeepCopy() *ClusterMetricsStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMetricsStatus.

func (*ClusterMetricsStatus) DeepCopyInto 

func (in *ClusterMetricsStatus) DeepCopyInto(out *ClusterMetricsStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterNodeGroupAffinity 

type ClusterNodeGroupAffinity struct {
	/* Immutable. */
	NodeGroupRef v1alpha1.ResourceRef `json:"nodeGroupRef"`
}

func (*ClusterNodeGroupAffinity) DeepCopy 

func (in *ClusterNodeGroupAffinity) DeepCopy() *ClusterNodeGroupAffinity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterNodeGroupAffinity.

func (*ClusterNodeGroupAffinity) DeepCopyInto 

func (in *ClusterNodeGroupAffinity) DeepCopyInto(out *ClusterNodeGroupAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterNodePoolConfig added in v1.97.0 

type ClusterNodePoolConfig struct {
	/* Immutable. Optional. The autoscaler configuration for this node pool. The autoscaler is enabled only when a valid configuration is present. */
	// +optional
	Autoscaling *ClusterAutoscaling `json:"autoscaling,omitempty"`

	/* Immutable. Optional. The node pool configuration. */
	// +optional
	Config *ClusterConfig `json:"config,omitempty"`

	/* Immutable. Optional. The list of Compute Engine [zones](https://cloud.google.com/compute/docs/zones#available) where node pool nodes associated with a Dataproc on GKE virtual cluster will be located. **Note:** All node pools associated with a virtual cluster must be located in the same region as the virtual cluster, and they must be located in the same zone within that region. If a location is not specified during node pool creation, Dataproc on GKE will choose the zone. */
	// +optional
	Locations []string `json:"locations,omitempty"`
}

func (*ClusterNodePoolConfig) DeepCopy added in v1.97.0 

func (in *ClusterNodePoolConfig) DeepCopy() *ClusterNodePoolConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterNodePoolConfig.

func (*ClusterNodePoolConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterNodePoolConfig) DeepCopyInto(out *ClusterNodePoolConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterNodePoolTarget added in v1.97.0 

type ClusterNodePoolTarget struct {
	/* Immutable. Input only. The configuration for the GKE node pool. If specified, Dataproc attempts to create a node pool with the specified shape. If one with the same name already exists, it is verified against all specified fields. If a field differs, the virtual cluster creation will fail. If omitted, any node pool with the specified name is used. If a node pool with the specified name does not exist, Dataproc create a node pool with default values. This is an input only field. It will not be returned by the API. */
	// +optional
	NodePoolConfig *ClusterNodePoolConfig `json:"nodePoolConfig,omitempty"`

	/* Immutable. */
	NodePoolRef v1alpha1.ResourceRef `json:"nodePoolRef"`

	/* Immutable. Required. The roles associated with the GKE node pool. */
	Roles []string `json:"roles"`
}

func (*ClusterNodePoolTarget) DeepCopy added in v1.97.0 

func (in *ClusterNodePoolTarget) DeepCopy() *ClusterNodePoolTarget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterNodePoolTarget.

func (*ClusterNodePoolTarget) DeepCopyInto added in v1.97.0 

func (in *ClusterNodePoolTarget) DeepCopyInto(out *ClusterNodePoolTarget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterReservationAffinity 

type ClusterReservationAffinity struct {
	/* Immutable. Optional. Type of reservation to consume Possible values: TYPE_UNSPECIFIED, NO_RESERVATION, ANY_RESERVATION, SPECIFIC_RESERVATION */
	// +optional
	ConsumeReservationType *string `json:"consumeReservationType,omitempty"`

	/* Immutable. Optional. Corresponds to the label key of reservation resource. */
	// +optional
	Key *string `json:"key,omitempty"`

	/* Immutable. Optional. Corresponds to the label values of reservation resource. */
	// +optional
	Values []string `json:"values,omitempty"`
}

func (*ClusterReservationAffinity) DeepCopy 

func (in *ClusterReservationAffinity) DeepCopy() *ClusterReservationAffinity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterReservationAffinity.

func (*ClusterReservationAffinity) DeepCopyInto 

func (in *ClusterReservationAffinity) DeepCopyInto(out *ClusterReservationAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSecondaryWorkerConfig 

type ClusterSecondaryWorkerConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []ClusterAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *ClusterDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*ClusterSecondaryWorkerConfig) DeepCopy 

func (in *ClusterSecondaryWorkerConfig) DeepCopy() *ClusterSecondaryWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSecondaryWorkerConfig.

func (*ClusterSecondaryWorkerConfig) DeepCopyInto 

func (in *ClusterSecondaryWorkerConfig) DeepCopyInto(out *ClusterSecondaryWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSecondaryWorkerConfigStatus 

type ClusterSecondaryWorkerConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. List of references to Compute Engine instances. */
	// +optional
	InstanceReferences []ClusterInstanceReferencesStatus `json:"instanceReferences,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *ClusterManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*ClusterSecondaryWorkerConfigStatus) DeepCopy 

func (in *ClusterSecondaryWorkerConfigStatus) DeepCopy() *ClusterSecondaryWorkerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSecondaryWorkerConfigStatus.

func (*ClusterSecondaryWorkerConfigStatus) DeepCopyInto 

func (in *ClusterSecondaryWorkerConfigStatus) DeepCopyInto(out *ClusterSecondaryWorkerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSecurityConfig 

type ClusterSecurityConfig struct {
	/* Immutable. Optional. Identity related configuration, including service account based secure multi-tenancy user mappings. */
	// +optional
	IdentityConfig *ClusterIdentityConfig `json:"identityConfig,omitempty"`

	/* Immutable. Optional. Kerberos related configuration. */
	// +optional
	KerberosConfig *ClusterKerberosConfig `json:"kerberosConfig,omitempty"`
}

func (*ClusterSecurityConfig) DeepCopy 

func (in *ClusterSecurityConfig) DeepCopy() *ClusterSecurityConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSecurityConfig.

func (*ClusterSecurityConfig) DeepCopyInto 

func (in *ClusterSecurityConfig) DeepCopyInto(out *ClusterSecurityConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterShieldedInstanceConfig added in v1.97.0 

type ClusterShieldedInstanceConfig struct {
	/* Immutable. Optional. Defines whether instances have integrity monitoring enabled. */
	// +optional
	EnableIntegrityMonitoring *bool `json:"enableIntegrityMonitoring,omitempty"`

	/* Immutable. Optional. Defines whether instances have Secure Boot enabled. */
	// +optional
	EnableSecureBoot *bool `json:"enableSecureBoot,omitempty"`

	/* Immutable. Optional. Defines whether instances have the vTPM enabled. */
	// +optional
	EnableVtpm *bool `json:"enableVtpm,omitempty"`
}

func (*ClusterShieldedInstanceConfig) DeepCopy added in v1.97.0 

func (in *ClusterShieldedInstanceConfig) DeepCopy() *ClusterShieldedInstanceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterShieldedInstanceConfig.

func (*ClusterShieldedInstanceConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterShieldedInstanceConfig) DeepCopyInto(out *ClusterShieldedInstanceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSoftwareConfig 

type ClusterSoftwareConfig struct {
	/* Immutable. Optional. The version of software inside the cluster. It must be one of the supported [Dataproc Versions](https://cloud.google.com/dataproc/docs/concepts/versioning/dataproc-versions#supported_dataproc_versions), such as "1.2" (including a subminor version, such as "1.2.29"), or the ["preview" version](https://cloud.google.com/dataproc/docs/concepts/versioning/dataproc-versions#other_versions). If unspecified, it defaults to the latest Debian version. */
	// +optional
	ImageVersion *string `json:"imageVersion,omitempty"`

	/* Immutable. Optional. The set of components to activate on the cluster. */
	// +optional
	OptionalComponents []string `json:"optionalComponents,omitempty"`

	/* Immutable. Optional. The properties to set on daemon config files. Property keys are specified in `prefix:property` format, for example `core:hadoop.tmp.dir`. The following are supported prefixes and their mappings: * capacity-scheduler: `capacity-scheduler.xml` * core: `core-site.xml` * distcp: `distcp-default.xml` * hdfs: `hdfs-site.xml` * hive: `hive-site.xml` * mapred: `mapred-site.xml` * pig: `pig.properties` * spark: `spark-defaults.conf` * yarn: `yarn-site.xml` For more information, see [Cluster properties](https://cloud.google.com/dataproc/docs/concepts/cluster-properties). */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*ClusterSoftwareConfig) DeepCopy 

func (in *ClusterSoftwareConfig) DeepCopy() *ClusterSoftwareConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSoftwareConfig.

func (*ClusterSoftwareConfig) DeepCopyInto 

func (in *ClusterSoftwareConfig) DeepCopyInto(out *ClusterSoftwareConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterSparkHistoryServerConfig added in v1.97.0 

type ClusterSparkHistoryServerConfig struct {
	/* Immutable. */
	// +optional
	DataprocClusterRef *v1alpha1.ResourceRef `json:"dataprocClusterRef,omitempty"`
}

func (*ClusterSparkHistoryServerConfig) DeepCopy added in v1.97.0 

func (in *ClusterSparkHistoryServerConfig) DeepCopy() *ClusterSparkHistoryServerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSparkHistoryServerConfig.

func (*ClusterSparkHistoryServerConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterSparkHistoryServerConfig) DeepCopyInto(out *ClusterSparkHistoryServerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterStatusHistoryStatus 

type ClusterStatusHistoryStatus struct {
	/* Optional. Output only. Details of cluster's state. */
	// +optional
	Detail *string `json:"detail,omitempty"`

	/* Output only. The cluster's state. Possible values: UNKNOWN, CREATING, RUNNING, ERROR, DELETING, UPDATING, STOPPING, STOPPED, STARTING */
	// +optional
	State *string `json:"state,omitempty"`

	/* Output only. Time when this state was entered (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	StateStartTime *string `json:"stateStartTime,omitempty"`

	/* Output only. Additional state information that includes status reported by the agent. Possible values: UNSPECIFIED, UNHEALTHY, STALE_STATUS */
	// +optional
	Substate *string `json:"substate,omitempty"`
}

func (*ClusterStatusHistoryStatus) DeepCopy 

func (in *ClusterStatusHistoryStatus) DeepCopy() *ClusterStatusHistoryStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatusHistoryStatus.

func (*ClusterStatusHistoryStatus) DeepCopyInto 

func (in *ClusterStatusHistoryStatus) DeepCopyInto(out *ClusterStatusHistoryStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterStatusStatus 

type ClusterStatusStatus struct {
	/* Optional. Output only. Details of cluster's state. */
	// +optional
	Detail *string `json:"detail,omitempty"`

	/* Output only. The cluster's state. Possible values: UNKNOWN, CREATING, RUNNING, ERROR, DELETING, UPDATING, STOPPING, STOPPED, STARTING */
	// +optional
	State *string `json:"state,omitempty"`

	/* Output only. Time when this state was entered (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	StateStartTime *string `json:"stateStartTime,omitempty"`

	/* Output only. Additional state information that includes status reported by the agent. Possible values: UNSPECIFIED, UNHEALTHY, STALE_STATUS */
	// +optional
	Substate *string `json:"substate,omitempty"`
}

func (*ClusterStatusStatus) DeepCopy 

func (in *ClusterStatusStatus) DeepCopy() *ClusterStatusStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatusStatus.

func (*ClusterStatusStatus) DeepCopyInto 

func (in *ClusterStatusStatus) DeepCopyInto(out *ClusterStatusStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterVirtualClusterConfig added in v1.97.0 

type ClusterVirtualClusterConfig struct {
	/* Immutable. Optional. Configuration of auxiliary services used by this cluster. */
	// +optional
	AuxiliaryServicesConfig *ClusterAuxiliaryServicesConfig `json:"auxiliaryServicesConfig,omitempty"`

	/* Immutable. Required. The configuration for running the Dataproc cluster on Kubernetes. */
	KubernetesClusterConfig ClusterKubernetesClusterConfig `json:"kubernetesClusterConfig"`

	/* Immutable. */
	// +optional
	StagingBucketRef *v1alpha1.ResourceRef `json:"stagingBucketRef,omitempty"`
}

func (*ClusterVirtualClusterConfig) DeepCopy added in v1.97.0 

func (in *ClusterVirtualClusterConfig) DeepCopy() *ClusterVirtualClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterVirtualClusterConfig.

func (*ClusterVirtualClusterConfig) DeepCopyInto added in v1.97.0 

func (in *ClusterVirtualClusterConfig) DeepCopyInto(out *ClusterVirtualClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterWorkerConfig 

type ClusterWorkerConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []ClusterAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *ClusterDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*ClusterWorkerConfig) DeepCopy 

func (in *ClusterWorkerConfig) DeepCopy() *ClusterWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterWorkerConfig.

func (*ClusterWorkerConfig) DeepCopyInto 

func (in *ClusterWorkerConfig) DeepCopyInto(out *ClusterWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterWorkerConfigStatus 

type ClusterWorkerConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. List of references to Compute Engine instances. */
	// +optional
	InstanceReferences []ClusterInstanceReferencesStatus `json:"instanceReferences,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *ClusterManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*ClusterWorkerConfigStatus) DeepCopy 

func (in *ClusterWorkerConfigStatus) DeepCopy() *ClusterWorkerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterWorkerConfigStatus.

func (*ClusterWorkerConfigStatus) DeepCopyInto 

func (in *ClusterWorkerConfigStatus) DeepCopyInto(out *ClusterWorkerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocAutoscalingPolicy 

type DataprocAutoscalingPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataprocAutoscalingPolicySpec   `json:"spec,omitempty"`
	Status DataprocAutoscalingPolicyStatus `json:"status,omitempty"`
}

DataprocAutoscalingPolicy is the Schema for the dataproc API +k8s:openapi-gen=true

func (*DataprocAutoscalingPolicy) DeepCopy 

func (in *DataprocAutoscalingPolicy) DeepCopy() *DataprocAutoscalingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocAutoscalingPolicy.

func (*DataprocAutoscalingPolicy) DeepCopyInto 

func (in *DataprocAutoscalingPolicy) DeepCopyInto(out *DataprocAutoscalingPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocAutoscalingPolicy) DeepCopyObject 

func (in *DataprocAutoscalingPolicy) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocAutoscalingPolicyList 

type DataprocAutoscalingPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DataprocAutoscalingPolicy `json:"items"`
}

DataprocAutoscalingPolicyList contains a list of DataprocAutoscalingPolicy

func (*DataprocAutoscalingPolicyList) DeepCopy 

func (in *DataprocAutoscalingPolicyList) DeepCopy() *DataprocAutoscalingPolicyList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocAutoscalingPolicyList.

func (*DataprocAutoscalingPolicyList) DeepCopyInto 

func (in *DataprocAutoscalingPolicyList) DeepCopyInto(out *DataprocAutoscalingPolicyList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocAutoscalingPolicyList) DeepCopyObject 

func (in *DataprocAutoscalingPolicyList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocAutoscalingPolicySpec 

type DataprocAutoscalingPolicySpec struct {
	BasicAlgorithm AutoscalingpolicyBasicAlgorithm `json:"basicAlgorithm"`

	/* Immutable. The location for the resource */
	Location string `json:"location"`

	/* Immutable. The Project that this resource belongs to. */
	// +optional
	ProjectRef *v1alpha1.ResourceRef `json:"projectRef,omitempty"`

	/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* Optional. Describes how the autoscaler will operate for secondary workers. */
	// +optional
	SecondaryWorkerConfig *AutoscalingpolicySecondaryWorkerConfig `json:"secondaryWorkerConfig,omitempty"`

	/* Required. Describes how the autoscaler will operate for primary workers. */
	WorkerConfig AutoscalingpolicyWorkerConfig `json:"workerConfig"`
}

func (*DataprocAutoscalingPolicySpec) DeepCopy 

func (in *DataprocAutoscalingPolicySpec) DeepCopy() *DataprocAutoscalingPolicySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocAutoscalingPolicySpec.

func (*DataprocAutoscalingPolicySpec) DeepCopyInto 

func (in *DataprocAutoscalingPolicySpec) DeepCopyInto(out *DataprocAutoscalingPolicySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocAutoscalingPolicyStatus 

type DataprocAutoscalingPolicyStatus struct {
	/* Conditions represent the latest available observations of the
	   DataprocAutoscalingPolicy's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int `json:"observedGeneration,omitempty"`
}

func (*DataprocAutoscalingPolicyStatus) DeepCopy 

func (in *DataprocAutoscalingPolicyStatus) DeepCopy() *DataprocAutoscalingPolicyStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocAutoscalingPolicyStatus.

func (*DataprocAutoscalingPolicyStatus) DeepCopyInto 

func (in *DataprocAutoscalingPolicyStatus) DeepCopyInto(out *DataprocAutoscalingPolicyStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocCluster 

type DataprocCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataprocClusterSpec   `json:"spec,omitempty"`
	Status DataprocClusterStatus `json:"status,omitempty"`
}

DataprocCluster is the Schema for the dataproc API +k8s:openapi-gen=true

func (*DataprocCluster) DeepCopy 

func (in *DataprocCluster) DeepCopy() *DataprocCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocCluster.

func (*DataprocCluster) DeepCopyInto 

func (in *DataprocCluster) DeepCopyInto(out *DataprocCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocCluster) DeepCopyObject 

func (in *DataprocCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocClusterList 

type DataprocClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DataprocCluster `json:"items"`
}

DataprocClusterList contains a list of DataprocCluster

func (*DataprocClusterList) DeepCopy 

func (in *DataprocClusterList) DeepCopy() *DataprocClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocClusterList.

func (*DataprocClusterList) DeepCopyInto 

func (in *DataprocClusterList) DeepCopyInto(out *DataprocClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocClusterList) DeepCopyObject 

func (in *DataprocClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocClusterSpec 

type DataprocClusterSpec struct {
	/* Immutable. The cluster config. Note that Dataproc may set default values, and values may change when clusters are updated. */
	// +optional
	Config *ClusterConfig `json:"config,omitempty"`

	/* Immutable. The location for the resource, usually a GCP region. */
	Location string `json:"location"`

	/* Immutable. The Project that this resource belongs to. */
	// +optional
	ProjectRef *v1alpha1.ResourceRef `json:"projectRef,omitempty"`

	/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* Immutable. Optional. The virtual cluster config is used when creating a Dataproc cluster that does not directly control the underlying compute resources, for example, when creating a [Dataproc-on-GKE cluster](https://cloud.google.com/dataproc/docs/guides/dpgke/dataproc-gke). Dataproc may set default values, and values may change when clusters are updated. Exactly one of config or virtual_cluster_config must be specified. */
	// +optional
	VirtualClusterConfig *ClusterVirtualClusterConfig `json:"virtualClusterConfig,omitempty"`
}

func (*DataprocClusterSpec) DeepCopy 

func (in *DataprocClusterSpec) DeepCopy() *DataprocClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocClusterSpec.

func (*DataprocClusterSpec) DeepCopyInto 

func (in *DataprocClusterSpec) DeepCopyInto(out *DataprocClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocClusterStatus 

type DataprocClusterStatus struct {
	/* Conditions represent the latest available observations of the
	   DataprocCluster's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* Output only. A cluster UUID (Unique Universal Identifier). Dataproc generates this value when it creates the cluster. */
	// +optional
	ClusterUuid *string `json:"clusterUuid,omitempty"`

	// +optional
	Config *ClusterConfigStatus `json:"config,omitempty"`

	/* Output only. Contains cluster daemon metrics such as HDFS and YARN stats. **Beta Feature**: This report is available for testing purposes only. It may be changed before final release. */
	// +optional
	Metrics *ClusterMetricsStatus `json:"metrics,omitempty"`

	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int `json:"observedGeneration,omitempty"`

	/* Output only. Cluster status. */
	// +optional
	Status *ClusterStatusStatus `json:"status,omitempty"`

	/* Output only. The previous cluster status. */
	// +optional
	StatusHistory []ClusterStatusHistoryStatus `json:"statusHistory,omitempty"`
}

func (*DataprocClusterStatus) DeepCopy 

func (in *DataprocClusterStatus) DeepCopy() *DataprocClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocClusterStatus.

func (*DataprocClusterStatus) DeepCopyInto 

func (in *DataprocClusterStatus) DeepCopyInto(out *DataprocClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocWorkflowTemplate 

type DataprocWorkflowTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataprocWorkflowTemplateSpec   `json:"spec,omitempty"`
	Status DataprocWorkflowTemplateStatus `json:"status,omitempty"`
}

DataprocWorkflowTemplate is the Schema for the dataproc API +k8s:openapi-gen=true

func (*DataprocWorkflowTemplate) DeepCopy 

func (in *DataprocWorkflowTemplate) DeepCopy() *DataprocWorkflowTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocWorkflowTemplate.

func (*DataprocWorkflowTemplate) DeepCopyInto 

func (in *DataprocWorkflowTemplate) DeepCopyInto(out *DataprocWorkflowTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocWorkflowTemplate) DeepCopyObject 

func (in *DataprocWorkflowTemplate) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocWorkflowTemplateList 

type DataprocWorkflowTemplateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DataprocWorkflowTemplate `json:"items"`
}

DataprocWorkflowTemplateList contains a list of DataprocWorkflowTemplate

func (*DataprocWorkflowTemplateList) DeepCopy 

func (in *DataprocWorkflowTemplateList) DeepCopy() *DataprocWorkflowTemplateList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocWorkflowTemplateList.

func (*DataprocWorkflowTemplateList) DeepCopyInto 

func (in *DataprocWorkflowTemplateList) DeepCopyInto(out *DataprocWorkflowTemplateList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DataprocWorkflowTemplateList) DeepCopyObject 

func (in *DataprocWorkflowTemplateList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DataprocWorkflowTemplateSpec 

type DataprocWorkflowTemplateSpec struct {
	/* Immutable. Optional. Timeout duration for the DAG of jobs, expressed in seconds (see [JSON representation of duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). The timeout duration must be from 10 minutes ("600s") to 24 hours ("86400s"). The timer begins when the first job is submitted. If the workflow is running at the end of the timeout period, any remaining jobs are cancelled, the workflow is ended, and if the workflow was running on a [managed cluster](/dataproc/docs/concepts/workflows/using-workflows#configuring_or_selecting_a_cluster), the cluster is deleted. */
	// +optional
	DagTimeout *string `json:"dagTimeout,omitempty"`

	/* Immutable. Required. The Directed Acyclic Graph of Jobs to submit. */
	Jobs []WorkflowtemplateJobs `json:"jobs"`

	/* Immutable. The location for the resource */
	Location string `json:"location"`

	/* Immutable. Optional. Template parameters whose values are substituted into the template. Values for parameters must be provided when the template is instantiated. */
	// +optional
	Parameters []WorkflowtemplateParameters `json:"parameters,omitempty"`

	/* Immutable. Required. WorkflowTemplate scheduling information. */
	Placement WorkflowtemplatePlacement `json:"placement"`

	/* Immutable. The Project that this resource belongs to. */
	// +optional
	ProjectRef *v1alpha1.ResourceRef `json:"projectRef,omitempty"`

	/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`
}

func (*DataprocWorkflowTemplateSpec) DeepCopy 

func (in *DataprocWorkflowTemplateSpec) DeepCopy() *DataprocWorkflowTemplateSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocWorkflowTemplateSpec.

func (*DataprocWorkflowTemplateSpec) DeepCopyInto 

func (in *DataprocWorkflowTemplateSpec) DeepCopyInto(out *DataprocWorkflowTemplateSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DataprocWorkflowTemplateStatus 

type DataprocWorkflowTemplateStatus struct {
	/* Conditions represent the latest available observations of the
	   DataprocWorkflowTemplate's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* Output only. The time template was created. */
	// +optional
	CreateTime *string `json:"createTime,omitempty"`

	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int `json:"observedGeneration,omitempty"`

	// +optional
	Placement *WorkflowtemplatePlacementStatus `json:"placement,omitempty"`

	/* Output only. The time template was last updated. */
	// +optional
	UpdateTime *string `json:"updateTime,omitempty"`

	/* Output only. The current version of this workflow template. */
	// +optional
	Version *int `json:"version,omitempty"`
}

func (*DataprocWorkflowTemplateStatus) DeepCopy 

func (in *DataprocWorkflowTemplateStatus) DeepCopy() *DataprocWorkflowTemplateStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataprocWorkflowTemplateStatus.

func (*DataprocWorkflowTemplateStatus) DeepCopyInto 

func (in *DataprocWorkflowTemplateStatus) DeepCopyInto(out *DataprocWorkflowTemplateStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateAccelerators 

type WorkflowtemplateAccelerators struct {
	/* Immutable. The number of the accelerator cards of this type exposed to this instance. */
	// +optional
	AcceleratorCount *int `json:"acceleratorCount,omitempty"`

	/* Immutable. 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/beta/acceleratorTypes). Examples: * `https://www.googleapis.com/compute/beta/projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` * `projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80` * `nvidia-tesla-k80` **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-k80`. */
	// +optional
	AcceleratorType *string `json:"acceleratorType,omitempty"`
}

func (*WorkflowtemplateAccelerators) DeepCopy 

func (in *WorkflowtemplateAccelerators) DeepCopy() *WorkflowtemplateAccelerators

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateAccelerators.

func (*WorkflowtemplateAccelerators) DeepCopyInto 

func (in *WorkflowtemplateAccelerators) DeepCopyInto(out *WorkflowtemplateAccelerators)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateAutoscalingConfig 

type WorkflowtemplateAutoscalingConfig struct {
	/* Immutable. */
	// +optional
	PolicyRef *v1alpha1.ResourceRef `json:"policyRef,omitempty"`
}

func (*WorkflowtemplateAutoscalingConfig) DeepCopy 

func (in *WorkflowtemplateAutoscalingConfig) DeepCopy() *WorkflowtemplateAutoscalingConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateAutoscalingConfig.

func (*WorkflowtemplateAutoscalingConfig) DeepCopyInto 

func (in *WorkflowtemplateAutoscalingConfig) DeepCopyInto(out *WorkflowtemplateAutoscalingConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateClusterSelector 

type WorkflowtemplateClusterSelector struct {
	/* Immutable. Required. The cluster labels. Cluster must have all labels to match. */
	ClusterLabels map[string]string `json:"clusterLabels"`

	/* Immutable. Optional. The zone where workflow process executes. This parameter does not affect the selection of the cluster. If unspecified, the zone of the first cluster matching the selector is used. */
	// +optional
	Zone *string `json:"zone,omitempty"`
}

func (*WorkflowtemplateClusterSelector) DeepCopy 

func (in *WorkflowtemplateClusterSelector) DeepCopy() *WorkflowtemplateClusterSelector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateClusterSelector.

func (*WorkflowtemplateClusterSelector) DeepCopyInto 

func (in *WorkflowtemplateClusterSelector) DeepCopyInto(out *WorkflowtemplateClusterSelector)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateConfig 

type WorkflowtemplateConfig struct {
	/* Immutable. Optional. Autoscaling config for the policy associated with the cluster. Cluster does not autoscale if this field is unset. */
	// +optional
	AutoscalingConfig *WorkflowtemplateAutoscalingConfig `json:"autoscalingConfig,omitempty"`

	/* Immutable. Optional. Encryption settings for the cluster. */
	// +optional
	EncryptionConfig *WorkflowtemplateEncryptionConfig `json:"encryptionConfig,omitempty"`

	/* Immutable. Optional. Port/endpoint configuration for this cluster */
	// +optional
	EndpointConfig *WorkflowtemplateEndpointConfig `json:"endpointConfig,omitempty"`

	/* Immutable. Optional. The shared Compute Engine config settings for all instances in a cluster. */
	// +optional
	GceClusterConfig *WorkflowtemplateGceClusterConfig `json:"gceClusterConfig,omitempty"`

	/* Immutable. Optional. Commands to execute on each node after config is completed. By default, executables are run on master and all worker nodes. You can test a node's `role` metadata to run an executable on a master or worker node, as shown below using `curl` (you can also use `wget`): ROLE=$(curl -H Metadata-Flavor:Google http://metadata/computeMetadata/v1/instance/attributes/dataproc-role) if [[ "${ROLE}" == 'Master' ]]; then ... master specific actions ... else ... worker specific actions ... fi */
	// +optional
	InitializationActions []WorkflowtemplateInitializationActions `json:"initializationActions,omitempty"`

	/* Immutable. Optional. Lifecycle setting for the cluster. */
	// +optional
	LifecycleConfig *WorkflowtemplateLifecycleConfig `json:"lifecycleConfig,omitempty"`

	/* Immutable. Optional. The Compute Engine config settings for the master instance in a cluster. */
	// +optional
	MasterConfig *WorkflowtemplateMasterConfig `json:"masterConfig,omitempty"`

	/* Immutable. Optional. The Compute Engine config settings for additional worker instances in a cluster. */
	// +optional
	SecondaryWorkerConfig *WorkflowtemplateSecondaryWorkerConfig `json:"secondaryWorkerConfig,omitempty"`

	/* Immutable. Optional. Security settings for the cluster. */
	// +optional
	SecurityConfig *WorkflowtemplateSecurityConfig `json:"securityConfig,omitempty"`

	/* Immutable. Optional. The config settings for software inside the cluster. */
	// +optional
	SoftwareConfig *WorkflowtemplateSoftwareConfig `json:"softwareConfig,omitempty"`

	/* Immutable. */
	// +optional
	StagingBucketRef *v1alpha1.ResourceRef `json:"stagingBucketRef,omitempty"`

	/* Immutable. */
	// +optional
	TempBucketRef *v1alpha1.ResourceRef `json:"tempBucketRef,omitempty"`

	/* Immutable. Optional. The Compute Engine config settings for worker instances in a cluster. */
	// +optional
	WorkerConfig *WorkflowtemplateWorkerConfig `json:"workerConfig,omitempty"`
}

func (*WorkflowtemplateConfig) DeepCopy 

func (in *WorkflowtemplateConfig) DeepCopy() *WorkflowtemplateConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateConfig.

func (*WorkflowtemplateConfig) DeepCopyInto 

func (in *WorkflowtemplateConfig) DeepCopyInto(out *WorkflowtemplateConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateConfigStatus 

type WorkflowtemplateConfigStatus struct {
	// +optional
	EndpointConfig *WorkflowtemplateEndpointConfigStatus `json:"endpointConfig,omitempty"`

	// +optional
	LifecycleConfig *WorkflowtemplateLifecycleConfigStatus `json:"lifecycleConfig,omitempty"`

	// +optional
	MasterConfig *WorkflowtemplateMasterConfigStatus `json:"masterConfig,omitempty"`

	// +optional
	SecondaryWorkerConfig *WorkflowtemplateSecondaryWorkerConfigStatus `json:"secondaryWorkerConfig,omitempty"`

	// +optional
	WorkerConfig *WorkflowtemplateWorkerConfigStatus `json:"workerConfig,omitempty"`
}

func (*WorkflowtemplateConfigStatus) DeepCopy 

func (in *WorkflowtemplateConfigStatus) DeepCopy() *WorkflowtemplateConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateConfigStatus.

func (*WorkflowtemplateConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateConfigStatus) DeepCopyInto(out *WorkflowtemplateConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateDiskConfig 

type WorkflowtemplateDiskConfig struct {
	/* Immutable. Optional. Size in GB of the boot disk (default is 500GB). */
	// +optional
	BootDiskSizeGb *int `json:"bootDiskSizeGb,omitempty"`

	/* Immutable. Optional. Type of the boot disk (default is "pd-standard"). Valid values: "pd-balanced" (Persistent Disk Balanced Solid State Drive), "pd-ssd" (Persistent Disk Solid State Drive), or "pd-standard" (Persistent Disk Hard Disk Drive). See [Disk types](https://cloud.google.com/compute/docs/disks#disk-types). */
	// +optional
	BootDiskType *string `json:"bootDiskType,omitempty"`

	/* Immutable. Optional. Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are not attached, the boot disk is used to store runtime logs and [HDFS](https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. If one or more SSDs are attached, this runtime bulk data is spread across them, and the boot disk contains only basic config and installed binaries. */
	// +optional
	NumLocalSsds *int `json:"numLocalSsds,omitempty"`
}

func (*WorkflowtemplateDiskConfig) DeepCopy 

func (in *WorkflowtemplateDiskConfig) DeepCopy() *WorkflowtemplateDiskConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateDiskConfig.

func (*WorkflowtemplateDiskConfig) DeepCopyInto 

func (in *WorkflowtemplateDiskConfig) DeepCopyInto(out *WorkflowtemplateDiskConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateEncryptionConfig 

type WorkflowtemplateEncryptionConfig struct {
	/* Immutable. */
	// +optional
	GcePdKmsKeyRef *v1alpha1.ResourceRef `json:"gcePdKmsKeyRef,omitempty"`
}

func (*WorkflowtemplateEncryptionConfig) DeepCopy 

func (in *WorkflowtemplateEncryptionConfig) DeepCopy() *WorkflowtemplateEncryptionConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateEncryptionConfig.

func (*WorkflowtemplateEncryptionConfig) DeepCopyInto 

func (in *WorkflowtemplateEncryptionConfig) DeepCopyInto(out *WorkflowtemplateEncryptionConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateEndpointConfig 

type WorkflowtemplateEndpointConfig struct {
	/* Immutable. Optional. If true, enable http access to specific ports on the cluster from external sources. Defaults to false. */
	// +optional
	EnableHttpPortAccess *bool `json:"enableHttpPortAccess,omitempty"`
}

func (*WorkflowtemplateEndpointConfig) DeepCopy 

func (in *WorkflowtemplateEndpointConfig) DeepCopy() *WorkflowtemplateEndpointConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateEndpointConfig.

func (*WorkflowtemplateEndpointConfig) DeepCopyInto 

func (in *WorkflowtemplateEndpointConfig) DeepCopyInto(out *WorkflowtemplateEndpointConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateEndpointConfigStatus 

type WorkflowtemplateEndpointConfigStatus struct {
	/* Output only. The map of port descriptions to URLs. Will only be populated if enable_http_port_access is true. */
	// +optional
	HttpPorts map[string]string `json:"httpPorts,omitempty"`
}

func (*WorkflowtemplateEndpointConfigStatus) DeepCopy 

func (in *WorkflowtemplateEndpointConfigStatus) DeepCopy() *WorkflowtemplateEndpointConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateEndpointConfigStatus.

func (*WorkflowtemplateEndpointConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateEndpointConfigStatus) DeepCopyInto(out *WorkflowtemplateEndpointConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateGceClusterConfig 

type WorkflowtemplateGceClusterConfig struct {
	/* Immutable. Optional. If true, all instances in the cluster will only have internal IP addresses. By default, clusters are not restricted to internal IP addresses, and will have ephemeral external IP addresses assigned to each instance. This `internal_ip_only` restriction can only be enabled for subnetwork enabled networks, and all off-cluster dependencies must be configured to be accessible without external IP addresses. */
	// +optional
	InternalIPOnly *bool `json:"internalIPOnly,omitempty"`

	/* Immutable. The Compute Engine metadata entries to add to all instances (see [Project and instance metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)). */
	// +optional
	Metadata map[string]string `json:"metadata,omitempty"`

	/* Immutable. */
	// +optional
	NetworkRef *v1alpha1.ResourceRef `json:"networkRef,omitempty"`

	/* Immutable. Optional. Node Group Affinity for sole-tenant clusters. */
	// +optional
	NodeGroupAffinity *WorkflowtemplateNodeGroupAffinity `json:"nodeGroupAffinity,omitempty"`

	/* Immutable. Optional. The type of IPv6 access for a cluster. Possible values: PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED, INHERIT_FROM_SUBNETWORK, OUTBOUND, BIDIRECTIONAL */
	// +optional
	PrivateIPv6GoogleAccess *string `json:"privateIPv6GoogleAccess,omitempty"`

	/* Immutable. Optional. Reservation Affinity for consuming Zonal reservation. */
	// +optional
	ReservationAffinity *WorkflowtemplateReservationAffinity `json:"reservationAffinity,omitempty"`

	/* Immutable. */
	// +optional
	ServiceAccountRef *v1alpha1.ResourceRef `json:"serviceAccountRef,omitempty"`

	/* Immutable. Optional. The URIs of service account scopes to be included in Compute Engine instances. The following base set of scopes is always included: * https://www.googleapis.com/auth/cloud.useraccounts.readonly * https://www.googleapis.com/auth/devstorage.read_write * https://www.googleapis.com/auth/logging.write If no scopes are specified, the following defaults are also provided: * https://www.googleapis.com/auth/bigquery * https://www.googleapis.com/auth/bigtable.admin.table * https://www.googleapis.com/auth/bigtable.data * https://www.googleapis.com/auth/devstorage.full_control */
	// +optional
	ServiceAccountScopes []string `json:"serviceAccountScopes,omitempty"`

	/* Immutable. Optional. Shielded Instance Config for clusters using Compute Engine Shielded VMs. */
	// +optional
	ShieldedInstanceConfig *WorkflowtemplateShieldedInstanceConfig `json:"shieldedInstanceConfig,omitempty"`

	/* Immutable. */
	// +optional
	SubnetworkRef *v1alpha1.ResourceRef `json:"subnetworkRef,omitempty"`

	/* Immutable. The Compute Engine tags to add to all instances (see [Tagging instances](https://cloud.google.com/compute/docs/label-or-tag-resources#tags)). */
	// +optional
	Tags []string `json:"tags,omitempty"`

	/* Immutable. Optional. The zone where the Compute Engine cluster will be located. On a create request, it is required in the "global" region. If omitted in a non-global Dataproc region, the service will pick a zone in the corresponding Compute Engine region. On a get request, zone will always be present. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]` * `projects/[project_id]/zones/[zone]` * `us-central1-f` */
	// +optional
	Zone *string `json:"zone,omitempty"`
}

func (*WorkflowtemplateGceClusterConfig) DeepCopy 

func (in *WorkflowtemplateGceClusterConfig) DeepCopy() *WorkflowtemplateGceClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateGceClusterConfig.

func (*WorkflowtemplateGceClusterConfig) DeepCopyInto 

func (in *WorkflowtemplateGceClusterConfig) DeepCopyInto(out *WorkflowtemplateGceClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateHadoopJob 

type WorkflowtemplateHadoopJob struct {
	/* Immutable. Optional. HCFS URIs of archives to be extracted in the working directory of Hadoop drivers and tasks. Supported file types: .jar, .tar, .tar.gz, .tgz, or .zip. */
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty"`

	/* Immutable. Optional. The arguments to pass to the driver. Do not include arguments, such as `-libjars` or `-Dfoo=bar`, that can be set as job properties, since a collision may occur that causes an incorrect job submission. */
	// +optional
	Args []string `json:"args,omitempty"`

	/* Immutable. Optional. HCFS (Hadoop Compatible Filesystem) URIs of files to be copied to the working directory of Hadoop drivers and distributed tasks. Useful for naively parallel tasks. */
	// +optional
	FileUris []string `json:"fileUris,omitempty"`

	/* Immutable. Optional. Jar file URIs to add to the CLASSPATHs of the Hadoop driver and tasks. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. The name of the driver's main class. The jar file containing the class must be in the default CLASSPATH or specified in `jar_file_uris`. */
	// +optional
	MainClass *string `json:"mainClass,omitempty"`

	/* Immutable. The HCFS URI of the jar file containing the main class. Examples: 'gs://foo-bucket/analytics-binaries/extract-useful-metrics-mr.jar' 'hdfs:/tmp/test-samples/custom-wordcount.jar' 'file:///home/usr/lib/hadoop-mapreduce/hadoop-mapreduce-examples.jar' */
	// +optional
	MainJarFileUri *string `json:"mainJarFileUri,omitempty"`

	/* Immutable. Optional. A mapping of property names to values, used to configure Hadoop. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/hadoop/conf/*-site and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*WorkflowtemplateHadoopJob) DeepCopy 

func (in *WorkflowtemplateHadoopJob) DeepCopy() *WorkflowtemplateHadoopJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateHadoopJob.

func (*WorkflowtemplateHadoopJob) DeepCopyInto 

func (in *WorkflowtemplateHadoopJob) DeepCopyInto(out *WorkflowtemplateHadoopJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateHiveJob 

type WorkflowtemplateHiveJob struct {
	/* Immutable. Optional. Whether to continue executing queries if a query fails. The default value is `false`. Setting to `true` can be useful when executing independent parallel queries. */
	// +optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty"`

	/* Immutable. Optional. HCFS URIs of jar files to add to the CLASSPATH of the Hive server and Hadoop MapReduce (MR) tasks. Can contain Hive SerDes and UDFs. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. A mapping of property names and values, used to configure Hive. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml, /etc/hive/conf/hive-site.xml, and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	/* Immutable. The HCFS URI of the script that contains Hive queries. */
	// +optional
	QueryFileUri *string `json:"queryFileUri,omitempty"`

	/* Immutable. A list of queries. */
	// +optional
	QueryList *WorkflowtemplateQueryList `json:"queryList,omitempty"`

	/* Immutable. Optional. Mapping of query variable names to values (equivalent to the Hive command: `SET name="value";`). */
	// +optional
	ScriptVariables map[string]string `json:"scriptVariables,omitempty"`
}

func (*WorkflowtemplateHiveJob) DeepCopy 

func (in *WorkflowtemplateHiveJob) DeepCopy() *WorkflowtemplateHiveJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateHiveJob.

func (*WorkflowtemplateHiveJob) DeepCopyInto 

func (in *WorkflowtemplateHiveJob) DeepCopyInto(out *WorkflowtemplateHiveJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateInitializationActions 

type WorkflowtemplateInitializationActions struct {
	/* Immutable. Required. Cloud Storage URI of executable file. */
	// +optional
	ExecutableFile *string `json:"executableFile,omitempty"`

	/* Immutable. Optional. Amount of time executable has to complete. Default is 10 minutes (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). Cluster creation fails with an explanatory error message (the name of the executable that caused the error and the exceeded timeout period) if the executable is not completed at end of the timeout period. */
	// +optional
	ExecutionTimeout *string `json:"executionTimeout,omitempty"`
}

func (*WorkflowtemplateInitializationActions) DeepCopy 

func (in *WorkflowtemplateInitializationActions) DeepCopy() *WorkflowtemplateInitializationActions

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateInitializationActions.

func (*WorkflowtemplateInitializationActions) DeepCopyInto 

func (in *WorkflowtemplateInitializationActions) DeepCopyInto(out *WorkflowtemplateInitializationActions)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateJobs 

type WorkflowtemplateJobs struct {
	/* Immutable. Optional. Job is a Hadoop job. */
	// +optional
	HadoopJob *WorkflowtemplateHadoopJob `json:"hadoopJob,omitempty"`

	/* Immutable. Optional. Job is a Hive job. */
	// +optional
	HiveJob *WorkflowtemplateHiveJob `json:"hiveJob,omitempty"`

	/* Immutable. Optional. The labels to associate with this job. Label keys must be between 1 and 63 characters long, and must conform to the following regular expression: p{Ll}p{Lo}{0,62} Label values must be between 1 and 63 characters long, and must conform to the following regular expression: [p{Ll}p{Lo}p{N}_-]{0,63} No more than 32 labels can be associated with a given job. */
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	/* Immutable. Optional. Job is a Pig job. */
	// +optional
	PigJob *WorkflowtemplatePigJob `json:"pigJob,omitempty"`

	/* Immutable. Optional. The optional list of prerequisite job step_ids. If not specified, the job will start at the beginning of workflow. */
	// +optional
	PrerequisiteStepIds []string `json:"prerequisiteStepIds,omitempty"`

	/* Immutable. Optional. Job is a Presto job. */
	// +optional
	PrestoJob *WorkflowtemplatePrestoJob `json:"prestoJob,omitempty"`

	/* Immutable. Optional. Job is a PySpark job. */
	// +optional
	PysparkJob *WorkflowtemplatePysparkJob `json:"pysparkJob,omitempty"`

	/* Immutable. Optional. Job scheduling configuration. */
	// +optional
	Scheduling *WorkflowtemplateScheduling `json:"scheduling,omitempty"`

	/* Immutable. Optional. Job is a Spark job. */
	// +optional
	SparkJob *WorkflowtemplateSparkJob `json:"sparkJob,omitempty"`

	/* Immutable. Optional. Job is a SparkR job. */
	// +optional
	SparkRJob *WorkflowtemplateSparkRJob `json:"sparkRJob,omitempty"`

	/* Immutable. Optional. Job is a SparkSql job. */
	// +optional
	SparkSqlJob *WorkflowtemplateSparkSqlJob `json:"sparkSqlJob,omitempty"`

	/* Immutable. Required. The step id. The id must be unique among all jobs within the template. The step id is used as prefix for job id, as job `goog-dataproc-workflow-step-id` label, and in prerequisiteStepIds field from other steps. 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. */
	StepId string `json:"stepId"`
}

func (*WorkflowtemplateJobs) DeepCopy 

func (in *WorkflowtemplateJobs) DeepCopy() *WorkflowtemplateJobs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateJobs.

func (*WorkflowtemplateJobs) DeepCopyInto 

func (in *WorkflowtemplateJobs) DeepCopyInto(out *WorkflowtemplateJobs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateKerberosConfig 

type WorkflowtemplateKerberosConfig struct {
	/* Immutable. Optional. The admin server (IP or hostname) for the remote trusted realm in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustAdminServer *string `json:"crossRealmTrustAdminServer,omitempty"`

	/* Immutable. Optional. The KDC (IP or hostname) for the remote trusted realm in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustKdc *string `json:"crossRealmTrustKdc,omitempty"`

	/* Immutable. Optional. The remote realm the Dataproc on-cluster KDC will trust, should the user enable cross realm trust. */
	// +optional
	CrossRealmTrustRealm *string `json:"crossRealmTrustRealm,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the shared password between the on-cluster Kerberos realm and the remote trusted realm, in a cross realm trust relationship. */
	// +optional
	CrossRealmTrustSharedPassword *string `json:"crossRealmTrustSharedPassword,omitempty"`

	/* Immutable. Optional. Flag to indicate whether to Kerberize the cluster (default: false). Set this field to true to enable Kerberos on a cluster. */
	// +optional
	EnableKerberos *bool `json:"enableKerberos,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the master key of the KDC database. */
	// +optional
	KdcDbKey *string `json:"kdcDbKey,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided key. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	KeyPassword *string `json:"keyPassword,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of the keystore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate. */
	// +optional
	Keystore *string `json:"keystore,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided keystore. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	KeystorePassword *string `json:"keystorePassword,omitempty"`

	/* Immutable. */
	// +optional
	KmsKeyRef *v1alpha1.ResourceRef `json:"kmsKeyRef,omitempty"`

	/* Immutable. Optional. The name of the on-cluster Kerberos realm. If not specified, the uppercased domain of hostnames will be the realm. */
	// +optional
	Realm *string `json:"realm,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the root principal password. */
	// +optional
	RootPrincipalPassword *string `json:"rootPrincipalPassword,omitempty"`

	/* Immutable. Optional. The lifetime of the ticket granting ticket, in hours. If not specified, or user specifies 0, then default value 10 will be used. */
	// +optional
	TgtLifetimeHours *int `json:"tgtLifetimeHours,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of the truststore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate. */
	// +optional
	Truststore *string `json:"truststore,omitempty"`

	/* Immutable. Optional. The Cloud Storage URI of a KMS encrypted file containing the password to the user provided truststore. For the self-signed certificate, this password is generated by Dataproc. */
	// +optional
	TruststorePassword *string `json:"truststorePassword,omitempty"`
}

func (*WorkflowtemplateKerberosConfig) DeepCopy 

func (in *WorkflowtemplateKerberosConfig) DeepCopy() *WorkflowtemplateKerberosConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateKerberosConfig.

func (*WorkflowtemplateKerberosConfig) DeepCopyInto 

func (in *WorkflowtemplateKerberosConfig) DeepCopyInto(out *WorkflowtemplateKerberosConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateLifecycleConfig 

type WorkflowtemplateLifecycleConfig struct {
	/* Immutable. Optional. The time when cluster will be auto-deleted (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	AutoDeleteTime *string `json:"autoDeleteTime,omitempty"`

	/* Immutable. Optional. The lifetime duration of cluster. The cluster will be auto-deleted at the end of this period. Minimum value is 10 minutes; maximum value is 14 days (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	AutoDeleteTtl *string `json:"autoDeleteTtl,omitempty"`

	/* Immutable. Optional. The duration to keep the cluster alive while idling (when no jobs are running). Passing this threshold will cause the cluster to be deleted. Minimum value is 5 minutes; maximum value is 14 days (see JSON representation of [Duration](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	IdleDeleteTtl *string `json:"idleDeleteTtl,omitempty"`
}

func (*WorkflowtemplateLifecycleConfig) DeepCopy 

func (in *WorkflowtemplateLifecycleConfig) DeepCopy() *WorkflowtemplateLifecycleConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateLifecycleConfig.

func (*WorkflowtemplateLifecycleConfig) DeepCopyInto 

func (in *WorkflowtemplateLifecycleConfig) DeepCopyInto(out *WorkflowtemplateLifecycleConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateLifecycleConfigStatus 

type WorkflowtemplateLifecycleConfigStatus struct {
	/* Output only. The time when cluster became idle (most recent job finished) and became eligible for deletion due to idleness (see JSON representation of [Timestamp](https://developers.google.com/protocol-buffers/docs/proto3#json)). */
	// +optional
	IdleStartTime *string `json:"idleStartTime,omitempty"`
}

func (*WorkflowtemplateLifecycleConfigStatus) DeepCopy 

func (in *WorkflowtemplateLifecycleConfigStatus) DeepCopy() *WorkflowtemplateLifecycleConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateLifecycleConfigStatus.

func (*WorkflowtemplateLifecycleConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateLifecycleConfigStatus) DeepCopyInto(out *WorkflowtemplateLifecycleConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateLoggingConfig 

type WorkflowtemplateLoggingConfig struct {
	/* Immutable. The per-package log levels for the driver. This may include "root" package name to configure rootLogger. Examples: 'com.google = FATAL', 'root = INFO', 'org.apache = DEBUG' */
	// +optional
	DriverLogLevels map[string]string `json:"driverLogLevels,omitempty"`
}

func (*WorkflowtemplateLoggingConfig) DeepCopy 

func (in *WorkflowtemplateLoggingConfig) DeepCopy() *WorkflowtemplateLoggingConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateLoggingConfig.

func (*WorkflowtemplateLoggingConfig) DeepCopyInto 

func (in *WorkflowtemplateLoggingConfig) DeepCopyInto(out *WorkflowtemplateLoggingConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateManagedCluster 

type WorkflowtemplateManagedCluster struct {
	/* Immutable. Required. The cluster name prefix. A unique cluster name will be formed by appending a random suffix. The name must contain only lower-case letters (a-z), numbers (0-9), and hyphens (-). Must begin with a letter. Cannot begin or end with hyphen. Must consist of between 2 and 35 characters. */
	ClusterName string `json:"clusterName"`

	/* Immutable. Required. The cluster configuration. */
	Config WorkflowtemplateConfig `json:"config"`

	/* Immutable. Optional. The labels to associate with this cluster. Label keys must be between 1 and 63 characters long, and must conform to the following PCRE regular expression: p{Ll}p{Lo}{0,62} Label values must be between 1 and 63 characters long, and must conform to the following PCRE regular expression: [p{Ll}p{Lo}p{N}_-]{0,63} No more than 32 labels can be associated with a given cluster. */
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
}

func (*WorkflowtemplateManagedCluster) DeepCopy 

func (in *WorkflowtemplateManagedCluster) DeepCopy() *WorkflowtemplateManagedCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateManagedCluster.

func (*WorkflowtemplateManagedCluster) DeepCopyInto 

func (in *WorkflowtemplateManagedCluster) DeepCopyInto(out *WorkflowtemplateManagedCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateManagedClusterStatus 

type WorkflowtemplateManagedClusterStatus struct {
	// +optional
	Config *WorkflowtemplateConfigStatus `json:"config,omitempty"`
}

func (*WorkflowtemplateManagedClusterStatus) DeepCopy 

func (in *WorkflowtemplateManagedClusterStatus) DeepCopy() *WorkflowtemplateManagedClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateManagedClusterStatus.

func (*WorkflowtemplateManagedClusterStatus) DeepCopyInto 

func (in *WorkflowtemplateManagedClusterStatus) DeepCopyInto(out *WorkflowtemplateManagedClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateManagedGroupConfigStatus 

type WorkflowtemplateManagedGroupConfigStatus struct {
	/* Output only. The name of the Instance Group Manager for this group. */
	// +optional
	InstanceGroupManagerName *string `json:"instanceGroupManagerName,omitempty"`

	/* Output only. The name of the Instance Template used for the Managed Instance Group. */
	// +optional
	InstanceTemplateName *string `json:"instanceTemplateName,omitempty"`
}

func (*WorkflowtemplateManagedGroupConfigStatus) DeepCopy 

func (in *WorkflowtemplateManagedGroupConfigStatus) DeepCopy() *WorkflowtemplateManagedGroupConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateManagedGroupConfigStatus.

func (*WorkflowtemplateManagedGroupConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateManagedGroupConfigStatus) DeepCopyInto(out *WorkflowtemplateManagedGroupConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateMasterConfig 

type WorkflowtemplateMasterConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []WorkflowtemplateAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *WorkflowtemplateDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*WorkflowtemplateMasterConfig) DeepCopy 

func (in *WorkflowtemplateMasterConfig) DeepCopy() *WorkflowtemplateMasterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateMasterConfig.

func (*WorkflowtemplateMasterConfig) DeepCopyInto 

func (in *WorkflowtemplateMasterConfig) DeepCopyInto(out *WorkflowtemplateMasterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateMasterConfigStatus 

type WorkflowtemplateMasterConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *WorkflowtemplateManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*WorkflowtemplateMasterConfigStatus) DeepCopy 

func (in *WorkflowtemplateMasterConfigStatus) DeepCopy() *WorkflowtemplateMasterConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateMasterConfigStatus.

func (*WorkflowtemplateMasterConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateMasterConfigStatus) DeepCopyInto(out *WorkflowtemplateMasterConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateNodeGroupAffinity 

type WorkflowtemplateNodeGroupAffinity struct {
	/* Immutable. */
	NodeGroupRef v1alpha1.ResourceRef `json:"nodeGroupRef"`
}

func (*WorkflowtemplateNodeGroupAffinity) DeepCopy 

func (in *WorkflowtemplateNodeGroupAffinity) DeepCopy() *WorkflowtemplateNodeGroupAffinity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateNodeGroupAffinity.

func (*WorkflowtemplateNodeGroupAffinity) DeepCopyInto 

func (in *WorkflowtemplateNodeGroupAffinity) DeepCopyInto(out *WorkflowtemplateNodeGroupAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateParameters 

type WorkflowtemplateParameters struct {
	/* Immutable. Optional. Brief description of the parameter. Must not exceed 1024 characters. */
	// +optional
	Description *string `json:"description,omitempty"`

	/* Immutable. Required. Paths to all fields that the parameter replaces. A field is allowed to appear in at most one parameter's list of field paths. A field path is similar in syntax to a google.protobuf.FieldMask. For example, a field path that references the zone field of a workflow template's cluster selector would be specified as `placement.clusterSelector.zone`. Also, field paths can reference fields using the following syntax: * Values in maps can be referenced by key: * labels['key'] * placement.clusterSelector.clusterLabels['key'] * placement.managedCluster.labels['key'] * placement.clusterSelector.clusterLabels['key'] * jobs['step-id'].labels['key'] * Jobs in the jobs list can be referenced by step-id: * jobs['step-id'].hadoopJob.mainJarFileUri * jobs['step-id'].hiveJob.queryFileUri * jobs['step-id'].pySparkJob.mainPythonFileUri * jobs['step-id'].hadoopJob.jarFileUris[0] * jobs['step-id'].hadoopJob.archiveUris[0] * jobs['step-id'].hadoopJob.fileUris[0] * jobs['step-id'].pySparkJob.pythonFileUris[0] * Items in repeated fields can be referenced by a zero-based index: * jobs['step-id'].sparkJob.args[0] * Other examples: * jobs['step-id'].hadoopJob.properties['key'] * jobs['step-id'].hadoopJob.args[0] * jobs['step-id'].hiveJob.scriptVariables['key'] * jobs['step-id'].hadoopJob.mainJarFileUri * placement.clusterSelector.zone It may not be possible to parameterize maps and repeated fields in their entirety since only individual map values and individual items in repeated fields can be referenced. For example, the following field paths are invalid: - placement.clusterSelector.clusterLabels - jobs['step-id'].sparkJob.args */
	Fields []string `json:"fields"`

	/* Immutable. Required. Parameter name. The parameter name is used as the key, and paired with the parameter value, which are passed to the template when the template is instantiated. The name must contain only capital letters (A-Z), numbers (0-9), and underscores (_), and must not start with a number. The maximum length is 40 characters. */
	Name string `json:"name"`

	/* Immutable. Optional. Validation rules to be applied to this parameter's value. */
	// +optional
	Validation *WorkflowtemplateValidation `json:"validation,omitempty"`
}

func (*WorkflowtemplateParameters) DeepCopy 

func (in *WorkflowtemplateParameters) DeepCopy() *WorkflowtemplateParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateParameters.

func (*WorkflowtemplateParameters) DeepCopyInto 

func (in *WorkflowtemplateParameters) DeepCopyInto(out *WorkflowtemplateParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplatePigJob 

type WorkflowtemplatePigJob struct {
	/* Immutable. Optional. Whether to continue executing queries if a query fails. The default value is `false`. Setting to `true` can be useful when executing independent parallel queries. */
	// +optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty"`

	/* Immutable. Optional. HCFS URIs of jar files to add to the CLASSPATH of the Pig Client and Hadoop MapReduce (MR) tasks. Can contain Pig UDFs. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. Optional. A mapping of property names to values, used to configure Pig. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml, /etc/pig/conf/pig.properties, and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	/* Immutable. The HCFS URI of the script that contains the Pig queries. */
	// +optional
	QueryFileUri *string `json:"queryFileUri,omitempty"`

	/* Immutable. A list of queries. */
	// +optional
	QueryList *WorkflowtemplateQueryList `json:"queryList,omitempty"`

	/* Immutable. Optional. Mapping of query variable names to values (equivalent to the Pig command: `name=[value]`). */
	// +optional
	ScriptVariables map[string]string `json:"scriptVariables,omitempty"`
}

func (*WorkflowtemplatePigJob) DeepCopy 

func (in *WorkflowtemplatePigJob) DeepCopy() *WorkflowtemplatePigJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplatePigJob.

func (*WorkflowtemplatePigJob) DeepCopyInto 

func (in *WorkflowtemplatePigJob) DeepCopyInto(out *WorkflowtemplatePigJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplatePlacement 

type WorkflowtemplatePlacement struct {
	/* Immutable. Optional. A selector that chooses target cluster for jobs based on metadata. The selector is evaluated at the time each job is submitted. */
	// +optional
	ClusterSelector *WorkflowtemplateClusterSelector `json:"clusterSelector,omitempty"`

	/* Immutable. A cluster that is managed by the workflow. */
	// +optional
	ManagedCluster *WorkflowtemplateManagedCluster `json:"managedCluster,omitempty"`
}

func (*WorkflowtemplatePlacement) DeepCopy 

func (in *WorkflowtemplatePlacement) DeepCopy() *WorkflowtemplatePlacement

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplatePlacement.

func (*WorkflowtemplatePlacement) DeepCopyInto 

func (in *WorkflowtemplatePlacement) DeepCopyInto(out *WorkflowtemplatePlacement)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplatePlacementStatus 

type WorkflowtemplatePlacementStatus struct {
	// +optional
	ManagedCluster *WorkflowtemplateManagedClusterStatus `json:"managedCluster,omitempty"`
}

func (*WorkflowtemplatePlacementStatus) DeepCopy 

func (in *WorkflowtemplatePlacementStatus) DeepCopy() *WorkflowtemplatePlacementStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplatePlacementStatus.

func (*WorkflowtemplatePlacementStatus) DeepCopyInto 

func (in *WorkflowtemplatePlacementStatus) DeepCopyInto(out *WorkflowtemplatePlacementStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplatePrestoJob 

type WorkflowtemplatePrestoJob struct {
	/* Immutable. Optional. Presto client tags to attach to this query */
	// +optional
	ClientTags []string `json:"clientTags,omitempty"`

	/* Immutable. Optional. Whether to continue executing queries if a query fails. The default value is `false`. Setting to `true` can be useful when executing independent parallel queries. */
	// +optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. Optional. The format in which query output will be displayed. See the Presto documentation for supported output formats */
	// +optional
	OutputFormat *string `json:"outputFormat,omitempty"`

	/* Immutable. Optional. A mapping of property names to values. Used to set Presto [session properties](https://prestodb.io/docs/current/sql/set-session.html) Equivalent to using the --session flag in the Presto CLI */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	/* Immutable. The HCFS URI of the script that contains SQL queries. */
	// +optional
	QueryFileUri *string `json:"queryFileUri,omitempty"`

	/* Immutable. A list of queries. */
	// +optional
	QueryList *WorkflowtemplateQueryList `json:"queryList,omitempty"`
}

func (*WorkflowtemplatePrestoJob) DeepCopy 

func (in *WorkflowtemplatePrestoJob) DeepCopy() *WorkflowtemplatePrestoJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplatePrestoJob.

func (*WorkflowtemplatePrestoJob) DeepCopyInto 

func (in *WorkflowtemplatePrestoJob) DeepCopyInto(out *WorkflowtemplatePrestoJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplatePysparkJob 

type WorkflowtemplatePysparkJob struct {
	/* Immutable. Optional. HCFS URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip. */
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty"`

	/* Immutable. Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision may occur that causes an incorrect job submission. */
	// +optional
	Args []string `json:"args,omitempty"`

	/* Immutable. Optional. HCFS URIs of files to be placed in the working directory of each executor. Useful for naively parallel tasks. */
	// +optional
	FileUris []string `json:"fileUris,omitempty"`

	/* Immutable. Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Python driver and tasks. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. Required. The HCFS URI of the main Python file to use as the driver. Must be a .py file. */
	MainPythonFileUri string `json:"mainPythonFileUri"`

	/* Immutable. Optional. A mapping of property names to values, used to configure PySpark. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	/* Immutable. Optional. HCFS file URIs of Python files to pass to the PySpark framework. Supported file types: .py, .egg, and .zip. */
	// +optional
	PythonFileUris []string `json:"pythonFileUris,omitempty"`
}

func (*WorkflowtemplatePysparkJob) DeepCopy 

func (in *WorkflowtemplatePysparkJob) DeepCopy() *WorkflowtemplatePysparkJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplatePysparkJob.

func (*WorkflowtemplatePysparkJob) DeepCopyInto 

func (in *WorkflowtemplatePysparkJob) DeepCopyInto(out *WorkflowtemplatePysparkJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateQueryList 

type WorkflowtemplateQueryList struct {
	/* Immutable. Required. The queries to execute. You do not need to end a query expression with a semicolon. Multiple queries can be specified in one string by separating each with a semicolon. Here is an example of a Dataproc API snippet that uses a QueryList to specify a HiveJob: "hiveJob": { "queryList": { "queries": [ "query1", "query2", "query3;query4", ] } } */
	Queries []string `json:"queries"`
}

func (*WorkflowtemplateQueryList) DeepCopy 

func (in *WorkflowtemplateQueryList) DeepCopy() *WorkflowtemplateQueryList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateQueryList.

func (*WorkflowtemplateQueryList) DeepCopyInto 

func (in *WorkflowtemplateQueryList) DeepCopyInto(out *WorkflowtemplateQueryList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateRegex 

type WorkflowtemplateRegex struct {
	/* Immutable. Required. RE2 regular expressions used to validate the parameter's value. The value must match the regex in its entirety (substring matches are not sufficient). */
	Regexes []string `json:"regexes"`
}

func (*WorkflowtemplateRegex) DeepCopy 

func (in *WorkflowtemplateRegex) DeepCopy() *WorkflowtemplateRegex

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateRegex.

func (*WorkflowtemplateRegex) DeepCopyInto 

func (in *WorkflowtemplateRegex) DeepCopyInto(out *WorkflowtemplateRegex)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateReservationAffinity 

type WorkflowtemplateReservationAffinity struct {
	/* Immutable. Optional. Type of reservation to consume Possible values: TYPE_UNSPECIFIED, NO_RESERVATION, ANY_RESERVATION, SPECIFIC_RESERVATION */
	// +optional
	ConsumeReservationType *string `json:"consumeReservationType,omitempty"`

	/* Immutable. Optional. Corresponds to the label key of reservation resource. */
	// +optional
	Key *string `json:"key,omitempty"`

	/* Immutable. Optional. Corresponds to the label values of reservation resource. */
	// +optional
	Values []WorkflowtemplateValues `json:"values,omitempty"`
}

func (*WorkflowtemplateReservationAffinity) DeepCopy 

func (in *WorkflowtemplateReservationAffinity) DeepCopy() *WorkflowtemplateReservationAffinity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateReservationAffinity.

func (*WorkflowtemplateReservationAffinity) DeepCopyInto 

func (in *WorkflowtemplateReservationAffinity) DeepCopyInto(out *WorkflowtemplateReservationAffinity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateScheduling 

type WorkflowtemplateScheduling struct {
	/* Immutable. Optional. Maximum number of times per hour a driver may be restarted as a result of driver exiting with non-zero code before job is reported failed. A job may be reported as thrashing if driver exits with non-zero code 4 times within 10 minute window. Maximum value is 10. */
	// +optional
	MaxFailuresPerHour *int `json:"maxFailuresPerHour,omitempty"`

	/* Immutable. Optional. Maximum number of times in total a driver may be restarted as a result of driver exiting with non-zero code before job is reported failed. Maximum value is 240. */
	// +optional
	MaxFailuresTotal *int `json:"maxFailuresTotal,omitempty"`
}

func (*WorkflowtemplateScheduling) DeepCopy 

func (in *WorkflowtemplateScheduling) DeepCopy() *WorkflowtemplateScheduling

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateScheduling.

func (*WorkflowtemplateScheduling) DeepCopyInto 

func (in *WorkflowtemplateScheduling) DeepCopyInto(out *WorkflowtemplateScheduling)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSecondaryWorkerConfig 

type WorkflowtemplateSecondaryWorkerConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []WorkflowtemplateAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *WorkflowtemplateDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*WorkflowtemplateSecondaryWorkerConfig) DeepCopy 

func (in *WorkflowtemplateSecondaryWorkerConfig) DeepCopy() *WorkflowtemplateSecondaryWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSecondaryWorkerConfig.

func (*WorkflowtemplateSecondaryWorkerConfig) DeepCopyInto 

func (in *WorkflowtemplateSecondaryWorkerConfig) DeepCopyInto(out *WorkflowtemplateSecondaryWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSecondaryWorkerConfigStatus 

type WorkflowtemplateSecondaryWorkerConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *WorkflowtemplateManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*WorkflowtemplateSecondaryWorkerConfigStatus) DeepCopy 

func (in *WorkflowtemplateSecondaryWorkerConfigStatus) DeepCopy() *WorkflowtemplateSecondaryWorkerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSecondaryWorkerConfigStatus.

func (*WorkflowtemplateSecondaryWorkerConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateSecondaryWorkerConfigStatus) DeepCopyInto(out *WorkflowtemplateSecondaryWorkerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSecurityConfig 

type WorkflowtemplateSecurityConfig struct {
	/* Immutable. Optional. Kerberos related configuration. */
	// +optional
	KerberosConfig *WorkflowtemplateKerberosConfig `json:"kerberosConfig,omitempty"`
}

func (*WorkflowtemplateSecurityConfig) DeepCopy 

func (in *WorkflowtemplateSecurityConfig) DeepCopy() *WorkflowtemplateSecurityConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSecurityConfig.

func (*WorkflowtemplateSecurityConfig) DeepCopyInto 

func (in *WorkflowtemplateSecurityConfig) DeepCopyInto(out *WorkflowtemplateSecurityConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateShieldedInstanceConfig added in v1.94.0 

type WorkflowtemplateShieldedInstanceConfig struct {
	/* Immutable. Optional. Defines whether instances have integrity monitoring enabled. Integrity monitoring compares the most recent boot measurements to the integrity policy baseline and returns a pair of pass/fail results depending on whether they match or not. */
	// +optional
	EnableIntegrityMonitoring *bool `json:"enableIntegrityMonitoring,omitempty"`

	/* Immutable. Optional. Defines whether the instances have Secure Boot enabled. Secure Boot helps ensure that the system only runs authentic software by verifying the digital signature of all boot components, and halting the boot process if signature verification fails. */
	// +optional
	EnableSecureBoot *bool `json:"enableSecureBoot,omitempty"`

	/* Immutable. Optional. Defines whether the instance have the vTPM enabled. Virtual Trusted Platform Module protects objects like keys, certificates and enables Measured Boot by performing the measurements needed to create a known good boot baseline, called the integrity policy baseline. */
	// +optional
	EnableVtpm *bool `json:"enableVtpm,omitempty"`
}

func (*WorkflowtemplateShieldedInstanceConfig) DeepCopy added in v1.94.0 

func (in *WorkflowtemplateShieldedInstanceConfig) DeepCopy() *WorkflowtemplateShieldedInstanceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateShieldedInstanceConfig.

func (*WorkflowtemplateShieldedInstanceConfig) DeepCopyInto added in v1.94.0 

func (in *WorkflowtemplateShieldedInstanceConfig) DeepCopyInto(out *WorkflowtemplateShieldedInstanceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSoftwareConfig 

type WorkflowtemplateSoftwareConfig struct {
	/* Immutable. Optional. The version of software inside the cluster. It must be one of the supported [Dataproc Versions](https://cloud.google.com/dataproc/docs/concepts/versioning/dataproc-versions#supported_dataproc_versions), such as "1.2" (including a subminor version, such as "1.2.29"), or the ["preview" version](https://cloud.google.com/dataproc/docs/concepts/versioning/dataproc-versions#other_versions). If unspecified, it defaults to the latest Debian version. */
	// +optional
	ImageVersion *string `json:"imageVersion,omitempty"`

	/* Immutable. Optional. The set of components to activate on the cluster. */
	// +optional
	OptionalComponents []string `json:"optionalComponents,omitempty"`

	/* Immutable. Optional. The properties to set on daemon config files. Property keys are specified in `prefix:property` format, for example `core:hadoop.tmp.dir`. The following are supported prefixes and their mappings: * capacity-scheduler: `capacity-scheduler.xml` * core: `core-site.xml` * distcp: `distcp-default.xml` * hdfs: `hdfs-site.xml` * hive: `hive-site.xml` * mapred: `mapred-site.xml` * pig: `pig.properties` * spark: `spark-defaults.conf` * yarn: `yarn-site.xml` For more information, see [Cluster properties](https://cloud.google.com/dataproc/docs/concepts/cluster-properties). */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*WorkflowtemplateSoftwareConfig) DeepCopy 

func (in *WorkflowtemplateSoftwareConfig) DeepCopy() *WorkflowtemplateSoftwareConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSoftwareConfig.

func (*WorkflowtemplateSoftwareConfig) DeepCopyInto 

func (in *WorkflowtemplateSoftwareConfig) DeepCopyInto(out *WorkflowtemplateSoftwareConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSparkJob 

type WorkflowtemplateSparkJob struct {
	/* Immutable. Optional. HCFS URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip. */
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty"`

	/* Immutable. Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision may occur that causes an incorrect job submission. */
	// +optional
	Args []string `json:"args,omitempty"`

	/* Immutable. Optional. HCFS URIs of files to be placed in the working directory of each executor. Useful for naively parallel tasks. */
	// +optional
	FileUris []string `json:"fileUris,omitempty"`

	/* Immutable. Optional. HCFS URIs of jar files to add to the CLASSPATHs of the Spark driver and tasks. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. The name of the driver's main class. The jar file that contains the class must be in the default CLASSPATH or specified in `jar_file_uris`. */
	// +optional
	MainClass *string `json:"mainClass,omitempty"`

	/* Immutable. The HCFS URI of the jar file that contains the main class. */
	// +optional
	MainJarFileUri *string `json:"mainJarFileUri,omitempty"`

	/* Immutable. Optional. A mapping of property names to values, used to configure Spark. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*WorkflowtemplateSparkJob) DeepCopy 

func (in *WorkflowtemplateSparkJob) DeepCopy() *WorkflowtemplateSparkJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSparkJob.

func (*WorkflowtemplateSparkJob) DeepCopyInto 

func (in *WorkflowtemplateSparkJob) DeepCopyInto(out *WorkflowtemplateSparkJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSparkRJob 

type WorkflowtemplateSparkRJob struct {
	/* Immutable. Optional. HCFS URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip. */
	// +optional
	ArchiveUris []string `json:"archiveUris,omitempty"`

	/* Immutable. Optional. The arguments to pass to the driver. Do not include arguments, such as `--conf`, that can be set as job properties, since a collision may occur that causes an incorrect job submission. */
	// +optional
	Args []string `json:"args,omitempty"`

	/* Immutable. Optional. HCFS URIs of files to be placed in the working directory of each executor. Useful for naively parallel tasks. */
	// +optional
	FileUris []string `json:"fileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. Required. The HCFS URI of the main R file to use as the driver. Must be a .R file. */
	MainRFileUri string `json:"mainRFileUri"`

	/* Immutable. Optional. A mapping of property names to values, used to configure SparkR. Properties that conflict with values set by the Dataproc API may be overwritten. Can include properties set in /etc/spark/conf/spark-defaults.conf and classes in user code. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`
}

func (*WorkflowtemplateSparkRJob) DeepCopy 

func (in *WorkflowtemplateSparkRJob) DeepCopy() *WorkflowtemplateSparkRJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSparkRJob.

func (*WorkflowtemplateSparkRJob) DeepCopyInto 

func (in *WorkflowtemplateSparkRJob) DeepCopyInto(out *WorkflowtemplateSparkRJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateSparkSqlJob 

type WorkflowtemplateSparkSqlJob struct {
	/* Immutable. Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH. */
	// +optional
	JarFileUris []string `json:"jarFileUris,omitempty"`

	/* Immutable. Optional. The runtime log config for job execution. */
	// +optional
	LoggingConfig *WorkflowtemplateLoggingConfig `json:"loggingConfig,omitempty"`

	/* Immutable. Optional. A mapping of property names to values, used to configure Spark SQL's SparkConf. Properties that conflict with values set by the Dataproc API may be overwritten. */
	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	/* Immutable. The HCFS URI of the script that contains SQL queries. */
	// +optional
	QueryFileUri *string `json:"queryFileUri,omitempty"`

	/* Immutable. A list of queries. */
	// +optional
	QueryList *WorkflowtemplateQueryList `json:"queryList,omitempty"`

	/* Immutable. Optional. Mapping of query variable names to values (equivalent to the Spark SQL command: SET `name="value";`). */
	// +optional
	ScriptVariables map[string]string `json:"scriptVariables,omitempty"`
}

func (*WorkflowtemplateSparkSqlJob) DeepCopy 

func (in *WorkflowtemplateSparkSqlJob) DeepCopy() *WorkflowtemplateSparkSqlJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateSparkSqlJob.

func (*WorkflowtemplateSparkSqlJob) DeepCopyInto 

func (in *WorkflowtemplateSparkSqlJob) DeepCopyInto(out *WorkflowtemplateSparkSqlJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateValidation 

type WorkflowtemplateValidation struct {
	/* Immutable. Validation based on regular expressions. */
	// +optional
	Regex *WorkflowtemplateRegex `json:"regex,omitempty"`

	/* Immutable. Validation based on a list of allowed values. */
	// +optional
	Values *WorkflowtemplateValues `json:"values,omitempty"`
}

func (*WorkflowtemplateValidation) DeepCopy 

func (in *WorkflowtemplateValidation) DeepCopy() *WorkflowtemplateValidation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateValidation.

func (*WorkflowtemplateValidation) DeepCopyInto 

func (in *WorkflowtemplateValidation) DeepCopyInto(out *WorkflowtemplateValidation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateValues 

type WorkflowtemplateValues struct {
	/* Immutable. Required. List of allowed values for the parameter. */
	Values []WorkflowtemplateValues `json:"values"`
}

func (*WorkflowtemplateValues) DeepCopy 

func (in *WorkflowtemplateValues) DeepCopy() *WorkflowtemplateValues

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateValues.

func (*WorkflowtemplateValues) DeepCopyInto 

func (in *WorkflowtemplateValues) DeepCopyInto(out *WorkflowtemplateValues)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateWorkerConfig 

type WorkflowtemplateWorkerConfig struct {
	/* Immutable. Optional. The Compute Engine accelerator configuration for these instances. */
	// +optional
	Accelerators []WorkflowtemplateAccelerators `json:"accelerators,omitempty"`

	/* Immutable. Optional. Disk option config settings. */
	// +optional
	DiskConfig *WorkflowtemplateDiskConfig `json:"diskConfig,omitempty"`

	/* Immutable. */
	// +optional
	ImageRef *v1alpha1.ResourceRef `json:"imageRef,omitempty"`

	/* Immutable. Optional. The Compute Engine machine type used for cluster instances. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2` * `n1-standard-2` **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 machine type resource, for example, `n1-standard-2`. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. Optional. Specifies the minimum cpu platform for the Instance Group. See [Dataproc -> Minimum CPU Platform](https://cloud.google.com/dataproc/docs/concepts/compute/dataproc-min-cpu). */
	// +optional
	MinCpuPlatform *string `json:"minCpuPlatform,omitempty"`

	/* Immutable. Optional. The number of VM instances in the instance group. For [HA cluster](/dataproc/docs/concepts/configuring-clusters/high-availability) [master_config](#FIELDS.master_config) groups, **must be set to 3**. For standard cluster [master_config](#FIELDS.master_config) groups, **must be set to 1**. */
	// +optional
	NumInstances *int `json:"numInstances,omitempty"`

	/* Immutable. Optional. Specifies the preemptibility of the instance group. The default value for master and worker groups is `NON_PREEMPTIBLE`. This default cannot be changed. The default value for secondary instances is `PREEMPTIBLE`. Possible values: PREEMPTIBILITY_UNSPECIFIED, NON_PREEMPTIBLE, PREEMPTIBLE */
	// +optional
	Preemptibility *string `json:"preemptibility,omitempty"`
}

func (*WorkflowtemplateWorkerConfig) DeepCopy 

func (in *WorkflowtemplateWorkerConfig) DeepCopy() *WorkflowtemplateWorkerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateWorkerConfig.

func (*WorkflowtemplateWorkerConfig) DeepCopyInto 

func (in *WorkflowtemplateWorkerConfig) DeepCopyInto(out *WorkflowtemplateWorkerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkflowtemplateWorkerConfigStatus 

type WorkflowtemplateWorkerConfigStatus struct {
	/* Output only. The list of instance names. Dataproc derives the names from `cluster_name`, `num_instances`, and the instance group. */
	// +optional
	InstanceNames []string `json:"instanceNames,omitempty"`

	/* Output only. Specifies that this instance group contains preemptible instances. */
	// +optional
	IsPreemptible *bool `json:"isPreemptible,omitempty"`

	/* Output only. The config for Compute Engine Instance Group Manager that manages this group. This is only used for preemptible instance groups. */
	// +optional
	ManagedGroupConfig *WorkflowtemplateManagedGroupConfigStatus `json:"managedGroupConfig,omitempty"`
}

func (*WorkflowtemplateWorkerConfigStatus) DeepCopy 

func (in *WorkflowtemplateWorkerConfigStatus) DeepCopy() *WorkflowtemplateWorkerConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkflowtemplateWorkerConfigStatus.

func (*WorkflowtemplateWorkerConfigStatus) DeepCopyInto 

func (in *WorkflowtemplateWorkerConfigStatus) DeepCopyInto(out *WorkflowtemplateWorkerConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.