- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 883 for deleteRS (0.16 sec)
-
cmd/api-datatypes.go
Location string `xml:"LocationConstraint"` } // DeleteObjectsRequest - xml carrying the object key names which needs to be deleted. type DeleteObjectsRequest struct { // Element to enable quiet mode for the request Quiet bool // List of objects to be deleted Objects []ObjectToDelete `xml:"Object"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:26:50 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
} // Modify sends a modify event. func (f *FakeWatcher) Modify(obj runtime.Object) { f.result <- Event{Modified, obj} } // Delete sends a delete event. func (f *FakeWatcher) Delete(lastValue runtime.Object) { f.result <- Event{Deleted, lastValue} } // Error sends an Error event. func (f *FakeWatcher) Error(errValue runtime.Object) { f.result <- Event{Error, errValue} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/CleaningJavaCompiler.java
private final Compiler<T> compiler; private final TaskOutputsInternal taskOutputs; private final Deleter deleter; public CleaningJavaCompiler(Compiler<T> compiler, TaskOutputsInternal taskOutputs, Deleter deleter) { this.compiler = compiler; this.taskOutputs = taskOutputs; this.deleter = deleter; } @Override public WorkResult execute(T spec) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/IoTestCase.java
@CanIgnoreReturnValue private boolean delete(File file) { if (file.isDirectory()) { File[] files = file.listFiles(); if (files != null) { for (File f : files) { if (!delete(f)) { return false; } } } } if (!file.delete()) { logger.log(Level.WARNING, "couldn't delete file: {0}", new Object[] {file}); return false;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 31 12:36:13 UTC 2024 - 5.6K bytes - Viewed (0) -
src/sync/map_reference_test.go
m.mu.Lock() value, loaded = m.dirty[key] if !loaded { m.mu.Unlock() return nil, false } delete(m.dirty, key) m.mu.Unlock() return value, loaded } func (m *RWMutexMap) Delete(key any) { m.mu.Lock() delete(m.dirty, key) m.mu.Unlock() } func (m *RWMutexMap) CompareAndSwap(key, old, new any) (swapped bool) { m.mu.Lock() defer m.mu.Unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 15:34:22 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake_test.go
} if len(list) != 3 { t.Errorf("Expect 2 virtual servers, got: %d", len(list)) } // Delete a virtual server err = fake.DeleteVirtualServer(vs1) if err != nil { t.Errorf("Fail to delete virtual server: %v, error: %v", vs1, err) } // Check the deleted virtual server no longer exists got, _ := fake.GetVirtualServer(vs1) if got != nil { t.Errorf("Expect nil, got: %v", got) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/controller/util/selectors/bimultimap.go
labeled := m.labeledBySelecting[sObject.selectorKey] labeled.objects[labeledObject.key] = labeledObject } } // Delete removes a labeled object and incoming associations. func (m *BiMultimap) Delete(key Key) { m.mux.Lock() defer m.mux.Unlock() m.delete(key) } func (m *BiMultimap) delete(key Key) { if _, ok := m.labeledObjects[key]; !ok { // Does not exist. return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 21:41:32 UTC 2023 - 9.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
// Only handle add. The controller only acts on parts of the service // that are immutable (e.g. name). When we create ServiceExport, we bind its // lifecycle to the Service so that when the Service is deleted, // k8s automatically deletes the ServiceExport. c.services.AddEventHandler(controllers.EventHandler[controllers.Object]{AddFunc: c.queue.AddObject}) return c } func (c *autoServiceExportController) Run(stopCh <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
if len(secret.UID) > 0 { options.Preconditions = &metav1.Preconditions{UID: &secret.UID} } err := tc.client.CoreV1().Secrets(secret.Namespace).Delete(ctx, secret.Name, options) // NotFound isn't a real error (it's already been deleted) // Conflict isn't a real error (the UID precondition failed) if err != nil && !apierrors.IsConflict(err) && !apierrors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/peer-s3-server.go
if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil { return nil, err } // include deleted buckets in listBuckets output deletedBuckets := map[string]VolInfo{} if opts.Deleted { // lists all deleted buckets across drives. if err := listDeletedBuckets(ctx, localDrives, deletedBuckets, quorum); err != nil { return nil, err } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.4K bytes - Viewed (0)