- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 3,012 for deleteSV (0.18 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/watch_test.go
f.Modify(testType("bar")) f.Delete(testType("bar")) f.Error(testType("error: blah")) f.Stop() } go sender() consumer(f) } func TestRaceFreeFake(t *testing.T) { f := NewRaceFreeFake() table := []struct { t EventType s testType }{ {Added, testType("foo")}, {Modified, testType("qux")}, {Modified, testType("bar")}, {Deleted, testType("bar")},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 15 11:34:31 UTC 2018 - 3.7K 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) -
pkg/controller/endpointslicemirroring/utils.go
}) } return epsPorts } // getServiceFromDeleteAction parses a Service resource from a delete // action. func getServiceFromDeleteAction(obj interface{}) *corev1.Service { if service, ok := obj.(*corev1.Service); ok { return service } // If we reached here it means the Service was deleted but its final state // is unrecorded. tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 8.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/DeleteTaskIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 11:16:24 UTC 2024 - 5.8K 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) -
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) -
tools/convert_RbacConfig_to_ClusterRbacConfig.sh
metadata: name: default ${SPEC} EOF # shellcheck disable=SC2181 if [ $? -ne 0 ] then echo "failed to apply ClusterRbacConfig" exit 1 fi echo "waiting for 15 seconds to delete RbacConfig" sleep 15
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Sep 14 20:15:07 UTC 2019 - 2K 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) -
test/typeparam/setsimp.dir/a.go
} // Add adds an element to a set. func (s Set[Elem]) Add(v Elem) { s.m[v] = struct{}{} } // Delete removes an element from a set. If the element is not present // in the set, this does nothing. func (s Set[Elem]) Delete(v Elem) { delete(s.m, v) } // Contains reports whether v is in the set. func (s Set[Elem]) Contains(v Elem) bool { _, ok := s.m[v] return ok }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 26 21:39:54 UTC 2021 - 2.7K 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)