Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 186 for tiver (0.03 seconds)

  1. cmd/tier-last-day-stats.go

    		merged.Bins[i] = cl.Bins[i].add(cm.Bins[i])
    	}
    
    	return merged
    }
    
    // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers
    type DailyAllTierStats map[string]lastDayTierStats
    
    func (l DailyAllTierStats) merge(m DailyAllTierStats) {
    	for tier, st := range m {
    		l[tier] = l[tier].merge(st)
    	}
    }
    
    func (l DailyAllTierStats) addToTierInfo(tierInfos []madmin.TierInfo) []madmin.TierInfo {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  2. docs/bucket/lifecycle/DESIGN.md

    Transition tiers can be added to MinIO using `mc admin tier add` command to associate a `gcs`, `s3` or `azure` bucket or prefix path on a bucket to the tier name.
    Lifecycle transition rules can be applied to buckets (both versioned and un-versioned) by specifying the tier name defined above as the transition storage class for the lifecycle rule.
    
    ## Implementation
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. cmd/data-usage-utils.go

    	if dui.TierStats == nil {
    		return nil
    	}
    	// e.g minio_cluster_ilm_transitioned_bytes{tier="S3TIER-1"}=136314880
    	//     minio_cluster_ilm_transitioned_objects{tier="S3TIER-1"}=1
    	//     minio_cluster_ilm_transitioned_versions{tier="S3TIER-1"}=3
    	for tier, st := range dui.TierStats.Tiers {
    		metrics = append(metrics, MetricV2{
    			Description:    getClusterTransitionedBytesMD(),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/timer/HotThreadMonitorTargetTest.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.timer;
    
    import static org.junit.jupiter.api.Assertions.assertNotSame;
    
    import org.codelibs.core.timer.TimeoutTarget;
    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.TestInfo;
    
    /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 4.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        @RetainedLocalRef Future<?> localTimer = timer;
        // Try to cancel the timer as an optimization.
        // timer may be null if this call to run was by the timer task since there is no happens-before
        // edge between the assignment to timer and an execution of the timer task.
        if (localTimer != null) {
          localTimer.cancel(false);
        }
    
        delegateRef = null;
        timer = null;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  6. cmd/bucket-lifecycle.go

    			}
    			t.activeTasks.Add(-1)
    		}
    	}
    }
    
    func (t *transitionState) addLastDayStats(tier string, ts tierStats) {
    	t.lastDayMu.Lock()
    	defer t.lastDayMu.Unlock()
    
    	if _, ok := t.lastDayStats[tier]; !ok {
    		t.lastDayStats[tier] = &lastDayTierStats{}
    	}
    	t.lastDayStats[tier].addStats(ts)
    }
    
    func (t *transitionState) getDailyAllTierStats() DailyAllTierStats {
    	t.lastDayMu.RLock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  7. cmd/benchmark-utils_test.go

    	sha256hex := ""
    
    	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    
    	for i := 0; b.Loop(); i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(b.Context(), bucket, "object"+strconv.Itoa(i),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  8. cmd/erasure-sets.go

    			wg.Wait()
    
    			// Reset for the next interval
    			timer.Reset(globalAPIConfig.getDeleteCleanupInterval())
    		}
    	}
    }
    
    func (s *erasureSets) cleanupStaleUploads(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  9. cmd/tier-last-day-stats_gen.go

    Klaus Post <******@****.***> 1759093161 +0200
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  10. docs/bucket/lifecycle/setup_ilm_transition.sh

    ./mc mb --ignore-existing sitea/bucket
    ./mc mb --ignore-existing siteb/bucket
    
    sleep 10s
    
    ## Add warm tier
    ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9004 --access-key minioadmin --secret-key minioadmin --bucket bucket
    
    ## Add ILM rules
    ./mc ilm add sitea/bucket --transition-days 0 --transition-tier WARM-TIER
    ./mc ilm rule list sitea/bucket
    
    ./mc cp README.md sitea/bucket/README.md
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 2.8K bytes
    - Click Count (0)
Back to Top