- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for IsSuspended (0.36 sec)
-
cmd/bucket-replication_test.go
info: ObjectInfo{Size: 100}, rcfg: replicationConfig{Config: &configs[0]}, expectedSync: false, }, { // 3. existing object replication config enabled, versioning suspended name: "existing object replication config enabled, versioning suspended", info: ObjectInfo{Size: 100, VersionID: nullVersionID}, rcfg: replicationConfig{Config: &configs[0]}, expectedSync: false, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} completeMultiPartUpload := objectAPI.CompleteMultipartUpload versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object) suspended := globalBucketVersioningSys.PrefixSuspended(bucket, object) os := newObjSweeper(bucket, object).WithVersioning(versioned, suspended) if !globalTierConfigMgr.Empty() { // Get appropriate object info to identify the remote object to delete goiOpts := os.GetOpts()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/erasure-object.go
if objects[i].VersionID == "" { // MinIO extension to bucket version configuration suspended := opts.VersionSuspended versioned := opts.Versioned if opts.PrefixEnabledFn != nil { versioned = opts.PrefixEnabledFn(objects[i].ObjectName) } if versioned || suspended { // Bucket is versioned and no version was explicitly // mentioned for deletes, create a delete marker instead.
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/bucket-lifecycle.go
} return tasks } // enqueueTierJournalEntry enqueues a tier journal entry referring to a remote // object corresponding to a 'replaced' object versions. This applies only to // non-versioned or version suspended buckets. func (es *expiryState) enqueueTierJournalEntry(je jentry) { wrkr := es.getWorkerCh(je.OpHash()) if wrkr == nil { es.stats.missedTierJournalTasks.Add(1) return } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/object-api-options.go
// dramatically reduces namespace pollution while keeping the // benefits of replication, make sure to apply version suspension // only at bucket level instead. opts.VersionSuspended = globalBucketVersioningSys.Suspended(bucket) // For directory objects, delete `null` version permanently. if isDirObject(object) && opts.VersionID == "" { opts.VersionID = nullVersionID }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/object-handlers-common.go
remaining = nil } vc, _ := globalBucketVersioningSys.Get(bucket) deletedObjs, errs := o.DeleteObjects(ctx, bucket, toDel, ObjectOptions{ PrefixEnabledFn: vc.PrefixEnabled, VersionSuspended: vc.Suspended(), }) for i, dobj := range deletedObjs { oi := ObjectInfo{ Bucket: bucket, Name: dobj.ObjectName, VersionID: dobj.VersionID, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/object-api-interface.go
type ObjectOptions struct { ServerSideEncryption encrypt.ServerSide VersionSuspended bool // indicates if the bucket was previously versioned but is currently suspended. Versioned bool // indicates if the bucket is versioned VersionID string // Specifies the versionID which needs to be overwritten or read
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
cmd/batch-expire.go
func (r *BatchJobExpire) Expire(ctx context.Context, api ObjectLayer, vc *versioning.Versioning, objsToDel []ObjectToDelete) []error { opts := ObjectOptions{ PrefixEnabledFn: vc.PrefixEnabled, VersionSuspended: vc.Suspended(), } _, errs := api.DeleteObjects(ctx, r.Bucket, objsToDel, opts) return errs } const ( batchExpireName = "batch-expire.bin" batchExpireFormat = 1
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/bucket-handlers.go
} continue } } opts := ObjectOptions{ VersionID: object.VersionID, Versioned: vc.PrefixEnabled(object.ObjectName), VersionSuspended: vc.Suspended(), } if replicateDeletes || object.VersionID != "" && hasLockEnabled || !globalTierConfigMgr.Empty() { if !globalTierConfigMgr.Empty() && object.VersionID == "" && opts.VersionSuspended {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
} func testDeleteObjectVersion(obj ObjectLayer, instanceType string, t1 TestErrHandler) { t, _ := t1.(*testing.T) testBuckets := []string{ "bucket-suspended-version", "bucket-suspended-version-id", } for _, bucket := range testBuckets { err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{ VersioningEnabled: true, }) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0)