- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for suspended (0.17 sec)
-
cmd/bucket-versioning-handler.go
HTTPStatusCode: http.StatusBadRequest, }, r.URL) return } if rc, _ := getReplicationConfig(ctx, bucket); rc != nil && v.Suspended() { writeErrorResponse(ctx, w, APIError{ Code: "InvalidBucketState", Description: "A replication configuration is present on this bucket, bucket wide versioning cannot be suspended.", HTTPStatusCode: http.StatusBadRequest,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/tier-sweeper.go
os.VersionID = vid return os } // WithVersioning sets bucket versioning for sweeper. func (os *objSweeper) WithVersioning(versioned, suspended bool) *objSweeper { os.Versioned = versioned os.Suspended = suspended return os } // GetOpts returns ObjectOptions to fetch the object version that may be // overwritten or deleted depending on bucket versioning status.
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/admin-bucket-handlers.go
bucketMap[bucket] = &v } if globalSiteReplicationSys.isEnabled() && v.Suspended() { rpt.SetStatus(bucket, fileName, fmt.Errorf("Cluster replication is enabled for this site, so the versioning state cannot be suspended.")) continue } if rcfg, _ := globalBucketObjectLockSys.Get(bucket); rcfg.LockEnabled && v.Suspended() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
internal/bucket/versioning/versioning.go
} } return true } // Suspended - returns true if versioning is suspended func (v Versioning) Suspended() bool { return v.Status == Suspended } // PrefixSuspended - returns true if versioning is suspended at the bucket level // or suspended on the given prefix. func (v Versioning) PrefixSuspended(prefix string) bool { if v.Status == Suspended { return true } if v.Status == Enabled {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.6K bytes - Viewed (0) -
internal/bucket/versioning/versioning_test.go
} } func TestVersioningZero(t *testing.T) { var v Versioning if v.Enabled() { t.Fatalf("Expected to be disabled but got enabled") } if v.Suspended() { t.Fatalf("Expected to be disabled but got suspended") } } func TestExcludeFolders(t *testing.T) { v := Versioning{ Status: Enabled, ExcludeFolders: true, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 08 05:06:44 GMT 2022 - 8.8K bytes - Viewed (0) -
cmd/bucket-versioning.go
if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.PrefixEnabled(prefix) } // Suspended suspended versioning? func (sys *BucketVersioningSys) Suspended(bucket string) bool { vc, err := sys.Get(bucket) if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.Suspended() } // PrefixSuspended returns true if the given prefix matches an excluded prefix
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 2.6K 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/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/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/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)