- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for updateStats (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)