Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 162 for suspend (0.05 seconds)

  1. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 2.6K bytes
    - Click Count (0)
  2. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  3. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Click Count (0)
  4. 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,
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun May 08 05:06:44 GMT 2022
    - 8.8K bytes
    - Click Count (0)
  5. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/GeneralRange.java

            upEnd = other.getUpperEndpoint();
            upType = other.getUpperBoundType();
          }
        }
    
        if (hasLowBound && hasUpBound) {
          int cmp = comparator.compare(lowEnd, upEnd);
          if (cmp > 0 || (cmp == 0 && lowType == OPEN && upType == OPEN)) {
            // force allowed empty range
            lowEnd = upEnd;
            lowType = OPEN;
            upType = CLOSED;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  7. 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() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 33.3K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/GeneralRange.java

            upEnd = other.getUpperEndpoint();
            upType = other.getUpperBoundType();
          }
        }
    
        if (hasLowBound && hasUpBound) {
          int cmp = comparator.compare(lowEnd, upEnd);
          if (cmp > 0 || (cmp == 0 && lowType == OPEN && upType == OPEN)) {
            // force allowed empty range
            lowEnd = upEnd;
            lowType = OPEN;
            upType = CLOSED;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       *       the integral of our function, between X permits and X-K permits, assuming we want to
       *       spend K saved permits.
       * </ol>
       *
       * <p>In summary, the time it takes to move to the left (spend K permits), is equal to the area of
       * the function of width == K.
       *
       * <p>Assuming we have saturated demand, the time to go from maxPermits to thresholdPermits is
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  10. 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,
    	},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.1K bytes
    - Click Count (0)
Back to Top