- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 96 for updateStats (0.16 sec)
-
pilot/pkg/config/aggregate/config.go
if cr.writer == nil { return "", errorUnsupported } return cr.writer.Update(c) } func (cr *store) UpdateStatus(c config.Config) (string, error) { if cr.writer == nil { return "", errorUnsupported } return cr.writer.UpdateStatus(c) } func (cr *store) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) { if cr.writer == nil { return "", errorUnsupported
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 5.4K bytes - Viewed (0) -
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/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) -
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) -
pilot/pkg/model/fake_store.go
if configs != nil { if _, f := configs[cfg.Name]; f { configs[cfg.Name] = cfg return "", nil } } } return "", errors.New("config not found") } func (*FakeStore) UpdateStatus(config config.Config) (string, error) { return "", nil } func (*FakeStore) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) { return "", nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 18 06:50:06 UTC 2023 - 3K bytes - Viewed (0) -
pkg/kube/kclient/client.go
} func (n *writeClient[T]) UpdateStatus(object T) (T, error) { api, ok := kubeclient.GetWriteClient[T](n.client, object.GetNamespace()).(kubetypes.WriteStatusAPI[T]) if !ok { return ptr.Empty[T](), fmt.Errorf("%T does not support UpdateStatus", object) } return api.UpdateStatus(context.Background(), object, metav1.UpdateOptions{}) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0)