Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for DELETING (0.12 sec)

  1. pkg/proxy/winkernel/proxier.go

    		klog.V(1).ErrorS(err, "Error deleting Hns loadbalancer policy resource.", "hnsID", svcInfo.hnsID, "ClusterIP", svcInfo.ClusterIP())
    	} else {
    		// On successful delete, remove hnsId
    		svcInfo.hnsID = ""
    	}
    
    	if err := hns.deleteLoadBalancer(svcInfo.nodePorthnsID); err != nil {
    		mapStaleLoadbalancer[svcInfo.nodePorthnsID] = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller.go

    	eventRecorder    record.EventRecorder
    
    	podControl controller.PodControlInterface
    	crControl  controller.ControllerRevisionControlInterface
    
    	// An dsc is temporarily suspended after creating/deleting these many replicas.
    	// It resumes normal action after observing the watch events for them.
    	burstReplicas int
    
    	// To allow injection of syncDaemonSet for testing.
    	syncHandler func(ctx context.Context, dsKey string) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting the object from the bucket.
    func getDeleteObjectURL(endPoint, bucketName, objectName string) string {
    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting multiple objects from a bucket.
    func getMultiDeleteObjectURL(endPoint, bucketName string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/pv_controller.go

    				// Save failed, retry on the next deletion attempt
    				return pluginName, err
    			}
    		}
    
    		// Despite the volume being Failed, the controller will retry deleting
    		// the volume in every syncVolume() call.
    		return pluginName, err
    	}
    	if !deleted {
    		// The volume waits for deletion by an external plugin. Do nothing.
    		return pluginName, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  6. pkg/controller/replicaset/replica_set_test.go

    		logger.V(8).Info("Waiting for queue to have 1 item", "length", manager.queue.Len())
    		return manager.queue.Len() == 1, nil
    	})
    	if err != nil {
    		t.Fatalf("Deleting RS didn't result in new item in the queue: %v", err)
    	}
    
    	_, exists, err = manager.expectations.GetExpectations(oldRSKey)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    	verifyGetByIP("3.3.3.3", nil)
    	verifyGetByIP("2.2.2.2", []*model.WorkloadInstance{wi3, wi1})
    
    	// simulate deleting a workload entry
    	ctl.workloadInstanceHandler(wi3, model.EventDelete)
    
    	verifyGetByIP("2.2.2.2", []*model.WorkloadInstance{wi1})
    
    	// simulate deleting a workload entry
    	ctl.workloadInstanceHandler(wi1, model.EventDelete)
    
    	verifyGetByIP("2.2.2.2", nil)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    	} else {
    		err = Rename(filePath, targetPath)
    	}
    
    	var targetPath2 string
    	if immediatePurge && HasSuffix(filePath, SlashSeparator) {
    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    		renameAll(encodeDirObject(filePath), targetPath2, pathutil.Join(s.drivePath, minioMetaBucket))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  9. platforms/documentation/docs/src/docs/userguide/authoring-builds/gradle-properties/working_with_files.adoc

    ----
    task moveFile(type: Copy) {
        from 'source.txt'
        into 'destination'
        rename { fileName ->
            'new_name.txt'
        }
    }
    ----
    
    [[sec:deleting_files_example]]
    == Deleting files and directories
    
    Deleting files and directories in Gradle involves removing them from the file system.
    
    === Using the `Delete` task
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 24 04:19:09 UTC 2024
    - 70.5K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceregistry_test.go

    					t.Fatal(err)
    				}
    				expectEndpoints(t, s, "outbound|80||service.namespace.svc.cluster.local", nil, nodeMeta)
    			})
    
    			t.Run("ServiceEntry selects Pod: deleting pod", func(t *testing.T) {
    				s := xds.NewFakeDiscoveryServer(t, opts)
    				makeIstioObject(t, s.Store(), serviceEntry)
    				makePod(t, s.KubeClient().Kube(), pod)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
Back to top