Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,226 for deleteSV (0.14 sec)

  1. pkg/scheduler/util/assumecache/assume_cache.go

    	c.add(newObj)
    }
    
    func (c *AssumeCache) delete(obj interface{}) {
    	if obj == nil {
    		return
    	}
    
    	name, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
    	if err != nil {
    		c.logger.Error(&ObjectNameError{err}, "Failed to delete")
    		return
    	}
    
    	c.rwMutex.Lock()
    	defer c.rwMutex.Unlock()
    
    	objInfo := &objInfo{name: name}
    	err = c.store.Delete(objInfo)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. 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)
  3. staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go

    				return false, nil
    			}
    			if watch.Deleted != watchEvent.Type {
    				return false, fmt.Errorf("expected DELETE, but got %#v", watchEvent)
    			}
    		case <-time.After(5 * time.Second):
    			return false, fmt.Errorf("gave up waiting for watch event")
    		}
    	}
    
    	return true, nil
    }
    
    // DeleteV1CustomResourceDefinition deletes a CRD and waits until it disappears from discovery.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 02:01:40 UTC 2021
    - 21.4K bytes
    - Viewed (0)
  4. pkg/controller/serviceaccount/tokens_controller_test.go

    		},
    
    		"deleted serviceaccount with no secrets": {
    			DeletedServiceAccount: serviceAccount(emptySecretReferences()),
    			ExpectedActions:       []core.Action{},
    		},
    		"deleted serviceaccount with missing secrets": {
    			DeletedServiceAccount: serviceAccount(missingSecretReferences()),
    			ExpectedActions:       []core.Action{},
    		},
    		"deleted serviceaccount with non-token secrets": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  5. pkg/volume/hostpath/host_path.go

    	}
    
    	return pv, nil
    }
    
    // hostPathDeleter deletes a hostPath PV from the cluster.
    // This deleter only works on a single host cluster and is for testing purposes only.
    type hostPathDeleter struct {
    	name string
    	path string
    	host volume.VolumeHost
    	volume.MetricsNil
    }
    
    func (r *hostPathDeleter) GetPath() string {
    	return r.path
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/incremental/recomp/AbstractRecompilationSpecProvider.java

        private static final String PACKAGE_INFO_CLASS_NAME = "package-info";
    
        private final Deleter deleter;
        private final FileOperations fileOperations;
        private final FileTree sourceTree;
        private final Iterable<FileChange> sourceChanges;
        private final boolean incremental;
    
        public AbstractRecompilationSpecProvider(
            Deleter deleter,
            FileOperations fileOperations,
            FileTree sourceTree,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Feb 06 23:55:46 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. 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)
  8. pkg/proxy/ipvs/graceful_termination_test.go

    							Weight:       0,
    							ActiveConn:   0,
    							InactiveConn: 10,
    						},
    					},
    				},
    			},
    			err: nil,
    		},
    		{
    			name: "graceful delete, real server has connections, but udp connections are deleted immediately",
    			vs: &utilipvs.VirtualServer{
    				Address:  netutils.ParseIPSloppy("1.1.1.1"),
    				Protocol: "udp",
    				Port:     uint16(80),
    			},
    			rs: &utilipvs.RealServer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 11K bytes
    - Viewed (0)
  9. platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/SettingsScriptApi.kt

            fileOperations.mkdir(path)
    
        /**
         * Deletes files and directories.
         *
         * This will not follow symlinks. If you need to follow symlinks too use [delete].
         *
         * @param paths Any type of object accepted by [file]
         * @return true if anything got deleted, false otherwise
         */
        @Suppress("unused")
        fun delete(vararg paths: Any): Boolean =
            fileOperations.delete(*paths)
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Aug 02 08:06:49 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  10. pkg/registry/core/pod/storage/eviction.go

    		// this can happen in cases where the PDB can be ignored, but there was a problem issuing the pod delete:
    		// maybe we conflicted too many times or we didn't have permission or something else weird.
    		return nil, err
    
    	case deletedPod:
    		// this happens when we successfully deleted the pod.  In this case, we're done executing because we've evicted/deleted the pod
    		return &metav1.Status{Status: metav1.StatusSuccess}, nil
    
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 11:58:48 UTC 2023
    - 18.2K bytes
    - Viewed (0)
Back to top