- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 300 for deleteSV (0.2 sec)
-
src/internal/concurrent/hashtriemap.go
i.mu.Unlock() return } if n.isEntry { // What we saw is still true, so we can continue with the delete. break } } // We have to start over. i.mu.Unlock() } // Try to delete the entry. e, deleted := n.entry().compareAndDelete(key, old, ht.keyEqual, ht.valEqual) if !deleted {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 11.8K 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) -
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) -
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) -
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/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) -
pkg/volume/hostpath/host_path.go
} return pv, nil } // hostPathDeleter deletes a hostPath PV from the cluster. // This deleter only works on a single host cluster and is for testing purposes only. type hostPathDeleter struct { name string path string host volume.VolumeHost volume.MetricsNil } func (r *hostPathDeleter) GetPath() string { return r.path }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
// deleteVolume runs in worker thread and handles "volume deleted" event. func (ctrl *PersistentVolumeController) deleteVolume(ctx context.Context, volume *v1.PersistentVolume) { logger := klog.FromContext(ctx) if err := ctrl.volumes.store.Delete(volume); err != nil { logger.Error(err, "Volume deletion encountered", "volumeName", volume.Name) } else { logger.V(4).Info("volume deleted", "volumeName", volume.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
cmd/bucket-object-lock.go
case objectlock.RetGovernance: // In governance mode, users can't overwrite or delete an object // version or alter its lock settings unless they have special // permissions. With governance mode, you protect objects against // being deleted by most users, but you can still grant some users // permission to alter the retention settings or delete the object // if necessary. You can also use governance mode to test retention-period
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
}}, nil } func (plugin *portworxVolumePlugin) NewDeleter(logger klog.Logger, spec *volume.Spec) (volume.Deleter, error) { return plugin.newDeleterInternal(spec, plugin.util) } func (plugin *portworxVolumePlugin) newDeleterInternal(spec *volume.Spec, manager portworxManager) (volume.Deleter, error) { if spec.PersistentVolume != nil && spec.PersistentVolume.Spec.PortworxVolume == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0)