Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,550 for deleteRS (0.19 sec)

  1. subprojects/core/src/integTest/groovy/org/gradle/api/tasks/DeleteTaskIntegrationTest.groovy

                import org.gradle.api.internal.tasks.TaskPropertyUtils
    
                task clean(type: Delete) {
                    delete 'foo'
                    delete file('bar')
                    delete files('baz')
    
    
                    doLast {
                        def destroyablePaths = []
                        def propertyWalker = services.get(PropertyWalker)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 20 11:16:24 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor.go

    	}
    }
    
    // DeleteBucket deletes monitoring the 'bucket'
    func (m *Monitor) DeleteBucket(bucket string) {
    	m.tlock.Lock()
    	for opts := range m.bucketsThrottle {
    		if opts.Name == bucket {
    			delete(m.bucketsThrottle, opts)
    		}
    	}
    	m.tlock.Unlock()
    
    	m.mlock.Lock()
    	for opts := range m.bucketsMeasurement {
    		if opts.Name == bucket {
    			delete(m.bucketsMeasurement, opts)
    		}
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. pkg/controller/volume/persistentvolume/pv_controller_base.go

    // deleteVolume runs in worker thread and handles "volume deleted" event.
    func (ctrl *PersistentVolumeController) deleteVolume(ctx context.Context, volume *v1.PersistentVolume) {
    	logger := klog.FromContext(ctx)
    	if err := ctrl.volumes.store.Delete(volume); err != nil {
    		logger.Error(err, "Volume deletion encountered", "volumeName", volume.Name)
    	} else {
    		logger.V(4).Info("volume deleted", "volumeName", volume.Name)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  4. pkg/kube/inject/watcher_test.go

    				g.Expect(err).Should(BeNil())
    			case step.updated != nil:
    				_, err := cms.Update(context.TODO(), step.updated, metav1.UpdateOptions{})
    				g.Expect(err).Should(BeNil())
    			case step.deleted != nil:
    				g.Expect(cms.Delete(context.TODO(), step.deleted.Name, metav1.DeleteOptions{})).
    					Should(Succeed())
    			}
    
    			g.Eventually(func() *Config {
    				mu.Lock()
    				defer mu.Unlock()
    				return newConfig
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. pkg/controller/garbagecollector/graph_builder.go

    					if len(matchingDependents) > 0 {
    						// mark the observed deleted identity as absent
    						gb.absentOwnerCache.Add(deletedIdentity)
    						// attempt to delete dependents that do match the verified deleted identity
    						for _, dep := range matchingDependents {
    							gb.attemptToDelete.Add(dep)
    						}
    					}
    
    					// if the delete event verified existingNode.identity doesn't exist...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  6. pkg/test/framework/components/istio/cleanup.go

    		i.installer.Dump(i.ctx)
    	}
    
    	if i.cfg.DeployIstio {
    		errG := multierror.Group{}
    		// Make sure to clean up primary clusters before remotes, or istiod will recreate some of the CMs that we delete
    		// in the remote clusters before it's deleted.
    		for _, c := range i.ctx.AllClusters().Primaries() {
    			i.cleanupCluster(c, &errG)
    		}
    		for _, c := range i.ctx.Clusters().Remotes() {
    			i.cleanupCluster(c, &errG)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    		// DeleteOptions does not have these fields.
    		delete(inMap, "fieldManager")
    		delete(inMap, "fieldValidation")
    
    		// UpdateOptions does not have these fields.
    		delete(outMap, "gracePeriodSeconds")
    		delete(outMap, "preconditions")
    		delete(outMap, "orphanDependents")
    		delete(outMap, "propagationPolicy")
    
    		// Compare the results.
    		inBytes, err = json.Marshal(inMap)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  8. operator/pkg/controller/istiocontrolplane/errdict.go

    			"not be fully removed.",
    		LikelyCause: formatCauses(likelyCauseAPIServer),
    		Action:      "Delete and re-add the IstioOperator resource. " + actionIfErrPersistsCheckBugList,
    	}
    	operatorFailedToRemoveFinalizer = &structured.Error{
    		MoreInfo: "The finalizer set by the operator controller could not be removed " +
    			"when the IstioOperator resource was deleted.",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. cmd/bucket-object-lock.go

    		case objectlock.RetGovernance:
    			// In governance mode, users can't overwrite or delete an object
    			// version or alter its lock settings unless they have special
    			// permissions. With governance mode, you protect objects against
    			// being deleted by most users, but you can still grant some users
    			// permission to alter the retention settings or delete the object
    			// if necessary. You can also use governance mode to test retention-period
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceentry/store.go

    		ikey := makeInstanceKey(i)
    		s.instancesByHostAndPort.Delete(hostPort{ikey, i.ServicePort.Port})
    		oldInstances := s.instances[ikey][key]
    		delete(s.instances[ikey], key)
    		if len(s.instances[ikey]) == 0 {
    			delete(s.instances, ikey)
    		}
    		delete(s.ip2instance, i.Endpoint.Address)
    		// Cleanup stale IPs, if the IPs changed
    		for _, oi := range oldInstances {
    			s.instancesByHostAndPort.Delete(hostPort{ikey, oi.ServicePort.Port})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top