- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 246 for delete1 (0.44 sec)
-
pilot/pkg/xds/deltatest.go
sotwRes model.Resources, deltaRes model.Resources, deleted model.DeletedResources, usedDelta bool, delta model.ResourceDelta, incremental bool, ) { current := con.proxy.GetWatchedResource(w.TypeUrl).LastResources if current == nil { log.Debugf("ADS:%s: resources initialized", v3.GetShortType(w.TypeUrl)) return } if deltaRes == nil && deleted == nil && len(sotwRes) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
src/sync/map.go
if !ok && read.amended { e, ok = m.dirty[key] delete(m.dirty, key) // Regardless of whether the entry was present, record a miss: this key // will take the slow path until the dirty map is promoted to the read // map. m.missLocked() } m.mu.Unlock() } if ok { return e.delete() } return nil, false } // Delete deletes the value for a key. func (m *Map) Delete(key any) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
DeleteFunc: func(ns *corev1.Namespace) { f.lock.Lock() defer f.lock.Unlock() // No need to notify handlers for deletes. The namespace was deleted, so the object will be as well (and a delete could not de-select). // Note that specifically for the edge case of a Namespace watcher that is filtering, this will ignore deletes we should // otherwise send. // See kclient.applyDynamicFilter for rationale. f.namespaceDeletedLocked(ns.ObjectMeta)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
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) -
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) -
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) -
pkg/kubelet/config/config.go
} if len(updates.Pods) > 0 { s.updates <- *updates } if len(deletes.Pods) > 0 { s.updates <- *deletes } if firstSet && len(adds.Pods) == 0 && len(updates.Pods) == 0 && len(deletes.Pods) == 0 { // Send an empty update when first seeing the source and there are // no ADD or UPDATE or DELETE pods from the source. This signals kubelet that // the source is ready. s.updates <- *adds }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
cmd/storage-datatypes.go
// Version of the file. VersionID string `msg:"vid,omitempty"` // Indicates if the version is the latest IsLatest bool `msg:"is"` // Deleted is set when this FileInfo represents // a deleted marker for a versioned bucket. Deleted bool `msg:"del"` // TransitionStatus is set to Pending/Complete for transitioned // entries based on state of transition TransitionStatus string `msg:"ts"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 15.7K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
pods: []*v1.Pod{ makePod("a", "deleted", v1.PodFailed), makePod("b", "deleted", v1.PodSucceeded), }, itemsInQueue: 1, deletedPodNames: sets.New("a", "b"), }, { name: "no nodes with PodDisruptionConditions enabled", delay: 2 * quarantineTime, pods: []*v1.Pod{ makePod("a", "deleted", v1.PodFailed), makePod("b", "deleted", v1.PodSucceeded),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
expectedDeleteCount: 3, }, // This test case is critical. If it is removed or broken we may // regress and allow a pod to be deleted without checking PDBs when the // pod should not be deleted. { name: "pdbs No disruptions allowed, pod pending, first delete conflict, pod becomes running, continueToPDBs", pdbs: []runtime.Object{&policyv1.PodDisruptionBudget{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0)