Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 96 for updateStats (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top