- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for deleteRS (0.36 sec)
-
pkg/controller/volume/persistentvolume/pv_controller.go
deleter, err := plugin.NewDeleter(logger, spec) if err != nil { // Cannot create deleter return pluginName, false, fmt.Errorf("failed to create deleter for volume %q: %w", volume.Name, err) } opComplete := util.OperationCompleteHook(pluginName, "volume_delete") err = deleter.Delete() opComplete(volumetypes.CompleteFuncParam{Err: &err}) if err != nil { // Deleter failed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K 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) -
cmd/xl-storage-format-v2.go
updateVersion = fi.MarkDeleted } else { // for replication scenario if fi.Deleted && fi.VersionPurgeStatus() != Complete { if !fi.VersionPurgeStatus().Empty() || fi.DeleteMarkerReplicationStatus().Empty() { updateVersion = true } } // object or delete-marker versioned delete is not complete if !fi.VersionPurgeStatus().Empty() && fi.VersionPurgeStatus() != Complete {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 29 19:14:09 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
} if curPod.DeletionTimestamp != nil { // when a pod is deleted gracefully it's 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 job to create more pods asap, not wait // until the kubelet actually deletes the pod. jm.deletePod(logger, curPod, false) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
cmd/xl-storage.go
for k := range foundDirs { delete(foundDirs, k) } // Populate into map for _, k := range dirs { foundDirs[k] = struct{}{} } // Delete all directories we expect to be there. for _, dir := range wantDirs { delete(foundDirs, dir) } // Nothing to delete if len(foundDirs) == 0 { return nil } // Delete excessive inline entries.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2) -
pkg/proxy/nftables/proxier.go
if deleted > 0 { proxier.logger.Info("Deleting stale nftables chains", "numChains", deleted) err := proxier.nftables.Run(context.TODO(), tx) if err != nil { // We already deleted the entries from staleChains, but if // the chains still exist, they'll just get added back // (with a later timestamp) at the end of the sync. proxier.logger.Error(err, "Unable to delete stale chains; will retry later")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
cmd/erasure-healing_test.go
expectedDangling: true, }, { name: "FileInfoDecided-case2-delete-marker", metaArr: []FileInfo{ {}, {}, {}, {Deleted: true}, }, errs: []error{ errFileNotFound, errFileNotFound, errFileNotFound, nil, }, dataErrs: nil, expectedMeta: FileInfo{Deleted: true}, expectedDangling: true, }, {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/bucket-handlers.go
apiErr.Description = "The bucket you tried to delete is not empty. You must delete all versions in the bucket." } } writeErrorResponse(ctx, w, apiErr, r.URL) return } if globalDNSConfig != nil { if err := globalDNSConfig.Delete(bucket); err != nil { dnsLogIf(ctx, fmt.Errorf("Unable to delete bucket DNS entry %w, please delete it manually, bucket on MinIO no longer exists", err))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// - https://github.com/kubernetes/kubernetes/pull/40664 // [DONE] Irrelevant for delete, as Delete doesn't write data (nor compare it). // - https://github.com/kubernetes/kubernetes/pull/47703 // [DONE] Irrelevant for delete, because Delete doesn't persist data. // - https://github.com/kubernetes/kubernetes/pull/48394/ // [DONE] Irrelevant for delete, because Delete doesn't compare data. // - https://github.com/kubernetes/kubernetes/pull/43152
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0)