Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for updateStats (0.31 sec)

  1. pkg/controller/storageversionmigrator/storageversionmigrator.go

    		}
    	} else {
    		// we can't migrate a resource that doesn't exist in the GC
    		_, err = svmc.kubeClient.StoragemigrationV1alpha1().
    			StorageVersionMigrations().
    			UpdateStatus(
    				ctx,
    				setStatusConditions(toBeProcessedSVM, svmv1alpha1.MigrationFailed, migrationFailedStatusReason),
    				metav1.UpdateOptions{},
    			)
    		if err != nil {
    			return err
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/fake/fake_customresourcedefinition.go

    	if obj == nil {
    		return emptyResult, err
    	}
    	return obj.(*v1beta1.CustomResourceDefinition), err
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake/fake_customresourcedefinition.go

    	if obj == nil {
    		return emptyResult, err
    	}
    	return obj.(*v1.CustomResourceDefinition), err
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. pkg/config/schema/codegen/templates/crdclient.go.tmpl

    		}, metav1.UpdateOptions{})
    	{{- end }}
    {{- end }}
    	default:
    		return nil, fmt.Errorf("unsupported type: %v", cfg.GroupVersionKind)
    	}
    }
    
    func updateStatus(c kube.Client, cfg config.Config, objMeta metav1.ObjectMeta) (metav1.Object, error) {
    	switch cfg.GroupVersionKind {
    {{- range .Entries }}
    	{{- if and (not .Resource.Synthetic) (not .Resource.Builtin) (not (eq .StatusType "")) }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. pkg/controller/storageversionmigrator/resourceversion.go

    		return nil
    	}
    
    	exists, err := rv.resourceExists(gvr)
    	if err != nil {
    		return err
    	}
    	if !exists {
    		_, err = rv.kubeClient.StoragemigrationV1alpha1().
    			StorageVersionMigrations().
    			UpdateStatus(
    				ctx,
    				setStatusConditions(toBeProcessedSVM, svmv1alpha1.MigrationFailed, migrationFailedStatusReason),
    				metav1.UpdateOptions{},
    			)
    		if err != nil {
    			return err
    		}
    
    		return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/reconciler/reconstruct.go

    	}
    
    	if len(reconstructedVolumes) > 0 {
    		// Add the volumes to ASW
    		rc.updateStates(reconstructedVolumes)
    
    		// Remember to update devicePath from node.status.volumesAttached
    		rc.volumesNeedUpdateFromNodeStatus = reconstructedVolumeNames
    	}
    	klog.V(2).InfoS("Volume reconstruction finished")
    }
    
    func (rc *reconciler) updateStates(reconstructedVolumes map[v1.UniqueVolumeName]*globalVolumeInfo) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go

    		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{})
    	if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
    		// deleted or changed in the meantime, we'll get called again
    		return nil
    	}
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go

    		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) {
    		// deleted or changed in the meantime, we'll get called again
    		return nil
    	}
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

    	} 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) {
    		// deleted or changed in the meantime, we'll get called again
    		return nil
    	}
    	if err != nil {
    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