dataproc

package
v1.154.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AcceleratorConfig_v1alpha1_FromProto added in v1.151.0 

func AcceleratorConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AcceleratorConfig) *krmdataprocv1alpha1.AcceleratorConfig

func AcceleratorConfig_v1alpha1_ToProto added in v1.151.0 

func AcceleratorConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.AcceleratorConfig) *pb.AcceleratorConfig

func AutotuningConfig_v1alpha1_FromProto added in v1.151.0 

func AutotuningConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AutotuningConfig) *krm.AutotuningConfig

func AutotuningConfig_v1alpha1_ToProto added in v1.151.0 

func AutotuningConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.AutotuningConfig) *pb.AutotuningConfig

func BasicAutoscalingAlgorithm_v1beta1_FromProto added in v1.151.0 

func BasicAutoscalingAlgorithm_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BasicAutoscalingAlgorithm) *krm.BasicAutoscalingAlgorithm

found existing non-generated mapping function "AutotuningConfig_v1alpha1_ToProto", skipping 

func AutotuningConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.AutotuningConfig) *pb.AutotuningConfig {
	if in == nil {
		return nil
	}
	out := &pb.AutotuningConfig{}
	out.Scenarios = direct.EnumSlice_ToProto[pb.AutotuningConfig_Scenario](mapCtx, in.Scenarios)
	return out
}

func BasicAutoscalingAlgorithm_v1beta1_ToProto added in v1.151.0 

func BasicAutoscalingAlgorithm_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BasicAutoscalingAlgorithm) *pb.BasicAutoscalingAlgorithm

func BasicYarnAutoscalingConfig_v1beta1_FromProto added in v1.151.0 

func BasicYarnAutoscalingConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BasicYarnAutoscalingConfig) *krm.BasicYarnAutoscalingConfig

func BasicYarnAutoscalingConfig_v1beta1_ToProto added in v1.151.0 

func BasicYarnAutoscalingConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BasicYarnAutoscalingConfig) *pb.BasicYarnAutoscalingConfig

func Batch_StateHistoryObservedState_v1alpha1_FromProto added in v1.151.0 

func Batch_StateHistoryObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Batch_StateHistory) *krm.Batch_StateHistoryObservedState

func Batch_StateHistoryObservedState_v1alpha1_ToProto added in v1.151.0 

func Batch_StateHistoryObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.Batch_StateHistoryObservedState) *pb.Batch_StateHistory

func Batch_StateHistory_v1alpha1_FromProto added in v1.151.0 

func Batch_StateHistory_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Batch_StateHistory) *krm.Batch_StateHistory

func Batch_StateHistory_v1alpha1_ToProto added in v1.151.0 

func Batch_StateHistory_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.Batch_StateHistory) *pb.Batch_StateHistory

func ClusterAccelerators_v1beta1_FromProto added in v1.154.0 

func ClusterAccelerators_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AcceleratorConfig) *krm.ClusterAccelerators

func ClusterAccelerators_v1beta1_ToProto added in v1.154.0 

func ClusterAccelerators_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterAccelerators) *pb.AcceleratorConfig

func ClusterAutoscalingConfig_v1beta1_FromProto added in v1.154.0 

func ClusterAutoscalingConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig) *krm.ClusterAutoscalingConfig

func ClusterAutoscalingConfig_v1beta1_ToProto added in v1.154.0 

func ClusterAutoscalingConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterAutoscalingConfig) *pb.AutoscalingConfig

func ClusterAutoscaling_v1beta1_FromProto added in v1.154.0 

func ClusterAutoscaling_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeNodePoolConfig_GkeNodePoolAutoscalingConfig) *krm.ClusterAutoscaling

func ClusterAutoscaling_v1beta1_ToProto added in v1.154.0 

func ClusterAutoscaling_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterAutoscaling) *pb.GkeNodePoolConfig_GkeNodePoolAutoscalingConfig

func ClusterAuxiliaryServicesConfig_v1beta1_FromProto added in v1.154.0 

func ClusterAuxiliaryServicesConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AuxiliaryServicesConfig) *krm.ClusterAuxiliaryServicesConfig

found existing non-generated mapping function "ClusterAutoscalingConfig_v1beta1_ToProto", skipping 

func ClusterAutoscalingConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterAutoscalingConfig) *pb.AutoscalingConfig {
	if in == nil {
		return nil
	}
	out := &pb.AutoscalingConfig{}
	// MISSING: PolicyURI
	return out
}

func ClusterAuxiliaryServicesConfig_v1beta1_ToProto added in v1.154.0 

func ClusterAuxiliaryServicesConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterAuxiliaryServicesConfig) *pb.AuxiliaryServicesConfig

func ClusterConfidentialInstanceConfig_v1beta1_FromProto added in v1.154.0 

func ClusterConfidentialInstanceConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ConfidentialInstanceConfig) *krm.ClusterConfidentialInstanceConfig

func ClusterConfidentialInstanceConfig_v1beta1_ToProto added in v1.154.0 

func ClusterConfidentialInstanceConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterConfidentialInstanceConfig) *pb.ConfidentialInstanceConfig

func ClusterConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ClusterConfig) *krm.ClusterConfigStatus

found existing non-generated mapping function "ClusterConfig_v1beta1_ToProto", skipping 

func ClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterConfig) *pb.ClusterConfig {
	if in == nil {
		return nil
	}
	out := &pb.ClusterConfig{}
	// MISSING: ClusterTier
	// MISSING: ConfigBucket
	if in.TempBucketRef != nil {
		out.TempBucket = in.TempBucketRef.External
	}
	// MISSING: GCEClusterConfig
	// (near miss): "GCEClusterConfig" vs "GceClusterConfig"
	out.MasterConfig = ClusterMasterConfig_v1beta1_ToProto(mapCtx, in.MasterConfig)
	out.WorkerConfig = ClusterWorkerConfig_v1beta1_ToProto(mapCtx, in.WorkerConfig)
	out.SecondaryWorkerConfig = ClusterSecondaryWorkerConfig_v1beta1_ToProto(mapCtx, in.SecondaryWorkerConfig)
	out.SoftwareConfig = ClusterSoftwareConfig_v1beta1_ToProto(mapCtx, in.SoftwareConfig)
	out.InitializationActions = direct.Slice_ToProto(mapCtx, in.InitializationActions, ClusterInitializationActions_v1beta1_ToProto)
	out.EncryptionConfig = ClusterEncryptionConfig_v1beta1_ToProto(mapCtx, in.EncryptionConfig)
	out.AutoscalingConfig = ClusterAutoscalingConfig_v1beta1_ToProto(mapCtx, in.AutoscalingConfig)
	out.SecurityConfig = ClusterSecurityConfig_v1beta1_ToProto(mapCtx, in.SecurityConfig)
	out.LifecycleConfig = ClusterLifecycleConfig_v1beta1_ToProto(mapCtx, in.LifecycleConfig)
	out.EndpointConfig = ClusterEndpointConfig_v1beta1_ToProto(mapCtx, in.EndpointConfig)
	out.MetastoreConfig = ClusterMetastoreConfig_v1beta1_ToProto(mapCtx, in.MetastoreConfig)
	out.DataprocMetricConfig = ClusterDataprocMetricConfig_v1beta1_ToProto(mapCtx, in.DataprocMetricConfig)
	// MISSING: AuxiliaryNodeGroups
	return out
}

func ClusterConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterConfigStatus) *pb.ClusterConfig

func ClusterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ClusterConfig) *krm.ClusterConfig

func ClusterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterConfig) *pb.ClusterConfig

func ClusterDataprocMetricConfig_v1beta1_FromProto added in v1.154.0 

func ClusterDataprocMetricConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.DataprocMetricConfig) *krm.ClusterDataprocMetricConfig

func ClusterDataprocMetricConfig_v1beta1_ToProto added in v1.154.0 

func ClusterDataprocMetricConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterDataprocMetricConfig) *pb.DataprocMetricConfig

func ClusterDiskConfig_v1beta1_FromProto added in v1.154.0 

func ClusterDiskConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.DiskConfig) *krm.ClusterDiskConfig

func ClusterDiskConfig_v1beta1_ToProto added in v1.154.0 

func ClusterDiskConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterDiskConfig) *pb.DiskConfig

func ClusterEncryptionConfig_v1beta1_FromProto added in v1.154.0 

func ClusterEncryptionConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionConfig) *krm.ClusterEncryptionConfig

found existing non-generated mapping function "ClusterDiskConfig_v1beta1_ToProto", skipping 

func ClusterDiskConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterDiskConfig) *pb.DiskConfig {
	if in == nil {
		return nil
	}
	out := &pb.DiskConfig{}
	out.BootDiskType = direct.ValueOf(in.BootDiskType)
	// MISSING: BootDiskSizeGB
	// (near miss): "BootDiskSizeGB" vs "BootDiskSizeGb"
	out.NumLocalSsds = direct.ValueOf(in.NumLocalSsds)
	out.LocalSsdInterface = direct.ValueOf(in.LocalSsdInterface)
	// MISSING: BootDiskProvisionedIops
	// MISSING: BootDiskProvisionedThroughput
	return out
}

func ClusterEncryptionConfig_v1beta1_ToProto added in v1.154.0 

func ClusterEncryptionConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterEncryptionConfig) *pb.EncryptionConfig

func ClusterEndpointConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterEndpointConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EndpointConfig) *krm.ClusterEndpointConfigStatus

func ClusterEndpointConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterEndpointConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterEndpointConfigStatus) *pb.EndpointConfig

func ClusterEndpointConfig_v1beta1_FromProto added in v1.154.0 

func ClusterEndpointConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EndpointConfig) *krm.ClusterEndpointConfig

func ClusterEndpointConfig_v1beta1_ToProto added in v1.154.0 

func ClusterEndpointConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterEndpointConfig) *pb.EndpointConfig

func ClusterGceClusterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterGceClusterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GceClusterConfig) *krm.ClusterGceClusterConfig

func ClusterGceClusterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterGceClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterGceClusterConfig) *pb.GceClusterConfig

func ClusterGkeClusterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterGkeClusterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeClusterConfig) *krm.ClusterGkeClusterConfig

func ClusterGkeClusterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterGkeClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterGkeClusterConfig) *pb.GkeClusterConfig

func ClusterGkeNodeConfig_v1beta1_FromProto added in v1.154.0 

func ClusterGkeNodeConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeNodePoolConfig_GkeNodeConfig) *krm.ClusterGkeNodeConfig

func ClusterGkeNodeConfig_v1beta1_ToProto added in v1.154.0 

func ClusterGkeNodeConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterGkeNodeConfig) *pb.GkeNodePoolConfig_GkeNodeConfig

func ClusterGkeNodePoolAccelerators_v1beta1_FromProto added in v1.154.0 

func ClusterGkeNodePoolAccelerators_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeNodePoolConfig_GkeNodePoolAcceleratorConfig) *krm.ClusterGkeNodePoolAccelerators

func ClusterGkeNodePoolAccelerators_v1beta1_ToProto added in v1.154.0 

func ClusterGkeNodePoolAccelerators_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterGkeNodePoolAccelerators) *pb.GkeNodePoolConfig_GkeNodePoolAcceleratorConfig

func ClusterIdentityConfig_v1beta1_FromProto added in v1.154.0 

func ClusterIdentityConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.IdentityConfig) *krm.ClusterIdentityConfig

found existing non-generated mapping function "ClusterGkeNodePoolAccelerators_v1beta1_ToProto", skipping 

func ClusterGkeNodePoolAccelerators_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterGkeNodePoolAccelerators) *pb.GkeNodePoolConfig_GkeNodePoolAcceleratorConfig {
	if in == nil {
		return nil
	}
	out := &pb.GkeNodePoolConfig_GkeNodePoolAcceleratorConfig{}
	out.AcceleratorCount = direct.ValueOf(in.AcceleratorCount)
	out.AcceleratorType = direct.ValueOf(in.AcceleratorType)
	out.GpuPartitionSize = direct.ValueOf(in.GpuPartitionSize)
	return out
}

func ClusterIdentityConfig_v1beta1_ToProto added in v1.154.0 

func ClusterIdentityConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterIdentityConfig) *pb.IdentityConfig

func ClusterInitializationActions_v1beta1_FromProto added in v1.154.0 

func ClusterInitializationActions_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.NodeInitializationAction) *krm.ClusterInitializationActions

func ClusterInitializationActions_v1beta1_ToProto added in v1.154.0 

func ClusterInitializationActions_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterInitializationActions) *pb.NodeInitializationAction

func ClusterInstanceReferencesStatus_v1beta1_FromProto added in v1.154.0 

func ClusterInstanceReferencesStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceReference) *krm.ClusterInstanceReferencesStatus

found existing non-generated mapping function "ClusterInitializationActions_v1beta1_ToProto", skipping 

func ClusterInitializationActions_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterInitializationActions) *pb.NodeInitializationAction {
	if in == nil {
		return nil
	}
	out := &pb.NodeInitializationAction{}
	out.ExecutableFile = ClusterInitializationActions_ExecutableFile_ToProto(mapCtx, in.ExecutableFile)
	out.ExecutionTimeout = direct.StringDuration_ToProto(mapCtx, in.ExecutionTimeout)
	return out
}

func ClusterInstanceReferencesStatus_v1beta1_ToProto added in v1.154.0 

func ClusterInstanceReferencesStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterInstanceReferencesStatus) *pb.InstanceReference

func ClusterKerberosConfig_v1beta1_FromProto added in v1.154.0 

func ClusterKerberosConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.KerberosConfig) *krm.ClusterKerberosConfig

func ClusterKerberosConfig_v1beta1_ToProto added in v1.154.0 

func ClusterKerberosConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterKerberosConfig) *pb.KerberosConfig

func ClusterKubernetesClusterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterKubernetesClusterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesClusterConfig) *krm.ClusterKubernetesClusterConfig

func ClusterKubernetesClusterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterKubernetesClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterKubernetesClusterConfig) *pb.KubernetesClusterConfig

func ClusterKubernetesSoftwareConfig_v1beta1_FromProto added in v1.154.0 

func ClusterKubernetesSoftwareConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.KubernetesSoftwareConfig) *krm.ClusterKubernetesSoftwareConfig

found existing non-generated mapping function "ClusterKubernetesClusterConfig_v1beta1_ToProto", skipping 

func ClusterKubernetesClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterKubernetesClusterConfig) *pb.KubernetesClusterConfig {
	if in == nil {
		return nil
	}
	out := &pb.KubernetesClusterConfig{}
	out.KubernetesNamespace = direct.ValueOf(in.KubernetesNamespace)
	// MISSING: GKEClusterConfig
	// (near miss): "GKEClusterConfig" vs "GkeClusterConfig"
	out.KubernetesSoftwareConfig = ClusterKubernetesSoftwareConfig_v1beta1_ToProto(mapCtx, in.KubernetesSoftwareConfig)
	return out
}

func ClusterKubernetesSoftwareConfig_v1beta1_ToProto added in v1.154.0 

func ClusterKubernetesSoftwareConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterKubernetesSoftwareConfig) *pb.KubernetesSoftwareConfig

func ClusterLifecycleConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterLifecycleConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.LifecycleConfig) *krm.ClusterLifecycleConfigStatus

func ClusterLifecycleConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterLifecycleConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterLifecycleConfigStatus) *pb.LifecycleConfig

func ClusterLifecycleConfig_v1beta1_FromProto added in v1.154.0 

func ClusterLifecycleConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.LifecycleConfig) *krm.ClusterLifecycleConfig

func ClusterLifecycleConfig_v1beta1_ToProto added in v1.154.0 

func ClusterLifecycleConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterLifecycleConfig) *pb.LifecycleConfig

func ClusterManagedGroupConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterManagedGroupConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ManagedGroupConfig) *krm.ClusterManagedGroupConfigStatus

func ClusterManagedGroupConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterManagedGroupConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterManagedGroupConfigStatus) *pb.ManagedGroupConfig

func ClusterMasterConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterMasterConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterMasterConfigStatus

func ClusterMasterConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterMasterConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMasterConfigStatus) *pb.InstanceGroupConfig

func ClusterMasterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterMasterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterMasterConfig

func ClusterMasterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterMasterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMasterConfig) *pb.InstanceGroupConfig

func ClusterMetastoreConfig_v1beta1_FromProto added in v1.154.0 

func ClusterMetastoreConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.MetastoreConfig) *krm.ClusterMetastoreConfig

func ClusterMetastoreConfig_v1beta1_ToProto added in v1.154.0 

func ClusterMetastoreConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMetastoreConfig) *pb.MetastoreConfig

func ClusterMetricsStatus_v1beta1_FromProto added in v1.154.0 

func ClusterMetricsStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ClusterMetrics) *krm.ClusterMetricsStatus

func ClusterMetricsStatus_v1beta1_ToProto added in v1.154.0 

func ClusterMetricsStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMetricsStatus) *pb.ClusterMetrics

func ClusterMetrics_v1beta1_FromProto added in v1.154.0 

func ClusterMetrics_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.DataprocMetricConfig_Metric) *krm.ClusterMetrics

func ClusterMetrics_v1beta1_ToProto added in v1.154.0 

func ClusterMetrics_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMetrics) *pb.DataprocMetricConfig_Metric

func ClusterNodeGroupAffinity_v1beta1_FromProto added in v1.154.0 

func ClusterNodeGroupAffinity_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.NodeGroupAffinity) *krm.ClusterNodeGroupAffinity

found existing non-generated mapping function "ClusterMetricsStatus_v1beta1_ToProto", skipping 

func ClusterMetricsStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterMetricsStatus) *pb.ClusterMetrics {
	if in == nil {
		return nil
	}
	out := &pb.ClusterMetrics{}
	out.HdfsMetrics = in.HdfsMetrics
	out.YarnMetrics = in.YarnMetrics
	return out
}

func ClusterNodeGroupAffinity_v1beta1_ToProto added in v1.154.0 

func ClusterNodeGroupAffinity_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterNodeGroupAffinity) *pb.NodeGroupAffinity

func ClusterNodePoolConfig_v1beta1_FromProto added in v1.154.0 

func ClusterNodePoolConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeNodePoolConfig) *krm.ClusterNodePoolConfig

func ClusterNodePoolConfig_v1beta1_ToProto added in v1.154.0 

func ClusterNodePoolConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterNodePoolConfig) *pb.GkeNodePoolConfig

func ClusterNodePoolTarget_v1beta1_FromProto added in v1.154.0 

func ClusterNodePoolTarget_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GkeNodePoolTarget) *krm.ClusterNodePoolTarget

func ClusterNodePoolTarget_v1beta1_ToProto added in v1.154.0 

func ClusterNodePoolTarget_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterNodePoolTarget) *pb.GkeNodePoolTarget

func ClusterReservationAffinity_v1beta1_FromProto added in v1.154.0 

func ClusterReservationAffinity_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ReservationAffinity) *krm.ClusterReservationAffinity

found existing non-generated mapping function "ClusterNodePoolTarget_v1beta1_ToProto", skipping 

func ClusterNodePoolTarget_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterNodePoolTarget) *pb.GkeNodePoolTarget {
	if in == nil {
		return nil
	}
	out := &pb.GkeNodePoolTarget{}
	if in.NodePoolRef != nil {
		out.NodePool = in.NodePoolRef.External
	}
	out.Roles = direct.EnumSlice_ToProto[pb.GkeNodePoolTarget_Role](mapCtx, in.Roles)
	out.NodePoolConfig = ClusterNodePoolConfig_v1beta1_ToProto(mapCtx, in.NodePoolConfig)
	return out
}

func ClusterReservationAffinity_v1beta1_ToProto added in v1.154.0 

func ClusterReservationAffinity_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterReservationAffinity) *pb.ReservationAffinity

func ClusterSecondaryWorkerConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterSecondaryWorkerConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterSecondaryWorkerConfigStatus

func ClusterSecondaryWorkerConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterSecondaryWorkerConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSecondaryWorkerConfigStatus) *pb.InstanceGroupConfig

func ClusterSecondaryWorkerConfig_v1beta1_FromProto added in v1.154.0 

func ClusterSecondaryWorkerConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterSecondaryWorkerConfig

func ClusterSecondaryWorkerConfig_v1beta1_ToProto added in v1.154.0 

func ClusterSecondaryWorkerConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSecondaryWorkerConfig) *pb.InstanceGroupConfig

func ClusterSecurityConfig_v1beta1_FromProto added in v1.154.0 

func ClusterSecurityConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.SecurityConfig) *krm.ClusterSecurityConfig

found existing non-generated mapping function "ClusterSecondaryWorkerConfigStatus_v1beta1_ToProto", skipping 

func ClusterSecondaryWorkerConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSecondaryWorkerConfigStatus) *pb.InstanceGroupConfig {
	if in == nil {
		return nil
	}
	out := &pb.InstanceGroupConfig{}
	// MISSING: NumInstances
	out.InstanceNames = in.InstanceNames
	out.InstanceReferences = direct.Slice_ToProto(mapCtx, in.InstanceReferences, ClusterInstanceReferencesStatus_v1beta1_ToProto)
	// MISSING: ImageURI
	// MISSING: MachineTypeURI
	// MISSING: DiskConfig
	out.IsPreemptible = direct.ValueOf(in.IsPreemptible)
	// MISSING: Preemptibility
	out.ManagedGroupConfig = ClusterManagedGroupConfigStatus_v1beta1_ToProto(mapCtx, in.ManagedGroupConfig)
	// MISSING: Accelerators
	// MISSING: MinCPUPlatform
	// MISSING: MinNumInstances
	// MISSING: InstanceFlexibilityPolicy
	// MISSING: StartupConfig
	return out
}

func ClusterSecurityConfig_v1beta1_ToProto added in v1.154.0 

func ClusterSecurityConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSecurityConfig) *pb.SecurityConfig

func ClusterShieldedInstanceConfig_v1beta1_FromProto added in v1.154.0 

func ClusterShieldedInstanceConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ShieldedInstanceConfig) *krm.ClusterShieldedInstanceConfig

func ClusterShieldedInstanceConfig_v1beta1_ToProto added in v1.154.0 

func ClusterShieldedInstanceConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterShieldedInstanceConfig) *pb.ShieldedInstanceConfig

func ClusterSoftwareConfig_v1beta1_FromProto added in v1.154.0 

func ClusterSoftwareConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.SoftwareConfig) *krm.ClusterSoftwareConfig

func ClusterSoftwareConfig_v1beta1_ToProto added in v1.154.0 

func ClusterSoftwareConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSoftwareConfig) *pb.SoftwareConfig

func ClusterSparkHistoryServerConfig_v1beta1_FromProto added in v1.154.0 

func ClusterSparkHistoryServerConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.ClusterSparkHistoryServerConfig

found existing non-generated mapping function "ClusterSoftwareConfig_v1beta1_ToProto", skipping 

func ClusterSoftwareConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSoftwareConfig) *pb.SoftwareConfig {
	if in == nil {
		return nil
	}
	out := &pb.SoftwareConfig{}
	out.ImageVersion = direct.ValueOf(in.ImageVersion)
	out.Properties = in.Properties
	out.OptionalComponents = direct.EnumSlice_ToProto[pb.Component](mapCtx, in.OptionalComponents)
	return out
}

func ClusterSparkHistoryServerConfig_v1beta1_ToProto added in v1.154.0 

func ClusterSparkHistoryServerConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterSparkHistoryServerConfig) *pb.SparkHistoryServerConfig

func ClusterStatusHistoryStatus_v1beta1_FromProto added in v1.154.0 

func ClusterStatusHistoryStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ClusterStatus) *krm.ClusterStatusHistoryStatus

func ClusterStatusHistoryStatus_v1beta1_ToProto added in v1.154.0 

func ClusterStatusHistoryStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterStatusHistoryStatus) *pb.ClusterStatus

func ClusterStatusStatus_v1beta1_FromProto added in v1.154.0 

func ClusterStatusStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ClusterStatus) *krm.ClusterStatusStatus

func ClusterStatusStatus_v1beta1_ToProto added in v1.154.0 

func ClusterStatusStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterStatusStatus) *pb.ClusterStatus

func ClusterVirtualClusterConfig_v1beta1_FromProto added in v1.154.0 

func ClusterVirtualClusterConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VirtualClusterConfig) *krm.ClusterVirtualClusterConfig

func ClusterVirtualClusterConfig_v1beta1_ToProto added in v1.154.0 

func ClusterVirtualClusterConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterVirtualClusterConfig) *pb.VirtualClusterConfig

func ClusterWorkerConfigStatus_v1beta1_FromProto added in v1.154.0 

func ClusterWorkerConfigStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterWorkerConfigStatus

func ClusterWorkerConfigStatus_v1beta1_ToProto added in v1.154.0 

func ClusterWorkerConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterWorkerConfigStatus) *pb.InstanceGroupConfig

func ClusterWorkerConfig_v1beta1_FromProto added in v1.154.0 

func ClusterWorkerConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krm.ClusterWorkerConfig

func ClusterWorkerConfig_v1beta1_ToProto added in v1.154.0 

func ClusterWorkerConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterWorkerConfig) *pb.InstanceGroupConfig

func DataprocAutoscalingPolicySpec_v1beta1_FromProto added in v1.151.0 

func DataprocAutoscalingPolicySpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingPolicy) *krm.DataprocAutoscalingPolicySpec

found existing non-generated mapping function "ClusterWorkerConfigStatus_v1beta1_ToProto", skipping 

func ClusterWorkerConfigStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ClusterWorkerConfigStatus) *pb.InstanceGroupConfig {
	if in == nil {
		return nil
	}
	out := &pb.InstanceGroupConfig{}
	// MISSING: NumInstances
	out.InstanceNames = in.InstanceNames
	out.InstanceReferences = direct.Slice_ToProto(mapCtx, in.InstanceReferences, ClusterInstanceReferencesStatus_v1beta1_ToProto)
	// MISSING: ImageURI
	// MISSING: MachineTypeURI
	// MISSING: DiskConfig
	out.IsPreemptible = direct.ValueOf(in.IsPreemptible)
	// MISSING: Preemptibility
	out.ManagedGroupConfig = ClusterManagedGroupConfigStatus_v1beta1_ToProto(mapCtx, in.ManagedGroupConfig)
	// MISSING: Accelerators
	// MISSING: MinCPUPlatform
	// MISSING: MinNumInstances
	// MISSING: InstanceFlexibilityPolicy
	// MISSING: StartupConfig
	return out
}

func DataprocAutoscalingPolicySpec_v1beta1_ToProto added in v1.151.0 

func DataprocAutoscalingPolicySpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocAutoscalingPolicySpec) *pb.AutoscalingPolicy

func DataprocBatchObservedState_v1alpha1_FromProto added in v1.151.0 

func DataprocBatchObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Batch) *krm.DataprocBatchObservedState

func DataprocBatchObservedState_v1alpha1_ToProto added in v1.151.0 

func DataprocBatchObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocBatchObservedState) *pb.Batch

func DataprocBatchSpec_v1alpha1_FromProto added in v1.151.0 

func DataprocBatchSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Batch) *krm.DataprocBatchSpec

func DataprocBatchSpec_v1alpha1_ToProto added in v1.151.0 

func DataprocBatchSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocBatchSpec) *pb.Batch

func DataprocClusterSpec_v1beta1_FromProto added in v1.154.0 

func DataprocClusterSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.DataprocClusterSpec

found existing non-generated mapping function "DataprocBatchSpec_v1alpha1_ToProto", skipping 

func DataprocBatchSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocBatchSpec) *pb.Batch {
	if in == nil {
		return nil
	}
	out := &pb.Batch{}
	// MISSING: Name
	if oneof := PySparkBatch_v1alpha1_ToProto(mapCtx, in.PysparkBatch); oneof != nil {
		out.BatchConfig = &pb.Batch_PysparkBatch{PysparkBatch: oneof}
	}
	if oneof := SparkBatch_v1alpha1_ToProto(mapCtx, in.SparkBatch); oneof != nil {
		out.BatchConfig = &pb.Batch_SparkBatch{SparkBatch: oneof}
	}
	if oneof := SparkRBatch_v1alpha1_ToProto(mapCtx, in.SparkRBatch); oneof != nil {
		out.BatchConfig = &pb.Batch_SparkRBatch{SparkRBatch: oneof}
	}
	if oneof := SparkSQLBatch_v1alpha1_ToProto(mapCtx, in.SparkSQLBatch); oneof != nil {
		out.BatchConfig = &pb.Batch_SparkSqlBatch{SparkSqlBatch: oneof}
	}
	out.Labels = in.Labels
	out.RuntimeConfig = RuntimeConfig_v1alpha1_ToProto(mapCtx, in.RuntimeConfig)
	out.EnvironmentConfig = EnvironmentConfig_v1alpha1_ToProto(mapCtx, in.EnvironmentConfig)
	return out
}

func DataprocClusterSpec_v1beta1_ToProto added in v1.154.0 

func DataprocClusterSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocClusterSpec) *pb.Cluster

func DataprocClusterStatus_v1beta1_FromProto added in v1.154.0 

func DataprocClusterStatus_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.DataprocClusterStatus

func DataprocClusterStatus_v1beta1_ToProto added in v1.154.0 

func DataprocClusterStatus_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocClusterStatus) *pb.Cluster

func DataprocJobObservedState_v1alpha1_FromProto added in v1.151.0 

func DataprocJobObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.DataprocJobObservedState

func DataprocJobObservedState_v1alpha1_ToProto added in v1.151.0 

func DataprocJobObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocJobObservedState) *pb.Job

func DataprocJobSpec_v1alpha1_FromProto added in v1.151.0 

func DataprocJobSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.DataprocJobSpec

func DataprocJobSpec_v1alpha1_ToProto added in v1.151.0 

func DataprocJobSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DataprocJobSpec) *pb.Job

func DataprocNodeGroupObservedState_v1alpha1_FromProto added in v1.151.0 

func DataprocNodeGroupObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NodeGroup) *krmdataprocv1alpha1.DataprocNodeGroupObservedState

found existing non-generated mapping function "DataprocJobSpec_v1alpha1_ToProto", skipping 

func DataprocJobSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocJobSpec) *pb.Job {
	if in == nil {
		return nil
	}
	out := &pb.Job{}
	out.Reference = JobReference_v1alpha1_ToProto(mapCtx, in.Reference)
	out.Placement = JobPlacement_v1alpha1_ToProto(mapCtx, in.Placement)
	if oneof := HadoopJob_v1alpha1_ToProto(mapCtx, in.HadoopJob); oneof != nil {
		out.TypeJob = &pb.Job_HadoopJob{HadoopJob: oneof}
	}
	if oneof := SparkJob_v1alpha1_ToProto(mapCtx, in.SparkJob); oneof != nil {
		out.TypeJob = &pb.Job_SparkJob{SparkJob: oneof}
	}
	if oneof := PySparkJob_v1alpha1_ToProto(mapCtx, in.PysparkJob); oneof != nil {
		out.TypeJob = &pb.Job_PysparkJob{PysparkJob: oneof}
	}
	if oneof := HiveJob_v1alpha1_ToProto(mapCtx, in.HiveJob); oneof != nil {
		out.TypeJob = &pb.Job_HiveJob{HiveJob: oneof}
	}
	if oneof := PigJob_v1alpha1_ToProto(mapCtx, in.PigJob); oneof != nil {
		out.TypeJob = &pb.Job_PigJob{PigJob: oneof}
	}
	if oneof := SparkRJob_v1alpha1_ToProto(mapCtx, in.SparkRJob); oneof != nil {
		out.TypeJob = &pb.Job_SparkRJob{SparkRJob: oneof}
	}
	if oneof := SparkSQLJob_v1alpha1_ToProto(mapCtx, in.SparkSQLJob); oneof != nil {
		out.TypeJob = &pb.Job_SparkSqlJob{SparkSqlJob: oneof}
	}
	if oneof := PrestoJob_v1alpha1_ToProto(mapCtx, in.PrestoJob); oneof != nil {
		out.TypeJob = &pb.Job_PrestoJob{PrestoJob: oneof}
	}
	if oneof := TrinoJob_v1alpha1_ToProto(mapCtx, in.TrinoJob); oneof != nil {
		out.TypeJob = &pb.Job_TrinoJob{TrinoJob: oneof}
	}
	if oneof := FlinkJob_v1alpha1_ToProto(mapCtx, in.FlinkJob); oneof != nil {
		out.TypeJob = &pb.Job_FlinkJob{FlinkJob: oneof}
	}
	out.Labels = in.Labels
	out.Scheduling = JobScheduling_v1alpha1_ToProto(mapCtx, in.Scheduling)
	// MISSING: JobUuid
	out.DriverSchedulingConfig = DriverSchedulingConfig_v1alpha1_ToProto(mapCtx, in.DriverSchedulingConfig)
	return out
}

func DataprocNodeGroupObservedState_v1alpha1_ToProto added in v1.151.0 

func DataprocNodeGroupObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocNodeGroupObservedState) *pb.NodeGroup

func DataprocNodeGroupSpec_v1alpha1_FromProto added in v1.151.0 

func DataprocNodeGroupSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NodeGroup) *krmdataprocv1alpha1.DataprocNodeGroupSpec

func DataprocNodeGroupSpec_v1alpha1_ToProto added in v1.151.0 

func DataprocNodeGroupSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocNodeGroupSpec) *pb.NodeGroup

func DataprocSessionObservedState_v1alpha1_FromProto added in v1.152.0 

func DataprocSessionObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Session) *krmdataprocv1alpha1.DataprocSessionObservedState

func DataprocSessionObservedState_v1alpha1_ToProto added in v1.152.0 

func DataprocSessionObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocSessionObservedState) *pb.Session

func DataprocSessionSpec_v1alpha1_FromProto added in v1.152.0 

func DataprocSessionSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Session) *krmdataprocv1alpha1.DataprocSessionSpec

func DataprocSessionSpec_v1alpha1_ToProto added in v1.152.0 

func DataprocSessionSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocSessionSpec) *pb.Session

func DataprocSessionTemplateObservedState_v1alpha1_FromProto added in v1.153.0 

func DataprocSessionTemplateObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SessionTemplate) *krmdataprocv1alpha1.DataprocSessionTemplateObservedState

func DataprocSessionTemplateObservedState_v1alpha1_ToProto added in v1.153.0 

func DataprocSessionTemplateObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocSessionTemplateObservedState) *pb.SessionTemplate

func DataprocSessionTemplateSpec_v1alpha1_FromProto added in v1.153.0 

func DataprocSessionTemplateSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SessionTemplate) *krmdataprocv1alpha1.DataprocSessionTemplateSpec

func DataprocSessionTemplateSpec_v1alpha1_ToProto added in v1.153.0 

func DataprocSessionTemplateSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.DataprocSessionTemplateSpec) *pb.SessionTemplate

func DiskConfig_v1alpha1_FromProto added in v1.151.0 

func DiskConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.DiskConfig) *krm.DiskConfig

func DiskConfig_v1alpha1_ToProto added in v1.151.0 

func DiskConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DiskConfig) *pb.DiskConfig

func DriverSchedulingConfig_v1alpha1_FromProto added in v1.151.0 

func DriverSchedulingConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.DriverSchedulingConfig) *krm.DriverSchedulingConfig

func DriverSchedulingConfig_v1alpha1_ToProto added in v1.151.0 

func DriverSchedulingConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.DriverSchedulingConfig) *pb.DriverSchedulingConfig

func EnvironmentConfig_v1alpha1_FromProto added in v1.151.0 

func EnvironmentConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EnvironmentConfig) *krm.EnvironmentConfig

func EnvironmentConfig_v1alpha1_ToProto added in v1.151.0 

func EnvironmentConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.EnvironmentConfig) *pb.EnvironmentConfig

func ExecutionConfig_NetworkUri_ToProto 

func ExecutionConfig_NetworkUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.ExecutionConfig_NetworkUri

found existing non-generated mapping function "ExecutionConfig_v1alpha1_ToProto", skipping 

func ExecutionConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.ExecutionConfig) *pb.ExecutionConfig {
	if in == nil {
		return nil
	}
	out := &pb.ExecutionConfig{}
	if in.ServiceAccountRef != nil {
		out.ServiceAccount = in.ServiceAccountRef.External
	}
	if oneof := ExecutionConfig_NetworkUri_ToProto(mapCtx, in.NetworkURI); oneof != nil {
		out.Network = oneof
	}
	if oneof := ExecutionConfig_SubnetworkUri_ToProto(mapCtx, in.SubnetworkURI); oneof != nil {
		out.Network = oneof
	}
	out.NetworkTags = in.NetworkTags
	if in.KMSKeyRef != nil {
		out.KmsKey = in.KMSKeyRef.External
	}
	out.IdleTtl = direct.StringDuration_ToProto(mapCtx, in.IdleTTL)
	out.Ttl = direct.StringDuration_ToProto(mapCtx, in.TTL)
	if in.StagingBucketRef != nil {
		out.StagingBucket = in.StagingBucketRef.External
	}
	// MISSING: AuthenticationConfig
	return out
}

func ExecutionConfig_NetworkUri_v1alpha1_ToProto added in v1.151.0 

func ExecutionConfig_NetworkUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.ExecutionConfig_NetworkUri

func ExecutionConfig_SubnetworkUri_ToProto 

func ExecutionConfig_SubnetworkUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.ExecutionConfig_SubnetworkUri

func ExecutionConfig_SubnetworkUri_v1alpha1_ToProto added in v1.151.0 

func ExecutionConfig_SubnetworkUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.ExecutionConfig_SubnetworkUri

func ExecutionConfig_v1alpha1_FromProto added in v1.151.0 

func ExecutionConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionConfig) *krm.ExecutionConfig

func ExecutionConfig_v1alpha1_ToProto added in v1.151.0 

func ExecutionConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionConfig) *pb.ExecutionConfig

func FlinkJob_MainClass_ToProto 

func FlinkJob_MainClass_ToProto(mapCtx *direct.MapContext, in *string) *pb.FlinkJob_MainClass

func FlinkJob_MainClass_v1alpha1_ToProto added in v1.151.0 

func FlinkJob_MainClass_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.FlinkJob_MainClass

func FlinkJob_MainJarFileUri_ToProto 

func FlinkJob_MainJarFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.FlinkJob_MainJarFileUri

found existing non-generated mapping function "FlinkJob_v1alpha1_ToProto", skipping 

func FlinkJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.FlinkJob) *pb.FlinkJob {
	if in == nil {
		return nil
	}
	out := &pb.FlinkJob{}
	if oneof := FlinkJob_MainJarFileUri_ToProto(mapCtx, in.MainJarFileURI); oneof != nil {
		out.Driver = oneof
	}
	if oneof := FlinkJob_MainClass_ToProto(mapCtx, in.MainClass); oneof != nil {
		out.Driver = oneof
	}
	out.Args = in.Args
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	out.SavepointUri = direct.ValueOf(in.SavepointURI)
	out.Properties = in.Properties
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func FlinkJob_MainJarFileUri_v1alpha1_ToProto added in v1.151.0 

func FlinkJob_MainJarFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.FlinkJob_MainJarFileUri

func FlinkJob_v1alpha1_FromProto added in v1.151.0 

func FlinkJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.FlinkJob) *krm.FlinkJob

func FlinkJob_v1alpha1_ToProto added in v1.151.0 

func FlinkJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.FlinkJob) *pb.FlinkJob

func HadoopJob_MainClass_ToProto 

func HadoopJob_MainClass_ToProto(mapCtx *direct.MapContext, in *string) *pb.HadoopJob_MainClass

func HadoopJob_MainClass_v1alpha1_ToProto added in v1.151.0 

func HadoopJob_MainClass_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.HadoopJob_MainClass

func HadoopJob_MainJarFileUri_ToProto 

func HadoopJob_MainJarFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.HadoopJob_MainJarFileUri

found existing non-generated mapping function "HadoopJob_v1alpha1_ToProto", skipping 

func HadoopJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.HadoopJob) *pb.HadoopJob {
	if in == nil {
		return nil
	}
	out := &pb.HadoopJob{}
	if oneof := HadoopJob_MainJarFileUri_ToProto(mapCtx, in.MainJarFileURI); oneof != nil {
		out.Driver = oneof
	}
	if oneof := HadoopJob_MainClass_ToProto(mapCtx, in.MainClass); oneof != nil {
		out.Driver = oneof
	}
	out.Args = in.Args
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	// MISSING: FileUris
	// (near miss): "FileUris" vs "FileURIs"
	// MISSING: ArchiveUris
	// (near miss): "ArchiveUris" vs "ArchiveURIs"
	out.Properties = in.Properties
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func HadoopJob_MainJarFileUri_v1alpha1_ToProto added in v1.151.0 

func HadoopJob_MainJarFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.HadoopJob_MainJarFileUri

func HadoopJob_v1alpha1_FromProto added in v1.151.0 

func HadoopJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.HadoopJob) *krm.HadoopJob

func HadoopJob_v1alpha1_ToProto added in v1.151.0 

func HadoopJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.HadoopJob) *pb.HadoopJob

func HiveJob_QueryFileUri_ToProto 

func HiveJob_QueryFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.HiveJob_QueryFileUri

found existing non-generated mapping function "HiveJob_v1alpha1_ToProto", skipping 

func HiveJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.HiveJob) *pb.HiveJob {
	if in == nil {
		return nil
	}
	out := &pb.HiveJob{}
	if oneof := HiveJob_QueryFileUri_ToProto(mapCtx, in.QueryFileURI); oneof != nil {
		out.Queries = oneof
	}
	if oneof := QueryList_v1alpha1_ToProto(mapCtx, in.QueryList); oneof != nil {
		out.Queries = &pb.HiveJob_QueryList{QueryList: oneof}
	}
	out.ContinueOnFailure = direct.ValueOf(in.ContinueOnFailure)
	out.ScriptVariables = in.ScriptVariables
	out.Properties = in.Properties
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	return out
}

func HiveJob_QueryFileUri_v1alpha1_ToProto added in v1.151.0 

func HiveJob_QueryFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.HiveJob_QueryFileUri

func HiveJob_v1alpha1_FromProto added in v1.151.0 

func HiveJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.HiveJob) *krm.HiveJob

func HiveJob_v1alpha1_ToProto added in v1.151.0 

func HiveJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.HiveJob) *pb.HiveJob

func InstanceFlexibilityPolicyObservedState_v1alpha1_FromProto added in v1.151.0 

func InstanceFlexibilityPolicyObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceFlexibilityPolicy) *krmdataprocv1alpha1.InstanceFlexibilityPolicyObservedState

func InstanceFlexibilityPolicyObservedState_v1alpha1_ToProto added in v1.151.0 

func InstanceFlexibilityPolicyObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceFlexibilityPolicyObservedState) *pb.InstanceFlexibilityPolicy

func InstanceFlexibilityPolicy_InstanceSelectionResultObservedState_v1alpha1_FromProto added in v1.151.0 

func InstanceFlexibilityPolicy_InstanceSelectionResultObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceFlexibilityPolicy_InstanceSelectionResult) *krmdataprocv1alpha1.InstanceFlexibilityPolicy_InstanceSelectionResultObservedState

func InstanceFlexibilityPolicy_InstanceSelectionResultObservedState_v1alpha1_ToProto added in v1.151.0 

func InstanceFlexibilityPolicy_InstanceSelectionResultObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceFlexibilityPolicy_InstanceSelectionResultObservedState) *pb.InstanceFlexibilityPolicy_InstanceSelectionResult

func InstanceFlexibilityPolicy_InstanceSelection_v1alpha1_FromProto added in v1.151.0 

func InstanceFlexibilityPolicy_InstanceSelection_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceFlexibilityPolicy_InstanceSelection) *krmdataprocv1alpha1.InstanceFlexibilityPolicy_InstanceSelection

func InstanceFlexibilityPolicy_InstanceSelection_v1alpha1_ToProto added in v1.151.0 

func InstanceFlexibilityPolicy_InstanceSelection_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceFlexibilityPolicy_InstanceSelection) *pb.InstanceFlexibilityPolicy_InstanceSelection

func InstanceFlexibilityPolicy_ProvisioningModelMix_v1alpha1_FromProto added in v1.151.0 

func InstanceFlexibilityPolicy_ProvisioningModelMix_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceFlexibilityPolicy_ProvisioningModelMix) *krmdataprocv1alpha1.InstanceFlexibilityPolicy_ProvisioningModelMix

func InstanceFlexibilityPolicy_ProvisioningModelMix_v1alpha1_ToProto added in v1.151.0 

func InstanceFlexibilityPolicy_ProvisioningModelMix_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceFlexibilityPolicy_ProvisioningModelMix) *pb.InstanceFlexibilityPolicy_ProvisioningModelMix

func InstanceFlexibilityPolicy_v1alpha1_FromProto added in v1.151.0 

func InstanceFlexibilityPolicy_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceFlexibilityPolicy) *krmdataprocv1alpha1.InstanceFlexibilityPolicy

func InstanceFlexibilityPolicy_v1alpha1_ToProto added in v1.151.0 

func InstanceFlexibilityPolicy_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceFlexibilityPolicy) *pb.InstanceFlexibilityPolicy

func InstanceGroupAutoscalingPolicyConfig_v1beta1_FromProto added in v1.151.0 

func InstanceGroupAutoscalingPolicyConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupAutoscalingPolicyConfig) *krm.InstanceGroupAutoscalingPolicyConfig

func InstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto added in v1.151.0 

func InstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.InstanceGroupAutoscalingPolicyConfig) *pb.InstanceGroupAutoscalingPolicyConfig

func InstanceGroupConfigObservedState_v1alpha1_FromProto added in v1.151.0 

func InstanceGroupConfigObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krmdataprocv1alpha1.InstanceGroupConfigObservedState

func InstanceGroupConfigObservedState_v1alpha1_ToProto added in v1.151.0 

func InstanceGroupConfigObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceGroupConfigObservedState) *pb.InstanceGroupConfig

func InstanceGroupConfig_v1alpha1_FromProto added in v1.151.0 

func InstanceGroupConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupConfig) *krmdataprocv1alpha1.InstanceGroupConfig

found existing non-generated mapping function "InstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto", skipping 

func InstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.InstanceGroupAutoscalingPolicyConfig) *pb.InstanceGroupAutoscalingPolicyConfig {
	if in == nil {
		return nil
	}
	out := &pb.InstanceGroupAutoscalingPolicyConfig{}
	out.MinInstances = direct.ValueOf(in.MinInstances)
	out.MaxInstances = direct.ValueOf(in.MaxInstances)
	out.Weight = direct.ValueOf(in.Weight)
	return out
}

func InstanceGroupConfig_v1alpha1_ToProto added in v1.151.0 

func InstanceGroupConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceGroupConfig) *pb.InstanceGroupConfig

func InstanceReference_v1alpha1_FromProto added in v1.151.0 

func InstanceReference_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceReference) *krmdataprocv1alpha1.InstanceReference

func InstanceReference_v1alpha1_ToProto added in v1.151.0 

func InstanceReference_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.InstanceReference) *pb.InstanceReference

func JobPlacementObservedState_v1alpha1_FromProto added in v1.151.0 

func JobPlacementObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobPlacement) *krm.JobPlacementObservedState

func JobPlacementObservedState_v1alpha1_ToProto added in v1.151.0 

func JobPlacementObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobPlacementObservedState) *pb.JobPlacement

func JobPlacement_v1alpha1_FromProto added in v1.151.0 

func JobPlacement_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobPlacement) *krm.JobPlacement

func JobPlacement_v1alpha1_ToProto added in v1.151.0 

func JobPlacement_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobPlacement) *pb.JobPlacement

func JobReference_v1alpha1_FromProto added in v1.151.0 

func JobReference_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobReference) *krm.JobReference

func JobReference_v1alpha1_ToProto added in v1.151.0 

func JobReference_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobReference) *pb.JobReference

func JobScheduling_v1alpha1_FromProto added in v1.151.0 

func JobScheduling_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobScheduling) *krm.JobScheduling

func JobScheduling_v1alpha1_ToProto added in v1.151.0 

func JobScheduling_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobScheduling) *pb.JobScheduling

func JobStatusObservedState_v1alpha1_FromProto added in v1.151.0 

func JobStatusObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobStatus) *krm.JobStatusObservedState

func JobStatusObservedState_v1alpha1_ToProto added in v1.151.0 

func JobStatusObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobStatusObservedState) *pb.JobStatus

func JobStatus_v1alpha1_FromProto added in v1.151.0 

func JobStatus_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JobStatus) *krm.JobStatus

func JobStatus_v1alpha1_ToProto added in v1.151.0 

func JobStatus_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.JobStatus) *pb.JobStatus

func JupyterConfig_v1alpha1_FromProto added in v1.152.0 

func JupyterConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.JupyterConfig) *krmdataprocv1alpha1.JupyterConfig

found existing non-generated mapping function "JobStatusObservedState_v1alpha1_ToProto", skipping 

func JobStatusObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.JobStatusObservedState) *pb.JobStatus {
	if in == nil {
		return nil
	}
	out := &pb.JobStatus{}
	out.State = direct.Enum_ToProto[pb.JobStatus_State](mapCtx, in.State)
	out.Details = direct.ValueOf(in.Details)
	out.StateStartTime = direct.StringTimestamp_ToProto(mapCtx, in.StateStartTime)
	out.Substate = direct.Enum_ToProto[pb.JobStatus_Substate](mapCtx, in.Substate)
	return out
}

func JupyterConfig_v1alpha1_ToProto added in v1.152.0 

func JupyterConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.JupyterConfig) *pb.JupyterConfig

func LoggingConfig_v1alpha1_FromProto added in v1.151.0 

func LoggingConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.LoggingConfig) *krm.LoggingConfig

func LoggingConfig_v1alpha1_ToProto added in v1.151.0 

func LoggingConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.LoggingConfig) *pb.LoggingConfig

func ManagedGroupConfigObservedState_v1alpha1_FromProto added in v1.151.0 

func ManagedGroupConfigObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ManagedGroupConfig) *krmdataprocv1alpha1.ManagedGroupConfigObservedState

found existing non-generated mapping function "LoggingConfig_v1alpha1_ToProto", skipping 

func LoggingConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.LoggingConfig) *pb.LoggingConfig {
	if in == nil {
		return nil
	}
	out := &pb.LoggingConfig{}
	// MISSING: DriverLogLevels
	return out
}

func ManagedGroupConfigObservedState_v1alpha1_ToProto added in v1.151.0 

func ManagedGroupConfigObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.ManagedGroupConfigObservedState) *pb.ManagedGroupConfig

func MapsEqual added in v1.132.0 

func MapsEqual(desired map[string]string, actual map[string]string) bool

func NewBatchModel 

func NewBatchModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewDataprocAutoscalingPolicyModel added in v1.154.0 

func NewDataprocAutoscalingPolicyModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewDataprocClusterModel added in v1.154.0 

func NewDataprocClusterModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewDataprocJobModel added in v1.132.0 

func NewDataprocJobModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewDataprocSessionModel added in v1.154.0 

func NewDataprocSessionModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func PeripheralsConfig_v1alpha1_FromProto added in v1.151.0 

func PeripheralsConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PeripheralsConfig) *krm.PeripheralsConfig

func PeripheralsConfig_v1alpha1_ToProto added in v1.151.0 

func PeripheralsConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PeripheralsConfig) *pb.PeripheralsConfig

func PigJob_QueryFileUri_ToProto 

func PigJob_QueryFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.PigJob_QueryFileUri

found existing non-generated mapping function "PigJob_v1alpha1_ToProto", skipping 

func PigJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.PigJob) *pb.PigJob {
	if in == nil {
		return nil
	}
	out := &pb.PigJob{}
	if oneof := PigJob_QueryFileUri_ToProto(mapCtx, in.QueryFileURI); oneof != nil {
		out.Queries = oneof
	}
	if oneof := QueryList_v1alpha1_ToProto(mapCtx, in.QueryList); oneof != nil {
		out.Queries = &pb.PigJob_QueryList{QueryList: oneof}
	}
	out.ContinueOnFailure = direct.ValueOf(in.ContinueOnFailure)
	out.ScriptVariables = in.ScriptVariables
	out.Properties = in.Properties
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func PigJob_QueryFileUri_v1alpha1_ToProto added in v1.151.0 

func PigJob_QueryFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.PigJob_QueryFileUri

func PigJob_v1alpha1_FromProto added in v1.151.0 

func PigJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PigJob) *krm.PigJob

func PigJob_v1alpha1_ToProto added in v1.151.0 

func PigJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PigJob) *pb.PigJob

func PrestoJob_QueryFileUri_ToProto 

func PrestoJob_QueryFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.PrestoJob_QueryFileUri

found existing non-generated mapping function "PrestoJob_v1alpha1_ToProto", skipping 

func PrestoJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.PrestoJob) *pb.PrestoJob {
	if in == nil {
		return nil
	}
	out := &pb.PrestoJob{}
	if oneof := PrestoJob_QueryFileUri_ToProto(mapCtx, in.QueryFileURI); oneof != nil {
		out.Queries = oneof
	}
	if oneof := QueryList_v1alpha1_ToProto(mapCtx, in.QueryList); oneof != nil {
		out.Queries = &pb.PrestoJob_QueryList{QueryList: oneof}
	}
	out.ContinueOnFailure = direct.ValueOf(in.ContinueOnFailure)
	out.OutputFormat = direct.ValueOf(in.OutputFormat)
	out.ClientTags = in.ClientTags
	out.Properties = in.Properties
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func PrestoJob_QueryFileUri_v1alpha1_ToProto added in v1.151.0 

func PrestoJob_QueryFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.PrestoJob_QueryFileUri

func PrestoJob_v1alpha1_FromProto added in v1.151.0 

func PrestoJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PrestoJob) *krm.PrestoJob

func PrestoJob_v1alpha1_ToProto added in v1.151.0 

func PrestoJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PrestoJob) *pb.PrestoJob

func PyPiRepositoryConfig_v1alpha1_FromProto added in v1.151.0 

func PyPiRepositoryConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PyPiRepositoryConfig) *krm.PyPiRepositoryConfig

func PyPiRepositoryConfig_v1alpha1_ToProto added in v1.151.0 

func PyPiRepositoryConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PyPiRepositoryConfig) *pb.PyPiRepositoryConfig

func PySparkBatch_v1alpha1_FromProto added in v1.151.0 

func PySparkBatch_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PySparkBatch) *krm.PySparkBatch

func PySparkBatch_v1alpha1_ToProto added in v1.151.0 

func PySparkBatch_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PySparkBatch) *pb.PySparkBatch

func PySparkJob_v1alpha1_FromProto added in v1.151.0 

func PySparkJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PySparkJob) *krm.PySparkJob

func PySparkJob_v1alpha1_ToProto added in v1.151.0 

func PySparkJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PySparkJob) *pb.PySparkJob

func QueryList_v1alpha1_FromProto added in v1.151.0 

func QueryList_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.QueryList) *krm.QueryList

func QueryList_v1alpha1_ToProto added in v1.151.0 

func QueryList_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.QueryList) *pb.QueryList

func RepositoryConfig_v1alpha1_FromProto added in v1.151.0 

func RepositoryConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.RepositoryConfig) *krm.RepositoryConfig

func RepositoryConfig_v1alpha1_ToProto added in v1.151.0 

func RepositoryConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.RepositoryConfig) *pb.RepositoryConfig

func RuntimeConfig_v1alpha1_FromProto added in v1.151.0 

func RuntimeConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.RuntimeConfig) *krm.RuntimeConfig

func RuntimeConfig_v1alpha1_ToProto added in v1.151.0 

func RuntimeConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.RuntimeConfig) *pb.RuntimeConfig

func RuntimeInfoObservedState_v1alpha1_FromProto added in v1.151.0 

func RuntimeInfoObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.RuntimeInfo) *krm.RuntimeInfoObservedState

func RuntimeInfoObservedState_v1alpha1_ToProto added in v1.151.0 

func RuntimeInfoObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.RuntimeInfoObservedState) *pb.RuntimeInfo

func RuntimeInfo_v1alpha1_FromProto added in v1.151.0 

func RuntimeInfo_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.RuntimeInfo) *krm.RuntimeInfo

func RuntimeInfo_v1alpha1_ToProto added in v1.151.0 

func RuntimeInfo_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.RuntimeInfo) *pb.RuntimeInfo

func SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_FromProto added in v1.151.0 

func SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceGroupAutoscalingPolicyConfig) *krm.SecondaryInstanceGroupAutoscalingPolicyConfig

func SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto added in v1.151.0 

func SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.SecondaryInstanceGroupAutoscalingPolicyConfig) *pb.InstanceGroupAutoscalingPolicyConfig

func Session_SessionStateHistoryObservedState_v1alpha1_FromProto added in v1.152.0 

func Session_SessionStateHistoryObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Session_SessionStateHistory) *krmdataprocv1alpha1.Session_SessionStateHistoryObservedState

found existing non-generated mapping function "SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto", skipping 

func SecondaryInstanceGroupAutoscalingPolicyConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.SecondaryInstanceGroupAutoscalingPolicyConfig) *pb.InstanceGroupAutoscalingPolicyConfig {
	if in == nil {
		return nil
	}
	out := &pb.InstanceGroupAutoscalingPolicyConfig{}
	out.MinInstances = direct.ValueOf(in.MinInstances)
	out.MaxInstances = direct.ValueOf(in.MaxInstances)
	out.Weight = direct.ValueOf(in.Weight)
	return out
}

func Session_SessionStateHistoryObservedState_v1alpha1_ToProto added in v1.152.0 

func Session_SessionStateHistoryObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.Session_SessionStateHistoryObservedState) *pb.Session_SessionStateHistory

func SparkBatch_MainClass_ToProto 

func SparkBatch_MainClass_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkBatch_MainClass

func SparkBatch_MainClass_v1alpha1_ToProto added in v1.151.0 

func SparkBatch_MainClass_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkBatch_MainClass

func SparkBatch_MainJarFileUri_ToProto 

func SparkBatch_MainJarFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkBatch_MainJarFileUri

found existing non-generated mapping function "SparkBatch_v1alpha1_ToProto", skipping 

func SparkBatch_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.SparkBatch) *pb.SparkBatch {
	if in == nil {
		return nil
	}
	out := &pb.SparkBatch{}
	if oneof := SparkBatch_MainJarFileUri_ToProto(mapCtx, in.MainJarFileURI); oneof != nil {
		out.Driver = oneof
	}
	if oneof := SparkBatch_MainClass_ToProto(mapCtx, in.MainClass); oneof != nil {
		out.Driver = oneof
	}
	out.Args = in.Args
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	// MISSING: FileUris
	// (near miss): "FileUris" vs "FileURIs"
	// MISSING: ArchiveUris
	// (near miss): "ArchiveUris" vs "ArchiveURIs"
	return out
}

func SparkBatch_MainJarFileUri_v1alpha1_ToProto added in v1.151.0 

func SparkBatch_MainJarFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkBatch_MainJarFileUri

func SparkBatch_v1alpha1_FromProto added in v1.151.0 

func SparkBatch_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkBatch) *krm.SparkBatch

func SparkBatch_v1alpha1_ToProto added in v1.151.0 

func SparkBatch_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkBatch) *pb.SparkBatch

func SparkConnectConfig_v1alpha1_FromProto added in v1.153.0 

func SparkConnectConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkConnectConfig) *krmdataprocv1alpha1.SparkConnectConfig

func SparkConnectConfig_v1alpha1_ToProto added in v1.153.0 

func SparkConnectConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.SparkConnectConfig) *pb.SparkConnectConfig

func SparkHistoryServerConfig_v1alpha1_FromProto added in v1.151.0 

func SparkHistoryServerConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkHistoryServerConfig) *krm.SparkHistoryServerConfig

func SparkHistoryServerConfig_v1alpha1_ToProto added in v1.151.0 

func SparkHistoryServerConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkHistoryServerConfig) *pb.SparkHistoryServerConfig

func SparkJob_MainClass_ToProto 

func SparkJob_MainClass_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkJob_MainClass

func SparkJob_MainClass_v1alpha1_ToProto added in v1.151.0 

func SparkJob_MainClass_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkJob_MainClass

func SparkJob_MainJarFileUri_ToProto 

func SparkJob_MainJarFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkJob_MainJarFileUri

found existing non-generated mapping function "SparkJob_v1alpha1_ToProto", skipping 

func SparkJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.SparkJob) *pb.SparkJob {
	if in == nil {
		return nil
	}
	out := &pb.SparkJob{}
	if oneof := SparkJob_MainJarFileUri_ToProto(mapCtx, in.MainJarFileURI); oneof != nil {
		out.Driver = oneof
	}
	if oneof := SparkJob_MainClass_ToProto(mapCtx, in.MainClass); oneof != nil {
		out.Driver = oneof
	}
	out.Args = in.Args
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	// MISSING: FileUris
	// (near miss): "FileUris" vs "FileURIs"
	// MISSING: ArchiveUris
	// (near miss): "ArchiveUris" vs "ArchiveURIs"
	out.Properties = in.Properties
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func SparkJob_MainJarFileUri_v1alpha1_ToProto added in v1.151.0 

func SparkJob_MainJarFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkJob_MainJarFileUri

func SparkJob_v1alpha1_FromProto added in v1.151.0 

func SparkJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkJob) *krm.SparkJob

func SparkJob_v1alpha1_ToProto added in v1.151.0 

func SparkJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkJob) *pb.SparkJob

func SparkRBatch_v1alpha1_FromProto added in v1.151.0 

func SparkRBatch_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkRBatch) *krm.SparkRBatch

func SparkRBatch_v1alpha1_ToProto added in v1.151.0 

func SparkRBatch_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkRBatch) *pb.SparkRBatch

func SparkRJob_v1alpha1_FromProto added in v1.151.0 

func SparkRJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkRJob) *krm.SparkRJob

func SparkRJob_v1alpha1_ToProto added in v1.151.0 

func SparkRJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkRJob) *pb.SparkRJob

func SparkSQLBatch_v1alpha1_FromProto added in v1.151.0 

func SparkSQLBatch_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkSqlBatch) *krm.SparkSQLBatch

func SparkSQLBatch_v1alpha1_ToProto added in v1.151.0 

func SparkSQLBatch_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkSQLBatch) *pb.SparkSqlBatch

func SparkSQLJob_QueryFileUri_ToProto 

func SparkSQLJob_QueryFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkSqlJob_QueryFileUri

found existing non-generated mapping function "SparkSQLJob_v1alpha1_ToProto", skipping 

func SparkSQLJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.SparkSQLJob) *pb.SparkSqlJob {
	if in == nil {
		return nil
	}
	out := &pb.SparkSqlJob{}
	if oneof := SparkSQLJob_QueryFileUri_ToProto(mapCtx, in.QueryFileURI); oneof != nil {
		out.Queries = oneof
	}
	if oneof := QueryList_v1alpha1_ToProto(mapCtx, in.QueryList); oneof != nil {
		out.Queries = &pb.SparkSqlJob_QueryList{QueryList: oneof}
	}
	out.ScriptVariables = in.ScriptVariables
	out.Properties = in.Properties
	// MISSING: JarFileUris
	// (near miss): "JarFileUris" vs "JarFileURIs"
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func SparkSQLJob_QueryFileUri_v1alpha1_ToProto added in v1.151.0 

func SparkSQLJob_QueryFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.SparkSqlJob_QueryFileUri

func SparkSQLJob_v1alpha1_FromProto added in v1.151.0 

func SparkSQLJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SparkSqlJob) *krm.SparkSQLJob

func SparkSQLJob_v1alpha1_ToProto added in v1.151.0 

func SparkSQLJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.SparkSQLJob) *pb.SparkSqlJob

func StartupConfig_v1alpha1_FromProto added in v1.151.0 

func StartupConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.StartupConfig) *krmdataprocv1alpha1.StartupConfig

func StartupConfig_v1alpha1_ToProto added in v1.151.0 

func StartupConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.StartupConfig) *pb.StartupConfig

func TrinoJob_QueryFileUri_ToProto 

func TrinoJob_QueryFileUri_ToProto(mapCtx *direct.MapContext, in *string) *pb.TrinoJob_QueryFileUri

found existing non-generated mapping function "TrinoJob_v1alpha1_ToProto", skipping 

func TrinoJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmdataprocv1alpha1.TrinoJob) *pb.TrinoJob {
	if in == nil {
		return nil
	}
	out := &pb.TrinoJob{}
	if oneof := TrinoJob_QueryFileUri_ToProto(mapCtx, in.QueryFileURI); oneof != nil {
		out.Queries = oneof
	}
	if oneof := QueryList_v1alpha1_ToProto(mapCtx, in.QueryList); oneof != nil {
		out.Queries = &pb.TrinoJob_QueryList{QueryList: oneof}
	}
	out.ContinueOnFailure = direct.ValueOf(in.ContinueOnFailure)
	out.OutputFormat = direct.ValueOf(in.OutputFormat)
	out.ClientTags = in.ClientTags
	out.Properties = in.Properties
	out.LoggingConfig = LoggingConfig_v1alpha1_ToProto(mapCtx, in.LoggingConfig)
	return out
}

func TrinoJob_QueryFileUri_v1alpha1_ToProto added in v1.151.0 

func TrinoJob_QueryFileUri_v1alpha1_ToProto(mapCtx *direct.MapContext, in *string) *pb.TrinoJob_QueryFileUri

func TrinoJob_v1alpha1_FromProto added in v1.151.0 

func TrinoJob_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.TrinoJob) *krm.TrinoJob

func TrinoJob_v1alpha1_ToProto added in v1.151.0 

func TrinoJob_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.TrinoJob) *pb.TrinoJob

func UsageMetrics_v1alpha1_FromProto added in v1.151.0 

func UsageMetrics_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.UsageMetrics) *krm.UsageMetrics

func UsageMetrics_v1alpha1_ToProto added in v1.151.0 

func UsageMetrics_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.UsageMetrics) *pb.UsageMetrics

func UsageSnapshot_v1alpha1_FromProto added in v1.151.0 

func UsageSnapshot_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.UsageSnapshot) *krm.UsageSnapshot

func UsageSnapshot_v1alpha1_ToProto added in v1.151.0 

func UsageSnapshot_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.UsageSnapshot) *pb.UsageSnapshot

func YarnApplication_v1alpha1_FromProto added in v1.151.0 

func YarnApplication_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.YarnApplication) *krm.YarnApplication

func YarnApplication_v1alpha1_ToProto added in v1.151.0 

func YarnApplication_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.YarnApplication) *pb.YarnApplication

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

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.