- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 123 for updateStats (0.31 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go
if err != nil { t.Fatalf("unexpected error: %v", err) } // UpdateStatus should not update spec. // Check that .spec.num = 10 and .status.num = 20 updatedStatusInstance, err := noxuResourceClient.UpdateStatus(context.TODO(), gottenNoxuInstance, metav1.UpdateOptions{}) if err != nil { t.Fatalf("unable to update status: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 12 17:35:34 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
Status: apiextensionsv1.ConditionTrue, Reason: "InstanceDeletionInProgress", Message: "CustomResource deletion is in progress", }) crd, 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 - 12.6K bytes - Viewed (0) -
pkg/controller/deployment/sync.go
deploymentutil.SetDeploymentCondition(&d.Status, *condition) needsUpdate = true } if !needsUpdate { return nil } var err error _, err = dc.client.AppsV1().Deployments(d.Namespace).UpdateStatus(ctx, d, metav1.UpdateOptions{}) return err } // getAllReplicaSetsAndSyncRevision returns all the replica sets for the provided deployment (new and all old), with new RS's and deployment's revision updated. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
pkg/controller/certificates/signer/signer.go
Status: v1.ConditionTrue, Reason: "SignerValidationFailure", Message: err.Error(), LastUpdateTime: metav1.Now(), }) _, err = s.client.CertificatesV1().CertificateSigningRequests().UpdateStatus(ctx, csr, metav1.UpdateOptions{}) if err != nil { return fmt.Errorf("error adding failure condition for csr: %v", err) } return nil } else if !recognized {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 10.3K 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/controller/statefulset/stateful_set_status_updater.go
set.Status = *status // TODO: This context.TODO should use a real context once we have RetryOnConflictWithContext _, updateErr := ssu.client.AppsV1().StatefulSets(set.Namespace).UpdateStatus(context.TODO(), set, metav1.UpdateOptions{}) if updateErr == nil { return nil } if updated, err := ssu.setLister.StatefulSets(set.Namespace).Get(set.Name); err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K 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) -
pilot/pkg/config/kube/crdclient/client.go
if err != nil { return "", err } return meta.GetResourceVersion(), nil } func (cl *Client) UpdateStatus(cfg config.Config) (string, error) { if cfg.Status == nil { return "", fmt.Errorf("nil status for %v/%v on updateStatus()", cfg.Name, cfg.Namespace) } meta, err := updateStatus(cl.client, cfg, getObjectMetadata(cfg)) if err != nil { return "", err } return meta.GetResourceVersion(), nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
tests/integration/pilot/analysis/analysis_test.go
} // append to conditions we.Status.Conditions = append(we.Status.Conditions, addedConds...) // update the status _, err = t.Clusters().Default().Istio().NetworkingV1alpha3().WorkloadEntries(ns.Name()).UpdateStatus(context.TODO(), we, metav1.UpdateOptions{}) if err != nil { t.Error(err) } // we should have all the conditions present retry.UntilSuccessOrFail(t, func() error { // should update
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PurgeLogJob.java
logger.error("Failed to purge user info.", e); resultBuf.append(e.getMessage()).append("\n"); } // update job logs try { jobLogService.updateStatus(); } catch (final Exception e) { logger.error("Failed to purge job logs.", e); resultBuf.append(e.getMessage()).append("\n"); } return resultBuf.toString(); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.7K bytes - Viewed (0)