Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 625 for delete1 (0.27 sec)

  1. pilot/pkg/networking/core/cluster.go

    		}
    	}
    
    	for key := range updates.ConfigsUpdated {
    		// deleted clusters for this config.
    		var deleted []string
    		var svcs []*model.Service
    		switch key.Kind {
    		case kind.ServiceEntry:
    			svcs, deleted = configgen.deltaFromServices(key, proxy, updates.Push, serviceClusters,
    				servicePortClusters, subsetClusters)
    		case kind.DestinationRule:
    			svcs, deleted = configgen.deltaFromDestinationRules(key, proxy, subsetClusters)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    			unchanged = append(unchanged, s)
    		} else if ok {
    			updated = append(updated, s)
    		} else {
    			added = append(added, s)
    		}
    		delete(oldServiceHosts, s.Hostname)
    	}
    	deleted = maps.Values(oldServiceHosts)
    
    	return added, deleted, updated, unchanged
    }
    
    // Automatically allocates IPs for service entry services WITHOUT an
    // address field if the hostname is not a wildcard, or when resolution
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    			var deleteMarkers uint64
    
    			for i, nerr := range errs {
    				if nerr != nil {
    					continue
    				}
    				for _, fi := range versions[i].Versions {
    					if fi.Deleted {
    						// Delete markers are a write operation not a permanent delete.
    						deleteMarkers++
    						continue
    					}
    					permanentDeletes++
    				}
    			}
    			if deleteMarkers > 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    			as := convertServices(*tt.current)
    			bs := convertServices(*tt.new)
    			added, deleted, updated, unchanged := servicesDiff(as, bs)
    			for i, item := range []struct {
    				hostnames []host.Name
    				services  []*model.Service
    			}{
    				{tt.added, added},
    				{tt.deleted, deleted},
    				{tt.updated, updated},
    				{tt.unchanged, unchanged},
    			} {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/apps/v1/types.go

    // deleted or scaled down.
    type PersistentVolumeClaimRetentionPolicyType string
    
    const (
    	// RetainPersistentVolumeClaimRetentionPolicyType is the default
    	// PersistentVolumeClaimRetentionPolicy and specifies that
    	// PersistentVolumeClaims associated with StatefulSet VolumeClaimTemplates
    	// will not be deleted.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 49.1K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common_test.go

    					// appears in outDatedDisks.
    					tamperedIndex = index
    					dErr := erasureDisks[index].Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    					if dErr != nil {
    						t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr)
    					}
    					break
    				}
    			case corruptPart:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  7. pkg/scheduler/scheduler_test.go

    				framework.CSIDriver:             framework.All - framework.Delete,
    				framework.CSIStorageCapacity:    framework.All - framework.Delete,
    				framework.PersistentVolume:      framework.All - framework.Delete,
    				framework.PersistentVolumeClaim: framework.All - framework.Delete,
    				framework.StorageClass:          framework.All - framework.Delete,
    			},
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  8. pkg/kubelet/config/config_test.go

    	// mark this pod as deleted
    	timestamp := metav1.NewTime(time.Now())
    	deletedPod := CreateValidPod("foo", "new")
    	deletedPod.ObjectMeta.DeletionTimestamp = &timestamp
    	podUpdate = CreatePodUpdate(kubetypes.DELETE, TestSource, deletedPod)
    	channel <- podUpdate
    	// the existing pod should be gracefully deleted
    	expectPodUpdate(t, ch, CreatePodUpdate(kubetypes.DELETE, TestSource, addedPod))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  9. tests/integration/ambient/waypoint_test.go

    						}
    					} else {
    						return fmt.Errorf("failed to delete multiple gateways: %s not cleaned up", name)
    					}
    				}
    				return nil
    			}, retry.Timeout(15*time.Second), retry.BackoffDelay(time.Millisecond*100))
    
    			// delete all waypoints in namespace, so w3 should be deleted
    			istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{
    				"waypoint",
    				"-n",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. pkg/controller/job/backoff_utils.go

    // 3. if the pod has been deleted, use the `deletionTimestamp - grace_period` to estimate the moment of deletion
    // 4. fallback to pod's creation time
    //
    // Pods owned by Kubelet are marked with Ready=False condition when
    // transitioning to terminal phase, thus being handled by (1.) or (2.).
    // Orphaned pods are deleted by PodGC, thus being handled by (3.).
    func getFinishedTime(p *v1.Pod) time.Time {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top