run

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 BinaryAuthorization_UseDefault_ToProto 

func BinaryAuthorization_UseDefault_ToProto(mapCtx *direct.MapContext, in *bool) *pb.BinaryAuthorization_UseDefault

func BinaryAuthorization_v1alpha1_FromProto added in v1.154.0 

func BinaryAuthorization_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.BinaryAuthorization) *krmrunv1alpha1.BinaryAuthorization

func BinaryAuthorization_v1alpha1_ToProto added in v1.154.0 

func BinaryAuthorization_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.BinaryAuthorization) *pb.BinaryAuthorization

func BinaryAuthorization_v1beta1_FromProto added in v1.154.0 

func BinaryAuthorization_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BinaryAuthorization) *krm.BinaryAuthorization

func BinaryAuthorization_v1beta1_ToProto added in v1.154.0 

func BinaryAuthorization_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BinaryAuthorization) *pb.BinaryAuthorization

func BuildInfoObservedState_v1alpha1_FromProto added in v1.154.0 

func BuildInfoObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.BuildInfo) *krmrunv1alpha1.BuildInfoObservedState

func BuildInfoObservedState_v1alpha1_ToProto added in v1.154.0 

func BuildInfoObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.BuildInfoObservedState) *pb.BuildInfo

func CloudSQLInstance_v1alpha1_FromProto added in v1.154.0 

func CloudSQLInstance_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlInstance) *krmrunv1alpha1.CloudSQLInstance

func CloudSQLInstance_v1alpha1_ToProto added in v1.154.0 

func CloudSQLInstance_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.CloudSQLInstance) *pb.CloudSqlInstance

func CloudSQLInstance_v1beta1_FromProto added in v1.154.0 

func CloudSQLInstance_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.CloudSqlInstance) *krm.CloudSQLInstance

func CloudSQLInstance_v1beta1_ToProto added in v1.154.0 

func CloudSQLInstance_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.CloudSQLInstance) *pb.CloudSqlInstance

func Condition_ExecutionReason_ToProto 

func Condition_ExecutionReason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_ExecutionReason_

func Condition_Reason_ToProto 

func Condition_Reason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_Reason

func Condition_RevisionReason_ToProto 

func Condition_RevisionReason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_RevisionReason_

func Condition_v1beta1_FromProto added in v1.154.0 

func Condition_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Condition) *krm.Condition

func Condition_v1beta1_ToProto added in v1.154.0 

func Condition_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Condition) *pb.Condition

func ContainerObservedState_v1alpha1_FromProto added in v1.154.0 

func ContainerObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Container) *krmrunv1alpha1.ContainerObservedState

func ContainerObservedState_v1alpha1_ToProto added in v1.154.0 

func ContainerObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.ContainerObservedState) *pb.Container

func ContainerPort_v1alpha1_FromProto added in v1.154.0 

func ContainerPort_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ContainerPort) *krmrunv1alpha1.ContainerPort

func ContainerPort_v1alpha1_ToProto added in v1.154.0 

func ContainerPort_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.ContainerPort) *pb.ContainerPort

func ContainerPort_v1beta1_FromProto added in v1.154.0 

func ContainerPort_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ContainerPort) *krm.ContainerPort

func ContainerPort_v1beta1_ToProto added in v1.154.0 

func ContainerPort_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ContainerPort) *pb.ContainerPort

func Container_v1alpha1_FromProto added in v1.154.0 

func Container_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Container) *krmrunv1alpha1.Container

func Container_v1alpha1_ToProto added in v1.154.0 

func Container_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.Container) *pb.Container

func Container_v1beta1_FromProto added in v1.154.0 

func Container_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Container) *krm.Container

func Container_v1beta1_ToProto added in v1.154.0 

func Container_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Container) *pb.Container

func EmptyDirVolumeSource_v1alpha1_FromProto added in v1.154.0 

func EmptyDirVolumeSource_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EmptyDirVolumeSource) *krmrunv1alpha1.EmptyDirVolumeSource

func EmptyDirVolumeSource_v1alpha1_ToProto added in v1.154.0 

func EmptyDirVolumeSource_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.EmptyDirVolumeSource) *pb.EmptyDirVolumeSource

func EmptyDirVolumeSource_v1beta1_FromProto added in v1.154.0 

func EmptyDirVolumeSource_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EmptyDirVolumeSource) *krm.EmptyDirVolumeSource

func EmptyDirVolumeSource_v1beta1_ToProto added in v1.154.0 

func EmptyDirVolumeSource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.EmptyDirVolumeSource) *pb.EmptyDirVolumeSource

func EnvVarSource_v1alpha1_FromProto added in v1.154.0 

func EnvVarSource_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EnvVarSource) *krmrunv1alpha1.EnvVarSource

func EnvVarSource_v1alpha1_ToProto added in v1.154.0 

func EnvVarSource_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.EnvVarSource) *pb.EnvVarSource

func EnvVarSource_v1beta1_FromProto added in v1.154.0 

func EnvVarSource_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EnvVarSource) *krm.EnvVarSource

func EnvVarSource_v1beta1_ToProto added in v1.154.0 

func EnvVarSource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.EnvVarSource) *pb.EnvVarSource

func EnvVar_Value_ToProto 

func EnvVar_Value_ToProto(mapCtx *direct.MapContext, in *string) *pb.EnvVar_Value

func EnvVar_v1alpha1_FromProto added in v1.154.0 

func EnvVar_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EnvVar) *krmrunv1alpha1.EnvVar

func EnvVar_v1alpha1_ToProto added in v1.154.0 

func EnvVar_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.EnvVar) *pb.EnvVar

func EnvVar_v1beta1_FromProto added in v1.154.0 

func EnvVar_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EnvVar) *krm.EnvVar

func EnvVar_v1beta1_ToProto added in v1.154.0 

func EnvVar_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.EnvVar) *pb.EnvVar

func ExecutionReference_v1beta1_FromProto added in v1.154.0 

func ExecutionReference_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionReference) *krm.ExecutionReference

func ExecutionReference_v1beta1_ToProto added in v1.154.0 

func ExecutionReference_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionReference) *pb.ExecutionReference

func ExecutionTemplate_v1beta1_FromProto added in v1.154.0 

func ExecutionTemplate_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionTemplate) *krm.ExecutionTemplate

func ExecutionTemplate_v1beta1_ToProto added in v1.154.0 

func ExecutionTemplate_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ExecutionTemplate) *pb.ExecutionTemplate

func GCSVolumeSource_v1alpha1_FromProto added in v1.154.0 

func GCSVolumeSource_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.GCSVolumeSource) *krmrunv1alpha1.GCSVolumeSource

func GCSVolumeSource_v1alpha1_ToProto added in v1.154.0 

func GCSVolumeSource_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.GCSVolumeSource) *pb.GCSVolumeSource

func GCSVolumeSource_v1beta1_FromProto added in v1.154.0 

func GCSVolumeSource_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GCSVolumeSource) *krm.GCSVolumeSource

func GCSVolumeSource_v1beta1_ToProto added in v1.154.0 

func GCSVolumeSource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.GCSVolumeSource) *pb.GCSVolumeSource

func GrpcAction_v1alpha1_FromProto added in v1.154.0 

func GrpcAction_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.GRPCAction) *krmrunv1alpha1.GrpcAction

func GrpcAction_v1alpha1_ToProto added in v1.154.0 

func GrpcAction_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.GrpcAction) *pb.GRPCAction

func HTTPGetAction_v1alpha1_FromProto added in v1.154.0 

func HTTPGetAction_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.HTTPGetAction) *krmrunv1alpha1.HTTPGetAction

func HTTPGetAction_v1alpha1_ToProto added in v1.154.0 

func HTTPGetAction_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.HTTPGetAction) *pb.HTTPGetAction

func HTTPGetAction_v1beta1_FromProto added in v1.154.0 

func HTTPGetAction_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.HTTPGetAction) *krm.HTTPGetAction

func HTTPGetAction_v1beta1_ToProto added in v1.154.0 

func HTTPGetAction_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.HTTPGetAction) *pb.HTTPGetAction

func HTTPHeader_v1alpha1_FromProto added in v1.154.0 

func HTTPHeader_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.HTTPHeader) *krmrunv1alpha1.HTTPHeader

func HTTPHeader_v1alpha1_ToProto added in v1.154.0 

func HTTPHeader_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.HTTPHeader) *pb.HTTPHeader

func HTTPHeader_v1beta1_FromProto added in v1.154.0 

func HTTPHeader_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.HTTPHeader) *krm.HTTPHeader

func HTTPHeader_v1beta1_ToProto added in v1.154.0 

func HTTPHeader_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.HTTPHeader) *pb.HTTPHeader

func InstanceSplitStatus_v1alpha1_FromProto added in v1.154.0 

func InstanceSplitStatus_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceSplitStatus) *krmrunv1alpha1.InstanceSplitStatus

func InstanceSplitStatus_v1alpha1_ToProto added in v1.154.0 

func InstanceSplitStatus_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.InstanceSplitStatus) *pb.InstanceSplitStatus

func InstanceSplit_v1alpha1_FromProto added in v1.154.0 

func InstanceSplit_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.InstanceSplit) *krmrunv1alpha1.InstanceSplit

func InstanceSplit_v1alpha1_ToProto added in v1.154.0 

func InstanceSplit_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.InstanceSplit) *pb.InstanceSplit

func NewJobModel 

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

func NfsVolumeSource_v1alpha1_FromProto added in v1.154.0 

func NfsVolumeSource_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NFSVolumeSource) *krmrunv1alpha1.NfsVolumeSource

func NfsVolumeSource_v1alpha1_ToProto added in v1.154.0 

func NfsVolumeSource_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.NfsVolumeSource) *pb.NFSVolumeSource

func NfsVolumeSource_v1beta1_FromProto added in v1.154.0 

func NfsVolumeSource_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.NFSVolumeSource) *krm.NfsVolumeSource

func NfsVolumeSource_v1beta1_ToProto added in v1.154.0 

func NfsVolumeSource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.NfsVolumeSource) *pb.NFSVolumeSource

func NodeSelector_v1alpha1_FromProto added in v1.154.0 

func NodeSelector_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NodeSelector) *krmrunv1alpha1.NodeSelector

func NodeSelector_v1alpha1_ToProto added in v1.154.0 

func NodeSelector_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.NodeSelector) *pb.NodeSelector

func Probe_v1alpha1_FromProto added in v1.154.0 

func Probe_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Probe) *krmrunv1alpha1.Probe

func Probe_v1alpha1_ToProto added in v1.154.0 

func Probe_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.Probe) *pb.Probe

func Probe_v1beta1_FromProto added in v1.154.0 

func Probe_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Probe) *krm.Probe

func Probe_v1beta1_ToProto added in v1.154.0 

func Probe_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Probe) *pb.Probe

func ResolveRunJobRefs 

func ResolveRunJobRefs(ctx context.Context, kube client.Reader, desired *krm.RunJob) error

func ResolveRunWorkerPoolRefs added in v1.154.0 

func ResolveRunWorkerPoolRefs(ctx context.Context, kube client.Reader, desired *krmrunv1alpha1.RunWorkerPool) error

func ResourceRequirements_v1alpha1_FromProto added in v1.154.0 

func ResourceRequirements_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ResourceRequirements) *krmrunv1alpha1.ResourceRequirements

func ResourceRequirements_v1alpha1_ToProto added in v1.154.0 

func ResourceRequirements_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.ResourceRequirements) *pb.ResourceRequirements

func ResourceRequirements_v1beta1_FromProto added in v1.154.0 

func ResourceRequirements_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ResourceRequirements) *krm.ResourceRequirements

func ResourceRequirements_v1beta1_ToProto added in v1.154.0 

func ResourceRequirements_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ResourceRequirements) *pb.ResourceRequirements

func RunCondition_ExecutionReason_ToProto added in v1.154.0 

func RunCondition_ExecutionReason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_ExecutionReason_

func RunCondition_Reason_ToProto added in v1.154.0 

func RunCondition_Reason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_Reason

func RunCondition_RevisionReason_ToProto added in v1.154.0 

func RunCondition_RevisionReason_ToProto(mapCtx *direct.MapContext, in *string) *pb.Condition_RevisionReason_

func RunCondition_v1alpha1_FromProto added in v1.154.0 

func RunCondition_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Condition) *krmrunv1alpha1.RunCondition

func RunCondition_v1alpha1_ToProto added in v1.154.0 

func RunCondition_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.RunCondition) *pb.Condition

func RunJobObservedState_v1beta1_FromProto added in v1.154.0 

func RunJobObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.RunJobObservedState

func RunJobObservedState_v1beta1_ToProto added in v1.154.0 

func RunJobObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.RunJobObservedState) *pb.Job

func RunJobSpec_v1beta1_FromProto added in v1.154.0 

func RunJobSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Job) *krm.RunJobSpec

func RunJobSpec_v1beta1_ToProto added in v1.154.0 

func RunJobSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.RunJobSpec) *pb.Job

func RunWorkerPoolObservedState_v1alpha1_FromProto added in v1.154.0 

func RunWorkerPoolObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPool) *krmrunv1alpha1.RunWorkerPoolObservedState

func RunWorkerPoolObservedState_v1alpha1_ToProto added in v1.154.0 

func RunWorkerPoolObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.RunWorkerPoolObservedState) *pb.WorkerPool

func RunWorkerPoolSpec_v1alpha1_FromProto added in v1.154.0 

func RunWorkerPoolSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPool) *krmrunv1alpha1.RunWorkerPoolSpec

func RunWorkerPoolSpec_v1alpha1_ToProto added in v1.154.0 

func RunWorkerPoolSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.RunWorkerPoolSpec) *pb.WorkerPool

func SecretKeySelector_v1alpha1_FromProto added in v1.154.0 

func SecretKeySelector_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SecretKeySelector) *krmrunv1alpha1.SecretKeySelector

func SecretKeySelector_v1alpha1_ToProto added in v1.154.0 

func SecretKeySelector_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.SecretKeySelector) *pb.SecretKeySelector

func SecretKeySelector_v1beta1_FromProto added in v1.154.0 

func SecretKeySelector_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.SecretKeySelector) *krm.SecretKeySelector

func SecretKeySelector_v1beta1_ToProto added in v1.154.0 

func SecretKeySelector_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.SecretKeySelector) *pb.SecretKeySelector

func SecretVolumeSource_v1alpha1_FromProto added in v1.154.0 

func SecretVolumeSource_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.SecretVolumeSource) *krmrunv1alpha1.SecretVolumeSource

func SecretVolumeSource_v1alpha1_ToProto added in v1.154.0 

func SecretVolumeSource_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.SecretVolumeSource) *pb.SecretVolumeSource

func SecretVolumeSource_v1beta1_FromProto added in v1.154.0 

func SecretVolumeSource_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.SecretVolumeSource) *krm.SecretVolumeSource

func SecretVolumeSource_v1beta1_ToProto added in v1.154.0 

func SecretVolumeSource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.SecretVolumeSource) *pb.SecretVolumeSource

func ServiceMesh_v1alpha1_FromProto added in v1.154.0 

func ServiceMesh_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ServiceMesh) *krmrunv1alpha1.ServiceMesh

func ServiceMesh_v1alpha1_ToProto added in v1.154.0 

func ServiceMesh_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.ServiceMesh) *pb.ServiceMesh

func TCPSocketAction_v1alpha1_FromProto added in v1.154.0 

func TCPSocketAction_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.TCPSocketAction) *krmrunv1alpha1.TCPSocketAction

func TCPSocketAction_v1alpha1_ToProto added in v1.154.0 

func TCPSocketAction_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.TCPSocketAction) *pb.TCPSocketAction

func TCPSocketAction_v1beta1_FromProto added in v1.154.0 

func TCPSocketAction_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.TCPSocketAction) *krm.TCPSocketAction

func TCPSocketAction_v1beta1_ToProto added in v1.154.0 

func TCPSocketAction_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.TCPSocketAction) *pb.TCPSocketAction

func TaskTemplate_MaxRetries_ToProto 

func TaskTemplate_MaxRetries_ToProto(mapCtx *direct.MapContext, in *int32) *pb.TaskTemplate_MaxRetries

func TaskTemplate_v1beta1_FromProto added in v1.154.0 

func TaskTemplate_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.TaskTemplate) *krm.TaskTemplate

func TaskTemplate_v1beta1_ToProto added in v1.154.0 

func TaskTemplate_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.TaskTemplate) *pb.TaskTemplate

func VPCAccess_NetworkInterface_v1alpha1_FromProto added in v1.154.0 

func VPCAccess_NetworkInterface_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.VpcAccess_NetworkInterface) *krmrunv1alpha1.VPCAccess_NetworkInterface

func VPCAccess_NetworkInterface_v1alpha1_ToProto added in v1.154.0 

func VPCAccess_NetworkInterface_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.VPCAccess_NetworkInterface) *pb.VpcAccess_NetworkInterface

func VPCAccess_NetworkInterface_v1beta1_FromProto added in v1.154.0 

func VPCAccess_NetworkInterface_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VpcAccess_NetworkInterface) *krm.VPCAccess_NetworkInterface

func VPCAccess_NetworkInterface_v1beta1_ToProto added in v1.154.0 

func VPCAccess_NetworkInterface_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.VPCAccess_NetworkInterface) *pb.VpcAccess_NetworkInterface

func VPCAccess_v1alpha1_FromProto added in v1.154.0 

func VPCAccess_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.VpcAccess) *krmrunv1alpha1.VPCAccess

func VPCAccess_v1alpha1_ToProto added in v1.154.0 

func VPCAccess_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.VPCAccess) *pb.VpcAccess

func VPCAccess_v1beta1_FromProto added in v1.154.0 

func VPCAccess_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VpcAccess) *krm.VPCAccess

func VPCAccess_v1beta1_ToProto added in v1.154.0 

func VPCAccess_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.VPCAccess) *pb.VpcAccess

func VersionToPath_v1alpha1_FromProto added in v1.154.0 

func VersionToPath_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.VersionToPath) *krmrunv1alpha1.VersionToPath

func VersionToPath_v1alpha1_ToProto added in v1.154.0 

func VersionToPath_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.VersionToPath) *pb.VersionToPath

func VersionToPath_v1beta1_FromProto added in v1.154.0 

func VersionToPath_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VersionToPath) *krm.VersionToPath

func VersionToPath_v1beta1_ToProto added in v1.154.0 

func VersionToPath_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.VersionToPath) *pb.VersionToPath

func VolumeMount_v1alpha1_FromProto added in v1.154.0 

func VolumeMount_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.VolumeMount) *krmrunv1alpha1.VolumeMount

func VolumeMount_v1alpha1_ToProto added in v1.154.0 

func VolumeMount_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.VolumeMount) *pb.VolumeMount

func VolumeMount_v1beta1_FromProto added in v1.154.0 

func VolumeMount_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VolumeMount) *krm.VolumeMount

func VolumeMount_v1beta1_ToProto added in v1.154.0 

func VolumeMount_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.VolumeMount) *pb.VolumeMount

func Volume_FromProto 

func Volume_FromProto(mapCtx *direct.MapContext, in *pb.Volume) *krm.Volume

func Volume_ToProto 

func Volume_ToProto(mapCtx *direct.MapContext, in *krm.Volume) *pb.Volume

func Volume_v1alpha1_FromProto added in v1.154.0 

func Volume_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Volume) *krmrunv1alpha1.Volume

func Volume_v1alpha1_ToProto added in v1.154.0 

func Volume_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.Volume) *pb.Volume

func Volume_v1beta1_FromProto added in v1.154.0 

func Volume_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Volume) *krm.Volume

func Volume_v1beta1_ToProto added in v1.154.0 

func Volume_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Volume) *pb.Volume

func WorkerPoolRevisionTemplateObservedState_v1alpha1_FromProto added in v1.154.0 

func WorkerPoolRevisionTemplateObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPoolRevisionTemplate) *krmrunv1alpha1.WorkerPoolRevisionTemplateObservedState

func WorkerPoolRevisionTemplateObservedState_v1alpha1_ToProto added in v1.154.0 

func WorkerPoolRevisionTemplateObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.WorkerPoolRevisionTemplateObservedState) *pb.WorkerPoolRevisionTemplate

func WorkerPoolRevisionTemplate_v1alpha1_FromProto added in v1.154.0 

func WorkerPoolRevisionTemplate_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPoolRevisionTemplate) *krmrunv1alpha1.WorkerPoolRevisionTemplate

func WorkerPoolRevisionTemplate_v1alpha1_ToProto added in v1.154.0 

func WorkerPoolRevisionTemplate_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.WorkerPoolRevisionTemplate) *pb.WorkerPoolRevisionTemplate

func WorkerPoolScaling_v1alpha1_FromProto added in v1.154.0 

func WorkerPoolScaling_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkerPoolScaling) *krmrunv1alpha1.WorkerPoolScaling

func WorkerPoolScaling_v1alpha1_ToProto added in v1.154.0 

func WorkerPoolScaling_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmrunv1alpha1.WorkerPoolScaling) *pb.WorkerPoolScaling

Types

type JobAdapter 

type JobAdapter struct {
	// contains filtered or unexported fields
}

func (*JobAdapter) Create 

func (a *JobAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*JobAdapter) Delete 

func (a *JobAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*JobAdapter) Export 

func (a *JobAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*JobAdapter) Find 

func (a *JobAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*JobAdapter) Update 

func (a *JobAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

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.