v1alpha1

package
v0.3.0-preview Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=dataproc.gcp.jet.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	CRDGroup   = "dataproc.gcp.jet.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	AutoscalingPolicy_Kind             = "AutoscalingPolicy"
	AutoscalingPolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: AutoscalingPolicy_Kind}.String()
	AutoscalingPolicy_KindAPIVersion   = AutoscalingPolicy_Kind + "." + CRDGroupVersion.String()
	AutoscalingPolicy_GroupVersionKind = CRDGroupVersion.WithKind(AutoscalingPolicy_Kind)
)

Repository type metadata.

View Source 
var (
	Cluster_Kind             = "Cluster"
	Cluster_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Cluster_Kind}.String()
	Cluster_KindAPIVersion   = Cluster_Kind + "." + CRDGroupVersion.String()
	Cluster_GroupVersionKind = CRDGroupVersion.WithKind(Cluster_Kind)
)

Repository type metadata.

View Source 
var (
	ClusterIAMBinding_Kind             = "ClusterIAMBinding"
	ClusterIAMBinding_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ClusterIAMBinding_Kind}.String()
	ClusterIAMBinding_KindAPIVersion   = ClusterIAMBinding_Kind + "." + CRDGroupVersion.String()
	ClusterIAMBinding_GroupVersionKind = CRDGroupVersion.WithKind(ClusterIAMBinding_Kind)
)

Repository type metadata.

View Source 
var (
	ClusterIAMMember_Kind             = "ClusterIAMMember"
	ClusterIAMMember_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ClusterIAMMember_Kind}.String()
	ClusterIAMMember_KindAPIVersion   = ClusterIAMMember_Kind + "." + CRDGroupVersion.String()
	ClusterIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(ClusterIAMMember_Kind)
)

Repository type metadata.

View Source 
var (
	ClusterIAMPolicy_Kind             = "ClusterIAMPolicy"
	ClusterIAMPolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ClusterIAMPolicy_Kind}.String()
	ClusterIAMPolicy_KindAPIVersion   = ClusterIAMPolicy_Kind + "." + CRDGroupVersion.String()
	ClusterIAMPolicy_GroupVersionKind = CRDGroupVersion.WithKind(ClusterIAMPolicy_Kind)
)

Repository type metadata.

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Job_Kind             = "Job"
	Job_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Job_Kind}.String()
	Job_KindAPIVersion   = Job_Kind + "." + CRDGroupVersion.String()
	Job_GroupVersionKind = CRDGroupVersion.WithKind(Job_Kind)
)

Repository type metadata.

View Source 
var (
	JobIAMBinding_Kind             = "JobIAMBinding"
	JobIAMBinding_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: JobIAMBinding_Kind}.String()
	JobIAMBinding_KindAPIVersion   = JobIAMBinding_Kind + "." + CRDGroupVersion.String()
	JobIAMBinding_GroupVersionKind = CRDGroupVersion.WithKind(JobIAMBinding_Kind)
)

Repository type metadata.

View Source 
var (
	JobIAMMember_Kind             = "JobIAMMember"
	JobIAMMember_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: JobIAMMember_Kind}.String()
	JobIAMMember_KindAPIVersion   = JobIAMMember_Kind + "." + CRDGroupVersion.String()
	JobIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(JobIAMMember_Kind)
)

Repository type metadata.

View Source 
var (
	JobIAMPolicy_Kind             = "JobIAMPolicy"
	JobIAMPolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: JobIAMPolicy_Kind}.String()
	JobIAMPolicy_KindAPIVersion   = JobIAMPolicy_Kind + "." + CRDGroupVersion.String()
	JobIAMPolicy_GroupVersionKind = CRDGroupVersion.WithKind(JobIAMPolicy_Kind)
)

Repository type metadata.

View Source 
var (
	WorkflowTemplate_Kind             = "WorkflowTemplate"
	WorkflowTemplate_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: WorkflowTemplate_Kind}.String()
	WorkflowTemplate_KindAPIVersion   = WorkflowTemplate_Kind + "." + CRDGroupVersion.String()
	WorkflowTemplate_GroupVersionKind = CRDGroupVersion.WithKind(WorkflowTemplate_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type AcceleratorsObservation 

type AcceleratorsObservation struct {
}

func (*AcceleratorsObservation) DeepCopy 

func (in *AcceleratorsObservation) DeepCopy() *AcceleratorsObservation

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

func (*AcceleratorsObservation) DeepCopyInto 

func (in *AcceleratorsObservation) DeepCopyInto(out *AcceleratorsObservation)

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

type AcceleratorsParameters 

type AcceleratorsParameters struct {

	// The number of the accelerator cards of this type exposed to this instance. Often restricted to one of 1, 2, 4, or 8.
	// +kubebuilder:validation:Required
	AcceleratorCount *float64 `json:"acceleratorCount" tf:"accelerator_count,omitempty"`

	// The short name of the accelerator type to expose to this instance. For example, nvidia-tesla-k80.
	// +kubebuilder:validation:Required
	AcceleratorType *string `json:"acceleratorType" tf:"accelerator_type,omitempty"`
}

func (*AcceleratorsParameters) DeepCopy 

func (in *AcceleratorsParameters) DeepCopy() *AcceleratorsParameters

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

func (*AcceleratorsParameters) DeepCopyInto 

func (in *AcceleratorsParameters) DeepCopyInto(out *AcceleratorsParameters)

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

type AutoscalingConfigObservation 

type AutoscalingConfigObservation struct {
}

func (*AutoscalingConfigObservation) DeepCopy 

func (in *AutoscalingConfigObservation) DeepCopy() *AutoscalingConfigObservation

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

func (*AutoscalingConfigObservation) DeepCopyInto 

func (in *AutoscalingConfigObservation) DeepCopyInto(out *AutoscalingConfigObservation)

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

type AutoscalingConfigParameters 

type AutoscalingConfigParameters struct {

	// The autoscaling policy used by the cluster.
	// +kubebuilder:validation:Required
	PolicyURI *string `json:"policyUri" tf:"policy_uri,omitempty"`
}

func (*AutoscalingConfigParameters) DeepCopy 

func (in *AutoscalingConfigParameters) DeepCopy() *AutoscalingConfigParameters

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

func (*AutoscalingConfigParameters) DeepCopyInto 

func (in *AutoscalingConfigParameters) DeepCopyInto(out *AutoscalingConfigParameters)

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

type AutoscalingPolicy 

type AutoscalingPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              AutoscalingPolicySpec   `json:"spec"`
	Status            AutoscalingPolicyStatus `json:"status,omitempty"`
}

AutoscalingPolicy is the Schema for the AutoscalingPolicys API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*AutoscalingPolicy) DeepCopy 

func (in *AutoscalingPolicy) DeepCopy() *AutoscalingPolicy

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

func (*AutoscalingPolicy) DeepCopyInto 

func (in *AutoscalingPolicy) DeepCopyInto(out *AutoscalingPolicy)

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

func (*AutoscalingPolicy) DeepCopyObject 

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

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

func (*AutoscalingPolicy) GetCondition 

func (mg *AutoscalingPolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this AutoscalingPolicy.

func (*AutoscalingPolicy) GetConnectionDetailsMapping 

func (tr *AutoscalingPolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this AutoscalingPolicy

func (*AutoscalingPolicy) GetDeletionPolicy 

func (mg *AutoscalingPolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this AutoscalingPolicy.

func (*AutoscalingPolicy) GetID 

func (tr *AutoscalingPolicy) GetID() string

GetID returns ID of underlying Terraform resource of this AutoscalingPolicy

func (*AutoscalingPolicy) GetObservation 

func (tr *AutoscalingPolicy) GetObservation() (map[string]interface{}, error)

GetObservation of this AutoscalingPolicy

func (*AutoscalingPolicy) GetParameters 

func (tr *AutoscalingPolicy) GetParameters() (map[string]interface{}, error)

GetParameters of this AutoscalingPolicy

func (*AutoscalingPolicy) GetProviderConfigReference 

func (mg *AutoscalingPolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this AutoscalingPolicy.

func (*AutoscalingPolicy) GetProviderReference 

func (mg *AutoscalingPolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this AutoscalingPolicy. Deprecated: Use GetProviderConfigReference.

func (*AutoscalingPolicy) GetPublishConnectionDetailsTo 

func (mg *AutoscalingPolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this AutoscalingPolicy.

func (*AutoscalingPolicy) GetTerraformResourceType 

func (mg *AutoscalingPolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this AutoscalingPolicy

func (*AutoscalingPolicy) GetTerraformSchemaVersion 

func (tr *AutoscalingPolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*AutoscalingPolicy) GetWriteConnectionSecretToReference 

func (mg *AutoscalingPolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this AutoscalingPolicy.

func (*AutoscalingPolicy) LateInitialize 

func (tr *AutoscalingPolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this AutoscalingPolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*AutoscalingPolicy) SetConditions 

func (mg *AutoscalingPolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this AutoscalingPolicy.

func (*AutoscalingPolicy) SetDeletionPolicy 

func (mg *AutoscalingPolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this AutoscalingPolicy.

func (*AutoscalingPolicy) SetObservation 

func (tr *AutoscalingPolicy) SetObservation(obs map[string]interface{}) error

SetObservation for this AutoscalingPolicy

func (*AutoscalingPolicy) SetParameters 

func (tr *AutoscalingPolicy) SetParameters(params map[string]interface{}) error

SetParameters for this AutoscalingPolicy

func (*AutoscalingPolicy) SetProviderConfigReference 

func (mg *AutoscalingPolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this AutoscalingPolicy.

func (*AutoscalingPolicy) SetProviderReference 

func (mg *AutoscalingPolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this AutoscalingPolicy. Deprecated: Use SetProviderConfigReference.

func (*AutoscalingPolicy) SetPublishConnectionDetailsTo 

func (mg *AutoscalingPolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this AutoscalingPolicy.

func (*AutoscalingPolicy) SetWriteConnectionSecretToReference 

func (mg *AutoscalingPolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this AutoscalingPolicy.

type AutoscalingPolicyList 

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

AutoscalingPolicyList contains a list of AutoscalingPolicys

func (*AutoscalingPolicyList) DeepCopy 

func (in *AutoscalingPolicyList) DeepCopy() *AutoscalingPolicyList

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

func (*AutoscalingPolicyList) DeepCopyInto 

func (in *AutoscalingPolicyList) DeepCopyInto(out *AutoscalingPolicyList)

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

func (*AutoscalingPolicyList) DeepCopyObject 

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

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

func (*AutoscalingPolicyList) GetItems 

func (l *AutoscalingPolicyList) GetItems() []resource.Managed

GetItems of this AutoscalingPolicyList.

type AutoscalingPolicyObservation 

type AutoscalingPolicyObservation struct {
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	Name *string `json:"name,omitempty" tf:"name,omitempty"`
}

func (*AutoscalingPolicyObservation) DeepCopy 

func (in *AutoscalingPolicyObservation) DeepCopy() *AutoscalingPolicyObservation

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

func (*AutoscalingPolicyObservation) DeepCopyInto 

func (in *AutoscalingPolicyObservation) DeepCopyInto(out *AutoscalingPolicyObservation)

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

type AutoscalingPolicyParameters 

type AutoscalingPolicyParameters struct {

	// Basic algorithm for autoscaling.
	// +kubebuilder:validation:Optional
	BasicAlgorithm []BasicAlgorithmParameters `json:"basicAlgorithm,omitempty" tf:"basic_algorithm,omitempty"`

	// The  location where the autoscaling policy should reside.
	// The default value is 'global'.
	// +kubebuilder:validation:Optional
	Location *string `json:"location,omitempty" tf:"location,omitempty"`

	// The policy id. The id must contain only letters (a-z, A-Z), numbers (0-9), underscores (_),
	// and hyphens (-). Cannot begin or end with underscore or hyphen. Must consist of between
	// 3 and 50 characters.
	// +kubebuilder:validation:Required
	PolicyID *string `json:"policyId" tf:"policy_id,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// Describes how the autoscaler will operate for secondary workers.
	// +kubebuilder:validation:Optional
	SecondaryWorkerConfig []SecondaryWorkerConfigParameters `json:"secondaryWorkerConfig,omitempty" tf:"secondary_worker_config,omitempty"`

	// Describes how the autoscaler will operate for primary workers.
	// +kubebuilder:validation:Optional
	WorkerConfig []WorkerConfigParameters `json:"workerConfig,omitempty" tf:"worker_config,omitempty"`
}

func (*AutoscalingPolicyParameters) DeepCopy 

func (in *AutoscalingPolicyParameters) DeepCopy() *AutoscalingPolicyParameters

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

func (*AutoscalingPolicyParameters) DeepCopyInto 

func (in *AutoscalingPolicyParameters) DeepCopyInto(out *AutoscalingPolicyParameters)

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

type AutoscalingPolicySpec 

type AutoscalingPolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     AutoscalingPolicyParameters `json:"forProvider"`
}

AutoscalingPolicySpec defines the desired state of AutoscalingPolicy

func (*AutoscalingPolicySpec) DeepCopy 

func (in *AutoscalingPolicySpec) DeepCopy() *AutoscalingPolicySpec

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

func (*AutoscalingPolicySpec) DeepCopyInto 

func (in *AutoscalingPolicySpec) DeepCopyInto(out *AutoscalingPolicySpec)

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

type AutoscalingPolicyStatus 

type AutoscalingPolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        AutoscalingPolicyObservation `json:"atProvider,omitempty"`
}

AutoscalingPolicyStatus defines the observed state of AutoscalingPolicy.

func (*AutoscalingPolicyStatus) DeepCopy 

func (in *AutoscalingPolicyStatus) DeepCopy() *AutoscalingPolicyStatus

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

func (*AutoscalingPolicyStatus) DeepCopyInto 

func (in *AutoscalingPolicyStatus) DeepCopyInto(out *AutoscalingPolicyStatus)

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

type BasicAlgorithmObservation 

type BasicAlgorithmObservation struct {
}

func (*BasicAlgorithmObservation) DeepCopy 

func (in *BasicAlgorithmObservation) DeepCopy() *BasicAlgorithmObservation

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

func (*BasicAlgorithmObservation) DeepCopyInto 

func (in *BasicAlgorithmObservation) DeepCopyInto(out *BasicAlgorithmObservation)

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

type BasicAlgorithmParameters 

type BasicAlgorithmParameters struct {

	// Duration between scaling events. A scaling period starts after the
	// update operation from the previous event has completed.
	//
	// Bounds: [2m, 1d]. Default: 2m.
	// +kubebuilder:validation:Optional
	CooldownPeriod *string `json:"cooldownPeriod,omitempty" tf:"cooldown_period,omitempty"`

	// YARN autoscaling configuration.
	// +kubebuilder:validation:Required
	YarnConfig []YarnConfigParameters `json:"yarnConfig" tf:"yarn_config,omitempty"`
}

func (*BasicAlgorithmParameters) DeepCopy 

func (in *BasicAlgorithmParameters) DeepCopy() *BasicAlgorithmParameters

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

func (*BasicAlgorithmParameters) DeepCopyInto 

func (in *BasicAlgorithmParameters) DeepCopyInto(out *BasicAlgorithmParameters)

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

type Cluster 

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec"`
	Status            ClusterStatus `json:"status,omitempty"`
}

Cluster is the Schema for the Clusters API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*Cluster) DeepCopy 

func (in *Cluster) DeepCopy() *Cluster

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

func (*Cluster) DeepCopyInto 

func (in *Cluster) DeepCopyInto(out *Cluster)

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

func (*Cluster) DeepCopyObject 

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

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

func (*Cluster) GetCondition 

func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Cluster.

func (*Cluster) GetConnectionDetailsMapping 

func (tr *Cluster) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Cluster

func (*Cluster) GetDeletionPolicy 

func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Cluster.

func (*Cluster) GetID 

func (tr *Cluster) GetID() string

GetID returns ID of underlying Terraform resource of this Cluster

func (*Cluster) GetObservation 

func (tr *Cluster) GetObservation() (map[string]interface{}, error)

GetObservation of this Cluster

func (*Cluster) GetParameters 

func (tr *Cluster) GetParameters() (map[string]interface{}, error)

GetParameters of this Cluster

func (*Cluster) GetProviderConfigReference 

func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Cluster.

func (*Cluster) GetProviderReference 

func (mg *Cluster) GetProviderReference() *xpv1.Reference

GetProviderReference of this Cluster. Deprecated: Use GetProviderConfigReference.

func (*Cluster) GetPublishConnectionDetailsTo 

func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) GetTerraformResourceType 

func (mg *Cluster) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Cluster

func (*Cluster) GetTerraformSchemaVersion 

func (tr *Cluster) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Cluster) GetWriteConnectionSecretToReference 

func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Cluster.

func (*Cluster) LateInitialize 

func (tr *Cluster) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Cluster using its observed tfState. returns True if there are any spec changes for the resource.

func (*Cluster) SetConditions 

func (mg *Cluster) SetConditions(c ...xpv1.Condition)

SetConditions of this Cluster.

func (*Cluster) SetDeletionPolicy 

func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Cluster.

func (*Cluster) SetObservation 

func (tr *Cluster) SetObservation(obs map[string]interface{}) error

SetObservation for this Cluster

func (*Cluster) SetParameters 

func (tr *Cluster) SetParameters(params map[string]interface{}) error

SetParameters for this Cluster

func (*Cluster) SetProviderConfigReference 

func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Cluster.

func (*Cluster) SetProviderReference 

func (mg *Cluster) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Cluster. Deprecated: Use SetProviderConfigReference.

func (*Cluster) SetPublishConnectionDetailsTo 

func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) SetWriteConnectionSecretToReference 

func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Cluster.

type ClusterConfigObservation 

type ClusterConfigObservation struct {
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`
}

func (*ClusterConfigObservation) DeepCopy 

func (in *ClusterConfigObservation) DeepCopy() *ClusterConfigObservation

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

func (*ClusterConfigObservation) DeepCopyInto 

func (in *ClusterConfigObservation) DeepCopyInto(out *ClusterConfigObservation)

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

type ClusterConfigParameters 

type ClusterConfigParameters struct {

	// The autoscaling policy config associated with the cluster.
	// +kubebuilder:validation:Optional
	AutoscalingConfig []AutoscalingConfigParameters `json:"autoscalingConfig,omitempty" tf:"autoscaling_config,omitempty"`

	// The Customer managed encryption keys settings for the cluster.
	// +kubebuilder:validation:Optional
	EncryptionConfig []EncryptionConfigParameters `json:"encryptionConfig,omitempty" tf:"encryption_config,omitempty"`

	// Common config settings for resources of Google Compute Engine cluster instances, applicable to all instances in the cluster.
	// +kubebuilder:validation:Optional
	GceClusterConfig []GceClusterConfigParameters `json:"gceClusterConfig,omitempty" tf:"gce_cluster_config,omitempty"`

	// Commands to execute on each node after config is completed. You can specify multiple versions of these.
	// +kubebuilder:validation:Optional
	InitializationAction []InitializationActionParameters `json:"initializationAction,omitempty" tf:"initialization_action,omitempty"`

	// The Google Compute Engine config settings for the master/worker instances in a cluster.
	// +kubebuilder:validation:Optional
	MasterConfig []MasterConfigParameters `json:"masterConfig,omitempty" tf:"master_config,omitempty"`

	// The Google Compute Engine config settings for the additional (aka preemptible) instances in a cluster.
	// +kubebuilder:validation:Optional
	PreemptibleWorkerConfig []PreemptibleWorkerConfigParameters `json:"preemptibleWorkerConfig,omitempty" tf:"preemptible_worker_config,omitempty"`

	// Security related configuration.
	// +kubebuilder:validation:Optional
	SecurityConfig []SecurityConfigParameters `json:"securityConfig,omitempty" tf:"security_config,omitempty"`

	// The config settings for software inside the cluster.
	// +kubebuilder:validation:Optional
	SoftwareConfig []SoftwareConfigParameters `json:"softwareConfig,omitempty" tf:"software_config,omitempty"`

	// The Cloud Storage staging bucket used to stage files, such as Hadoop jars, between client machines and the cluster. Note: If you don't explicitly specify a staging_bucket then GCP will auto create / assign one for you. However, you are not guaranteed an auto generated bucket which is solely dedicated to your cluster; it may be shared with other clusters in the same region/zone also choosing to use the auto generation option.
	// +kubebuilder:validation:Optional
	StagingBucket *string `json:"stagingBucket,omitempty" tf:"staging_bucket,omitempty"`

	// The Cloud Storage temp bucket used to store ephemeral cluster and jobs data, such as Spark and MapReduce history files. Note: If you don't explicitly specify a temp_bucket then GCP will auto create / assign one for you.
	// +kubebuilder:validation:Optional
	TempBucket *string `json:"tempBucket,omitempty" tf:"temp_bucket,omitempty"`

	// The Google Compute Engine config settings for the master/worker instances in a cluster.
	// +kubebuilder:validation:Optional
	WorkerConfig []ClusterConfigWorkerConfigParameters `json:"workerConfig,omitempty" tf:"worker_config,omitempty"`
}

func (*ClusterConfigParameters) DeepCopy 

func (in *ClusterConfigParameters) DeepCopy() *ClusterConfigParameters

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

func (*ClusterConfigParameters) DeepCopyInto 

func (in *ClusterConfigParameters) DeepCopyInto(out *ClusterConfigParameters)

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

type ClusterConfigWorkerConfigObservation 

type ClusterConfigWorkerConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`
}

func (*ClusterConfigWorkerConfigObservation) DeepCopy 

func (in *ClusterConfigWorkerConfigObservation) DeepCopy() *ClusterConfigWorkerConfigObservation

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

func (*ClusterConfigWorkerConfigObservation) DeepCopyInto 

func (in *ClusterConfigWorkerConfigObservation) DeepCopyInto(out *ClusterConfigWorkerConfigObservation)

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

type ClusterConfigWorkerConfigParameters 

type ClusterConfigWorkerConfigParameters struct {

	// The Compute Engine accelerator (GPU) configuration for these instances. Can be specified multiple times.
	// +kubebuilder:validation:Optional
	Accelerators []WorkerConfigAcceleratorsParameters `json:"accelerators,omitempty" tf:"accelerators,omitempty"`

	// Disk Config
	// +kubebuilder:validation:Optional
	DiskConfig []WorkerConfigDiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// The URI for the image to use for this master/worker
	// +kubebuilder:validation:Optional
	ImageURI *string `json:"imageUri,omitempty" tf:"image_uri,omitempty"`

	// The name of a Google Compute Engine machine type to create for the master/worker
	// +kubebuilder:validation:Optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type,omitempty"`

	// The name of a minimum generation of CPU family for the master/worker. If not specified, GCP will default to a predetermined computed value for each zone.
	// +kubebuilder:validation:Optional
	MinCPUPlatform *string `json:"minCpuPlatform,omitempty" tf:"min_cpu_platform,omitempty"`

	// Specifies the number of master/worker nodes to create. If not specified, GCP will default to a predetermined computed value.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`
}

func (*ClusterConfigWorkerConfigParameters) DeepCopy 

func (in *ClusterConfigWorkerConfigParameters) DeepCopy() *ClusterConfigWorkerConfigParameters

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

func (*ClusterConfigWorkerConfigParameters) DeepCopyInto 

func (in *ClusterConfigWorkerConfigParameters) DeepCopyInto(out *ClusterConfigWorkerConfigParameters)

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

type ClusterIAMBinding 

type ClusterIAMBinding struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIAMBindingSpec   `json:"spec"`
	Status            ClusterIAMBindingStatus `json:"status,omitempty"`
}

ClusterIAMBinding is the Schema for the ClusterIAMBindings API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*ClusterIAMBinding) DeepCopy 

func (in *ClusterIAMBinding) DeepCopy() *ClusterIAMBinding

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

func (*ClusterIAMBinding) DeepCopyInto 

func (in *ClusterIAMBinding) DeepCopyInto(out *ClusterIAMBinding)

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

func (*ClusterIAMBinding) DeepCopyObject 

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

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

func (*ClusterIAMBinding) GetCondition 

func (mg *ClusterIAMBinding) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this ClusterIAMBinding.

func (*ClusterIAMBinding) GetConnectionDetailsMapping 

func (tr *ClusterIAMBinding) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this ClusterIAMBinding

func (*ClusterIAMBinding) GetDeletionPolicy 

func (mg *ClusterIAMBinding) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this ClusterIAMBinding.

func (*ClusterIAMBinding) GetID 

func (tr *ClusterIAMBinding) GetID() string

GetID returns ID of underlying Terraform resource of this ClusterIAMBinding

func (*ClusterIAMBinding) GetObservation 

func (tr *ClusterIAMBinding) GetObservation() (map[string]interface{}, error)

GetObservation of this ClusterIAMBinding

func (*ClusterIAMBinding) GetParameters 

func (tr *ClusterIAMBinding) GetParameters() (map[string]interface{}, error)

GetParameters of this ClusterIAMBinding

func (*ClusterIAMBinding) GetProviderConfigReference 

func (mg *ClusterIAMBinding) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this ClusterIAMBinding.

func (*ClusterIAMBinding) GetProviderReference 

func (mg *ClusterIAMBinding) GetProviderReference() *xpv1.Reference

GetProviderReference of this ClusterIAMBinding. Deprecated: Use GetProviderConfigReference.

func (*ClusterIAMBinding) GetPublishConnectionDetailsTo 

func (mg *ClusterIAMBinding) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this ClusterIAMBinding.

func (*ClusterIAMBinding) GetTerraformResourceType 

func (mg *ClusterIAMBinding) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ClusterIAMBinding

func (*ClusterIAMBinding) GetTerraformSchemaVersion 

func (tr *ClusterIAMBinding) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ClusterIAMBinding) GetWriteConnectionSecretToReference 

func (mg *ClusterIAMBinding) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this ClusterIAMBinding.

func (*ClusterIAMBinding) LateInitialize 

func (tr *ClusterIAMBinding) LateInitialize(attrs []byte) (bool, error)

LateInitialize this ClusterIAMBinding using its observed tfState. returns True if there are any spec changes for the resource.

func (*ClusterIAMBinding) SetConditions 

func (mg *ClusterIAMBinding) SetConditions(c ...xpv1.Condition)

SetConditions of this ClusterIAMBinding.

func (*ClusterIAMBinding) SetDeletionPolicy 

func (mg *ClusterIAMBinding) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this ClusterIAMBinding.

func (*ClusterIAMBinding) SetObservation 

func (tr *ClusterIAMBinding) SetObservation(obs map[string]interface{}) error

SetObservation for this ClusterIAMBinding

func (*ClusterIAMBinding) SetParameters 

func (tr *ClusterIAMBinding) SetParameters(params map[string]interface{}) error

SetParameters for this ClusterIAMBinding

func (*ClusterIAMBinding) SetProviderConfigReference 

func (mg *ClusterIAMBinding) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this ClusterIAMBinding.

func (*ClusterIAMBinding) SetProviderReference 

func (mg *ClusterIAMBinding) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this ClusterIAMBinding. Deprecated: Use SetProviderConfigReference.

func (*ClusterIAMBinding) SetPublishConnectionDetailsTo 

func (mg *ClusterIAMBinding) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this ClusterIAMBinding.

func (*ClusterIAMBinding) SetWriteConnectionSecretToReference 

func (mg *ClusterIAMBinding) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this ClusterIAMBinding.

type ClusterIAMBindingList 

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

ClusterIAMBindingList contains a list of ClusterIAMBindings

func (*ClusterIAMBindingList) DeepCopy 

func (in *ClusterIAMBindingList) DeepCopy() *ClusterIAMBindingList

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

func (*ClusterIAMBindingList) DeepCopyInto 

func (in *ClusterIAMBindingList) DeepCopyInto(out *ClusterIAMBindingList)

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

func (*ClusterIAMBindingList) DeepCopyObject 

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

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

func (*ClusterIAMBindingList) GetItems 

func (l *ClusterIAMBindingList) GetItems() []resource.Managed

GetItems of this ClusterIAMBindingList.

type ClusterIAMBindingObservation 

type ClusterIAMBindingObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*ClusterIAMBindingObservation) DeepCopy 

func (in *ClusterIAMBindingObservation) DeepCopy() *ClusterIAMBindingObservation

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

func (*ClusterIAMBindingObservation) DeepCopyInto 

func (in *ClusterIAMBindingObservation) DeepCopyInto(out *ClusterIAMBindingObservation)

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

type ClusterIAMBindingParameters 

type ClusterIAMBindingParameters struct {

	// +kubebuilder:validation:Required
	Cluster *string `json:"cluster" tf:"cluster,omitempty"`

	// +kubebuilder:validation:Optional
	Condition []ConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Required
	Members []*string `json:"members" tf:"members,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// +kubebuilder:validation:Required
	Role *string `json:"role" tf:"role,omitempty"`
}

func (*ClusterIAMBindingParameters) DeepCopy 

func (in *ClusterIAMBindingParameters) DeepCopy() *ClusterIAMBindingParameters

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

func (*ClusterIAMBindingParameters) DeepCopyInto 

func (in *ClusterIAMBindingParameters) DeepCopyInto(out *ClusterIAMBindingParameters)

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

type ClusterIAMBindingSpec 

type ClusterIAMBindingSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ClusterIAMBindingParameters `json:"forProvider"`
}

ClusterIAMBindingSpec defines the desired state of ClusterIAMBinding

func (*ClusterIAMBindingSpec) DeepCopy 

func (in *ClusterIAMBindingSpec) DeepCopy() *ClusterIAMBindingSpec

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

func (*ClusterIAMBindingSpec) DeepCopyInto 

func (in *ClusterIAMBindingSpec) DeepCopyInto(out *ClusterIAMBindingSpec)

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

type ClusterIAMBindingStatus 

type ClusterIAMBindingStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ClusterIAMBindingObservation `json:"atProvider,omitempty"`
}

ClusterIAMBindingStatus defines the observed state of ClusterIAMBinding.

func (*ClusterIAMBindingStatus) DeepCopy 

func (in *ClusterIAMBindingStatus) DeepCopy() *ClusterIAMBindingStatus

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

func (*ClusterIAMBindingStatus) DeepCopyInto 

func (in *ClusterIAMBindingStatus) DeepCopyInto(out *ClusterIAMBindingStatus)

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

type ClusterIAMMember 

type ClusterIAMMember struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIAMMemberSpec   `json:"spec"`
	Status            ClusterIAMMemberStatus `json:"status,omitempty"`
}

ClusterIAMMember is the Schema for the ClusterIAMMembers API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*ClusterIAMMember) DeepCopy 

func (in *ClusterIAMMember) DeepCopy() *ClusterIAMMember

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

func (*ClusterIAMMember) DeepCopyInto 

func (in *ClusterIAMMember) DeepCopyInto(out *ClusterIAMMember)

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

func (*ClusterIAMMember) DeepCopyObject 

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

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

func (*ClusterIAMMember) GetCondition 

func (mg *ClusterIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this ClusterIAMMember.

func (*ClusterIAMMember) GetConnectionDetailsMapping 

func (tr *ClusterIAMMember) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this ClusterIAMMember

func (*ClusterIAMMember) GetDeletionPolicy 

func (mg *ClusterIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this ClusterIAMMember.

func (*ClusterIAMMember) GetID 

func (tr *ClusterIAMMember) GetID() string

GetID returns ID of underlying Terraform resource of this ClusterIAMMember

func (*ClusterIAMMember) GetObservation 

func (tr *ClusterIAMMember) GetObservation() (map[string]interface{}, error)

GetObservation of this ClusterIAMMember

func (*ClusterIAMMember) GetParameters 

func (tr *ClusterIAMMember) GetParameters() (map[string]interface{}, error)

GetParameters of this ClusterIAMMember

func (*ClusterIAMMember) GetProviderConfigReference 

func (mg *ClusterIAMMember) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this ClusterIAMMember.

func (*ClusterIAMMember) GetProviderReference 

func (mg *ClusterIAMMember) GetProviderReference() *xpv1.Reference

GetProviderReference of this ClusterIAMMember. Deprecated: Use GetProviderConfigReference.

func (*ClusterIAMMember) GetPublishConnectionDetailsTo 

func (mg *ClusterIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this ClusterIAMMember.

func (*ClusterIAMMember) GetTerraformResourceType 

func (mg *ClusterIAMMember) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ClusterIAMMember

func (*ClusterIAMMember) GetTerraformSchemaVersion 

func (tr *ClusterIAMMember) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ClusterIAMMember) GetWriteConnectionSecretToReference 

func (mg *ClusterIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this ClusterIAMMember.

func (*ClusterIAMMember) LateInitialize 

func (tr *ClusterIAMMember) LateInitialize(attrs []byte) (bool, error)

LateInitialize this ClusterIAMMember using its observed tfState. returns True if there are any spec changes for the resource.

func (*ClusterIAMMember) SetConditions 

func (mg *ClusterIAMMember) SetConditions(c ...xpv1.Condition)

SetConditions of this ClusterIAMMember.

func (*ClusterIAMMember) SetDeletionPolicy 

func (mg *ClusterIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this ClusterIAMMember.

func (*ClusterIAMMember) SetObservation 

func (tr *ClusterIAMMember) SetObservation(obs map[string]interface{}) error

SetObservation for this ClusterIAMMember

func (*ClusterIAMMember) SetParameters 

func (tr *ClusterIAMMember) SetParameters(params map[string]interface{}) error

SetParameters for this ClusterIAMMember

func (*ClusterIAMMember) SetProviderConfigReference 

func (mg *ClusterIAMMember) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this ClusterIAMMember.

func (*ClusterIAMMember) SetProviderReference 

func (mg *ClusterIAMMember) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this ClusterIAMMember. Deprecated: Use SetProviderConfigReference.

func (*ClusterIAMMember) SetPublishConnectionDetailsTo 

func (mg *ClusterIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this ClusterIAMMember.

func (*ClusterIAMMember) SetWriteConnectionSecretToReference 

func (mg *ClusterIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this ClusterIAMMember.

type ClusterIAMMemberConditionObservation 

type ClusterIAMMemberConditionObservation struct {
}

func (*ClusterIAMMemberConditionObservation) DeepCopy 

func (in *ClusterIAMMemberConditionObservation) DeepCopy() *ClusterIAMMemberConditionObservation

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

func (*ClusterIAMMemberConditionObservation) DeepCopyInto 

func (in *ClusterIAMMemberConditionObservation) DeepCopyInto(out *ClusterIAMMemberConditionObservation)

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

type ClusterIAMMemberConditionParameters 

type ClusterIAMMemberConditionParameters struct {

	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// +kubebuilder:validation:Required
	Expression *string `json:"expression" tf:"expression,omitempty"`

	// +kubebuilder:validation:Required
	Title *string `json:"title" tf:"title,omitempty"`
}

func (*ClusterIAMMemberConditionParameters) DeepCopy 

func (in *ClusterIAMMemberConditionParameters) DeepCopy() *ClusterIAMMemberConditionParameters

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

func (*ClusterIAMMemberConditionParameters) DeepCopyInto 

func (in *ClusterIAMMemberConditionParameters) DeepCopyInto(out *ClusterIAMMemberConditionParameters)

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

type ClusterIAMMemberList 

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

ClusterIAMMemberList contains a list of ClusterIAMMembers

func (*ClusterIAMMemberList) DeepCopy 

func (in *ClusterIAMMemberList) DeepCopy() *ClusterIAMMemberList

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

func (*ClusterIAMMemberList) DeepCopyInto 

func (in *ClusterIAMMemberList) DeepCopyInto(out *ClusterIAMMemberList)

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

func (*ClusterIAMMemberList) DeepCopyObject 

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

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

func (*ClusterIAMMemberList) GetItems 

func (l *ClusterIAMMemberList) GetItems() []resource.Managed

GetItems of this ClusterIAMMemberList.

type ClusterIAMMemberObservation 

type ClusterIAMMemberObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*ClusterIAMMemberObservation) DeepCopy 

func (in *ClusterIAMMemberObservation) DeepCopy() *ClusterIAMMemberObservation

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

func (*ClusterIAMMemberObservation) DeepCopyInto 

func (in *ClusterIAMMemberObservation) DeepCopyInto(out *ClusterIAMMemberObservation)

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

type ClusterIAMMemberParameters 

type ClusterIAMMemberParameters struct {

	// +kubebuilder:validation:Required
	Cluster *string `json:"cluster" tf:"cluster,omitempty"`

	// +kubebuilder:validation:Optional
	Condition []ClusterIAMMemberConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Required
	Member *string `json:"member" tf:"member,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// +kubebuilder:validation:Required
	Role *string `json:"role" tf:"role,omitempty"`
}

func (*ClusterIAMMemberParameters) DeepCopy 

func (in *ClusterIAMMemberParameters) DeepCopy() *ClusterIAMMemberParameters

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

func (*ClusterIAMMemberParameters) DeepCopyInto 

func (in *ClusterIAMMemberParameters) DeepCopyInto(out *ClusterIAMMemberParameters)

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

type ClusterIAMMemberSpec 

type ClusterIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ClusterIAMMemberParameters `json:"forProvider"`
}

ClusterIAMMemberSpec defines the desired state of ClusterIAMMember

func (*ClusterIAMMemberSpec) DeepCopy 

func (in *ClusterIAMMemberSpec) DeepCopy() *ClusterIAMMemberSpec

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

func (*ClusterIAMMemberSpec) DeepCopyInto 

func (in *ClusterIAMMemberSpec) DeepCopyInto(out *ClusterIAMMemberSpec)

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

type ClusterIAMMemberStatus 

type ClusterIAMMemberStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ClusterIAMMemberObservation `json:"atProvider,omitempty"`
}

ClusterIAMMemberStatus defines the observed state of ClusterIAMMember.

func (*ClusterIAMMemberStatus) DeepCopy 

func (in *ClusterIAMMemberStatus) DeepCopy() *ClusterIAMMemberStatus

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

func (*ClusterIAMMemberStatus) DeepCopyInto 

func (in *ClusterIAMMemberStatus) DeepCopyInto(out *ClusterIAMMemberStatus)

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

type ClusterIAMPolicy 

type ClusterIAMPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterIAMPolicySpec   `json:"spec"`
	Status            ClusterIAMPolicyStatus `json:"status,omitempty"`
}

ClusterIAMPolicy is the Schema for the ClusterIAMPolicys API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*ClusterIAMPolicy) DeepCopy 

func (in *ClusterIAMPolicy) DeepCopy() *ClusterIAMPolicy

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

func (*ClusterIAMPolicy) DeepCopyInto 

func (in *ClusterIAMPolicy) DeepCopyInto(out *ClusterIAMPolicy)

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

func (*ClusterIAMPolicy) DeepCopyObject 

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

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

func (*ClusterIAMPolicy) GetCondition 

func (mg *ClusterIAMPolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) GetConnectionDetailsMapping 

func (tr *ClusterIAMPolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this ClusterIAMPolicy

func (*ClusterIAMPolicy) GetDeletionPolicy 

func (mg *ClusterIAMPolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) GetID 

func (tr *ClusterIAMPolicy) GetID() string

GetID returns ID of underlying Terraform resource of this ClusterIAMPolicy

func (*ClusterIAMPolicy) GetObservation 

func (tr *ClusterIAMPolicy) GetObservation() (map[string]interface{}, error)

GetObservation of this ClusterIAMPolicy

func (*ClusterIAMPolicy) GetParameters 

func (tr *ClusterIAMPolicy) GetParameters() (map[string]interface{}, error)

GetParameters of this ClusterIAMPolicy

func (*ClusterIAMPolicy) GetProviderConfigReference 

func (mg *ClusterIAMPolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) GetProviderReference 

func (mg *ClusterIAMPolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this ClusterIAMPolicy. Deprecated: Use GetProviderConfigReference.

func (*ClusterIAMPolicy) GetPublishConnectionDetailsTo 

func (mg *ClusterIAMPolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) GetTerraformResourceType 

func (mg *ClusterIAMPolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ClusterIAMPolicy

func (*ClusterIAMPolicy) GetTerraformSchemaVersion 

func (tr *ClusterIAMPolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ClusterIAMPolicy) GetWriteConnectionSecretToReference 

func (mg *ClusterIAMPolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) LateInitialize 

func (tr *ClusterIAMPolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this ClusterIAMPolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*ClusterIAMPolicy) SetConditions 

func (mg *ClusterIAMPolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) SetDeletionPolicy 

func (mg *ClusterIAMPolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) SetObservation 

func (tr *ClusterIAMPolicy) SetObservation(obs map[string]interface{}) error

SetObservation for this ClusterIAMPolicy

func (*ClusterIAMPolicy) SetParameters 

func (tr *ClusterIAMPolicy) SetParameters(params map[string]interface{}) error

SetParameters for this ClusterIAMPolicy

func (*ClusterIAMPolicy) SetProviderConfigReference 

func (mg *ClusterIAMPolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) SetProviderReference 

func (mg *ClusterIAMPolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this ClusterIAMPolicy. Deprecated: Use SetProviderConfigReference.

func (*ClusterIAMPolicy) SetPublishConnectionDetailsTo 

func (mg *ClusterIAMPolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this ClusterIAMPolicy.

func (*ClusterIAMPolicy) SetWriteConnectionSecretToReference 

func (mg *ClusterIAMPolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this ClusterIAMPolicy.

type ClusterIAMPolicyList 

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

ClusterIAMPolicyList contains a list of ClusterIAMPolicys

func (*ClusterIAMPolicyList) DeepCopy 

func (in *ClusterIAMPolicyList) DeepCopy() *ClusterIAMPolicyList

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

func (*ClusterIAMPolicyList) DeepCopyInto 

func (in *ClusterIAMPolicyList) DeepCopyInto(out *ClusterIAMPolicyList)

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

func (*ClusterIAMPolicyList) DeepCopyObject 

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

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

func (*ClusterIAMPolicyList) GetItems 

func (l *ClusterIAMPolicyList) GetItems() []resource.Managed

GetItems of this ClusterIAMPolicyList.

type ClusterIAMPolicyObservation 

type ClusterIAMPolicyObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*ClusterIAMPolicyObservation) DeepCopy 

func (in *ClusterIAMPolicyObservation) DeepCopy() *ClusterIAMPolicyObservation

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

func (*ClusterIAMPolicyObservation) DeepCopyInto 

func (in *ClusterIAMPolicyObservation) DeepCopyInto(out *ClusterIAMPolicyObservation)

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

type ClusterIAMPolicyParameters 

type ClusterIAMPolicyParameters struct {

	// +kubebuilder:validation:Required
	Cluster *string `json:"cluster" tf:"cluster,omitempty"`

	// +kubebuilder:validation:Required
	PolicyData *string `json:"policyData" tf:"policy_data,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`
}

func (*ClusterIAMPolicyParameters) DeepCopy 

func (in *ClusterIAMPolicyParameters) DeepCopy() *ClusterIAMPolicyParameters

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

func (*ClusterIAMPolicyParameters) DeepCopyInto 

func (in *ClusterIAMPolicyParameters) DeepCopyInto(out *ClusterIAMPolicyParameters)

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

type ClusterIAMPolicySpec 

type ClusterIAMPolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ClusterIAMPolicyParameters `json:"forProvider"`
}

ClusterIAMPolicySpec defines the desired state of ClusterIAMPolicy

func (*ClusterIAMPolicySpec) DeepCopy 

func (in *ClusterIAMPolicySpec) DeepCopy() *ClusterIAMPolicySpec

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

func (*ClusterIAMPolicySpec) DeepCopyInto 

func (in *ClusterIAMPolicySpec) DeepCopyInto(out *ClusterIAMPolicySpec)

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

type ClusterIAMPolicyStatus 

type ClusterIAMPolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ClusterIAMPolicyObservation `json:"atProvider,omitempty"`
}

ClusterIAMPolicyStatus defines the observed state of ClusterIAMPolicy.

func (*ClusterIAMPolicyStatus) DeepCopy 

func (in *ClusterIAMPolicyStatus) DeepCopy() *ClusterIAMPolicyStatus

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

func (*ClusterIAMPolicyStatus) DeepCopyInto 

func (in *ClusterIAMPolicyStatus) DeepCopyInto(out *ClusterIAMPolicyStatus)

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

type ClusterList 

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

ClusterList contains a list of Clusters

func (*ClusterList) DeepCopy 

func (in *ClusterList) DeepCopy() *ClusterList

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

func (*ClusterList) DeepCopyInto 

func (in *ClusterList) DeepCopyInto(out *ClusterList)

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

func (*ClusterList) DeepCopyObject 

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

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

func (*ClusterList) GetItems 

func (l *ClusterList) GetItems() []resource.Managed

GetItems of this ClusterList.

type ClusterObservation 

type ClusterObservation struct {
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*ClusterObservation) DeepCopy 

func (in *ClusterObservation) DeepCopy() *ClusterObservation

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

func (*ClusterObservation) DeepCopyInto 

func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)

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

type ClusterParameters 

type ClusterParameters struct {

	// Allows you to configure various aspects of the cluster.
	// +kubebuilder:validation:Optional
	ClusterConfig []ClusterConfigParameters `json:"clusterConfig,omitempty" tf:"cluster_config,omitempty"`

	// The timeout duration which allows graceful decomissioning when you change the number of worker nodes directly through a terraform apply
	// +kubebuilder:validation:Optional
	GracefulDecommissionTimeout *string `json:"gracefulDecommissionTimeout,omitempty" tf:"graceful_decommission_timeout,omitempty"`

	// The list of labels (key/value pairs) to be applied to instances in the cluster. GCP generates some itself including goog-dataproc-cluster-name which is the name of the cluster.
	// +kubebuilder:validation:Optional
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// The name of the cluster, unique within the project and zone.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// The ID of the project in which the cluster will exist. If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region in which the cluster and associated nodes will be created in. Defaults to global.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`
}

func (*ClusterParameters) DeepCopy 

func (in *ClusterParameters) DeepCopy() *ClusterParameters

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

func (*ClusterParameters) DeepCopyInto 

func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)

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

type ClusterSelectorObservation 

type ClusterSelectorObservation struct {
}

func (*ClusterSelectorObservation) DeepCopy 

func (in *ClusterSelectorObservation) DeepCopy() *ClusterSelectorObservation

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

func (*ClusterSelectorObservation) DeepCopyInto 

func (in *ClusterSelectorObservation) DeepCopyInto(out *ClusterSelectorObservation)

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

type ClusterSelectorParameters 

type ClusterSelectorParameters struct {

	// Required. The cluster labels. Cluster must have all labels to match.
	// +kubebuilder:validation:Required
	ClusterLabels map[string]*string `json:"clusterLabels" tf:"cluster_labels,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Zone *string `json:"zone,omitempty" tf:"zone,omitempty"`
}

func (*ClusterSelectorParameters) DeepCopy 

func (in *ClusterSelectorParameters) DeepCopy() *ClusterSelectorParameters

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

func (*ClusterSelectorParameters) DeepCopyInto 

func (in *ClusterSelectorParameters) DeepCopyInto(out *ClusterSelectorParameters)

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

type ClusterSpec 

type ClusterSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ClusterParameters `json:"forProvider"`
}

ClusterSpec defines the desired state of Cluster

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

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

func (*ClusterSpec) DeepCopyInto 

func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

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

type ClusterStatus 

type ClusterStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ClusterObservation `json:"atProvider,omitempty"`
}

ClusterStatus defines the observed state of Cluster.

func (*ClusterStatus) DeepCopy 

func (in *ClusterStatus) DeepCopy() *ClusterStatus

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

func (*ClusterStatus) DeepCopyInto 

func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

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

type ConditionObservation 

type ConditionObservation struct {
}

func (*ConditionObservation) DeepCopy 

func (in *ConditionObservation) DeepCopy() *ConditionObservation

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

func (*ConditionObservation) DeepCopyInto 

func (in *ConditionObservation) DeepCopyInto(out *ConditionObservation)

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

type ConditionParameters 

type ConditionParameters struct {

	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// +kubebuilder:validation:Required
	Expression *string `json:"expression" tf:"expression,omitempty"`

	// +kubebuilder:validation:Required
	Title *string `json:"title" tf:"title,omitempty"`
}

func (*ConditionParameters) DeepCopy 

func (in *ConditionParameters) DeepCopy() *ConditionParameters

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

func (*ConditionParameters) DeepCopyInto 

func (in *ConditionParameters) DeepCopyInto(out *ConditionParameters)

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

type ConfigAutoscalingConfigObservation 

type ConfigAutoscalingConfigObservation struct {
}

func (*ConfigAutoscalingConfigObservation) DeepCopy 

func (in *ConfigAutoscalingConfigObservation) DeepCopy() *ConfigAutoscalingConfigObservation

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

func (*ConfigAutoscalingConfigObservation) DeepCopyInto 

func (in *ConfigAutoscalingConfigObservation) DeepCopyInto(out *ConfigAutoscalingConfigObservation)

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

type ConfigAutoscalingConfigParameters 

type ConfigAutoscalingConfigParameters struct {

	// Optional. The autoscaling policy used by the cluster. Only resource names including projectid and location (region) are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]` * `projects/[project_id]/locations/[dataproc_region]/autoscalingPolicies/[policy_id]` Note that the policy must be in the same project and Dataproc region.
	// +kubebuilder:validation:Optional
	Policy *string `json:"policy,omitempty" tf:"policy,omitempty"`
}

func (*ConfigAutoscalingConfigParameters) DeepCopy 

func (in *ConfigAutoscalingConfigParameters) DeepCopy() *ConfigAutoscalingConfigParameters

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

func (*ConfigAutoscalingConfigParameters) DeepCopyInto 

func (in *ConfigAutoscalingConfigParameters) DeepCopyInto(out *ConfigAutoscalingConfigParameters)

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

type ConfigEncryptionConfigObservation 

type ConfigEncryptionConfigObservation struct {
}

func (*ConfigEncryptionConfigObservation) DeepCopy 

func (in *ConfigEncryptionConfigObservation) DeepCopy() *ConfigEncryptionConfigObservation

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

func (*ConfigEncryptionConfigObservation) DeepCopyInto 

func (in *ConfigEncryptionConfigObservation) DeepCopyInto(out *ConfigEncryptionConfigObservation)

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

type ConfigEncryptionConfigParameters 

type ConfigEncryptionConfigParameters struct {

	// Optional. The Cloud KMS key name to use for PD disk encryption for all instances in the cluster.
	// +kubebuilder:validation:Optional
	GcePdKMSKeyName *string `json:"gcePdKmsKeyName,omitempty" tf:"gce_pd_kms_key_name,omitempty"`
}

func (*ConfigEncryptionConfigParameters) DeepCopy 

func (in *ConfigEncryptionConfigParameters) DeepCopy() *ConfigEncryptionConfigParameters

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

func (*ConfigEncryptionConfigParameters) DeepCopyInto 

func (in *ConfigEncryptionConfigParameters) DeepCopyInto(out *ConfigEncryptionConfigParameters)

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

type ConfigGceClusterConfigObservation 

type ConfigGceClusterConfigObservation struct {
}

func (*ConfigGceClusterConfigObservation) DeepCopy 

func (in *ConfigGceClusterConfigObservation) DeepCopy() *ConfigGceClusterConfigObservation

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

func (*ConfigGceClusterConfigObservation) DeepCopyInto 

func (in *ConfigGceClusterConfigObservation) DeepCopyInto(out *ConfigGceClusterConfigObservation)

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

type ConfigGceClusterConfigParameters 

type ConfigGceClusterConfigParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	InternalIPOnly *bool `json:"internalIpOnly,omitempty" tf:"internal_ip_only,omitempty"`

	// 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)).
	// +kubebuilder:validation:Optional
	Metadata map[string]*string `json:"metadata,omitempty" tf:"metadata,omitempty"`

	// Optional. The Compute Engine network to be used for machine communications. Cannot be specified with subnetwork_uri. If neither `network_uri` nor `subnetwork_uri` is specified, the "default" network of the project is used, if it exists. Cannot be a "Custom Subnet Network" (see [Using Subnetworks](https://cloud.google.com/compute/docs/subnetworks) for more information). A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default` * `projects/[project_id]/regions/global/default` * `default`
	// +kubebuilder:validation:Optional
	Network *string `json:"network,omitempty" tf:"network,omitempty"`

	// Optional. Node Group Affinity for sole-tenant clusters.
	// +kubebuilder:validation:Optional
	NodeGroupAffinity []NodeGroupAffinityParameters `json:"nodeGroupAffinity,omitempty" tf:"node_group_affinity,omitempty"`

	// Optional. The type of IPv6 access for a cluster. Possible values: PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED, INHERIT_FROM_SUBNETWORK, OUTBOUND, BIDIRECTIONAL
	// +kubebuilder:validation:Optional
	PrivateIPv6GoogleAccess *string `json:"privateIpv6GoogleAccess,omitempty" tf:"private_ipv6_google_access,omitempty"`

	// Optional. Reservation Affinity for consuming Zonal reservation.
	// +kubebuilder:validation:Optional
	ReservationAffinity []ReservationAffinityParameters `json:"reservationAffinity,omitempty" tf:"reservation_affinity,omitempty"`

	// Optional. The [Dataproc service account](https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/service-accounts#service_accounts_in_dataproc) (also see [VM Data Plane identity](https://cloud.google.com/dataproc/docs/concepts/iam/dataproc-principals#vm_service_account_data_plane_identity)) used by Dataproc cluster VM instances to access Google Cloud Platform services. If not specified, the [Compute Engine default service account](https://cloud.google.com/compute/docs/access/service-accounts#default_service_account) is used.
	// +kubebuilder:validation:Optional
	ServiceAccount *string `json:"serviceAccount,omitempty" tf:"service_account,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	ServiceAccountScopes []*string `json:"serviceAccountScopes,omitempty" tf:"service_account_scopes,omitempty"`

	// Optional. The Compute Engine subnetwork to be used for machine communications. Cannot be specified with network_uri. A full URL, partial URI, or short name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/subnetworks/sub0` * `projects/[project_id]/regions/us-east1/subnetworks/sub0` * `sub0`
	// +kubebuilder:validation:Optional
	Subnetwork *string `json:"subnetwork,omitempty" tf:"subnetwork,omitempty"`

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

	// 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`
	// +kubebuilder:validation:Optional
	Zone *string `json:"zone,omitempty" tf:"zone,omitempty"`
}

func (*ConfigGceClusterConfigParameters) DeepCopy 

func (in *ConfigGceClusterConfigParameters) DeepCopy() *ConfigGceClusterConfigParameters

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

func (*ConfigGceClusterConfigParameters) DeepCopyInto 

func (in *ConfigGceClusterConfigParameters) DeepCopyInto(out *ConfigGceClusterConfigParameters)

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

type ConfigMasterConfigObservation 

type ConfigMasterConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`

	IsPreemptible *bool `json:"isPreemptible,omitempty" tf:"is_preemptible,omitempty"`

	ManagedGroupConfig []ManagedGroupConfigObservation `json:"managedGroupConfig,omitempty" tf:"managed_group_config,omitempty"`
}

func (*ConfigMasterConfigObservation) DeepCopy 

func (in *ConfigMasterConfigObservation) DeepCopy() *ConfigMasterConfigObservation

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

func (*ConfigMasterConfigObservation) DeepCopyInto 

func (in *ConfigMasterConfigObservation) DeepCopyInto(out *ConfigMasterConfigObservation)

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

type ConfigMasterConfigParameters 

type ConfigMasterConfigParameters struct {

	// Optional. The Compute Engine accelerator configuration for these instances.
	// +kubebuilder:validation:Optional
	Accelerators []MasterConfigAcceleratorsParameters `json:"accelerators,omitempty" tf:"accelerators,omitempty"`

	// Optional. Disk option config settings.
	// +kubebuilder:validation:Optional
	DiskConfig []MasterConfigDiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// Optional. The Compute Engine image resource used for cluster instances. The URI can represent an image or image family. Image examples: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/[image-id]` * `projects/[project_id]/global/images/[image-id]` * `image-id` Image family examples. Dataproc will use the most recent image from the family: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/family/[custom-image-family-name]` * `projects/[project_id]/global/images/family/[custom-image-family-name]` If the URI is unspecified, it will be inferred from `SoftwareConfig.image_version` or the system default.
	// +kubebuilder:validation:Optional
	Image *string `json:"image,omitempty" tf:"image,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	MinCPUPlatform *string `json:"minCpuPlatform,omitempty" tf:"min_cpu_platform,omitempty"`

	// 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**.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	Preemptibility *string `json:"preemptibility,omitempty" tf:"preemptibility,omitempty"`
}

func (*ConfigMasterConfigParameters) DeepCopy 

func (in *ConfigMasterConfigParameters) DeepCopy() *ConfigMasterConfigParameters

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

func (*ConfigMasterConfigParameters) DeepCopyInto 

func (in *ConfigMasterConfigParameters) DeepCopyInto(out *ConfigMasterConfigParameters)

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

type ConfigObservation 

type ConfigObservation struct {
}

func (*ConfigObservation) DeepCopy 

func (in *ConfigObservation) DeepCopy() *ConfigObservation

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

func (*ConfigObservation) DeepCopyInto 

func (in *ConfigObservation) DeepCopyInto(out *ConfigObservation)

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

type ConfigParameters 

type ConfigParameters struct {

	// Optional. Autoscaling config for the policy associated with the cluster. Cluster does not autoscale if this field is unset.
	// +kubebuilder:validation:Optional
	AutoscalingConfig []ConfigAutoscalingConfigParameters `json:"autoscalingConfig,omitempty" tf:"autoscaling_config,omitempty"`

	// Optional. Encryption settings for the cluster.
	// +kubebuilder:validation:Optional
	EncryptionConfig []ConfigEncryptionConfigParameters `json:"encryptionConfig,omitempty" tf:"encryption_config,omitempty"`

	// Optional. Port/endpoint configuration for this cluster
	// +kubebuilder:validation:Optional
	EndpointConfig []EndpointConfigParameters `json:"endpointConfig,omitempty" tf:"endpoint_config,omitempty"`

	// Optional. The shared Compute Engine config settings for all instances in a cluster.
	// +kubebuilder:validation:Optional
	GceClusterConfig []ConfigGceClusterConfigParameters `json:"gceClusterConfig,omitempty" tf:"gce_cluster_config,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	InitializationActions []InitializationActionsParameters `json:"initializationActions,omitempty" tf:"initialization_actions,omitempty"`

	// Optional. Lifecycle setting for the cluster.
	// +kubebuilder:validation:Optional
	LifecycleConfig []LifecycleConfigParameters `json:"lifecycleConfig,omitempty" tf:"lifecycle_config,omitempty"`

	// Optional. The Compute Engine config settings for the master instance in a cluster.
	// +kubebuilder:validation:Optional
	MasterConfig []ConfigMasterConfigParameters `json:"masterConfig,omitempty" tf:"master_config,omitempty"`

	// Optional. The Compute Engine config settings for additional worker instances in a cluster.
	// +kubebuilder:validation:Optional
	SecondaryWorkerConfig []ConfigSecondaryWorkerConfigParameters `json:"secondaryWorkerConfig,omitempty" tf:"secondary_worker_config,omitempty"`

	// Optional. Security settings for the cluster.
	// +kubebuilder:validation:Optional
	SecurityConfig []ConfigSecurityConfigParameters `json:"securityConfig,omitempty" tf:"security_config,omitempty"`

	// Optional. The config settings for software inside the cluster.
	// +kubebuilder:validation:Optional
	SoftwareConfig []ConfigSoftwareConfigParameters `json:"softwareConfig,omitempty" tf:"software_config,omitempty"`

	// Optional. A Cloud Storage bucket used to stage job dependencies, config files, and job driver console output. If you do not specify a staging bucket, Cloud Dataproc will determine a Cloud Storage location (US, ASIA, or EU) for your cluster's staging bucket according to the Compute Engine zone where your cluster is deployed, and then create and manage this project-level, per-location bucket (see [Dataproc staging bucket](https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/staging-bucket)). **This field requires a Cloud Storage bucket name, not a URI to a Cloud Storage bucket.**
	// +kubebuilder:validation:Optional
	StagingBucket *string `json:"stagingBucket,omitempty" tf:"staging_bucket,omitempty"`

	// Optional. A Cloud Storage bucket used to store ephemeral cluster and jobs data, such as Spark and MapReduce history files. If you do not specify a temp bucket, Dataproc will determine a Cloud Storage location (US, ASIA, or EU) for your cluster's temp bucket according to the Compute Engine zone where your cluster is deployed, and then create and manage this project-level, per-location bucket. The default bucket has a TTL of 90 days, but you can use any TTL (or none) if you specify a bucket. **This field requires a Cloud Storage bucket name, not a URI to a Cloud Storage bucket.**
	// +kubebuilder:validation:Optional
	TempBucket *string `json:"tempBucket,omitempty" tf:"temp_bucket,omitempty"`

	// Optional. The Compute Engine config settings for worker instances in a cluster.
	// +kubebuilder:validation:Optional
	WorkerConfig []ConfigWorkerConfigParameters `json:"workerConfig,omitempty" tf:"worker_config,omitempty"`
}

func (*ConfigParameters) DeepCopy 

func (in *ConfigParameters) DeepCopy() *ConfigParameters

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

func (*ConfigParameters) DeepCopyInto 

func (in *ConfigParameters) DeepCopyInto(out *ConfigParameters)

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

type ConfigSecondaryWorkerConfigObservation 

type ConfigSecondaryWorkerConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`

	IsPreemptible *bool `json:"isPreemptible,omitempty" tf:"is_preemptible,omitempty"`

	ManagedGroupConfig []SecondaryWorkerConfigManagedGroupConfigObservation `json:"managedGroupConfig,omitempty" tf:"managed_group_config,omitempty"`
}

func (*ConfigSecondaryWorkerConfigObservation) DeepCopy 

func (in *ConfigSecondaryWorkerConfigObservation) DeepCopy() *ConfigSecondaryWorkerConfigObservation

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

func (*ConfigSecondaryWorkerConfigObservation) DeepCopyInto 

func (in *ConfigSecondaryWorkerConfigObservation) DeepCopyInto(out *ConfigSecondaryWorkerConfigObservation)

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

type ConfigSecondaryWorkerConfigParameters 

type ConfigSecondaryWorkerConfigParameters struct {

	// Optional. The Compute Engine accelerator configuration for these instances.
	// +kubebuilder:validation:Optional
	Accelerators []SecondaryWorkerConfigAcceleratorsParameters `json:"accelerators,omitempty" tf:"accelerators,omitempty"`

	// Optional. Disk option config settings.
	// +kubebuilder:validation:Optional
	DiskConfig []SecondaryWorkerConfigDiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// Optional. The Compute Engine image resource used for cluster instances. The URI can represent an image or image family. Image examples: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/[image-id]` * `projects/[project_id]/global/images/[image-id]` * `image-id` Image family examples. Dataproc will use the most recent image from the family: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/family/[custom-image-family-name]` * `projects/[project_id]/global/images/family/[custom-image-family-name]` If the URI is unspecified, it will be inferred from `SoftwareConfig.image_version` or the system default.
	// +kubebuilder:validation:Optional
	Image *string `json:"image,omitempty" tf:"image,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	MinCPUPlatform *string `json:"minCpuPlatform,omitempty" tf:"min_cpu_platform,omitempty"`

	// 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**.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	Preemptibility *string `json:"preemptibility,omitempty" tf:"preemptibility,omitempty"`
}

func (*ConfigSecondaryWorkerConfigParameters) DeepCopy 

func (in *ConfigSecondaryWorkerConfigParameters) DeepCopy() *ConfigSecondaryWorkerConfigParameters

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

func (*ConfigSecondaryWorkerConfigParameters) DeepCopyInto 

func (in *ConfigSecondaryWorkerConfigParameters) DeepCopyInto(out *ConfigSecondaryWorkerConfigParameters)

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

type ConfigSecurityConfigObservation 

type ConfigSecurityConfigObservation struct {
}

func (*ConfigSecurityConfigObservation) DeepCopy 

func (in *ConfigSecurityConfigObservation) DeepCopy() *ConfigSecurityConfigObservation

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

func (*ConfigSecurityConfigObservation) DeepCopyInto 

func (in *ConfigSecurityConfigObservation) DeepCopyInto(out *ConfigSecurityConfigObservation)

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

type ConfigSecurityConfigParameters 

type ConfigSecurityConfigParameters struct {

	// Optional. Kerberos related configuration.
	// +kubebuilder:validation:Optional
	KerberosConfig []SecurityConfigKerberosConfigParameters `json:"kerberosConfig,omitempty" tf:"kerberos_config,omitempty"`
}

func (*ConfigSecurityConfigParameters) DeepCopy 

func (in *ConfigSecurityConfigParameters) DeepCopy() *ConfigSecurityConfigParameters

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

func (*ConfigSecurityConfigParameters) DeepCopyInto 

func (in *ConfigSecurityConfigParameters) DeepCopyInto(out *ConfigSecurityConfigParameters)

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

type ConfigSoftwareConfigObservation 

type ConfigSoftwareConfigObservation struct {
}

func (*ConfigSoftwareConfigObservation) DeepCopy 

func (in *ConfigSoftwareConfigObservation) DeepCopy() *ConfigSoftwareConfigObservation

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

func (*ConfigSoftwareConfigObservation) DeepCopyInto 

func (in *ConfigSoftwareConfigObservation) DeepCopyInto(out *ConfigSoftwareConfigObservation)

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

type ConfigSoftwareConfigParameters 

type ConfigSoftwareConfigParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ImageVersion *string `json:"imageVersion,omitempty" tf:"image_version,omitempty"`

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

	// 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).
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`
}

func (*ConfigSoftwareConfigParameters) DeepCopy 

func (in *ConfigSoftwareConfigParameters) DeepCopy() *ConfigSoftwareConfigParameters

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

func (*ConfigSoftwareConfigParameters) DeepCopyInto 

func (in *ConfigSoftwareConfigParameters) DeepCopyInto(out *ConfigSoftwareConfigParameters)

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

type ConfigWorkerConfigAcceleratorsObservation 

type ConfigWorkerConfigAcceleratorsObservation struct {
}

func (*ConfigWorkerConfigAcceleratorsObservation) DeepCopy 

func (in *ConfigWorkerConfigAcceleratorsObservation) DeepCopy() *ConfigWorkerConfigAcceleratorsObservation

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

func (*ConfigWorkerConfigAcceleratorsObservation) DeepCopyInto 

func (in *ConfigWorkerConfigAcceleratorsObservation) DeepCopyInto(out *ConfigWorkerConfigAcceleratorsObservation)

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

type ConfigWorkerConfigAcceleratorsParameters 

type ConfigWorkerConfigAcceleratorsParameters struct {

	// The number of the accelerator cards of this type exposed to this instance.
	// +kubebuilder:validation:Optional
	AcceleratorCount *float64 `json:"acceleratorCount,omitempty" tf:"accelerator_count,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	AcceleratorType *string `json:"acceleratorType,omitempty" tf:"accelerator_type,omitempty"`
}

func (*ConfigWorkerConfigAcceleratorsParameters) DeepCopy 

func (in *ConfigWorkerConfigAcceleratorsParameters) DeepCopy() *ConfigWorkerConfigAcceleratorsParameters

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

func (*ConfigWorkerConfigAcceleratorsParameters) DeepCopyInto 

func (in *ConfigWorkerConfigAcceleratorsParameters) DeepCopyInto(out *ConfigWorkerConfigAcceleratorsParameters)

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

type ConfigWorkerConfigDiskConfigObservation 

type ConfigWorkerConfigDiskConfigObservation struct {
}

func (*ConfigWorkerConfigDiskConfigObservation) DeepCopy 

func (in *ConfigWorkerConfigDiskConfigObservation) DeepCopy() *ConfigWorkerConfigDiskConfigObservation

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

func (*ConfigWorkerConfigDiskConfigObservation) DeepCopyInto 

func (in *ConfigWorkerConfigDiskConfigObservation) DeepCopyInto(out *ConfigWorkerConfigDiskConfigObservation)

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

type ConfigWorkerConfigDiskConfigParameters 

type ConfigWorkerConfigDiskConfigParameters struct {

	// Optional. Size in GB of the boot disk (default is 500GB).
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*ConfigWorkerConfigDiskConfigParameters) DeepCopy 

func (in *ConfigWorkerConfigDiskConfigParameters) DeepCopy() *ConfigWorkerConfigDiskConfigParameters

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

func (*ConfigWorkerConfigDiskConfigParameters) DeepCopyInto 

func (in *ConfigWorkerConfigDiskConfigParameters) DeepCopyInto(out *ConfigWorkerConfigDiskConfigParameters)

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

type ConfigWorkerConfigObservation 

type ConfigWorkerConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`

	IsPreemptible *bool `json:"isPreemptible,omitempty" tf:"is_preemptible,omitempty"`

	ManagedGroupConfig []WorkerConfigManagedGroupConfigObservation `json:"managedGroupConfig,omitempty" tf:"managed_group_config,omitempty"`
}

func (*ConfigWorkerConfigObservation) DeepCopy 

func (in *ConfigWorkerConfigObservation) DeepCopy() *ConfigWorkerConfigObservation

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

func (*ConfigWorkerConfigObservation) DeepCopyInto 

func (in *ConfigWorkerConfigObservation) DeepCopyInto(out *ConfigWorkerConfigObservation)

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

type ConfigWorkerConfigParameters 

type ConfigWorkerConfigParameters struct {

	// Optional. The Compute Engine accelerator configuration for these instances.
	// +kubebuilder:validation:Optional
	Accelerators []ConfigWorkerConfigAcceleratorsParameters `json:"accelerators,omitempty" tf:"accelerators,omitempty"`

	// Optional. Disk option config settings.
	// +kubebuilder:validation:Optional
	DiskConfig []ConfigWorkerConfigDiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// Optional. The Compute Engine image resource used for cluster instances. The URI can represent an image or image family. Image examples: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/[image-id]` * `projects/[project_id]/global/images/[image-id]` * `image-id` Image family examples. Dataproc will use the most recent image from the family: * `https://www.googleapis.com/compute/beta/projects/[project_id]/global/images/family/[custom-image-family-name]` * `projects/[project_id]/global/images/family/[custom-image-family-name]` If the URI is unspecified, it will be inferred from `SoftwareConfig.image_version` or the system default.
	// +kubebuilder:validation:Optional
	Image *string `json:"image,omitempty" tf:"image,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	MinCPUPlatform *string `json:"minCpuPlatform,omitempty" tf:"min_cpu_platform,omitempty"`

	// 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**.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	Preemptibility *string `json:"preemptibility,omitempty" tf:"preemptibility,omitempty"`
}

func (*ConfigWorkerConfigParameters) DeepCopy 

func (in *ConfigWorkerConfigParameters) DeepCopy() *ConfigWorkerConfigParameters

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

func (*ConfigWorkerConfigParameters) DeepCopyInto 

func (in *ConfigWorkerConfigParameters) DeepCopyInto(out *ConfigWorkerConfigParameters)

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

type DiskConfigObservation 

type DiskConfigObservation struct {
}

func (*DiskConfigObservation) DeepCopy 

func (in *DiskConfigObservation) DeepCopy() *DiskConfigObservation

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

func (*DiskConfigObservation) DeepCopyInto 

func (in *DiskConfigObservation) DeepCopyInto(out *DiskConfigObservation)

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

type DiskConfigParameters 

type DiskConfigParameters struct {

	// Size of the primary disk attached to each node, specified in GB. The primary disk contains the boot volume and system libraries, and the smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// The disk type of the primary disk attached to each node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// The amount of local SSD disks that will be attached to each master cluster node. Defaults to 0.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*DiskConfigParameters) DeepCopy 

func (in *DiskConfigParameters) DeepCopy() *DiskConfigParameters

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

func (*DiskConfigParameters) DeepCopyInto 

func (in *DiskConfigParameters) DeepCopyInto(out *DiskConfigParameters)

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

type EncryptionConfigObservation 

type EncryptionConfigObservation struct {
}

func (*EncryptionConfigObservation) DeepCopy 

func (in *EncryptionConfigObservation) DeepCopy() *EncryptionConfigObservation

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

func (*EncryptionConfigObservation) DeepCopyInto 

func (in *EncryptionConfigObservation) DeepCopyInto(out *EncryptionConfigObservation)

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

type EncryptionConfigParameters 

type EncryptionConfigParameters struct {

	// The Cloud KMS key name to use for PD disk encryption for all instances in the cluster.
	// +kubebuilder:validation:Required
	KMSKeyName *string `json:"kmsKeyName" tf:"kms_key_name,omitempty"`
}

func (*EncryptionConfigParameters) DeepCopy 

func (in *EncryptionConfigParameters) DeepCopy() *EncryptionConfigParameters

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

func (*EncryptionConfigParameters) DeepCopyInto 

func (in *EncryptionConfigParameters) DeepCopyInto(out *EncryptionConfigParameters)

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

type EndpointConfigObservation 

type EndpointConfigObservation struct {
	HTTPPorts map[string]*string `json:"httpPorts,omitempty" tf:"http_ports,omitempty"`
}

func (*EndpointConfigObservation) DeepCopy 

func (in *EndpointConfigObservation) DeepCopy() *EndpointConfigObservation

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

func (*EndpointConfigObservation) DeepCopyInto 

func (in *EndpointConfigObservation) DeepCopyInto(out *EndpointConfigObservation)

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

type EndpointConfigParameters 

type EndpointConfigParameters struct {

	// Optional. If true, enable http access to specific ports on the cluster from external sources. Defaults to false.
	// +kubebuilder:validation:Optional
	EnableHTTPPortAccess *bool `json:"enableHttpPortAccess,omitempty" tf:"enable_http_port_access,omitempty"`
}

func (*EndpointConfigParameters) DeepCopy 

func (in *EndpointConfigParameters) DeepCopy() *EndpointConfigParameters

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

func (*EndpointConfigParameters) DeepCopyInto 

func (in *EndpointConfigParameters) DeepCopyInto(out *EndpointConfigParameters)

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

type GceClusterConfigObservation 

type GceClusterConfigObservation struct {
}

func (*GceClusterConfigObservation) DeepCopy 

func (in *GceClusterConfigObservation) DeepCopy() *GceClusterConfigObservation

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

func (*GceClusterConfigObservation) DeepCopyInto 

func (in *GceClusterConfigObservation) DeepCopyInto(out *GceClusterConfigObservation)

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

type GceClusterConfigParameters 

type GceClusterConfigParameters struct {

	// By default, clusters are not restricted to internal IP addresses, and will have ephemeral external IP addresses assigned to each instance. If set to true, all instances in the cluster will only have internal IP addresses. Note: Private Google Access (also known as privateIpGoogleAccess) must be enabled on the subnetwork that the cluster will be launched in.
	// +kubebuilder:validation:Optional
	InternalIPOnly *bool `json:"internalIpOnly,omitempty" tf:"internal_ip_only,omitempty"`

	// A map of the Compute Engine metadata entries to add to all instances
	// +kubebuilder:validation:Optional
	Metadata map[string]*string `json:"metadata,omitempty" tf:"metadata,omitempty"`

	// The name or self_link of the Google Compute Engine network to the cluster will be part of. Conflicts with subnetwork. If neither is specified, this defaults to the "default" network.
	// +kubebuilder:validation:Optional
	Network *string `json:"network,omitempty" tf:"network,omitempty"`

	// The service account to be used by the Node VMs. If not specified, the "default" service account is used.
	// +kubebuilder:validation:Optional
	ServiceAccount *string `json:"serviceAccount,omitempty" tf:"service_account,omitempty"`

	// The set of Google API scopes to be made available on all of the node VMs under the service_account specified. These can be either FQDNs, or scope aliases.
	// +kubebuilder:validation:Optional
	ServiceAccountScopes []*string `json:"serviceAccountScopes,omitempty" tf:"service_account_scopes,omitempty"`

	// Shielded Instance Config for clusters using Compute Engine Shielded VMs.
	// +kubebuilder:validation:Optional
	ShieldedInstanceConfig []ShieldedInstanceConfigParameters `json:"shieldedInstanceConfig,omitempty" tf:"shielded_instance_config,omitempty"`

	// The name or self_link of the Google Compute Engine subnetwork the cluster will be part of. Conflicts with network.
	// +kubebuilder:validation:Optional
	Subnetwork *string `json:"subnetwork,omitempty" tf:"subnetwork,omitempty"`

	// The list of instance tags applied to instances in the cluster. Tags are used to identify valid sources or targets for network firewalls.
	// +kubebuilder:validation:Optional
	Tags []*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// The GCP zone where your data is stored and used (i.e. where the master and the worker nodes will be created in). If region is set to 'global' (default) then zone is mandatory, otherwise GCP is able to make use of Auto Zone Placement to determine this automatically for you. Note: This setting additionally determines and restricts which computing resources are available for use with other configs such as cluster_config.master_config.machine_type and cluster_config.worker_config.machine_type.
	// +kubebuilder:validation:Optional
	Zone *string `json:"zone,omitempty" tf:"zone,omitempty"`
}

func (*GceClusterConfigParameters) DeepCopy 

func (in *GceClusterConfigParameters) DeepCopy() *GceClusterConfigParameters

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

func (*GceClusterConfigParameters) DeepCopyInto 

func (in *GceClusterConfigParameters) DeepCopyInto(out *GceClusterConfigParameters)

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

type HadoopConfigObservation 

type HadoopConfigObservation struct {
}

func (*HadoopConfigObservation) DeepCopy 

func (in *HadoopConfigObservation) DeepCopy() *HadoopConfigObservation

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

func (*HadoopConfigObservation) DeepCopyInto 

func (in *HadoopConfigObservation) DeepCopyInto(out *HadoopConfigObservation)

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

type HadoopConfigParameters 

type HadoopConfigParameters struct {

	// HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// The arguments to pass to the driver.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

	// HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
	// +kubebuilder:validation:Optional
	FileUris []*string `json:"fileUris,omitempty" tf:"file_uris,omitempty"`

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

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []LoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// The class containing the main method of the driver. Must be in a provided jar or jar that is already on the classpath. Conflicts with main_jar_file_uri
	// +kubebuilder:validation:Optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class,omitempty"`

	// The HCFS URI of jar file containing the driver jar. Conflicts with main_class
	// +kubebuilder:validation:Optional
	MainJarFileURI *string `json:"mainJarFileUri,omitempty" tf:"main_jar_file_uri,omitempty"`

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

func (*HadoopConfigParameters) DeepCopy 

func (in *HadoopConfigParameters) DeepCopy() *HadoopConfigParameters

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

func (*HadoopConfigParameters) DeepCopyInto 

func (in *HadoopConfigParameters) DeepCopyInto(out *HadoopConfigParameters)

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

type HadoopJobLoggingConfigObservation 

type HadoopJobLoggingConfigObservation struct {
}

func (*HadoopJobLoggingConfigObservation) DeepCopy 

func (in *HadoopJobLoggingConfigObservation) DeepCopy() *HadoopJobLoggingConfigObservation

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

func (*HadoopJobLoggingConfigObservation) DeepCopyInto 

func (in *HadoopJobLoggingConfigObservation) DeepCopyInto(out *HadoopJobLoggingConfigObservation)

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

type HadoopJobLoggingConfigParameters 

type HadoopJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*HadoopJobLoggingConfigParameters) DeepCopy 

func (in *HadoopJobLoggingConfigParameters) DeepCopy() *HadoopJobLoggingConfigParameters

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

func (*HadoopJobLoggingConfigParameters) DeepCopyInto 

func (in *HadoopJobLoggingConfigParameters) DeepCopyInto(out *HadoopJobLoggingConfigParameters)

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

type HadoopJobObservation 

type HadoopJobObservation struct {
}

func (*HadoopJobObservation) DeepCopy 

func (in *HadoopJobObservation) DeepCopy() *HadoopJobObservation

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

func (*HadoopJobObservation) DeepCopyInto 

func (in *HadoopJobObservation) DeepCopyInto(out *HadoopJobObservation)

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

type HadoopJobParameters 

type HadoopJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	FileUris []*string `json:"fileUris,omitempty" tf:"file_uris,omitempty"`

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

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []HadoopJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class,omitempty"`

	// 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'
	// +kubebuilder:validation:Optional
	MainJarFileURI *string `json:"mainJarFileUri,omitempty" tf:"main_jar_file_uri,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`
}

func (*HadoopJobParameters) DeepCopy 

func (in *HadoopJobParameters) DeepCopy() *HadoopJobParameters

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

func (*HadoopJobParameters) DeepCopyInto 

func (in *HadoopJobParameters) DeepCopyInto(out *HadoopJobParameters)

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

type HiveConfigObservation 

type HiveConfigObservation struct {
}

func (*HiveConfigObservation) DeepCopy 

func (in *HiveConfigObservation) DeepCopy() *HiveConfigObservation

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

func (*HiveConfigObservation) DeepCopyInto 

func (in *HiveConfigObservation) DeepCopyInto(out *HiveConfigObservation)

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

type HiveConfigParameters 

type HiveConfigParameters struct {

	// 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. Defaults to false.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	JarFileUris []*string `json:"jarFileUris,omitempty" tf:"jar_file_uris,omitempty"`

	// A mapping of property names and values, used to configure Hive. Properties that conflict with values set by the Cloud 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// HCFS URI of file containing Hive script to execute as the job. Conflicts with query_list
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// The list of Hive queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +kubebuilder:validation:Optional
	QueryList []*string `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*HiveConfigParameters) DeepCopy 

func (in *HiveConfigParameters) DeepCopy() *HiveConfigParameters

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

func (*HiveConfigParameters) DeepCopyInto 

func (in *HiveConfigParameters) DeepCopyInto(out *HiveConfigParameters)

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

type HiveJobObservation 

type HiveJobObservation struct {
}

func (*HiveJobObservation) DeepCopy 

func (in *HiveJobObservation) DeepCopy() *HiveJobObservation

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

func (*HiveJobObservation) DeepCopyInto 

func (in *HiveJobObservation) DeepCopyInto(out *HiveJobObservation)

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

type HiveJobParameters 

type HiveJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	JarFileUris []*string `json:"jarFileUris,omitempty" tf:"jar_file_uris,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// The HCFS URI of the script that contains Hive queries.
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// A list of queries.
	// +kubebuilder:validation:Optional
	QueryList []QueryListParameters `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*HiveJobParameters) DeepCopy 

func (in *HiveJobParameters) DeepCopy() *HiveJobParameters

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

func (*HiveJobParameters) DeepCopyInto 

func (in *HiveJobParameters) DeepCopyInto(out *HiveJobParameters)

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

type InitializationActionObservation 

type InitializationActionObservation struct {
}

func (*InitializationActionObservation) DeepCopy 

func (in *InitializationActionObservation) DeepCopy() *InitializationActionObservation

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

func (*InitializationActionObservation) DeepCopyInto 

func (in *InitializationActionObservation) DeepCopyInto(out *InitializationActionObservation)

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

type InitializationActionParameters 

type InitializationActionParameters struct {

	// The script to be executed during initialization of the cluster. The script must be a GCS file with a gs:// prefix.
	// +kubebuilder:validation:Required
	Script *string `json:"script" tf:"script,omitempty"`

	// The maximum duration (in seconds) which script is allowed to take to execute its action. GCP will default to a predetermined computed value if not set (currently 300).
	// +kubebuilder:validation:Optional
	TimeoutSec *float64 `json:"timeoutSec,omitempty" tf:"timeout_sec,omitempty"`
}

func (*InitializationActionParameters) DeepCopy 

func (in *InitializationActionParameters) DeepCopy() *InitializationActionParameters

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

func (*InitializationActionParameters) DeepCopyInto 

func (in *InitializationActionParameters) DeepCopyInto(out *InitializationActionParameters)

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

type InitializationActionsObservation 

type InitializationActionsObservation struct {
}

func (*InitializationActionsObservation) DeepCopy 

func (in *InitializationActionsObservation) DeepCopy() *InitializationActionsObservation

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

func (*InitializationActionsObservation) DeepCopyInto 

func (in *InitializationActionsObservation) DeepCopyInto(out *InitializationActionsObservation)

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

type InitializationActionsParameters 

type InitializationActionsParameters struct {

	// Required. Cloud Storage URI of executable file.
	// +kubebuilder:validation:Optional
	ExecutableFile *string `json:"executableFile,omitempty" tf:"executable_file,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	ExecutionTimeout *string `json:"executionTimeout,omitempty" tf:"execution_timeout,omitempty"`
}

func (*InitializationActionsParameters) DeepCopy 

func (in *InitializationActionsParameters) DeepCopy() *InitializationActionsParameters

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

func (*InitializationActionsParameters) DeepCopyInto 

func (in *InitializationActionsParameters) DeepCopyInto(out *InitializationActionsParameters)

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

type Job 

type Job struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobSpec   `json:"spec"`
	Status            JobStatus `json:"status,omitempty"`
}

Job is the Schema for the Jobs API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*Job) DeepCopy 

func (in *Job) DeepCopy() *Job

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

func (*Job) DeepCopyInto 

func (in *Job) DeepCopyInto(out *Job)

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

func (*Job) DeepCopyObject 

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

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

func (*Job) GetCondition 

func (mg *Job) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Job.

func (*Job) GetConnectionDetailsMapping 

func (tr *Job) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Job

func (*Job) GetDeletionPolicy 

func (mg *Job) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Job.

func (*Job) GetID 

func (tr *Job) GetID() string

GetID returns ID of underlying Terraform resource of this Job

func (*Job) GetObservation 

func (tr *Job) GetObservation() (map[string]interface{}, error)

GetObservation of this Job

func (*Job) GetParameters 

func (tr *Job) GetParameters() (map[string]interface{}, error)

GetParameters of this Job

func (*Job) GetProviderConfigReference 

func (mg *Job) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Job.

func (*Job) GetProviderReference 

func (mg *Job) GetProviderReference() *xpv1.Reference

GetProviderReference of this Job. Deprecated: Use GetProviderConfigReference.

func (*Job) GetPublishConnectionDetailsTo 

func (mg *Job) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Job.

func (*Job) GetTerraformResourceType 

func (mg *Job) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Job

func (*Job) GetTerraformSchemaVersion 

func (tr *Job) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Job) GetWriteConnectionSecretToReference 

func (mg *Job) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Job.

func (*Job) LateInitialize 

func (tr *Job) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Job using its observed tfState. returns True if there are any spec changes for the resource.

func (*Job) SetConditions 

func (mg *Job) SetConditions(c ...xpv1.Condition)

SetConditions of this Job.

func (*Job) SetDeletionPolicy 

func (mg *Job) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Job.

func (*Job) SetObservation 

func (tr *Job) SetObservation(obs map[string]interface{}) error

SetObservation for this Job

func (*Job) SetParameters 

func (tr *Job) SetParameters(params map[string]interface{}) error

SetParameters for this Job

func (*Job) SetProviderConfigReference 

func (mg *Job) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Job.

func (*Job) SetProviderReference 

func (mg *Job) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Job. Deprecated: Use SetProviderConfigReference.

func (*Job) SetPublishConnectionDetailsTo 

func (mg *Job) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Job.

func (*Job) SetWriteConnectionSecretToReference 

func (mg *Job) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Job.

type JobIAMBinding 

type JobIAMBinding struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIAMBindingSpec   `json:"spec"`
	Status            JobIAMBindingStatus `json:"status,omitempty"`
}

JobIAMBinding is the Schema for the JobIAMBindings API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*JobIAMBinding) DeepCopy 

func (in *JobIAMBinding) DeepCopy() *JobIAMBinding

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

func (*JobIAMBinding) DeepCopyInto 

func (in *JobIAMBinding) DeepCopyInto(out *JobIAMBinding)

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

func (*JobIAMBinding) DeepCopyObject 

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

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

func (*JobIAMBinding) GetCondition 

func (mg *JobIAMBinding) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this JobIAMBinding.

func (*JobIAMBinding) GetConnectionDetailsMapping 

func (tr *JobIAMBinding) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this JobIAMBinding

func (*JobIAMBinding) GetDeletionPolicy 

func (mg *JobIAMBinding) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this JobIAMBinding.

func (*JobIAMBinding) GetID 

func (tr *JobIAMBinding) GetID() string

GetID returns ID of underlying Terraform resource of this JobIAMBinding

func (*JobIAMBinding) GetObservation 

func (tr *JobIAMBinding) GetObservation() (map[string]interface{}, error)

GetObservation of this JobIAMBinding

func (*JobIAMBinding) GetParameters 

func (tr *JobIAMBinding) GetParameters() (map[string]interface{}, error)

GetParameters of this JobIAMBinding

func (*JobIAMBinding) GetProviderConfigReference 

func (mg *JobIAMBinding) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this JobIAMBinding.

func (*JobIAMBinding) GetProviderReference 

func (mg *JobIAMBinding) GetProviderReference() *xpv1.Reference

GetProviderReference of this JobIAMBinding. Deprecated: Use GetProviderConfigReference.

func (*JobIAMBinding) GetPublishConnectionDetailsTo 

func (mg *JobIAMBinding) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this JobIAMBinding.

func (*JobIAMBinding) GetTerraformResourceType 

func (mg *JobIAMBinding) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this JobIAMBinding

func (*JobIAMBinding) GetTerraformSchemaVersion 

func (tr *JobIAMBinding) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*JobIAMBinding) GetWriteConnectionSecretToReference 

func (mg *JobIAMBinding) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this JobIAMBinding.

func (*JobIAMBinding) LateInitialize 

func (tr *JobIAMBinding) LateInitialize(attrs []byte) (bool, error)

LateInitialize this JobIAMBinding using its observed tfState. returns True if there are any spec changes for the resource.

func (*JobIAMBinding) SetConditions 

func (mg *JobIAMBinding) SetConditions(c ...xpv1.Condition)

SetConditions of this JobIAMBinding.

func (*JobIAMBinding) SetDeletionPolicy 

func (mg *JobIAMBinding) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this JobIAMBinding.

func (*JobIAMBinding) SetObservation 

func (tr *JobIAMBinding) SetObservation(obs map[string]interface{}) error

SetObservation for this JobIAMBinding

func (*JobIAMBinding) SetParameters 

func (tr *JobIAMBinding) SetParameters(params map[string]interface{}) error

SetParameters for this JobIAMBinding

func (*JobIAMBinding) SetProviderConfigReference 

func (mg *JobIAMBinding) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this JobIAMBinding.

func (*JobIAMBinding) SetProviderReference 

func (mg *JobIAMBinding) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this JobIAMBinding. Deprecated: Use SetProviderConfigReference.

func (*JobIAMBinding) SetPublishConnectionDetailsTo 

func (mg *JobIAMBinding) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this JobIAMBinding.

func (*JobIAMBinding) SetWriteConnectionSecretToReference 

func (mg *JobIAMBinding) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this JobIAMBinding.

type JobIAMBindingConditionObservation 

type JobIAMBindingConditionObservation struct {
}

func (*JobIAMBindingConditionObservation) DeepCopy 

func (in *JobIAMBindingConditionObservation) DeepCopy() *JobIAMBindingConditionObservation

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

func (*JobIAMBindingConditionObservation) DeepCopyInto 

func (in *JobIAMBindingConditionObservation) DeepCopyInto(out *JobIAMBindingConditionObservation)

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

type JobIAMBindingConditionParameters 

type JobIAMBindingConditionParameters struct {

	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// +kubebuilder:validation:Required
	Expression *string `json:"expression" tf:"expression,omitempty"`

	// +kubebuilder:validation:Required
	Title *string `json:"title" tf:"title,omitempty"`
}

func (*JobIAMBindingConditionParameters) DeepCopy 

func (in *JobIAMBindingConditionParameters) DeepCopy() *JobIAMBindingConditionParameters

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

func (*JobIAMBindingConditionParameters) DeepCopyInto 

func (in *JobIAMBindingConditionParameters) DeepCopyInto(out *JobIAMBindingConditionParameters)

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

type JobIAMBindingList 

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

JobIAMBindingList contains a list of JobIAMBindings

func (*JobIAMBindingList) DeepCopy 

func (in *JobIAMBindingList) DeepCopy() *JobIAMBindingList

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

func (*JobIAMBindingList) DeepCopyInto 

func (in *JobIAMBindingList) DeepCopyInto(out *JobIAMBindingList)

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

func (*JobIAMBindingList) DeepCopyObject 

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

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

func (*JobIAMBindingList) GetItems 

func (l *JobIAMBindingList) GetItems() []resource.Managed

GetItems of this JobIAMBindingList.

type JobIAMBindingObservation 

type JobIAMBindingObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*JobIAMBindingObservation) DeepCopy 

func (in *JobIAMBindingObservation) DeepCopy() *JobIAMBindingObservation

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

func (*JobIAMBindingObservation) DeepCopyInto 

func (in *JobIAMBindingObservation) DeepCopyInto(out *JobIAMBindingObservation)

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

type JobIAMBindingParameters 

type JobIAMBindingParameters struct {

	// +kubebuilder:validation:Optional
	Condition []JobIAMBindingConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Required
	JobID *string `json:"jobId" tf:"job_id,omitempty"`

	// +kubebuilder:validation:Required
	Members []*string `json:"members" tf:"members,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// +kubebuilder:validation:Required
	Role *string `json:"role" tf:"role,omitempty"`
}

func (*JobIAMBindingParameters) DeepCopy 

func (in *JobIAMBindingParameters) DeepCopy() *JobIAMBindingParameters

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

func (*JobIAMBindingParameters) DeepCopyInto 

func (in *JobIAMBindingParameters) DeepCopyInto(out *JobIAMBindingParameters)

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

type JobIAMBindingSpec 

type JobIAMBindingSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     JobIAMBindingParameters `json:"forProvider"`
}

JobIAMBindingSpec defines the desired state of JobIAMBinding

func (*JobIAMBindingSpec) DeepCopy 

func (in *JobIAMBindingSpec) DeepCopy() *JobIAMBindingSpec

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

func (*JobIAMBindingSpec) DeepCopyInto 

func (in *JobIAMBindingSpec) DeepCopyInto(out *JobIAMBindingSpec)

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

type JobIAMBindingStatus 

type JobIAMBindingStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        JobIAMBindingObservation `json:"atProvider,omitempty"`
}

JobIAMBindingStatus defines the observed state of JobIAMBinding.

func (*JobIAMBindingStatus) DeepCopy 

func (in *JobIAMBindingStatus) DeepCopy() *JobIAMBindingStatus

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

func (*JobIAMBindingStatus) DeepCopyInto 

func (in *JobIAMBindingStatus) DeepCopyInto(out *JobIAMBindingStatus)

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

type JobIAMMember 

type JobIAMMember struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIAMMemberSpec   `json:"spec"`
	Status            JobIAMMemberStatus `json:"status,omitempty"`
}

JobIAMMember is the Schema for the JobIAMMembers API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*JobIAMMember) DeepCopy 

func (in *JobIAMMember) DeepCopy() *JobIAMMember

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

func (*JobIAMMember) DeepCopyInto 

func (in *JobIAMMember) DeepCopyInto(out *JobIAMMember)

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

func (*JobIAMMember) DeepCopyObject 

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

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

func (*JobIAMMember) GetCondition 

func (mg *JobIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this JobIAMMember.

func (*JobIAMMember) GetConnectionDetailsMapping 

func (tr *JobIAMMember) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this JobIAMMember

func (*JobIAMMember) GetDeletionPolicy 

func (mg *JobIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this JobIAMMember.

func (*JobIAMMember) GetID 

func (tr *JobIAMMember) GetID() string

GetID returns ID of underlying Terraform resource of this JobIAMMember

func (*JobIAMMember) GetObservation 

func (tr *JobIAMMember) GetObservation() (map[string]interface{}, error)

GetObservation of this JobIAMMember

func (*JobIAMMember) GetParameters 

func (tr *JobIAMMember) GetParameters() (map[string]interface{}, error)

GetParameters of this JobIAMMember

func (*JobIAMMember) GetProviderConfigReference 

func (mg *JobIAMMember) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this JobIAMMember.

func (*JobIAMMember) GetProviderReference 

func (mg *JobIAMMember) GetProviderReference() *xpv1.Reference

GetProviderReference of this JobIAMMember. Deprecated: Use GetProviderConfigReference.

func (*JobIAMMember) GetPublishConnectionDetailsTo 

func (mg *JobIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this JobIAMMember.

func (*JobIAMMember) GetTerraformResourceType 

func (mg *JobIAMMember) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this JobIAMMember

func (*JobIAMMember) GetTerraformSchemaVersion 

func (tr *JobIAMMember) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*JobIAMMember) GetWriteConnectionSecretToReference 

func (mg *JobIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this JobIAMMember.

func (*JobIAMMember) LateInitialize 

func (tr *JobIAMMember) LateInitialize(attrs []byte) (bool, error)

LateInitialize this JobIAMMember using its observed tfState. returns True if there are any spec changes for the resource.

func (*JobIAMMember) SetConditions 

func (mg *JobIAMMember) SetConditions(c ...xpv1.Condition)

SetConditions of this JobIAMMember.

func (*JobIAMMember) SetDeletionPolicy 

func (mg *JobIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this JobIAMMember.

func (*JobIAMMember) SetObservation 

func (tr *JobIAMMember) SetObservation(obs map[string]interface{}) error

SetObservation for this JobIAMMember

func (*JobIAMMember) SetParameters 

func (tr *JobIAMMember) SetParameters(params map[string]interface{}) error

SetParameters for this JobIAMMember

func (*JobIAMMember) SetProviderConfigReference 

func (mg *JobIAMMember) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this JobIAMMember.

func (*JobIAMMember) SetProviderReference 

func (mg *JobIAMMember) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this JobIAMMember. Deprecated: Use SetProviderConfigReference.

func (*JobIAMMember) SetPublishConnectionDetailsTo 

func (mg *JobIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this JobIAMMember.

func (*JobIAMMember) SetWriteConnectionSecretToReference 

func (mg *JobIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this JobIAMMember.

type JobIAMMemberConditionObservation 

type JobIAMMemberConditionObservation struct {
}

func (*JobIAMMemberConditionObservation) DeepCopy 

func (in *JobIAMMemberConditionObservation) DeepCopy() *JobIAMMemberConditionObservation

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

func (*JobIAMMemberConditionObservation) DeepCopyInto 

func (in *JobIAMMemberConditionObservation) DeepCopyInto(out *JobIAMMemberConditionObservation)

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

type JobIAMMemberConditionParameters 

type JobIAMMemberConditionParameters struct {

	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// +kubebuilder:validation:Required
	Expression *string `json:"expression" tf:"expression,omitempty"`

	// +kubebuilder:validation:Required
	Title *string `json:"title" tf:"title,omitempty"`
}

func (*JobIAMMemberConditionParameters) DeepCopy 

func (in *JobIAMMemberConditionParameters) DeepCopy() *JobIAMMemberConditionParameters

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

func (*JobIAMMemberConditionParameters) DeepCopyInto 

func (in *JobIAMMemberConditionParameters) DeepCopyInto(out *JobIAMMemberConditionParameters)

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

type JobIAMMemberList 

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

JobIAMMemberList contains a list of JobIAMMembers

func (*JobIAMMemberList) DeepCopy 

func (in *JobIAMMemberList) DeepCopy() *JobIAMMemberList

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

func (*JobIAMMemberList) DeepCopyInto 

func (in *JobIAMMemberList) DeepCopyInto(out *JobIAMMemberList)

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

func (*JobIAMMemberList) DeepCopyObject 

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

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

func (*JobIAMMemberList) GetItems 

func (l *JobIAMMemberList) GetItems() []resource.Managed

GetItems of this JobIAMMemberList.

type JobIAMMemberObservation 

type JobIAMMemberObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*JobIAMMemberObservation) DeepCopy 

func (in *JobIAMMemberObservation) DeepCopy() *JobIAMMemberObservation

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

func (*JobIAMMemberObservation) DeepCopyInto 

func (in *JobIAMMemberObservation) DeepCopyInto(out *JobIAMMemberObservation)

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

type JobIAMMemberParameters 

type JobIAMMemberParameters struct {

	// +kubebuilder:validation:Optional
	Condition []JobIAMMemberConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Required
	JobID *string `json:"jobId" tf:"job_id,omitempty"`

	// +kubebuilder:validation:Required
	Member *string `json:"member" tf:"member,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// +kubebuilder:validation:Required
	Role *string `json:"role" tf:"role,omitempty"`
}

func (*JobIAMMemberParameters) DeepCopy 

func (in *JobIAMMemberParameters) DeepCopy() *JobIAMMemberParameters

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

func (*JobIAMMemberParameters) DeepCopyInto 

func (in *JobIAMMemberParameters) DeepCopyInto(out *JobIAMMemberParameters)

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

type JobIAMMemberSpec 

type JobIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     JobIAMMemberParameters `json:"forProvider"`
}

JobIAMMemberSpec defines the desired state of JobIAMMember

func (*JobIAMMemberSpec) DeepCopy 

func (in *JobIAMMemberSpec) DeepCopy() *JobIAMMemberSpec

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

func (*JobIAMMemberSpec) DeepCopyInto 

func (in *JobIAMMemberSpec) DeepCopyInto(out *JobIAMMemberSpec)

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

type JobIAMMemberStatus 

type JobIAMMemberStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        JobIAMMemberObservation `json:"atProvider,omitempty"`
}

JobIAMMemberStatus defines the observed state of JobIAMMember.

func (*JobIAMMemberStatus) DeepCopy 

func (in *JobIAMMemberStatus) DeepCopy() *JobIAMMemberStatus

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

func (*JobIAMMemberStatus) DeepCopyInto 

func (in *JobIAMMemberStatus) DeepCopyInto(out *JobIAMMemberStatus)

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

type JobIAMPolicy 

type JobIAMPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobIAMPolicySpec   `json:"spec"`
	Status            JobIAMPolicyStatus `json:"status,omitempty"`
}

JobIAMPolicy is the Schema for the JobIAMPolicys API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*JobIAMPolicy) DeepCopy 

func (in *JobIAMPolicy) DeepCopy() *JobIAMPolicy

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

func (*JobIAMPolicy) DeepCopyInto 

func (in *JobIAMPolicy) DeepCopyInto(out *JobIAMPolicy)

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

func (*JobIAMPolicy) DeepCopyObject 

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

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

func (*JobIAMPolicy) GetCondition 

func (mg *JobIAMPolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this JobIAMPolicy.

func (*JobIAMPolicy) GetConnectionDetailsMapping 

func (tr *JobIAMPolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this JobIAMPolicy

func (*JobIAMPolicy) GetDeletionPolicy 

func (mg *JobIAMPolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this JobIAMPolicy.

func (*JobIAMPolicy) GetID 

func (tr *JobIAMPolicy) GetID() string

GetID returns ID of underlying Terraform resource of this JobIAMPolicy

func (*JobIAMPolicy) GetObservation 

func (tr *JobIAMPolicy) GetObservation() (map[string]interface{}, error)

GetObservation of this JobIAMPolicy

func (*JobIAMPolicy) GetParameters 

func (tr *JobIAMPolicy) GetParameters() (map[string]interface{}, error)

GetParameters of this JobIAMPolicy

func (*JobIAMPolicy) GetProviderConfigReference 

func (mg *JobIAMPolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this JobIAMPolicy.

func (*JobIAMPolicy) GetProviderReference 

func (mg *JobIAMPolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this JobIAMPolicy. Deprecated: Use GetProviderConfigReference.

func (*JobIAMPolicy) GetPublishConnectionDetailsTo 

func (mg *JobIAMPolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this JobIAMPolicy.

func (*JobIAMPolicy) GetTerraformResourceType 

func (mg *JobIAMPolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this JobIAMPolicy

func (*JobIAMPolicy) GetTerraformSchemaVersion 

func (tr *JobIAMPolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*JobIAMPolicy) GetWriteConnectionSecretToReference 

func (mg *JobIAMPolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this JobIAMPolicy.

func (*JobIAMPolicy) LateInitialize 

func (tr *JobIAMPolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this JobIAMPolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*JobIAMPolicy) SetConditions 

func (mg *JobIAMPolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this JobIAMPolicy.

func (*JobIAMPolicy) SetDeletionPolicy 

func (mg *JobIAMPolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this JobIAMPolicy.

func (*JobIAMPolicy) SetObservation 

func (tr *JobIAMPolicy) SetObservation(obs map[string]interface{}) error

SetObservation for this JobIAMPolicy

func (*JobIAMPolicy) SetParameters 

func (tr *JobIAMPolicy) SetParameters(params map[string]interface{}) error

SetParameters for this JobIAMPolicy

func (*JobIAMPolicy) SetProviderConfigReference 

func (mg *JobIAMPolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this JobIAMPolicy.

func (*JobIAMPolicy) SetProviderReference 

func (mg *JobIAMPolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this JobIAMPolicy. Deprecated: Use SetProviderConfigReference.

func (*JobIAMPolicy) SetPublishConnectionDetailsTo 

func (mg *JobIAMPolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this JobIAMPolicy.

func (*JobIAMPolicy) SetWriteConnectionSecretToReference 

func (mg *JobIAMPolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this JobIAMPolicy.

type JobIAMPolicyList 

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

JobIAMPolicyList contains a list of JobIAMPolicys

func (*JobIAMPolicyList) DeepCopy 

func (in *JobIAMPolicyList) DeepCopy() *JobIAMPolicyList

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

func (*JobIAMPolicyList) DeepCopyInto 

func (in *JobIAMPolicyList) DeepCopyInto(out *JobIAMPolicyList)

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

func (*JobIAMPolicyList) DeepCopyObject 

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

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

func (*JobIAMPolicyList) GetItems 

func (l *JobIAMPolicyList) GetItems() []resource.Managed

GetItems of this JobIAMPolicyList.

type JobIAMPolicyObservation 

type JobIAMPolicyObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*JobIAMPolicyObservation) DeepCopy 

func (in *JobIAMPolicyObservation) DeepCopy() *JobIAMPolicyObservation

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

func (*JobIAMPolicyObservation) DeepCopyInto 

func (in *JobIAMPolicyObservation) DeepCopyInto(out *JobIAMPolicyObservation)

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

type JobIAMPolicyParameters 

type JobIAMPolicyParameters struct {

	// +kubebuilder:validation:Required
	JobID *string `json:"jobId" tf:"job_id,omitempty"`

	// +kubebuilder:validation:Required
	PolicyData *string `json:"policyData" tf:"policy_data,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`
}

func (*JobIAMPolicyParameters) DeepCopy 

func (in *JobIAMPolicyParameters) DeepCopy() *JobIAMPolicyParameters

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

func (*JobIAMPolicyParameters) DeepCopyInto 

func (in *JobIAMPolicyParameters) DeepCopyInto(out *JobIAMPolicyParameters)

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

type JobIAMPolicySpec 

type JobIAMPolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     JobIAMPolicyParameters `json:"forProvider"`
}

JobIAMPolicySpec defines the desired state of JobIAMPolicy

func (*JobIAMPolicySpec) DeepCopy 

func (in *JobIAMPolicySpec) DeepCopy() *JobIAMPolicySpec

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

func (*JobIAMPolicySpec) DeepCopyInto 

func (in *JobIAMPolicySpec) DeepCopyInto(out *JobIAMPolicySpec)

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

type JobIAMPolicyStatus 

type JobIAMPolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        JobIAMPolicyObservation `json:"atProvider,omitempty"`
}

JobIAMPolicyStatus defines the observed state of JobIAMPolicy.

func (*JobIAMPolicyStatus) DeepCopy 

func (in *JobIAMPolicyStatus) DeepCopy() *JobIAMPolicyStatus

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

func (*JobIAMPolicyStatus) DeepCopyInto 

func (in *JobIAMPolicyStatus) DeepCopyInto(out *JobIAMPolicyStatus)

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

type JobList 

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

JobList contains a list of Jobs

func (*JobList) DeepCopy 

func (in *JobList) DeepCopy() *JobList

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

func (*JobList) DeepCopyInto 

func (in *JobList) DeepCopyInto(out *JobList)

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

func (*JobList) DeepCopyObject 

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

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

func (*JobList) GetItems 

func (l *JobList) GetItems() []resource.Managed

GetItems of this JobList.

type JobObservation 

type JobObservation struct {
	DriverControlsFilesURI *string `json:"driverControlsFilesUri,omitempty" tf:"driver_controls_files_uri,omitempty"`

	DriverOutputResourceURI *string `json:"driverOutputResourceUri,omitempty" tf:"driver_output_resource_uri,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	Status []StatusObservation `json:"status,omitempty" tf:"status,omitempty"`
}

func (*JobObservation) DeepCopy 

func (in *JobObservation) DeepCopy() *JobObservation

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

func (*JobObservation) DeepCopyInto 

func (in *JobObservation) DeepCopyInto(out *JobObservation)

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

type JobParameters 

type JobParameters struct {

	// By default, you can only delete inactive jobs within Dataproc. Setting this to true, and calling destroy, will ensure that the job is first cancelled before issuing the delete.
	// +kubebuilder:validation:Optional
	ForceDelete *bool `json:"forceDelete,omitempty" tf:"force_delete,omitempty"`

	// The config of Hadoop job
	// +kubebuilder:validation:Optional
	HadoopConfig []HadoopConfigParameters `json:"hadoopConfig,omitempty" tf:"hadoop_config,omitempty"`

	// The config of hive job
	// +kubebuilder:validation:Optional
	HiveConfig []HiveConfigParameters `json:"hiveConfig,omitempty" tf:"hive_config,omitempty"`

	// Optional. The labels to associate with this job.
	// +kubebuilder:validation:Optional
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// The config of pag job.
	// +kubebuilder:validation:Optional
	PigConfig []PigConfigParameters `json:"pigConfig,omitempty" tf:"pig_config,omitempty"`

	// The config of job placement.
	// +kubebuilder:validation:Required
	Placement []PlacementParameters `json:"placement" tf:"placement,omitempty"`

	// The config of presto job
	// +kubebuilder:validation:Optional
	PrestoConfig []PrestoConfigParameters `json:"prestoConfig,omitempty" tf:"presto_config,omitempty"`

	// The project in which the cluster can be found and jobs subsequently run against. If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The config of pySpark job.
	// +kubebuilder:validation:Optional
	PysparkConfig []PysparkConfigParameters `json:"pysparkConfig,omitempty" tf:"pyspark_config,omitempty"`

	// The reference of the job
	// +kubebuilder:validation:Optional
	Reference []ReferenceParameters `json:"reference,omitempty" tf:"reference,omitempty"`

	// The Cloud Dataproc region. This essentially determines which clusters are available for this job to be submitted to. If not specified, defaults to global.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Optional. Job scheduling configuration.
	// +kubebuilder:validation:Optional
	Scheduling []SchedulingParameters `json:"scheduling,omitempty" tf:"scheduling,omitempty"`

	// The config of the Spark job.
	// +kubebuilder:validation:Optional
	SparkConfig []SparkConfigParameters `json:"sparkConfig,omitempty" tf:"spark_config,omitempty"`

	// The config of SparkSql job
	// +kubebuilder:validation:Optional
	SparksqlConfig []SparksqlConfigParameters `json:"sparksqlConfig,omitempty" tf:"sparksql_config,omitempty"`
}

func (*JobParameters) DeepCopy 

func (in *JobParameters) DeepCopy() *JobParameters

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

func (*JobParameters) DeepCopyInto 

func (in *JobParameters) DeepCopyInto(out *JobParameters)

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

type JobSpec 

type JobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     JobParameters `json:"forProvider"`
}

JobSpec defines the desired state of Job

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

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

func (*JobSpec) DeepCopyInto 

func (in *JobSpec) DeepCopyInto(out *JobSpec)

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

type JobStatus 

type JobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        JobObservation `json:"atProvider,omitempty"`
}

JobStatus defines the observed state of Job.

func (*JobStatus) DeepCopy 

func (in *JobStatus) DeepCopy() *JobStatus

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

func (*JobStatus) DeepCopyInto 

func (in *JobStatus) DeepCopyInto(out *JobStatus)

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

type JobsObservation 

type JobsObservation struct {
}

func (*JobsObservation) DeepCopy 

func (in *JobsObservation) DeepCopy() *JobsObservation

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

func (*JobsObservation) DeepCopyInto 

func (in *JobsObservation) DeepCopyInto(out *JobsObservation)

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

type JobsParameters 

type JobsParameters struct {

	// Optional. Job is a Hadoop job.
	// +kubebuilder:validation:Optional
	HadoopJob []HadoopJobParameters `json:"hadoopJob,omitempty" tf:"hadoop_job,omitempty"`

	// Optional. Job is a Hive job.
	// +kubebuilder:validation:Optional
	HiveJob []HiveJobParameters `json:"hiveJob,omitempty" tf:"hive_job,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// Optional. Job is a Pig job.
	// +kubebuilder:validation:Optional
	PigJob []PigJobParameters `json:"pigJob,omitempty" tf:"pig_job,omitempty"`

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

	// Optional. Job is a Presto job.
	// +kubebuilder:validation:Optional
	PrestoJob []PrestoJobParameters `json:"prestoJob,omitempty" tf:"presto_job,omitempty"`

	// Optional. Job is a PySpark job.
	// +kubebuilder:validation:Optional
	PysparkJob []PysparkJobParameters `json:"pysparkJob,omitempty" tf:"pyspark_job,omitempty"`

	// Optional. Job scheduling configuration.
	// +kubebuilder:validation:Optional
	Scheduling []JobsSchedulingParameters `json:"scheduling,omitempty" tf:"scheduling,omitempty"`

	// Optional. Job is a Spark job.
	// +kubebuilder:validation:Optional
	SparkJob []SparkJobParameters `json:"sparkJob,omitempty" tf:"spark_job,omitempty"`

	// Optional. Job is a SparkR job.
	// +kubebuilder:validation:Optional
	SparkRJob []SparkRJobParameters `json:"sparkRJob,omitempty" tf:"spark_r_job,omitempty"`

	// Optional. Job is a SparkSql job.
	// +kubebuilder:validation:Optional
	SparkSQLJob []SparkSQLJobParameters `json:"sparkSqlJob,omitempty" tf:"spark_sql_job,omitempty"`

	// 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.
	// +kubebuilder:validation:Required
	StepID *string `json:"stepId" tf:"step_id,omitempty"`
}

func (*JobsParameters) DeepCopy 

func (in *JobsParameters) DeepCopy() *JobsParameters

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

func (*JobsParameters) DeepCopyInto 

func (in *JobsParameters) DeepCopyInto(out *JobsParameters)

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

type JobsSchedulingObservation 

type JobsSchedulingObservation struct {
}

func (*JobsSchedulingObservation) DeepCopy 

func (in *JobsSchedulingObservation) DeepCopy() *JobsSchedulingObservation

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

func (*JobsSchedulingObservation) DeepCopyInto 

func (in *JobsSchedulingObservation) DeepCopyInto(out *JobsSchedulingObservation)

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

type JobsSchedulingParameters 

type JobsSchedulingParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	MaxFailuresPerHour *float64 `json:"maxFailuresPerHour,omitempty" tf:"max_failures_per_hour,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	MaxFailuresTotal *float64 `json:"maxFailuresTotal,omitempty" tf:"max_failures_total,omitempty"`
}

func (*JobsSchedulingParameters) DeepCopy 

func (in *JobsSchedulingParameters) DeepCopy() *JobsSchedulingParameters

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

func (*JobsSchedulingParameters) DeepCopyInto 

func (in *JobsSchedulingParameters) DeepCopyInto(out *JobsSchedulingParameters)

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

type KerberosConfigObservation 

type KerberosConfigObservation struct {
}

func (*KerberosConfigObservation) DeepCopy 

func (in *KerberosConfigObservation) DeepCopy() *KerberosConfigObservation

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

func (*KerberosConfigObservation) DeepCopyInto 

func (in *KerberosConfigObservation) DeepCopyInto(out *KerberosConfigObservation)

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

type KerberosConfigParameters 

type KerberosConfigParameters struct {

	// The admin server (IP or hostname) for the remote trusted realm in a cross realm trust relationship.
	// +kubebuilder:validation:Optional
	CrossRealmTrustAdminServer *string `json:"crossRealmTrustAdminServer,omitempty" tf:"cross_realm_trust_admin_server,omitempty"`

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

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

	// 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.
	// +kubebuilder:validation:Optional
	CrossRealmTrustSharedPasswordURI *string `json:"crossRealmTrustSharedPasswordUri,omitempty" tf:"cross_realm_trust_shared_password_uri,omitempty"`

	// Flag to indicate whether to Kerberize the cluster.
	// +kubebuilder:validation:Optional
	EnableKerberos *bool `json:"enableKerberos,omitempty" tf:"enable_kerberos,omitempty"`

	// The uri of the KMS key used to encrypt various sensitive files.
	// +kubebuilder:validation:Required
	KMSKeyURI *string `json:"kmsKeyUri" tf:"kms_key_uri,omitempty"`

	// The Cloud Storage URI of a KMS encrypted file containing the master key of the KDC database.
	// +kubebuilder:validation:Optional
	KdcDBKeyURI *string `json:"kdcDbKeyUri,omitempty" tf:"kdc_db_key_uri,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	KeyPasswordURI *string `json:"keyPasswordUri,omitempty" tf:"key_password_uri,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	KeystorePasswordURI *string `json:"keystorePasswordUri,omitempty" tf:"keystore_password_uri,omitempty"`

	// The Cloud Storage URI of the keystore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate.
	// +kubebuilder:validation:Optional
	KeystoreURI *string `json:"keystoreUri,omitempty" tf:"keystore_uri,omitempty"`

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

	// The cloud Storage URI of a KMS encrypted file containing the root principal password.
	// +kubebuilder:validation:Required
	RootPrincipalPasswordURI *string `json:"rootPrincipalPasswordUri" tf:"root_principal_password_uri,omitempty"`

	// The lifetime of the ticket granting ticket, in hours.
	// +kubebuilder:validation:Optional
	TgtLifetimeHours *float64 `json:"tgtLifetimeHours,omitempty" tf:"tgt_lifetime_hours,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	TruststorePasswordURI *string `json:"truststorePasswordUri,omitempty" tf:"truststore_password_uri,omitempty"`

	// The Cloud Storage URI of the truststore file used for SSL encryption. If not provided, Dataproc will provide a self-signed certificate.
	// +kubebuilder:validation:Optional
	TruststoreURI *string `json:"truststoreUri,omitempty" tf:"truststore_uri,omitempty"`
}

func (*KerberosConfigParameters) DeepCopy 

func (in *KerberosConfigParameters) DeepCopy() *KerberosConfigParameters

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

func (*KerberosConfigParameters) DeepCopyInto 

func (in *KerberosConfigParameters) DeepCopyInto(out *KerberosConfigParameters)

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

type LifecycleConfigObservation 

type LifecycleConfigObservation struct {
	IdleStartTime *string `json:"idleStartTime,omitempty" tf:"idle_start_time,omitempty"`
}

func (*LifecycleConfigObservation) DeepCopy 

func (in *LifecycleConfigObservation) DeepCopy() *LifecycleConfigObservation

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

func (*LifecycleConfigObservation) DeepCopyInto 

func (in *LifecycleConfigObservation) DeepCopyInto(out *LifecycleConfigObservation)

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

type LifecycleConfigParameters 

type LifecycleConfigParameters struct {

	// 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)).
	// +kubebuilder:validation:Optional
	AutoDeleteTTL *string `json:"autoDeleteTtl,omitempty" tf:"auto_delete_ttl,omitempty"`

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

	// 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)).
	// +kubebuilder:validation:Optional
	IdleDeleteTTL *string `json:"idleDeleteTtl,omitempty" tf:"idle_delete_ttl,omitempty"`
}

func (*LifecycleConfigParameters) DeepCopy 

func (in *LifecycleConfigParameters) DeepCopy() *LifecycleConfigParameters

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

func (*LifecycleConfigParameters) DeepCopyInto 

func (in *LifecycleConfigParameters) DeepCopyInto(out *LifecycleConfigParameters)

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

type LoggingConfigObservation 

type LoggingConfigObservation struct {
}

func (*LoggingConfigObservation) DeepCopy 

func (in *LoggingConfigObservation) DeepCopy() *LoggingConfigObservation

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

func (*LoggingConfigObservation) DeepCopyInto 

func (in *LoggingConfigObservation) DeepCopyInto(out *LoggingConfigObservation)

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

type LoggingConfigParameters 

type LoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*LoggingConfigParameters) DeepCopy 

func (in *LoggingConfigParameters) DeepCopy() *LoggingConfigParameters

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

func (*LoggingConfigParameters) DeepCopyInto 

func (in *LoggingConfigParameters) DeepCopyInto(out *LoggingConfigParameters)

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

type ManagedClusterObservation 

type ManagedClusterObservation struct {
}

func (*ManagedClusterObservation) DeepCopy 

func (in *ManagedClusterObservation) DeepCopy() *ManagedClusterObservation

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

func (*ManagedClusterObservation) DeepCopyInto 

func (in *ManagedClusterObservation) DeepCopyInto(out *ManagedClusterObservation)

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

type ManagedClusterParameters 

type ManagedClusterParameters struct {

	// 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.
	// +kubebuilder:validation:Required
	ClusterName *string `json:"clusterName" tf:"cluster_name,omitempty"`

	// Required. The cluster configuration.
	// +kubebuilder:validation:Required
	Config []ConfigParameters `json:"config" tf:"config,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`
}

func (*ManagedClusterParameters) DeepCopy 

func (in *ManagedClusterParameters) DeepCopy() *ManagedClusterParameters

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

func (*ManagedClusterParameters) DeepCopyInto 

func (in *ManagedClusterParameters) DeepCopyInto(out *ManagedClusterParameters)

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

type ManagedGroupConfigObservation 

type ManagedGroupConfigObservation struct {
	InstanceGroupManagerName *string `json:"instanceGroupManagerName,omitempty" tf:"instance_group_manager_name,omitempty"`

	InstanceTemplateName *string `json:"instanceTemplateName,omitempty" tf:"instance_template_name,omitempty"`
}

func (*ManagedGroupConfigObservation) DeepCopy 

func (in *ManagedGroupConfigObservation) DeepCopy() *ManagedGroupConfigObservation

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

func (*ManagedGroupConfigObservation) DeepCopyInto 

func (in *ManagedGroupConfigObservation) DeepCopyInto(out *ManagedGroupConfigObservation)

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

type ManagedGroupConfigParameters 

type ManagedGroupConfigParameters struct {
}

func (*ManagedGroupConfigParameters) DeepCopy 

func (in *ManagedGroupConfigParameters) DeepCopy() *ManagedGroupConfigParameters

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

func (*ManagedGroupConfigParameters) DeepCopyInto 

func (in *ManagedGroupConfigParameters) DeepCopyInto(out *ManagedGroupConfigParameters)

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

type MasterConfigAcceleratorsObservation 

type MasterConfigAcceleratorsObservation struct {
}

func (*MasterConfigAcceleratorsObservation) DeepCopy 

func (in *MasterConfigAcceleratorsObservation) DeepCopy() *MasterConfigAcceleratorsObservation

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

func (*MasterConfigAcceleratorsObservation) DeepCopyInto 

func (in *MasterConfigAcceleratorsObservation) DeepCopyInto(out *MasterConfigAcceleratorsObservation)

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

type MasterConfigAcceleratorsParameters 

type MasterConfigAcceleratorsParameters struct {

	// The number of the accelerator cards of this type exposed to this instance.
	// +kubebuilder:validation:Optional
	AcceleratorCount *float64 `json:"acceleratorCount,omitempty" tf:"accelerator_count,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	AcceleratorType *string `json:"acceleratorType,omitempty" tf:"accelerator_type,omitempty"`
}

func (*MasterConfigAcceleratorsParameters) DeepCopy 

func (in *MasterConfigAcceleratorsParameters) DeepCopy() *MasterConfigAcceleratorsParameters

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

func (*MasterConfigAcceleratorsParameters) DeepCopyInto 

func (in *MasterConfigAcceleratorsParameters) DeepCopyInto(out *MasterConfigAcceleratorsParameters)

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

type MasterConfigDiskConfigObservation 

type MasterConfigDiskConfigObservation struct {
}

func (*MasterConfigDiskConfigObservation) DeepCopy 

func (in *MasterConfigDiskConfigObservation) DeepCopy() *MasterConfigDiskConfigObservation

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

func (*MasterConfigDiskConfigObservation) DeepCopyInto 

func (in *MasterConfigDiskConfigObservation) DeepCopyInto(out *MasterConfigDiskConfigObservation)

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

type MasterConfigDiskConfigParameters 

type MasterConfigDiskConfigParameters struct {

	// Optional. Size in GB of the boot disk (default is 500GB).
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*MasterConfigDiskConfigParameters) DeepCopy 

func (in *MasterConfigDiskConfigParameters) DeepCopy() *MasterConfigDiskConfigParameters

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

func (*MasterConfigDiskConfigParameters) DeepCopyInto 

func (in *MasterConfigDiskConfigParameters) DeepCopyInto(out *MasterConfigDiskConfigParameters)

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

type MasterConfigObservation 

type MasterConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`
}

func (*MasterConfigObservation) DeepCopy 

func (in *MasterConfigObservation) DeepCopy() *MasterConfigObservation

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

func (*MasterConfigObservation) DeepCopyInto 

func (in *MasterConfigObservation) DeepCopyInto(out *MasterConfigObservation)

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

type MasterConfigParameters 

type MasterConfigParameters struct {

	// The Compute Engine accelerator (GPU) configuration for these instances. Can be specified multiple times.
	// +kubebuilder:validation:Optional
	Accelerators []AcceleratorsParameters `json:"accelerators,omitempty" tf:"accelerators,omitempty"`

	// Disk Config
	// +kubebuilder:validation:Optional
	DiskConfig []DiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// The URI for the image to use for this master/worker
	// +kubebuilder:validation:Optional
	ImageURI *string `json:"imageUri,omitempty" tf:"image_uri,omitempty"`

	// The name of a Google Compute Engine machine type to create for the master/worker
	// +kubebuilder:validation:Optional
	MachineType *string `json:"machineType,omitempty" tf:"machine_type,omitempty"`

	// The name of a minimum generation of CPU family for the master/worker. If not specified, GCP will default to a predetermined computed value for each zone.
	// +kubebuilder:validation:Optional
	MinCPUPlatform *string `json:"minCpuPlatform,omitempty" tf:"min_cpu_platform,omitempty"`

	// Specifies the number of master/worker nodes to create. If not specified, GCP will default to a predetermined computed value.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`
}

func (*MasterConfigParameters) DeepCopy 

func (in *MasterConfigParameters) DeepCopy() *MasterConfigParameters

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

func (*MasterConfigParameters) DeepCopyInto 

func (in *MasterConfigParameters) DeepCopyInto(out *MasterConfigParameters)

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

type NodeGroupAffinityObservation 

type NodeGroupAffinityObservation struct {
}

func (*NodeGroupAffinityObservation) DeepCopy 

func (in *NodeGroupAffinityObservation) DeepCopy() *NodeGroupAffinityObservation

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

func (*NodeGroupAffinityObservation) DeepCopyInto 

func (in *NodeGroupAffinityObservation) DeepCopyInto(out *NodeGroupAffinityObservation)

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

type NodeGroupAffinityParameters 

type NodeGroupAffinityParameters struct {

	// Required. The URI of a sole-tenant [node group resource](https://cloud.google.com/compute/docs/reference/rest/v1/nodeGroups) that the cluster will be created on. A full URL, partial URI, or node group name are valid. Examples: * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-central1-a/nodeGroups/node-group-1` * `projects/[project_id]/zones/us-central1-a/nodeGroups/node-group-1` * `node-group-1`
	// +kubebuilder:validation:Required
	NodeGroup *string `json:"nodeGroup" tf:"node_group,omitempty"`
}

func (*NodeGroupAffinityParameters) DeepCopy 

func (in *NodeGroupAffinityParameters) DeepCopy() *NodeGroupAffinityParameters

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

func (*NodeGroupAffinityParameters) DeepCopyInto 

func (in *NodeGroupAffinityParameters) DeepCopyInto(out *NodeGroupAffinityParameters)

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

type ParametersObservation 

type ParametersObservation struct {
}

func (*ParametersObservation) DeepCopy 

func (in *ParametersObservation) DeepCopy() *ParametersObservation

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

func (*ParametersObservation) DeepCopyInto 

func (in *ParametersObservation) DeepCopyInto(out *ParametersObservation)

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

type ParametersParameters 

type ParametersParameters struct {

	// Optional. Brief description of the parameter. Must not exceed 1024 characters.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// 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
	// +kubebuilder:validation:Required
	Fields []*string `json:"fields" tf:"fields,omitempty"`

	// 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.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Optional. Validation rules to be applied to this parameter's value.
	// +kubebuilder:validation:Optional
	Validation []ValidationParameters `json:"validation,omitempty" tf:"validation,omitempty"`
}

func (*ParametersParameters) DeepCopy 

func (in *ParametersParameters) DeepCopy() *ParametersParameters

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

func (*ParametersParameters) DeepCopyInto 

func (in *ParametersParameters) DeepCopyInto(out *ParametersParameters)

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

type PigConfigLoggingConfigObservation 

type PigConfigLoggingConfigObservation struct {
}

func (*PigConfigLoggingConfigObservation) DeepCopy 

func (in *PigConfigLoggingConfigObservation) DeepCopy() *PigConfigLoggingConfigObservation

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

func (*PigConfigLoggingConfigObservation) DeepCopyInto 

func (in *PigConfigLoggingConfigObservation) DeepCopyInto(out *PigConfigLoggingConfigObservation)

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

type PigConfigLoggingConfigParameters 

type PigConfigLoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*PigConfigLoggingConfigParameters) DeepCopy 

func (in *PigConfigLoggingConfigParameters) DeepCopy() *PigConfigLoggingConfigParameters

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

func (*PigConfigLoggingConfigParameters) DeepCopyInto 

func (in *PigConfigLoggingConfigParameters) DeepCopyInto(out *PigConfigLoggingConfigParameters)

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

type PigConfigObservation 

type PigConfigObservation struct {
}

func (*PigConfigObservation) DeepCopy 

func (in *PigConfigObservation) DeepCopy() *PigConfigObservation

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

func (*PigConfigObservation) DeepCopyInto 

func (in *PigConfigObservation) DeepCopyInto(out *PigConfigObservation)

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

type PigConfigParameters 

type PigConfigParameters struct {

	// 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. Defaults to false.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

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

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []PigConfigLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// A mapping of property names to values, used to configure Pig. Properties that conflict with values set by the Cloud 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// HCFS URI of file containing Hive script to execute as the job. Conflicts with query_list
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// The list of Hive queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +kubebuilder:validation:Optional
	QueryList []*string `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*PigConfigParameters) DeepCopy 

func (in *PigConfigParameters) DeepCopy() *PigConfigParameters

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

func (*PigConfigParameters) DeepCopyInto 

func (in *PigConfigParameters) DeepCopyInto(out *PigConfigParameters)

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

type PigJobLoggingConfigObservation 

type PigJobLoggingConfigObservation struct {
}

func (*PigJobLoggingConfigObservation) DeepCopy 

func (in *PigJobLoggingConfigObservation) DeepCopy() *PigJobLoggingConfigObservation

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

func (*PigJobLoggingConfigObservation) DeepCopyInto 

func (in *PigJobLoggingConfigObservation) DeepCopyInto(out *PigJobLoggingConfigObservation)

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

type PigJobLoggingConfigParameters 

type PigJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*PigJobLoggingConfigParameters) DeepCopy 

func (in *PigJobLoggingConfigParameters) DeepCopy() *PigJobLoggingConfigParameters

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

func (*PigJobLoggingConfigParameters) DeepCopyInto 

func (in *PigJobLoggingConfigParameters) DeepCopyInto(out *PigJobLoggingConfigParameters)

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

type PigJobObservation 

type PigJobObservation struct {
}

func (*PigJobObservation) DeepCopy 

func (in *PigJobObservation) DeepCopy() *PigJobObservation

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

func (*PigJobObservation) DeepCopyInto 

func (in *PigJobObservation) DeepCopyInto(out *PigJobObservation)

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

type PigJobParameters 

type PigJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

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

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []PigJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// The HCFS URI of the script that contains the Pig queries.
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// A list of queries.
	// +kubebuilder:validation:Optional
	QueryList []PigJobQueryListParameters `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*PigJobParameters) DeepCopy 

func (in *PigJobParameters) DeepCopy() *PigJobParameters

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

func (*PigJobParameters) DeepCopyInto 

func (in *PigJobParameters) DeepCopyInto(out *PigJobParameters)

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

type PigJobQueryListObservation 

type PigJobQueryListObservation struct {
}

func (*PigJobQueryListObservation) DeepCopy 

func (in *PigJobQueryListObservation) DeepCopy() *PigJobQueryListObservation

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

func (*PigJobQueryListObservation) DeepCopyInto 

func (in *PigJobQueryListObservation) DeepCopyInto(out *PigJobQueryListObservation)

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

type PigJobQueryListParameters 

type PigJobQueryListParameters struct {

	// 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", ] } }
	// +kubebuilder:validation:Required
	Queries []*string `json:"queries" tf:"queries,omitempty"`
}

func (*PigJobQueryListParameters) DeepCopy 

func (in *PigJobQueryListParameters) DeepCopy() *PigJobQueryListParameters

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

func (*PigJobQueryListParameters) DeepCopyInto 

func (in *PigJobQueryListParameters) DeepCopyInto(out *PigJobQueryListParameters)

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

type PlacementObservation 

type PlacementObservation struct {
	ClusterUUID *string `json:"clusterUuid,omitempty" tf:"cluster_uuid,omitempty"`
}

func (*PlacementObservation) DeepCopy 

func (in *PlacementObservation) DeepCopy() *PlacementObservation

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

func (*PlacementObservation) DeepCopyInto 

func (in *PlacementObservation) DeepCopyInto(out *PlacementObservation)

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

type PlacementParameters 

type PlacementParameters struct {

	// The name of the cluster where the job will be submitted
	// +kubebuilder:validation:Required
	ClusterName *string `json:"clusterName" tf:"cluster_name,omitempty"`
}

func (*PlacementParameters) DeepCopy 

func (in *PlacementParameters) DeepCopy() *PlacementParameters

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

func (*PlacementParameters) DeepCopyInto 

func (in *PlacementParameters) DeepCopyInto(out *PlacementParameters)

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

type PreemptibleWorkerConfigDiskConfigObservation 

type PreemptibleWorkerConfigDiskConfigObservation struct {
}

func (*PreemptibleWorkerConfigDiskConfigObservation) DeepCopy 

func (in *PreemptibleWorkerConfigDiskConfigObservation) DeepCopy() *PreemptibleWorkerConfigDiskConfigObservation

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

func (*PreemptibleWorkerConfigDiskConfigObservation) DeepCopyInto 

func (in *PreemptibleWorkerConfigDiskConfigObservation) DeepCopyInto(out *PreemptibleWorkerConfigDiskConfigObservation)

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

type PreemptibleWorkerConfigDiskConfigParameters 

type PreemptibleWorkerConfigDiskConfigParameters struct {

	// Size of the primary disk attached to each preemptible worker node, specified in GB. The smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// The disk type of the primary disk attached to each preemptible worker node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// The amount of local SSD disks that will be attached to each preemptible worker node. Defaults to 0.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*PreemptibleWorkerConfigDiskConfigParameters) DeepCopy 

func (in *PreemptibleWorkerConfigDiskConfigParameters) DeepCopy() *PreemptibleWorkerConfigDiskConfigParameters

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

func (*PreemptibleWorkerConfigDiskConfigParameters) DeepCopyInto 

func (in *PreemptibleWorkerConfigDiskConfigParameters) DeepCopyInto(out *PreemptibleWorkerConfigDiskConfigParameters)

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

type PreemptibleWorkerConfigObservation 

type PreemptibleWorkerConfigObservation struct {
	InstanceNames []*string `json:"instanceNames,omitempty" tf:"instance_names,omitempty"`
}

func (*PreemptibleWorkerConfigObservation) DeepCopy 

func (in *PreemptibleWorkerConfigObservation) DeepCopy() *PreemptibleWorkerConfigObservation

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

func (*PreemptibleWorkerConfigObservation) DeepCopyInto 

func (in *PreemptibleWorkerConfigObservation) DeepCopyInto(out *PreemptibleWorkerConfigObservation)

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

type PreemptibleWorkerConfigParameters 

type PreemptibleWorkerConfigParameters struct {

	// Disk Config
	// +kubebuilder:validation:Optional
	DiskConfig []PreemptibleWorkerConfigDiskConfigParameters `json:"diskConfig,omitempty" tf:"disk_config,omitempty"`

	// Specifies the number of preemptible nodes to create. Defaults to 0.
	// +kubebuilder:validation:Optional
	NumInstances *float64 `json:"numInstances,omitempty" tf:"num_instances,omitempty"`

	// Specifies the preemptibility of the secondary nodes. Defaults to PREEMPTIBLE.
	// +kubebuilder:validation:Optional
	Preemptibility *string `json:"preemptibility,omitempty" tf:"preemptibility,omitempty"`
}

func (*PreemptibleWorkerConfigParameters) DeepCopy 

func (in *PreemptibleWorkerConfigParameters) DeepCopy() *PreemptibleWorkerConfigParameters

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

func (*PreemptibleWorkerConfigParameters) DeepCopyInto 

func (in *PreemptibleWorkerConfigParameters) DeepCopyInto(out *PreemptibleWorkerConfigParameters)

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

type PrestoConfigLoggingConfigObservation 

type PrestoConfigLoggingConfigObservation struct {
}

func (*PrestoConfigLoggingConfigObservation) DeepCopy 

func (in *PrestoConfigLoggingConfigObservation) DeepCopy() *PrestoConfigLoggingConfigObservation

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

func (*PrestoConfigLoggingConfigObservation) DeepCopyInto 

func (in *PrestoConfigLoggingConfigObservation) DeepCopyInto(out *PrestoConfigLoggingConfigObservation)

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

type PrestoConfigLoggingConfigParameters 

type PrestoConfigLoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*PrestoConfigLoggingConfigParameters) DeepCopy 

func (in *PrestoConfigLoggingConfigParameters) DeepCopy() *PrestoConfigLoggingConfigParameters

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

func (*PrestoConfigLoggingConfigParameters) DeepCopyInto 

func (in *PrestoConfigLoggingConfigParameters) DeepCopyInto(out *PrestoConfigLoggingConfigParameters)

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

type PrestoConfigObservation 

type PrestoConfigObservation struct {
}

func (*PrestoConfigObservation) DeepCopy 

func (in *PrestoConfigObservation) DeepCopy() *PrestoConfigObservation

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

func (*PrestoConfigObservation) DeepCopyInto 

func (in *PrestoConfigObservation) DeepCopyInto(out *PrestoConfigObservation)

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

type PrestoConfigParameters 

type PrestoConfigParameters struct {

	// Presto client tags to attach to this query.
	// +kubebuilder:validation:Optional
	ClientTags []*string `json:"clientTags,omitempty" tf:"client_tags,omitempty"`

	// Whether to continue executing queries if a query fails. Setting to true can be useful when executing independent parallel queries. Defaults to false.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []PrestoConfigLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

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

	// A mapping of property names to values. Used to set Presto session properties Equivalent to using the --session flag in the Presto CLI.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// The HCFS URI of the script that contains SQL queries. Conflicts with query_list
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// The list of SQL queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +kubebuilder:validation:Optional
	QueryList []*string `json:"queryList,omitempty" tf:"query_list,omitempty"`
}

func (*PrestoConfigParameters) DeepCopy 

func (in *PrestoConfigParameters) DeepCopy() *PrestoConfigParameters

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

func (*PrestoConfigParameters) DeepCopyInto 

func (in *PrestoConfigParameters) DeepCopyInto(out *PrestoConfigParameters)

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

type PrestoJobLoggingConfigObservation 

type PrestoJobLoggingConfigObservation struct {
}

func (*PrestoJobLoggingConfigObservation) DeepCopy 

func (in *PrestoJobLoggingConfigObservation) DeepCopy() *PrestoJobLoggingConfigObservation

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

func (*PrestoJobLoggingConfigObservation) DeepCopyInto 

func (in *PrestoJobLoggingConfigObservation) DeepCopyInto(out *PrestoJobLoggingConfigObservation)

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

type PrestoJobLoggingConfigParameters 

type PrestoJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*PrestoJobLoggingConfigParameters) DeepCopy 

func (in *PrestoJobLoggingConfigParameters) DeepCopy() *PrestoJobLoggingConfigParameters

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

func (*PrestoJobLoggingConfigParameters) DeepCopyInto 

func (in *PrestoJobLoggingConfigParameters) DeepCopyInto(out *PrestoJobLoggingConfigParameters)

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

type PrestoJobObservation 

type PrestoJobObservation struct {
}

func (*PrestoJobObservation) DeepCopy 

func (in *PrestoJobObservation) DeepCopy() *PrestoJobObservation

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

func (*PrestoJobObservation) DeepCopyInto 

func (in *PrestoJobObservation) DeepCopyInto(out *PrestoJobObservation)

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

type PrestoJobParameters 

type PrestoJobParameters struct {

	// Optional. Presto client tags to attach to this query
	// +kubebuilder:validation:Optional
	ClientTags []*string `json:"clientTags,omitempty" tf:"client_tags,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	ContinueOnFailure *bool `json:"continueOnFailure,omitempty" tf:"continue_on_failure,omitempty"`

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []PrestoJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

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

	// 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
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// The HCFS URI of the script that contains SQL queries.
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// A list of queries.
	// +kubebuilder:validation:Optional
	QueryList []PrestoJobQueryListParameters `json:"queryList,omitempty" tf:"query_list,omitempty"`
}

func (*PrestoJobParameters) DeepCopy 

func (in *PrestoJobParameters) DeepCopy() *PrestoJobParameters

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

func (*PrestoJobParameters) DeepCopyInto 

func (in *PrestoJobParameters) DeepCopyInto(out *PrestoJobParameters)

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

type PrestoJobQueryListObservation 

type PrestoJobQueryListObservation struct {
}

func (*PrestoJobQueryListObservation) DeepCopy 

func (in *PrestoJobQueryListObservation) DeepCopy() *PrestoJobQueryListObservation

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

func (*PrestoJobQueryListObservation) DeepCopyInto 

func (in *PrestoJobQueryListObservation) DeepCopyInto(out *PrestoJobQueryListObservation)

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

type PrestoJobQueryListParameters 

type PrestoJobQueryListParameters struct {

	// 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", ] } }
	// +kubebuilder:validation:Required
	Queries []*string `json:"queries" tf:"queries,omitempty"`
}

func (*PrestoJobQueryListParameters) DeepCopy 

func (in *PrestoJobQueryListParameters) DeepCopy() *PrestoJobQueryListParameters

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

func (*PrestoJobQueryListParameters) DeepCopyInto 

func (in *PrestoJobQueryListParameters) DeepCopyInto(out *PrestoJobQueryListParameters)

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

type PysparkConfigLoggingConfigObservation 

type PysparkConfigLoggingConfigObservation struct {
}

func (*PysparkConfigLoggingConfigObservation) DeepCopy 

func (in *PysparkConfigLoggingConfigObservation) DeepCopy() *PysparkConfigLoggingConfigObservation

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

func (*PysparkConfigLoggingConfigObservation) DeepCopyInto 

func (in *PysparkConfigLoggingConfigObservation) DeepCopyInto(out *PysparkConfigLoggingConfigObservation)

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

type PysparkConfigLoggingConfigParameters 

type PysparkConfigLoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*PysparkConfigLoggingConfigParameters) DeepCopy 

func (in *PysparkConfigLoggingConfigParameters) DeepCopy() *PysparkConfigLoggingConfigParameters

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

func (*PysparkConfigLoggingConfigParameters) DeepCopyInto 

func (in *PysparkConfigLoggingConfigParameters) DeepCopyInto(out *PysparkConfigLoggingConfigParameters)

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

type PysparkConfigObservation 

type PysparkConfigObservation struct {
}

func (*PysparkConfigObservation) DeepCopy 

func (in *PysparkConfigObservation) DeepCopy() *PysparkConfigObservation

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

func (*PysparkConfigObservation) DeepCopyInto 

func (in *PysparkConfigObservation) DeepCopyInto(out *PysparkConfigObservation)

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

type PysparkConfigParameters 

type PysparkConfigParameters struct {

	// Optional. HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// 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
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

	// Optional. HCFS URIs of files to be copied to the working directory of Python drivers and distributed tasks. Useful for naively parallel tasks
	// +kubebuilder:validation:Optional
	FileUris []*string `json:"fileUris,omitempty" tf:"file_uris,omitempty"`

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

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []PysparkConfigLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// Required. The HCFS URI of the main Python file to use as the driver. Must be a .py file
	// +kubebuilder:validation:Required
	MainPythonFileURI *string `json:"mainPythonFileUri" tf:"main_python_file_uri,omitempty"`

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

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

func (*PysparkConfigParameters) DeepCopy 

func (in *PysparkConfigParameters) DeepCopy() *PysparkConfigParameters

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

func (*PysparkConfigParameters) DeepCopyInto 

func (in *PysparkConfigParameters) DeepCopyInto(out *PysparkConfigParameters)

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

type PysparkJobLoggingConfigObservation 

type PysparkJobLoggingConfigObservation struct {
}

func (*PysparkJobLoggingConfigObservation) DeepCopy 

func (in *PysparkJobLoggingConfigObservation) DeepCopy() *PysparkJobLoggingConfigObservation

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

func (*PysparkJobLoggingConfigObservation) DeepCopyInto 

func (in *PysparkJobLoggingConfigObservation) DeepCopyInto(out *PysparkJobLoggingConfigObservation)

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

type PysparkJobLoggingConfigParameters 

type PysparkJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*PysparkJobLoggingConfigParameters) DeepCopy 

func (in *PysparkJobLoggingConfigParameters) DeepCopy() *PysparkJobLoggingConfigParameters

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

func (*PysparkJobLoggingConfigParameters) DeepCopyInto 

func (in *PysparkJobLoggingConfigParameters) DeepCopyInto(out *PysparkJobLoggingConfigParameters)

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

type PysparkJobObservation 

type PysparkJobObservation struct {
}

func (*PysparkJobObservation) DeepCopy 

func (in *PysparkJobObservation) DeepCopy() *PysparkJobObservation

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

func (*PysparkJobObservation) DeepCopyInto 

func (in *PysparkJobObservation) DeepCopyInto(out *PysparkJobObservation)

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

type PysparkJobParameters 

type PysparkJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

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

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

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []PysparkJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// Required. The HCFS URI of the main Python file to use as the driver. Must be a .py file.
	// +kubebuilder:validation:Required
	MainPythonFileURI *string `json:"mainPythonFileUri" tf:"main_python_file_uri,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

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

func (*PysparkJobParameters) DeepCopy 

func (in *PysparkJobParameters) DeepCopy() *PysparkJobParameters

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

func (*PysparkJobParameters) DeepCopyInto 

func (in *PysparkJobParameters) DeepCopyInto(out *PysparkJobParameters)

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

type QueryListObservation 

type QueryListObservation struct {
}

func (*QueryListObservation) DeepCopy 

func (in *QueryListObservation) DeepCopy() *QueryListObservation

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

func (*QueryListObservation) DeepCopyInto 

func (in *QueryListObservation) DeepCopyInto(out *QueryListObservation)

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

type QueryListParameters 

type QueryListParameters struct {

	// 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", ] } }
	// +kubebuilder:validation:Required
	Queries []*string `json:"queries" tf:"queries,omitempty"`
}

func (*QueryListParameters) DeepCopy 

func (in *QueryListParameters) DeepCopy() *QueryListParameters

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

func (*QueryListParameters) DeepCopyInto 

func (in *QueryListParameters) DeepCopyInto(out *QueryListParameters)

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

type ReferenceObservation 

type ReferenceObservation struct {
}

func (*ReferenceObservation) DeepCopy 

func (in *ReferenceObservation) DeepCopy() *ReferenceObservation

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

func (*ReferenceObservation) DeepCopyInto 

func (in *ReferenceObservation) DeepCopyInto(out *ReferenceObservation)

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

type ReferenceParameters 

type ReferenceParameters struct {

	// The job ID, which must be unique within the project. The job ID is generated by the server upon job submission or provided by the user as a means to perform retries without creating duplicate jobs
	// +kubebuilder:validation:Optional
	JobID *string `json:"jobId,omitempty" tf:"job_id,omitempty"`
}

func (*ReferenceParameters) DeepCopy 

func (in *ReferenceParameters) DeepCopy() *ReferenceParameters

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

func (*ReferenceParameters) DeepCopyInto 

func (in *ReferenceParameters) DeepCopyInto(out *ReferenceParameters)

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

type RegexObservation 

type RegexObservation struct {
}

func (*RegexObservation) DeepCopy 

func (in *RegexObservation) DeepCopy() *RegexObservation

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

func (*RegexObservation) DeepCopyInto 

func (in *RegexObservation) DeepCopyInto(out *RegexObservation)

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

type RegexParameters 

type RegexParameters struct {

	// 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).
	// +kubebuilder:validation:Required
	Regexes []*string `json:"regexes" tf:"regexes,omitempty"`
}

func (*RegexParameters) DeepCopy 

func (in *RegexParameters) DeepCopy() *RegexParameters

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

func (*RegexParameters) DeepCopyInto 

func (in *RegexParameters) DeepCopyInto(out *RegexParameters)

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

type ReservationAffinityObservation 

type ReservationAffinityObservation struct {
}

func (*ReservationAffinityObservation) DeepCopy 

func (in *ReservationAffinityObservation) DeepCopy() *ReservationAffinityObservation

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

func (*ReservationAffinityObservation) DeepCopyInto 

func (in *ReservationAffinityObservation) DeepCopyInto(out *ReservationAffinityObservation)

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

type ReservationAffinityParameters 

type ReservationAffinityParameters struct {

	// Optional. Type of reservation to consume Possible values: TYPE_UNSPECIFIED, NO_RESERVATION, ANY_RESERVATION, SPECIFIC_RESERVATION
	// +kubebuilder:validation:Optional
	ConsumeReservationType *string `json:"consumeReservationType,omitempty" tf:"consume_reservation_type,omitempty"`

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

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

func (*ReservationAffinityParameters) DeepCopy 

func (in *ReservationAffinityParameters) DeepCopy() *ReservationAffinityParameters

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

func (*ReservationAffinityParameters) DeepCopyInto 

func (in *ReservationAffinityParameters) DeepCopyInto(out *ReservationAffinityParameters)

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

type SchedulingObservation 

type SchedulingObservation struct {
}

func (*SchedulingObservation) DeepCopy 

func (in *SchedulingObservation) DeepCopy() *SchedulingObservation

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

func (*SchedulingObservation) DeepCopyInto 

func (in *SchedulingObservation) DeepCopyInto(out *SchedulingObservation)

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

type SchedulingParameters 

type SchedulingParameters struct {

	// 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.
	// +kubebuilder:validation:Required
	MaxFailuresPerHour *float64 `json:"maxFailuresPerHour" tf:"max_failures_per_hour,omitempty"`

	// 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.
	// +kubebuilder:validation:Required
	MaxFailuresTotal *float64 `json:"maxFailuresTotal" tf:"max_failures_total,omitempty"`
}

func (*SchedulingParameters) DeepCopy 

func (in *SchedulingParameters) DeepCopy() *SchedulingParameters

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

func (*SchedulingParameters) DeepCopyInto 

func (in *SchedulingParameters) DeepCopyInto(out *SchedulingParameters)

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

type SecondaryWorkerConfigAcceleratorsObservation 

type SecondaryWorkerConfigAcceleratorsObservation struct {
}

func (*SecondaryWorkerConfigAcceleratorsObservation) DeepCopy 

func (in *SecondaryWorkerConfigAcceleratorsObservation) DeepCopy() *SecondaryWorkerConfigAcceleratorsObservation

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

func (*SecondaryWorkerConfigAcceleratorsObservation) DeepCopyInto 

func (in *SecondaryWorkerConfigAcceleratorsObservation) DeepCopyInto(out *SecondaryWorkerConfigAcceleratorsObservation)

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

type SecondaryWorkerConfigAcceleratorsParameters 

type SecondaryWorkerConfigAcceleratorsParameters struct {

	// The number of the accelerator cards of this type exposed to this instance.
	// +kubebuilder:validation:Optional
	AcceleratorCount *float64 `json:"acceleratorCount,omitempty" tf:"accelerator_count,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	AcceleratorType *string `json:"acceleratorType,omitempty" tf:"accelerator_type,omitempty"`
}

func (*SecondaryWorkerConfigAcceleratorsParameters) DeepCopy 

func (in *SecondaryWorkerConfigAcceleratorsParameters) DeepCopy() *SecondaryWorkerConfigAcceleratorsParameters

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

func (*SecondaryWorkerConfigAcceleratorsParameters) DeepCopyInto 

func (in *SecondaryWorkerConfigAcceleratorsParameters) DeepCopyInto(out *SecondaryWorkerConfigAcceleratorsParameters)

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

type SecondaryWorkerConfigDiskConfigObservation 

type SecondaryWorkerConfigDiskConfigObservation struct {
}

func (*SecondaryWorkerConfigDiskConfigObservation) DeepCopy 

func (in *SecondaryWorkerConfigDiskConfigObservation) DeepCopy() *SecondaryWorkerConfigDiskConfigObservation

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

func (*SecondaryWorkerConfigDiskConfigObservation) DeepCopyInto 

func (in *SecondaryWorkerConfigDiskConfigObservation) DeepCopyInto(out *SecondaryWorkerConfigDiskConfigObservation)

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

type SecondaryWorkerConfigDiskConfigParameters 

type SecondaryWorkerConfigDiskConfigParameters struct {

	// Optional. Size in GB of the boot disk (default is 500GB).
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// 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).
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*SecondaryWorkerConfigDiskConfigParameters) DeepCopy 

func (in *SecondaryWorkerConfigDiskConfigParameters) DeepCopy() *SecondaryWorkerConfigDiskConfigParameters

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

func (*SecondaryWorkerConfigDiskConfigParameters) DeepCopyInto 

func (in *SecondaryWorkerConfigDiskConfigParameters) DeepCopyInto(out *SecondaryWorkerConfigDiskConfigParameters)

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

type SecondaryWorkerConfigManagedGroupConfigObservation 

type SecondaryWorkerConfigManagedGroupConfigObservation struct {
	InstanceGroupManagerName *string `json:"instanceGroupManagerName,omitempty" tf:"instance_group_manager_name,omitempty"`

	InstanceTemplateName *string `json:"instanceTemplateName,omitempty" tf:"instance_template_name,omitempty"`
}

func (*SecondaryWorkerConfigManagedGroupConfigObservation) DeepCopy 

func (in *SecondaryWorkerConfigManagedGroupConfigObservation) DeepCopy() *SecondaryWorkerConfigManagedGroupConfigObservation

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

func (*SecondaryWorkerConfigManagedGroupConfigObservation) DeepCopyInto 

func (in *SecondaryWorkerConfigManagedGroupConfigObservation) DeepCopyInto(out *SecondaryWorkerConfigManagedGroupConfigObservation)

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

type SecondaryWorkerConfigManagedGroupConfigParameters 

type SecondaryWorkerConfigManagedGroupConfigParameters struct {
}

func (*SecondaryWorkerConfigManagedGroupConfigParameters) DeepCopy 

func (in *SecondaryWorkerConfigManagedGroupConfigParameters) DeepCopy() *SecondaryWorkerConfigManagedGroupConfigParameters

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

func (*SecondaryWorkerConfigManagedGroupConfigParameters) DeepCopyInto 

func (in *SecondaryWorkerConfigManagedGroupConfigParameters) DeepCopyInto(out *SecondaryWorkerConfigManagedGroupConfigParameters)

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

type SecondaryWorkerConfigObservation 

type SecondaryWorkerConfigObservation struct {
}

func (*SecondaryWorkerConfigObservation) DeepCopy 

func (in *SecondaryWorkerConfigObservation) DeepCopy() *SecondaryWorkerConfigObservation

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

func (*SecondaryWorkerConfigObservation) DeepCopyInto 

func (in *SecondaryWorkerConfigObservation) DeepCopyInto(out *SecondaryWorkerConfigObservation)

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

type SecondaryWorkerConfigParameters 

type SecondaryWorkerConfigParameters struct {

	// 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.
	// Bounds: [minInstances, ). Defaults to 0.
	// +kubebuilder:validation:Optional
	MaxInstances *float64 `json:"maxInstances,omitempty" tf:"max_instances,omitempty"`

	// Minimum number of instances for this group. Bounds: [0, maxInstances]. Defaults to 0.
	// +kubebuilder:validation:Optional
	MinInstances *float64 `json:"minInstances,omitempty" tf:"min_instances,omitempty"`

	// 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 maxInstances 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.
	// +kubebuilder:validation:Optional
	Weight *float64 `json:"weight,omitempty" tf:"weight,omitempty"`
}

func (*SecondaryWorkerConfigParameters) DeepCopy 

func (in *SecondaryWorkerConfigParameters) DeepCopy() *SecondaryWorkerConfigParameters

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

func (*SecondaryWorkerConfigParameters) DeepCopyInto 

func (in *SecondaryWorkerConfigParameters) DeepCopyInto(out *SecondaryWorkerConfigParameters)

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

type SecurityConfigKerberosConfigObservation 

type SecurityConfigKerberosConfigObservation struct {
}

func (*SecurityConfigKerberosConfigObservation) DeepCopy 

func (in *SecurityConfigKerberosConfigObservation) DeepCopy() *SecurityConfigKerberosConfigObservation

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

func (*SecurityConfigKerberosConfigObservation) DeepCopyInto 

func (in *SecurityConfigKerberosConfigObservation) DeepCopyInto(out *SecurityConfigKerberosConfigObservation)

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

type SecurityConfigKerberosConfigParameters 

type SecurityConfigKerberosConfigParameters struct {

	// Optional. The admin server (IP or hostname) for the remote trusted realm in a cross realm trust relationship.
	// +kubebuilder:validation:Optional
	CrossRealmTrustAdminServer *string `json:"crossRealmTrustAdminServer,omitempty" tf:"cross_realm_trust_admin_server,omitempty"`

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

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

	// 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.
	// +kubebuilder:validation:Optional
	CrossRealmTrustSharedPassword *string `json:"crossRealmTrustSharedPassword,omitempty" tf:"cross_realm_trust_shared_password,omitempty"`

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

	// Optional. The uri of the KMS key used to encrypt various sensitive files.
	// +kubebuilder:validation:Optional
	KMSKey *string `json:"kmsKey,omitempty" tf:"kms_key,omitempty"`

	// Optional. The Cloud Storage URI of a KMS encrypted file containing the master key of the KDC database.
	// +kubebuilder:validation:Optional
	KdcDBKey *string `json:"kdcDbKey,omitempty" tf:"kdc_db_key,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	KeyPassword *string `json:"keyPassword,omitempty" tf:"key_password,omitempty"`

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

	// 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.
	// +kubebuilder:validation:Optional
	KeystorePassword *string `json:"keystorePassword,omitempty" tf:"keystore_password,omitempty"`

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

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

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

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

	// 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.
	// +kubebuilder:validation:Optional
	TruststorePassword *string `json:"truststorePassword,omitempty" tf:"truststore_password,omitempty"`
}

func (*SecurityConfigKerberosConfigParameters) DeepCopy 

func (in *SecurityConfigKerberosConfigParameters) DeepCopy() *SecurityConfigKerberosConfigParameters

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

func (*SecurityConfigKerberosConfigParameters) DeepCopyInto 

func (in *SecurityConfigKerberosConfigParameters) DeepCopyInto(out *SecurityConfigKerberosConfigParameters)

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

type SecurityConfigObservation 

type SecurityConfigObservation struct {
}

func (*SecurityConfigObservation) DeepCopy 

func (in *SecurityConfigObservation) DeepCopy() *SecurityConfigObservation

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

func (*SecurityConfigObservation) DeepCopyInto 

func (in *SecurityConfigObservation) DeepCopyInto(out *SecurityConfigObservation)

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

type SecurityConfigParameters 

type SecurityConfigParameters struct {

	// Kerberos related configuration
	// +kubebuilder:validation:Required
	KerberosConfig []KerberosConfigParameters `json:"kerberosConfig" tf:"kerberos_config,omitempty"`
}

func (*SecurityConfigParameters) DeepCopy 

func (in *SecurityConfigParameters) DeepCopy() *SecurityConfigParameters

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

func (*SecurityConfigParameters) DeepCopyInto 

func (in *SecurityConfigParameters) DeepCopyInto(out *SecurityConfigParameters)

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

type ShieldedInstanceConfigObservation 

type ShieldedInstanceConfigObservation struct {
}

func (*ShieldedInstanceConfigObservation) DeepCopy 

func (in *ShieldedInstanceConfigObservation) DeepCopy() *ShieldedInstanceConfigObservation

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

func (*ShieldedInstanceConfigObservation) DeepCopyInto 

func (in *ShieldedInstanceConfigObservation) DeepCopyInto(out *ShieldedInstanceConfigObservation)

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

type ShieldedInstanceConfigParameters 

type ShieldedInstanceConfigParameters struct {

	// Defines whether instances have integrity monitoring enabled.
	// +kubebuilder:validation:Optional
	EnableIntegrityMonitoring *bool `json:"enableIntegrityMonitoring,omitempty" tf:"enable_integrity_monitoring,omitempty"`

	// Defines whether instances have Secure Boot enabled.
	// +kubebuilder:validation:Optional
	EnableSecureBoot *bool `json:"enableSecureBoot,omitempty" tf:"enable_secure_boot,omitempty"`

	// Defines whether instances have the vTPM enabled.
	// +kubebuilder:validation:Optional
	EnableVtpm *bool `json:"enableVtpm,omitempty" tf:"enable_vtpm,omitempty"`
}

func (*ShieldedInstanceConfigParameters) DeepCopy 

func (in *ShieldedInstanceConfigParameters) DeepCopy() *ShieldedInstanceConfigParameters

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

func (*ShieldedInstanceConfigParameters) DeepCopyInto 

func (in *ShieldedInstanceConfigParameters) DeepCopyInto(out *ShieldedInstanceConfigParameters)

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

type SoftwareConfigObservation 

type SoftwareConfigObservation struct {
	Properties map[string]string `json:"properties,omitempty" tf:"properties,omitempty"`
}

func (*SoftwareConfigObservation) DeepCopy 

func (in *SoftwareConfigObservation) DeepCopy() *SoftwareConfigObservation

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

func (*SoftwareConfigObservation) DeepCopyInto 

func (in *SoftwareConfigObservation) DeepCopyInto(out *SoftwareConfigObservation)

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

type SoftwareConfigParameters 

type SoftwareConfigParameters struct {

	// The Cloud Dataproc image version to use for the cluster - this controls the sets of software versions installed onto the nodes when you create clusters. If not specified, defaults to the latest version.
	// +kubebuilder:validation:Optional
	ImageVersion *string `json:"imageVersion,omitempty" tf:"image_version,omitempty"`

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

	// A list of override and additional properties (key/value pairs) used to modify various aspects of the common configuration files used when creating a cluster.
	// +kubebuilder:validation:Optional
	OverrideProperties map[string]*string `json:"overrideProperties,omitempty" tf:"override_properties,omitempty"`
}

func (*SoftwareConfigParameters) DeepCopy 

func (in *SoftwareConfigParameters) DeepCopy() *SoftwareConfigParameters

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

func (*SoftwareConfigParameters) DeepCopyInto 

func (in *SoftwareConfigParameters) DeepCopyInto(out *SoftwareConfigParameters)

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

type SparkConfigLoggingConfigObservation 

type SparkConfigLoggingConfigObservation struct {
}

func (*SparkConfigLoggingConfigObservation) DeepCopy 

func (in *SparkConfigLoggingConfigObservation) DeepCopy() *SparkConfigLoggingConfigObservation

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

func (*SparkConfigLoggingConfigObservation) DeepCopyInto 

func (in *SparkConfigLoggingConfigObservation) DeepCopyInto(out *SparkConfigLoggingConfigObservation)

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

type SparkConfigLoggingConfigParameters 

type SparkConfigLoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*SparkConfigLoggingConfigParameters) DeepCopy 

func (in *SparkConfigLoggingConfigParameters) DeepCopy() *SparkConfigLoggingConfigParameters

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

func (*SparkConfigLoggingConfigParameters) DeepCopyInto 

func (in *SparkConfigLoggingConfigParameters) DeepCopyInto(out *SparkConfigLoggingConfigParameters)

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

type SparkConfigObservation 

type SparkConfigObservation struct {
}

func (*SparkConfigObservation) DeepCopy 

func (in *SparkConfigObservation) DeepCopy() *SparkConfigObservation

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

func (*SparkConfigObservation) DeepCopyInto 

func (in *SparkConfigObservation) DeepCopyInto(out *SparkConfigObservation)

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

type SparkConfigParameters 

type SparkConfigParameters struct {

	// HCFS URIs of archives to be extracted in the working directory of .jar, .tar, .tar.gz, .tgz, and .zip.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// The arguments to pass to the driver.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

	// HCFS URIs of files to be copied to the working directory of Spark drivers and distributed tasks. Useful for naively parallel tasks.
	// +kubebuilder:validation:Optional
	FileUris []*string `json:"fileUris,omitempty" tf:"file_uris,omitempty"`

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

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []SparkConfigLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// The class containing the main method of the driver. Must be in a provided jar or jar that is already on the classpath. Conflicts with main_jar_file_uri
	// +kubebuilder:validation:Optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class,omitempty"`

	// The HCFS URI of jar file containing the driver jar. Conflicts with main_class
	// +kubebuilder:validation:Optional
	MainJarFileURI *string `json:"mainJarFileUri,omitempty" tf:"main_jar_file_uri,omitempty"`

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

func (*SparkConfigParameters) DeepCopy 

func (in *SparkConfigParameters) DeepCopy() *SparkConfigParameters

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

func (*SparkConfigParameters) DeepCopyInto 

func (in *SparkConfigParameters) DeepCopyInto(out *SparkConfigParameters)

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

type SparkJobLoggingConfigObservation 

type SparkJobLoggingConfigObservation struct {
}

func (*SparkJobLoggingConfigObservation) DeepCopy 

func (in *SparkJobLoggingConfigObservation) DeepCopy() *SparkJobLoggingConfigObservation

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

func (*SparkJobLoggingConfigObservation) DeepCopyInto 

func (in *SparkJobLoggingConfigObservation) DeepCopyInto(out *SparkJobLoggingConfigObservation)

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

type SparkJobLoggingConfigParameters 

type SparkJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*SparkJobLoggingConfigParameters) DeepCopy 

func (in *SparkJobLoggingConfigParameters) DeepCopy() *SparkJobLoggingConfigParameters

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

func (*SparkJobLoggingConfigParameters) DeepCopyInto 

func (in *SparkJobLoggingConfigParameters) DeepCopyInto(out *SparkJobLoggingConfigParameters)

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

type SparkJobObservation 

type SparkJobObservation struct {
}

func (*SparkJobObservation) DeepCopy 

func (in *SparkJobObservation) DeepCopy() *SparkJobObservation

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

func (*SparkJobObservation) DeepCopyInto 

func (in *SparkJobObservation) DeepCopyInto(out *SparkJobObservation)

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

type SparkJobParameters 

type SparkJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

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

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

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []SparkJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// 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`.
	// +kubebuilder:validation:Optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class,omitempty"`

	// The HCFS URI of the jar file that contains the main class.
	// +kubebuilder:validation:Optional
	MainJarFileURI *string `json:"mainJarFileUri,omitempty" tf:"main_jar_file_uri,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`
}

func (*SparkJobParameters) DeepCopy 

func (in *SparkJobParameters) DeepCopy() *SparkJobParameters

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

func (*SparkJobParameters) DeepCopyInto 

func (in *SparkJobParameters) DeepCopyInto(out *SparkJobParameters)

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

type SparkRJobLoggingConfigObservation 

type SparkRJobLoggingConfigObservation struct {
}

func (*SparkRJobLoggingConfigObservation) DeepCopy 

func (in *SparkRJobLoggingConfigObservation) DeepCopy() *SparkRJobLoggingConfigObservation

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

func (*SparkRJobLoggingConfigObservation) DeepCopyInto 

func (in *SparkRJobLoggingConfigObservation) DeepCopyInto(out *SparkRJobLoggingConfigObservation)

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

type SparkRJobLoggingConfigParameters 

type SparkRJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*SparkRJobLoggingConfigParameters) DeepCopy 

func (in *SparkRJobLoggingConfigParameters) DeepCopy() *SparkRJobLoggingConfigParameters

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

func (*SparkRJobLoggingConfigParameters) DeepCopyInto 

func (in *SparkRJobLoggingConfigParameters) DeepCopyInto(out *SparkRJobLoggingConfigParameters)

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

type SparkRJobObservation 

type SparkRJobObservation struct {
}

func (*SparkRJobObservation) DeepCopy 

func (in *SparkRJobObservation) DeepCopy() *SparkRJobObservation

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

func (*SparkRJobObservation) DeepCopyInto 

func (in *SparkRJobObservation) DeepCopyInto(out *SparkRJobObservation)

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

type SparkRJobParameters 

type SparkRJobParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	ArchiveUris []*string `json:"archiveUris,omitempty" tf:"archive_uris,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Args []*string `json:"args,omitempty" tf:"args,omitempty"`

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

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []SparkRJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// Required. The HCFS URI of the main R file to use as the driver. Must be a .R file.
	// +kubebuilder:validation:Required
	MainRFileURI *string `json:"mainRFileUri" tf:"main_r_file_uri,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`
}

func (*SparkRJobParameters) DeepCopy 

func (in *SparkRJobParameters) DeepCopy() *SparkRJobParameters

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

func (*SparkRJobParameters) DeepCopyInto 

func (in *SparkRJobParameters) DeepCopyInto(out *SparkRJobParameters)

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

type SparkSQLJobLoggingConfigObservation 

type SparkSQLJobLoggingConfigObservation struct {
}

func (*SparkSQLJobLoggingConfigObservation) DeepCopy 

func (in *SparkSQLJobLoggingConfigObservation) DeepCopy() *SparkSQLJobLoggingConfigObservation

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

func (*SparkSQLJobLoggingConfigObservation) DeepCopyInto 

func (in *SparkSQLJobLoggingConfigObservation) DeepCopyInto(out *SparkSQLJobLoggingConfigObservation)

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

type SparkSQLJobLoggingConfigParameters 

type SparkSQLJobLoggingConfigParameters struct {

	// 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'
	// +kubebuilder:validation:Optional
	DriverLogLevels map[string]*string `json:"driverLogLevels,omitempty" tf:"driver_log_levels,omitempty"`
}

func (*SparkSQLJobLoggingConfigParameters) DeepCopy 

func (in *SparkSQLJobLoggingConfigParameters) DeepCopy() *SparkSQLJobLoggingConfigParameters

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

func (*SparkSQLJobLoggingConfigParameters) DeepCopyInto 

func (in *SparkSQLJobLoggingConfigParameters) DeepCopyInto(out *SparkSQLJobLoggingConfigParameters)

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

type SparkSQLJobObservation 

type SparkSQLJobObservation struct {
}

func (*SparkSQLJobObservation) DeepCopy 

func (in *SparkSQLJobObservation) DeepCopy() *SparkSQLJobObservation

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

func (*SparkSQLJobObservation) DeepCopyInto 

func (in *SparkSQLJobObservation) DeepCopyInto(out *SparkSQLJobObservation)

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

type SparkSQLJobParameters 

type SparkSQLJobParameters struct {

	// Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.
	// +kubebuilder:validation:Optional
	JarFileUris []*string `json:"jarFileUris,omitempty" tf:"jar_file_uris,omitempty"`

	// Optional. The runtime log config for job execution.
	// +kubebuilder:validation:Optional
	LoggingConfig []SparkSQLJobLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	Properties map[string]*string `json:"properties,omitempty" tf:"properties,omitempty"`

	// The HCFS URI of the script that contains SQL queries.
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// A list of queries.
	// +kubebuilder:validation:Optional
	QueryList []SparkSQLJobQueryListParameters `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*SparkSQLJobParameters) DeepCopy 

func (in *SparkSQLJobParameters) DeepCopy() *SparkSQLJobParameters

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

func (*SparkSQLJobParameters) DeepCopyInto 

func (in *SparkSQLJobParameters) DeepCopyInto(out *SparkSQLJobParameters)

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

type SparkSQLJobQueryListObservation 

type SparkSQLJobQueryListObservation struct {
}

func (*SparkSQLJobQueryListObservation) DeepCopy 

func (in *SparkSQLJobQueryListObservation) DeepCopy() *SparkSQLJobQueryListObservation

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

func (*SparkSQLJobQueryListObservation) DeepCopyInto 

func (in *SparkSQLJobQueryListObservation) DeepCopyInto(out *SparkSQLJobQueryListObservation)

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

type SparkSQLJobQueryListParameters 

type SparkSQLJobQueryListParameters struct {

	// 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", ] } }
	// +kubebuilder:validation:Required
	Queries []*string `json:"queries" tf:"queries,omitempty"`
}

func (*SparkSQLJobQueryListParameters) DeepCopy 

func (in *SparkSQLJobQueryListParameters) DeepCopy() *SparkSQLJobQueryListParameters

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

func (*SparkSQLJobQueryListParameters) DeepCopyInto 

func (in *SparkSQLJobQueryListParameters) DeepCopyInto(out *SparkSQLJobQueryListParameters)

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

type SparksqlConfigLoggingConfigObservation 

type SparksqlConfigLoggingConfigObservation struct {
}

func (*SparksqlConfigLoggingConfigObservation) DeepCopy 

func (in *SparksqlConfigLoggingConfigObservation) DeepCopy() *SparksqlConfigLoggingConfigObservation

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

func (*SparksqlConfigLoggingConfigObservation) DeepCopyInto 

func (in *SparksqlConfigLoggingConfigObservation) DeepCopyInto(out *SparksqlConfigLoggingConfigObservation)

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

type SparksqlConfigLoggingConfigParameters 

type SparksqlConfigLoggingConfigParameters struct {

	// Optional. 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'.
	// +kubebuilder:validation:Required
	DriverLogLevels map[string]*string `json:"driverLogLevels" tf:"driver_log_levels,omitempty"`
}

func (*SparksqlConfigLoggingConfigParameters) DeepCopy 

func (in *SparksqlConfigLoggingConfigParameters) DeepCopy() *SparksqlConfigLoggingConfigParameters

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

func (*SparksqlConfigLoggingConfigParameters) DeepCopyInto 

func (in *SparksqlConfigLoggingConfigParameters) DeepCopyInto(out *SparksqlConfigLoggingConfigParameters)

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

type SparksqlConfigObservation 

type SparksqlConfigObservation struct {
}

func (*SparksqlConfigObservation) DeepCopy 

func (in *SparksqlConfigObservation) DeepCopy() *SparksqlConfigObservation

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

func (*SparksqlConfigObservation) DeepCopyInto 

func (in *SparksqlConfigObservation) DeepCopyInto(out *SparksqlConfigObservation)

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

type SparksqlConfigParameters 

type SparksqlConfigParameters struct {

	// HCFS URIs of jar files to be added to the Spark CLASSPATH.
	// +kubebuilder:validation:Optional
	JarFileUris []*string `json:"jarFileUris,omitempty" tf:"jar_file_uris,omitempty"`

	// The runtime logging config of the job
	// +kubebuilder:validation:Optional
	LoggingConfig []SparksqlConfigLoggingConfigParameters `json:"loggingConfig,omitempty" tf:"logging_config,omitempty"`

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

	// The HCFS URI of the script that contains SQL queries. Conflicts with query_list
	// +kubebuilder:validation:Optional
	QueryFileURI *string `json:"queryFileUri,omitempty" tf:"query_file_uri,omitempty"`

	// The list of SQL queries or statements to execute as part of the job. Conflicts with query_file_uri
	// +kubebuilder:validation:Optional
	QueryList []*string `json:"queryList,omitempty" tf:"query_list,omitempty"`

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

func (*SparksqlConfigParameters) DeepCopy 

func (in *SparksqlConfigParameters) DeepCopy() *SparksqlConfigParameters

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

func (*SparksqlConfigParameters) DeepCopyInto 

func (in *SparksqlConfigParameters) DeepCopyInto(out *SparksqlConfigParameters)

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

type StatusObservation 

type StatusObservation struct {
	Details *string `json:"details,omitempty" tf:"details,omitempty"`

	State *string `json:"state,omitempty" tf:"state,omitempty"`

	StateStartTime *string `json:"stateStartTime,omitempty" tf:"state_start_time,omitempty"`

	Substate *string `json:"substate,omitempty" tf:"substate,omitempty"`
}

func (*StatusObservation) DeepCopy 

func (in *StatusObservation) DeepCopy() *StatusObservation

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

func (*StatusObservation) DeepCopyInto 

func (in *StatusObservation) DeepCopyInto(out *StatusObservation)

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

type StatusParameters 

type StatusParameters struct {
}

func (*StatusParameters) DeepCopy 

func (in *StatusParameters) DeepCopy() *StatusParameters

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

func (*StatusParameters) DeepCopyInto 

func (in *StatusParameters) DeepCopyInto(out *StatusParameters)

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

type ValidationObservation 

type ValidationObservation struct {
}

func (*ValidationObservation) DeepCopy 

func (in *ValidationObservation) DeepCopy() *ValidationObservation

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

func (*ValidationObservation) DeepCopyInto 

func (in *ValidationObservation) DeepCopyInto(out *ValidationObservation)

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

type ValidationParameters 

type ValidationParameters struct {

	// Validation based on regular expressions.
	// +kubebuilder:validation:Optional
	Regex []RegexParameters `json:"regex,omitempty" tf:"regex,omitempty"`

	// Validation based on a list of allowed values.
	// +kubebuilder:validation:Optional
	Values []ValuesParameters `json:"values,omitempty" tf:"values,omitempty"`
}

func (*ValidationParameters) DeepCopy 

func (in *ValidationParameters) DeepCopy() *ValidationParameters

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

func (*ValidationParameters) DeepCopyInto 

func (in *ValidationParameters) DeepCopyInto(out *ValidationParameters)

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

type ValuesObservation 

type ValuesObservation struct {
}

func (*ValuesObservation) DeepCopy 

func (in *ValuesObservation) DeepCopy() *ValuesObservation

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

func (*ValuesObservation) DeepCopyInto 

func (in *ValuesObservation) DeepCopyInto(out *ValuesObservation)

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

type ValuesParameters 

type ValuesParameters struct {

	// Required. List of allowed values for the parameter.
	// +kubebuilder:validation:Required
	Values []*string `json:"values" tf:"values,omitempty"`
}

func (*ValuesParameters) DeepCopy 

func (in *ValuesParameters) DeepCopy() *ValuesParameters

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

func (*ValuesParameters) DeepCopyInto 

func (in *ValuesParameters) DeepCopyInto(out *ValuesParameters)

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

type WorkerConfigAcceleratorsObservation 

type WorkerConfigAcceleratorsObservation struct {
}

func (*WorkerConfigAcceleratorsObservation) DeepCopy 

func (in *WorkerConfigAcceleratorsObservation) DeepCopy() *WorkerConfigAcceleratorsObservation

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

func (*WorkerConfigAcceleratorsObservation) DeepCopyInto 

func (in *WorkerConfigAcceleratorsObservation) DeepCopyInto(out *WorkerConfigAcceleratorsObservation)

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

type WorkerConfigAcceleratorsParameters 

type WorkerConfigAcceleratorsParameters struct {

	// The number of the accelerator cards of this type exposed to this instance. Often restricted to one of 1, 2, 4, or 8.
	// +kubebuilder:validation:Required
	AcceleratorCount *float64 `json:"acceleratorCount" tf:"accelerator_count,omitempty"`

	// The short name of the accelerator type to expose to this instance. For example, nvidia-tesla-k80.
	// +kubebuilder:validation:Required
	AcceleratorType *string `json:"acceleratorType" tf:"accelerator_type,omitempty"`
}

func (*WorkerConfigAcceleratorsParameters) DeepCopy 

func (in *WorkerConfigAcceleratorsParameters) DeepCopy() *WorkerConfigAcceleratorsParameters

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

func (*WorkerConfigAcceleratorsParameters) DeepCopyInto 

func (in *WorkerConfigAcceleratorsParameters) DeepCopyInto(out *WorkerConfigAcceleratorsParameters)

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

type WorkerConfigDiskConfigObservation 

type WorkerConfigDiskConfigObservation struct {
}

func (*WorkerConfigDiskConfigObservation) DeepCopy 

func (in *WorkerConfigDiskConfigObservation) DeepCopy() *WorkerConfigDiskConfigObservation

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

func (*WorkerConfigDiskConfigObservation) DeepCopyInto 

func (in *WorkerConfigDiskConfigObservation) DeepCopyInto(out *WorkerConfigDiskConfigObservation)

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

type WorkerConfigDiskConfigParameters 

type WorkerConfigDiskConfigParameters struct {

	// Size of the primary disk attached to each node, specified in GB. The primary disk contains the boot volume and system libraries, and the smallest allowed disk size is 10GB. GCP will default to a predetermined computed value if not set (currently 500GB). Note: If SSDs are not attached, it also contains the HDFS data blocks and Hadoop working directories.
	// +kubebuilder:validation:Optional
	BootDiskSizeGb *float64 `json:"bootDiskSizeGb,omitempty" tf:"boot_disk_size_gb,omitempty"`

	// The disk type of the primary disk attached to each node. One of "pd-ssd" or "pd-standard". Defaults to "pd-standard".
	// +kubebuilder:validation:Optional
	BootDiskType *string `json:"bootDiskType,omitempty" tf:"boot_disk_type,omitempty"`

	// The amount of local SSD disks that will be attached to each master cluster node. Defaults to 0.
	// +kubebuilder:validation:Optional
	NumLocalSsds *float64 `json:"numLocalSsds,omitempty" tf:"num_local_ssds,omitempty"`
}

func (*WorkerConfigDiskConfigParameters) DeepCopy 

func (in *WorkerConfigDiskConfigParameters) DeepCopy() *WorkerConfigDiskConfigParameters

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

func (*WorkerConfigDiskConfigParameters) DeepCopyInto 

func (in *WorkerConfigDiskConfigParameters) DeepCopyInto(out *WorkerConfigDiskConfigParameters)

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

type WorkerConfigManagedGroupConfigObservation 

type WorkerConfigManagedGroupConfigObservation struct {
	InstanceGroupManagerName *string `json:"instanceGroupManagerName,omitempty" tf:"instance_group_manager_name,omitempty"`

	InstanceTemplateName *string `json:"instanceTemplateName,omitempty" tf:"instance_template_name,omitempty"`
}

func (*WorkerConfigManagedGroupConfigObservation) DeepCopy 

func (in *WorkerConfigManagedGroupConfigObservation) DeepCopy() *WorkerConfigManagedGroupConfigObservation

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

func (*WorkerConfigManagedGroupConfigObservation) DeepCopyInto 

func (in *WorkerConfigManagedGroupConfigObservation) DeepCopyInto(out *WorkerConfigManagedGroupConfigObservation)

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

type WorkerConfigManagedGroupConfigParameters 

type WorkerConfigManagedGroupConfigParameters struct {
}

func (*WorkerConfigManagedGroupConfigParameters) DeepCopy 

func (in *WorkerConfigManagedGroupConfigParameters) DeepCopy() *WorkerConfigManagedGroupConfigParameters

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

func (*WorkerConfigManagedGroupConfigParameters) DeepCopyInto 

func (in *WorkerConfigManagedGroupConfigParameters) DeepCopyInto(out *WorkerConfigManagedGroupConfigParameters)

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

type WorkerConfigObservation 

type WorkerConfigObservation struct {
}

func (*WorkerConfigObservation) DeepCopy 

func (in *WorkerConfigObservation) DeepCopy() *WorkerConfigObservation

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

func (*WorkerConfigObservation) DeepCopyInto 

func (in *WorkerConfigObservation) DeepCopyInto(out *WorkerConfigObservation)

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

type WorkerConfigParameters 

type WorkerConfigParameters struct {

	// Maximum number of instances for this group.
	// +kubebuilder:validation:Required
	MaxInstances *float64 `json:"maxInstances" tf:"max_instances,omitempty"`

	// Minimum number of instances for this group. Bounds: [2, maxInstances]. Defaults to 2.
	// +kubebuilder:validation:Optional
	MinInstances *float64 `json:"minInstances,omitempty" tf:"min_instances,omitempty"`

	// 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 maxInstances 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.
	// +kubebuilder:validation:Optional
	Weight *float64 `json:"weight,omitempty" tf:"weight,omitempty"`
}

func (*WorkerConfigParameters) DeepCopy 

func (in *WorkerConfigParameters) DeepCopy() *WorkerConfigParameters

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

func (*WorkerConfigParameters) DeepCopyInto 

func (in *WorkerConfigParameters) DeepCopyInto(out *WorkerConfigParameters)

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

type WorkflowTemplate 

type WorkflowTemplate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              WorkflowTemplateSpec   `json:"spec"`
	Status            WorkflowTemplateStatus `json:"status,omitempty"`
}

WorkflowTemplate is the Schema for the WorkflowTemplates API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcpjet}

func (*WorkflowTemplate) DeepCopy 

func (in *WorkflowTemplate) DeepCopy() *WorkflowTemplate

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

func (*WorkflowTemplate) DeepCopyInto 

func (in *WorkflowTemplate) DeepCopyInto(out *WorkflowTemplate)

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

func (*WorkflowTemplate) DeepCopyObject 

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

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

func (*WorkflowTemplate) GetCondition 

func (mg *WorkflowTemplate) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this WorkflowTemplate.

func (*WorkflowTemplate) GetConnectionDetailsMapping 

func (tr *WorkflowTemplate) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this WorkflowTemplate

func (*WorkflowTemplate) GetDeletionPolicy 

func (mg *WorkflowTemplate) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this WorkflowTemplate.

func (*WorkflowTemplate) GetID 

func (tr *WorkflowTemplate) GetID() string

GetID returns ID of underlying Terraform resource of this WorkflowTemplate

func (*WorkflowTemplate) GetObservation 

func (tr *WorkflowTemplate) GetObservation() (map[string]interface{}, error)

GetObservation of this WorkflowTemplate

func (*WorkflowTemplate) GetParameters 

func (tr *WorkflowTemplate) GetParameters() (map[string]interface{}, error)

GetParameters of this WorkflowTemplate

func (*WorkflowTemplate) GetProviderConfigReference 

func (mg *WorkflowTemplate) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this WorkflowTemplate.

func (*WorkflowTemplate) GetProviderReference 

func (mg *WorkflowTemplate) GetProviderReference() *xpv1.Reference

GetProviderReference of this WorkflowTemplate. Deprecated: Use GetProviderConfigReference.

func (*WorkflowTemplate) GetPublishConnectionDetailsTo 

func (mg *WorkflowTemplate) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this WorkflowTemplate.

func (*WorkflowTemplate) GetTerraformResourceType 

func (mg *WorkflowTemplate) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this WorkflowTemplate

func (*WorkflowTemplate) GetTerraformSchemaVersion 

func (tr *WorkflowTemplate) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*WorkflowTemplate) GetWriteConnectionSecretToReference 

func (mg *WorkflowTemplate) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this WorkflowTemplate.

func (*WorkflowTemplate) LateInitialize 

func (tr *WorkflowTemplate) LateInitialize(attrs []byte) (bool, error)

LateInitialize this WorkflowTemplate using its observed tfState. returns True if there are any spec changes for the resource.

func (*WorkflowTemplate) SetConditions 

func (mg *WorkflowTemplate) SetConditions(c ...xpv1.Condition)

SetConditions of this WorkflowTemplate.

func (*WorkflowTemplate) SetDeletionPolicy 

func (mg *WorkflowTemplate) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this WorkflowTemplate.

func (*WorkflowTemplate) SetObservation 

func (tr *WorkflowTemplate) SetObservation(obs map[string]interface{}) error

SetObservation for this WorkflowTemplate

func (*WorkflowTemplate) SetParameters 

func (tr *WorkflowTemplate) SetParameters(params map[string]interface{}) error

SetParameters for this WorkflowTemplate

func (*WorkflowTemplate) SetProviderConfigReference 

func (mg *WorkflowTemplate) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this WorkflowTemplate.

func (*WorkflowTemplate) SetProviderReference 

func (mg *WorkflowTemplate) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this WorkflowTemplate. Deprecated: Use SetProviderConfigReference.

func (*WorkflowTemplate) SetPublishConnectionDetailsTo 

func (mg *WorkflowTemplate) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this WorkflowTemplate.

func (*WorkflowTemplate) SetWriteConnectionSecretToReference 

func (mg *WorkflowTemplate) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this WorkflowTemplate.

type WorkflowTemplateList 

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

WorkflowTemplateList contains a list of WorkflowTemplates

func (*WorkflowTemplateList) DeepCopy 

func (in *WorkflowTemplateList) DeepCopy() *WorkflowTemplateList

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

func (*WorkflowTemplateList) DeepCopyInto 

func (in *WorkflowTemplateList) DeepCopyInto(out *WorkflowTemplateList)

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

func (*WorkflowTemplateList) DeepCopyObject 

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

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

func (*WorkflowTemplateList) GetItems 

func (l *WorkflowTemplateList) GetItems() []resource.Managed

GetItems of this WorkflowTemplateList.

type WorkflowTemplateObservation 

type WorkflowTemplateObservation struct {
	CreateTime *string `json:"createTime,omitempty" tf:"create_time,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	UpdateTime *string `json:"updateTime,omitempty" tf:"update_time,omitempty"`
}

func (*WorkflowTemplateObservation) DeepCopy 

func (in *WorkflowTemplateObservation) DeepCopy() *WorkflowTemplateObservation

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

func (*WorkflowTemplateObservation) DeepCopyInto 

func (in *WorkflowTemplateObservation) DeepCopyInto(out *WorkflowTemplateObservation)

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

type WorkflowTemplateParameters 

type WorkflowTemplateParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	DagTimeout *string `json:"dagTimeout,omitempty" tf:"dag_timeout,omitempty"`

	// Required. The Directed Acyclic Graph of Jobs to submit.
	// +kubebuilder:validation:Required
	Jobs []JobsParameters `json:"jobs" tf:"jobs,omitempty"`

	// Optional. The labels to associate with this template. These labels will be propagated to all jobs and clusters created by the workflow instance. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a template.
	// +kubebuilder:validation:Optional
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// The location for the resource
	// +kubebuilder:validation:Required
	Location *string `json:"location" tf:"location,omitempty"`

	// Output only. The resource name of the workflow template, as described in https://cloud.google.com/apis/design/resource_names. * For `projects.regions.workflowTemplates`, the resource name of the template has the following format: `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}` * For `projects.locations.workflowTemplates`, the resource name of the template has the following format: `projects/{project_id}/locations/{location}/workflowTemplates/{template_id}`
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Optional. Template parameters whose values are substituted into the template. Values for parameters must be provided when the template is instantiated.
	// +kubebuilder:validation:Optional
	Parameters []ParametersParameters `json:"parameters,omitempty" tf:"parameters,omitempty"`

	// Required. WorkflowTemplate scheduling information.
	// +kubebuilder:validation:Required
	Placement []WorkflowTemplatePlacementParameters `json:"placement" tf:"placement,omitempty"`

	// The project for the resource
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// Output only. The current version of this workflow template.
	// +kubebuilder:validation:Optional
	Version *float64 `json:"version,omitempty" tf:"version,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 WorkflowTemplatePlacementObservation 

type WorkflowTemplatePlacementObservation struct {
}

func (*WorkflowTemplatePlacementObservation) DeepCopy 

func (in *WorkflowTemplatePlacementObservation) DeepCopy() *WorkflowTemplatePlacementObservation

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

func (*WorkflowTemplatePlacementObservation) DeepCopyInto 

func (in *WorkflowTemplatePlacementObservation) DeepCopyInto(out *WorkflowTemplatePlacementObservation)

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

type WorkflowTemplatePlacementParameters 

type WorkflowTemplatePlacementParameters struct {

	// Optional. A selector that chooses target cluster for jobs based on metadata. The selector is evaluated at the time each job is submitted.
	// +kubebuilder:validation:Optional
	ClusterSelector []ClusterSelectorParameters `json:"clusterSelector,omitempty" tf:"cluster_selector,omitempty"`

	// A cluster that is managed by the workflow.
	// +kubebuilder:validation:Optional
	ManagedCluster []ManagedClusterParameters `json:"managedCluster,omitempty" tf:"managed_cluster,omitempty"`
}

func (*WorkflowTemplatePlacementParameters) DeepCopy 

func (in *WorkflowTemplatePlacementParameters) DeepCopy() *WorkflowTemplatePlacementParameters

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

func (*WorkflowTemplatePlacementParameters) DeepCopyInto 

func (in *WorkflowTemplatePlacementParameters) DeepCopyInto(out *WorkflowTemplatePlacementParameters)

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

type WorkflowTemplateSpec 

type WorkflowTemplateSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     WorkflowTemplateParameters `json:"forProvider"`
}

WorkflowTemplateSpec defines the desired state of WorkflowTemplate

func (*WorkflowTemplateSpec) DeepCopy 

func (in *WorkflowTemplateSpec) DeepCopy() *WorkflowTemplateSpec

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

func (*WorkflowTemplateSpec) DeepCopyInto 

func (in *WorkflowTemplateSpec) DeepCopyInto(out *WorkflowTemplateSpec)

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

type WorkflowTemplateStatus 

type WorkflowTemplateStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        WorkflowTemplateObservation `json:"atProvider,omitempty"`
}

WorkflowTemplateStatus defines the observed state of WorkflowTemplate.

func (*WorkflowTemplateStatus) DeepCopy 

func (in *WorkflowTemplateStatus) DeepCopy() *WorkflowTemplateStatus

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

func (*WorkflowTemplateStatus) DeepCopyInto 

func (in *WorkflowTemplateStatus) DeepCopyInto(out *WorkflowTemplateStatus)

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

type YarnConfigObservation 

type YarnConfigObservation struct {
}

func (*YarnConfigObservation) DeepCopy 

func (in *YarnConfigObservation) DeepCopy() *YarnConfigObservation

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

func (*YarnConfigObservation) DeepCopyInto 

func (in *YarnConfigObservation) DeepCopyInto(out *YarnConfigObservation)

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

type YarnConfigParameters 

type YarnConfigParameters struct {

	// Timeout for YARN graceful decommissioning of Node Managers. Specifies the
	// duration to wait for jobs to complete before forcefully removing workers
	// (and potentially interrupting jobs). Only applicable to downscaling operations.
	//
	// Bounds: [0s, 1d].
	// +kubebuilder:validation:Required
	GracefulDecommissionTimeout *string `json:"gracefulDecommissionTimeout" tf:"graceful_decommission_timeout,omitempty"`

	// Fraction of average 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.
	//
	// Bounds: [0.0, 1.0].
	// +kubebuilder:validation:Required
	ScaleDownFactor *float64 `json:"scaleDownFactor" tf:"scale_down_factor,omitempty"`

	// Minimum scale-down threshold as a fraction of total cluster size before scaling occurs.
	// For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler must
	// recommend at least a 2 worker scale-down for the cluster to scale. A threshold of 0
	// means the autoscaler will scale down on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	// +kubebuilder:validation:Optional
	ScaleDownMinWorkerFraction *float64 `json:"scaleDownMinWorkerFraction,omitempty" tf:"scale_down_min_worker_fraction,omitempty"`

	// Fraction of average 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).
	//
	// Bounds: [0.0, 1.0].
	// +kubebuilder:validation:Required
	ScaleUpFactor *float64 `json:"scaleUpFactor" tf:"scale_up_factor,omitempty"`

	// Minimum scale-up threshold as a fraction of total cluster size before scaling
	// occurs. For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler
	// must recommend at least a 2-worker scale-up for the cluster to scale. A threshold of
	// 0 means the autoscaler will scale up on any recommended change.
	//
	// Bounds: [0.0, 1.0]. Default: 0.0.
	// +kubebuilder:validation:Optional
	ScaleUpMinWorkerFraction *float64 `json:"scaleUpMinWorkerFraction,omitempty" tf:"scale_up_min_worker_fraction,omitempty"`
}

func (*YarnConfigParameters) DeepCopy 

func (in *YarnConfigParameters) DeepCopy() *YarnConfigParameters

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

func (*YarnConfigParameters) DeepCopyInto 

func (in *YarnConfigParameters) DeepCopyInto(out *YarnConfigParameters)

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.