Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for SetCRDCondition (0.2 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/helpers_test.go

    		crdCondition         []CustomResourceDefinitionCondition
    		newCondition         CustomResourceDefinitionCondition
    		expectedcrdCondition []CustomResourceDefinitionCondition
    	}{
    		{
    			name: "test setCRDcondition when one condition",
    			crdCondition: []CustomResourceDefinitionCondition{
    				{
    					Type:               Established,
    					Status:             ConditionTrue,
    					Reason:             "Accepted",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 17 19:08:05 UTC 2019
    - 15.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		cond, deleteErr := c.deleteInstances(crd)
    		apiextensionshelpers.SetCRDCondition(crd, cond)
    		if deleteErr != nil {
    			if _, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{}); err != nil {
    				utilruntime.HandleError(err)
    			}
    			return deleteErr
    		}
    	} else {
    		apiextensionshelpers.SetCRDCondition(crd, apiextensionsv1.CustomResourceDefinitionCondition{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/apihelpers/helpers_test.go

    		newCondition         apiextensionsv1.CustomResourceDefinitionCondition
    		expectedcrdCondition []apiextensionsv1.CustomResourceDefinitionCondition
    	}{
    		{
    			name: "test setCRDcondition when one condition",
    			crdCondition: []apiextensionsv1.CustomResourceDefinitionCondition{
    				{
    					Type:               apiextensionsv1.Established,
    					Status:             apiextensionsv1.ConditionTrue,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 03 16:49:27 UTC 2019
    - 20.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/apihelpers/helpers.go

    	}
    }
    
    // SetCRDCondition sets the status condition. It either overwrites the existing one or creates a new one.
    func SetCRDCondition(crd *apiextensionsv1.CustomResourceDefinition, newCondition apiextensionsv1.CustomResourceDefinitionCondition) {
    	newCondition.LastTransitionTime = metav1.NewTime(time.Now())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 03 16:49:27 UTC 2019
    - 9.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/helpers.go

    import (
    	"fmt"
    	"time"
    
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    )
    
    var swaggerMetadataDescriptions = metav1.ObjectMeta{}.SwaggerDoc()
    
    // SetCRDCondition sets the status condition. It either overwrites the existing one or creates a new one.
    func SetCRDCondition(crd *CustomResourceDefinition, newCondition CustomResourceDefinitionCondition) {
    	newCondition.LastTransitionTime = metav1.NewTime(time.Now())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 27 10:54:44 UTC 2019
    - 9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go

    		Type:    apiextensionsv1.Established,
    		Status:  apiextensionsv1.ConditionTrue,
    		Reason:  "InitialNamesAccepted",
    		Message: "the initial names have been accepted",
    	}
    	apiextensionshelpers.SetCRDCondition(crd, establishedCondition)
    
    	// Update server with new CRD condition.
    	_, err = ec.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

    		return nil
    	}
    
    	crd := inCustomResourceDefinition.DeepCopy()
    	crd.Status.AcceptedNames = acceptedNames
    	apiextensionshelpers.SetCRDCondition(crd, namingCondition)
    	apiextensionshelpers.SetCRDCondition(crd, establishedCondition)
    
    	updatedObj, err := c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/etcd.go

    					existingCRD.Finalizers = append(existingCRD.Finalizers, apiextensions.CustomResourceCleanupFinalizer)
    				}
    				// update the status condition too
    				apiextensions.SetCRDCondition(existingCRD, apiextensions.CustomResourceDefinitionCondition{
    					Type:    apiextensions.Terminating,
    					Status:  apiextensions.ConditionTrue,
    					Reason:  "InstanceDeletionPending",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:19 UTC 2022
    - 8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go

    		// no need to update annotation because we took no action.
    		return nil
    	}
    
    	// update condition
    	crd := inCustomResourceDefinition.DeepCopy()
    	apihelpers.SetCRDCondition(crd, *cond)
    
    	_, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    	if cond == nil {
    		apiextensionshelpers.RemoveCRDCondition(crd, apiextensionsv1.NonStructuralSchema)
    	} else {
    		cond.LastTransitionTime = metav1.NewTime(time.Now())
    		apiextensionshelpers.SetCRDCondition(crd, *cond)
    	}
    
    	_, err = c.crdClient.CustomResourceDefinitions().UpdateStatus(context.TODO(), crd, metav1.UpdateOptions{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top