Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,033 for delete1 (0.39 sec)

  1. pilot/pkg/serviceregistry/kube/controller/pod.go

    			}
    		}
    	}
    	return pmap
    }
    
    // deleteIP returns true if the pod and ip are really deleted.
    func (pc *PodCache) deleteIP(ip string, podKey types.NamespacedName) bool {
    	pc.Lock()
    	defer pc.Unlock()
    	if pc.podsByIP[ip].Contains(podKey) {
    		sets.DeleteCleanupLast(pc.podsByIP, ip, podKey)
    		delete(pc.IPByPods, podKey)
    		return true
    	}
    	return false
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    			if versioned || suspended {
    				// Bucket is versioned and no version was explicitly
    				// mentioned for deletes, create a delete marker instead.
    				vr.ModTime = UTCNow()
    				vr.Deleted = true
    				// Versioning suspended means that we add a `null` version
    				// delete marker, if not add a new version for this delete
    				// marker.
    				if versioned {
    					vr.VersionID = mustGetUUID()
    				}
    			}
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  3. pkg/controller/daemon/daemon_controller.go

    	if curPod.DeletionTimestamp != nil {
    		// when a pod is deleted gracefully its deletion timestamp is first modified to reflect a grace period,
    		// and after such time has passed, the kubelet actually deletes it from the store. We receive an update
    		// for modification of the deletion timestamp and expect an ds to create more replicas asap, not wait
    		// until the kubelet actually deletes the pod.
    		dsc.deletePod(logger, curPod)
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/lifecycle.go

    	DeleteRestoredAction
    	// DeleteRestoredVersionAction deletes a particular version that was temporarily restored
    	DeleteRestoredVersionAction
    	// DeleteAllVersionsAction deletes all versions when an object expires
    	DeleteAllVersionsAction
    	// DelMarkerDeleteAllVersionsAction deletes all versions when an object with delete marker as latest version expires
    	DelMarkerDeleteAllVersionsAction
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	// Act
    	dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName)
    	volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName)
    	if volumeExists {
    		t.Fatalf(
    			"Deleted pod %q from volume %q/node %q. Volume should also be deleted but it still exists.",
    			podName,
    			generatedVolumeName,
    			nodeName)
    	}
    	asw.SetVolumesMountedByNode(logger, []v1.UniqueVolumeName{generatedVolumeName}, nodeName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  6. pkg/kube/controllers/common.go

    	EventUpdate
    
    	// EventDelete is sent when an object is deleted
    	// Captures the object at the last known state
    	EventDelete
    )
    
    func (event EventType) String() string {
    	out := "unknown"
    	switch event {
    	case EventAdd:
    		out = "add"
    	case EventUpdate:
    		out = "update"
    	case EventDelete:
    		out = "delete"
    	}
    	return out
    }
    
    type Event struct {
    	Old   Object
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/util/workloadinstances/index_test.go

    	// Delete should return previously inserted value
    
    	deleted := index.Delete(wi1)
    	assert.Equal(t, wi1, deleted)
    
    	// GetByIP should return 1 workload instance
    
    	verifyGetByIP("2.2.2.2", []*model.WorkloadInstance{wi3})
    
    	// Delete should return nil since there is no such element in the index
    
    	deleted = index.Delete(wi1)
    	assert.Equal(t, nil, deleted)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. 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)
  9. cmd/iam-store.go

    					delete(cache.iamUsersMap, k)
    				}
    			}
    			for k, u := range cache.iamSTSAccountsMap {
    				if u.Credentials.ParentUser == accessKey {
    					delete(cache.iamSTSAccountsMap, k)
    				}
    			}
    		}
    
    		// 3. Delete any mapped policy
    		cache.iamUserPolicyMap.Delete(accessKey)
    
    		return nil
    	}
    
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  10. tests/integration/helm/upgrade/util.go

    	if err := h.DeleteChart(helmtest.BaseReleaseName, helmtest.IstioNamespace); err != nil {
    		return fmt.Errorf("failed to delete %s release", helmtest.BaseReleaseName)
    	}
    	if err := cs.Kube().CoreV1().Namespaces().Delete(context.TODO(), helmtest.IstioNamespace, metav1.DeleteOptions{}); err != nil {
    		return fmt.Errorf("failed to delete istio namespace: %v", err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top