- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Deletion (0.15 sec)
-
cmd/tier-sweeper.go
os.TransitionVersionID = info.VersionID } // shouldRemoveRemoteObject determines if a transitioned object should be // removed from remote tier. If remote object is to be deleted, returns the // corresponding tier deletion journal entry and true. Otherwise returns empty // jentry value and false. func (os *objSweeper) shouldRemoveRemoteObject() (jentry, bool) { if os.TransitionStatus != lifecycle.TransitionComplete { return jentry{}, false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/iam.go
for i := 1; i < len(origKeys); i++ { delete(policyMap, origKeys[i]) // Remove the mapping from storage by setting the policy to "". if entityKeysInStorage.Contains(origKeys[i]) { // Ignore any deletion error. _, _ = sys.PolicyDBSet(ctx, origKeys[i], "", stsUser, isGroup) } } } // Replacing origKeys[0] with normKey in the policyMap
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/erasure-object.go
if disks[index] == nil { return errDiskNotFound } return disks[index].DeleteVersion(ctx, bucket, object, fi, forceDelMarker, DeleteOptions{}) }, index) } // return errors if any during deletion return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum) } // DeleteObjects deletes objects/versions in bulk, this function will still automatically split objects list
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/iam-store.go
cache := store.lock() defer store.unlock() if !isFromNotification { // Check if policy is mapped to any existing user or group. If so, we do not // allow deletion of the policy. If the policy is mapped to an STS account, // we do allow deletion. users := []string{} groups := []string{} cache.iamUserPolicyMap.Range(func(u string, mp MappedPolicy) bool { pset := mp.policySet()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/metacache-server-pool.go
"time" xioutil "github.com/minio/minio/internal/ioutil" ) func renameAllBucketMetacache(epPath string) error { // Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to // to `.minio.sys/tmp/` for deletion. return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error { if typ == os.ModeDir { tmpMetacacheOld := pathutil.Join(epPath, minioMetaTmpDeletedBucket, mustGetUUID())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/erasure-metadata.go
} // SetSkipTierFreeVersion indicates to skip adding a tier free version id. // Note: Used only when expiring tiered objects and the remote content has // already been scheduled for deletion func (fi *FileInfo) SetSkipTierFreeVersion() { if fi.Metadata == nil { fi.Metadata = make(map[string]string) } fi.Metadata[ReservedMetadataPrefixLower+tierSkipFVID] = "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/batch-expire.go
case <-ctx.Done(): return default: } stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts) // Copying toDel to select from objects whose // deletion failed copy(toDelCopy, toDel) var failed int errs := r.Expire(ctx, api, vc, toDel) // reslice toDel in preparation for next retry // attempt toDel = toDel[:0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/server_test.go
} // TestBucketPolicy - Inserts the bucket policy and verifies it by fetching the policy back. // Deletes the policy and verifies the deletion by fetching it back. func (s *TestSuiteCommon) TestBucketPolicy(c *check) { // Sample bucket policy.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
internal/bucket/replication/sourceselectioncriteria.go
) // ReplicaModifications specifies if replica modification sync is enabled type ReplicaModifications struct { Status Status `xml:"Status" json:"Status"` } // SourceSelectionCriteria - specifies additional source selection criteria in ReplicationConfiguration. type SourceSelectionCriteria struct { ReplicaModifications ReplicaModifications `xml:"ReplicaModifications" json:"ReplicaModifications"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.5K bytes - Viewed (0) -
internal/s3select/select.go
if s3Select.progressReader != nil { return s3Select.progressReader.Stats() } return -1, -1 } // Open - opens S3 object by using callback for SQL selection query. // Currently CSV, JSON and Apache Parquet formats are supported. func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error { offset, length, err := s3Select.ScanRange.StartLen() if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0)