Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,631 for deleteRS (0.18 sec)

  1. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	// Act
    	dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName)
    	volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName)
    	if volumeExists {
    		t.Fatalf(
    			"Deleted pod %q from volume %q/node %q. Volume should also be deleted but it still exists.",
    			podName,
    			generatedVolumeName,
    			nodeName)
    	}
    	asw.SetVolumesMountedByNode(logger, []v1.UniqueVolumeName{generatedVolumeName}, nodeName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  2. pilot/pkg/model/push_context_test.go

    				total1 := 0
    				// Validate that empty namespace is deleted when all filters in that namespace are deleted.
    				for ns, envoyFilters := range pc1.envoyFiltersByNamespace {
    					total1 += len(envoyFilters)
    					deleted := 0
    					for _, ef := range envoyFilters {
    						key := ConfigKey{Kind: kind.EnvoyFilter, Namespace: ns, Name: ef.Name}
    						if deletes.Contains(key) {
    							deleted++
    						}
    					}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/tokens_controller.go

    	// syncSecretQueue handles secret events:
    	//   * deletes tokens whose service account no longer exists
    	//   * updates tokens with missing token or namespace data, or mismatched ca data
    	//   * ensures service account secret references are removed for tokens which are deleted
    	// key is a secretQueueKey{}
    	syncSecretQueue workqueue.TypedRateLimitingInterface[secretQueueKey]
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  4. subprojects/core/src/test/groovy/org/gradle/api/internal/file/DefaultFileOperationsTest.groovy

            !result.didWork
        }
    
        def deletes() {
            def fileToBeDeleted = tmpDir.file("file")
            def fileCollection = Stub(FileCollectionInternal)
            fileCollectionFactory.resolving(["file"] as Object[]) >> fileCollection
            fileCollection.iterator() >> [fileToBeDeleted].iterator()
            fileToBeDeleted.touch()
    
            expect:
            fileOperations.delete('file') == true
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 26 15:15:04 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. pkg/controller/garbagecollector/garbagecollector.go

    	// system. If it's not a valid resource, the garbage collector should i)
    	// ignore the reference when decide if the object should be deleted, and
    	// ii) should update the object to remove such references. This is to
    	// prevent objects having references to an old resource from being
    	// deleted during a cluster upgrade.
    	resource, namespaced, err := gc.apiResource(reference.APIVersion, reference.Kind)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/pv_controller_test.go

    				return nil
    			},
    		},
    		{
    			// deleteClaim with a bound claim makes bound volume released with external deleter.
    			// delete the corresponding volume from apiserver, and report latency metric
    			name: "5-5 - delete claim and delete volume report metric",
    			initialVolumes: volumesWithAnnotation(volume.AnnDynamicallyProvisioned, "gcr.io/vendor-csi",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  7. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/AssignImmutableWorkspaceStep.java

        private final Deleter deleter;
        private final FileSystemAccess fileSystemAccess;
    
        private final ImmutableWorkspaceMetadataStore workspaceMetadataStore;
        private final OutputSnapshotter outputSnapshotter;
        private final Step<? super PreviousExecutionContext, ? extends CachingResult> delegate;
    
        public AssignImmutableWorkspaceStep(
            Deleter deleter,
            FileSystemAccess fileSystemAccess,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 19 16:44:11 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    		return framework.QueueSkip, nil
    	}
    
    	// Pod is deleted. Return Queue when the deleted Pod has a label that matches with topologySpread's selector.
    	if podLabelsMatchSpreadConstraints(constraints, originalPod.Labels) {
    		logger.V(5).Info("a scheduled pod which matches with the pod's topology spread constraints was deleted, and the pod may be schedulable now",
    			"pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. pkg/proxy/conntrack/conntrack.go

    	utilnet "k8s.io/utils/net"
    )
    
    // Interface for dealing with conntrack
    type Interface interface {
    	// ClearEntriesForIP deletes conntrack entries for connections of the given
    	// protocol, to the given IP.
    	ClearEntriesForIP(ip string, protocol v1.Protocol) error
    
    	// ClearEntriesForPort deletes conntrack entries for connections of the given
    	// protocol and IP family, to the given port.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. plugin/pkg/auth/authorizer/node/graph.go

    	for _, edge := range edgesToRemoveFromIndexes {
    		g.removeEdgeFromDestinationIndex_locked(edge)
    	}
    }
    
    // must be called under write lock
    // deletes edges from a given vertex type to a specific vertex
    // will delete each orphaned "from" vertex, but will never delete the "to" vertex
    func (g *Graph) deleteEdges_locked(fromType, toType vertexType, toNamespace, toName string) {
    	// get the "to" side
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
Back to top