Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 123 for updateStats (0.31 sec)

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