- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 625 for delete1 (0.27 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/config/config_test.go
// mark this pod as deleted timestamp := metav1.NewTime(time.Now()) deletedPod := CreateValidPod("foo", "new") deletedPod.ObjectMeta.DeletionTimestamp = ×tamp 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) -
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) -
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)