Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 244 for transitioned (0.21 sec)

  1. cmd/storage-datatypes.go

    	// Deleted is set when this FileInfo represents
    	// a deleted marker for a versioned bucket.
    	Deleted bool `msg:"del"`
    
    	// TransitionStatus is set to Pending/Complete for transitioned
    	// entries based on state of transition
    	TransitionStatus string `msg:"ts"`
    	// TransitionedObjName is the object name on the remote tier corresponding
    	// to object (version) on the source tier.
    	TransitionedObjName string `msg:"to"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    }
    
    // TransitionObject - transition object content to target tier.
    func (s *erasureSets) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts)
    }
    
    // RestoreTransitionedObject - restore transitioned object content locally on this cluster.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  3. cmd/erasure-server-pool.go

    	if err != nil {
    		return err
    	}
    
    	return z.serverPools[idx].TransitionObject(ctx, bucket, object, opts)
    }
    
    // RestoreTransitionedObject - restore transitioned object content locally on this cluster.
    func (z *erasureServerPools) RestoreTransitionedObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	object = encodeDirObject(object)
    	if z.SinglePool() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  4. cmd/metrics-v2.go

    		Name:      transitionedBytes,
    		Help:      "Total bytes transitioned to a tier",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterTransitionedObjectsMD() MetricDescription {
    	return MetricDescription{
    		Namespace: clusterMetricNamespace,
    		Subsystem: ilmSubsystem,
    		Name:      transitionedObjects,
    		Help:      "Total number of objects transitioned to a tier",
    		Type:      gaugeMetric,
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    			var rebalanced, expired int
    			for _, version := range fivs.Versions {
    				stopFn := globalRebalanceMetrics.log(rebalanceMetricRebalanceObject, poolIdx, bucket, version.Name, version.VersionID)
    
    				// Skip transitioned objects for now. TBD
    				if version.IsRemote() {
    					stopFn(version.Size, errors.New("ILM Tiered version will be skipped for now"))
    					continue
    				}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    			}
    			if oi.VersionID != "" && sz == actualSz {
    				sizeS.versions++
    			}
    			sizeS.totalSize += sz
    
    			// Skip tier accounting if object version is a delete-marker or a free-version
    			// tracking deleted transitioned objects
    			switch {
    			case oi.DeleteMarker, oi.TransitionedObject.FreeVersion:
    				return
    			}
    			tier := oi.StorageClass
    			if tier == "" {
    				tier = storageclass.STANDARD // no SC means "STANDARD"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    			Object:    objInfo.Name,
    			VersionID: objInfo.VersionID,
    			Status:    http.StatusText(http.StatusOK),
    		})
    	}
    
    	// Remove the transitioned object whose object version is being overwritten.
    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2.go

    // its contents and false otherwise.
    func (j xlMetaV2Object) UsesDataDir() bool {
    	// Skip if this version is not transitioned, i.e it uses its data directory.
    	if !bytes.Equal(j.MetaSys[metaTierStatus], []byte(lifecycle.TransitionComplete)) {
    		return true
    	}
    
    	// Check if this transitioned object has been restored on disk.
    	return isRestoredObjectOnDisk(j.MetaUser)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  9. cmd/bucket-handlers.go

    			Object:       objInfo,
    			ReqParams:    extractReqParams(r),
    			RespElements: extractRespElements(w),
    			UserAgent:    r.UserAgent(),
    			Host:         handlers.GetSourceIP(r),
    		})
    	}
    
    	// Clean up transitioned objects from remote tier
    	for _, os := range oss {
    		if os == nil { // skip objects that weren't deleted due to invalid versionID etc.
    			continue
    		}
    		os.Sweep()
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  10. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

            // Test max attempts in half-open with failure scenario
            circuitBreaker.trip(); // Open again
            Thread.sleep(1100); // Wait for reset
    
            // First attempt transitions to HALF_OPEN
            try {
                circuitBreaker.executeWithCircuitBreaker(() -> {
                    // Verify we're in HALF_OPEN
                    assertEquals(State.HALF_OPEN, circuitBreaker.getState());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
Back to top