- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,226 for deleteSV (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)