Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NumSubscribers (0.07 sec)

  1. cmd/xl-storage-disk-id-check.go

    	}
    }
    
    // Update storage metrics
    func (p *xlStorageDiskIDCheck) updateStorageMetrics(s storageMetric, paths ...string) func(sz int64, err *error) {
    	startTime := time.Now()
    	trace := globalTrace.NumSubscribers(madmin.TraceStorage) > 0
    	return func(sz int64, errp *error) {
    		duration := time.Since(startTime)
    
    		var err error
    		if errp != nil && *errp != nil {
    			err = *errp
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	startTime := time.Now()
    	return func(event string, metadata map[string]string, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
    			e := ""
    			if err != nil {
    				e = err.Error()
    			}
    			globalTrace.Publish(ilmTrace(startTime, duration, oi, event, metadata, e))
    		}
    	}
    }
    
    type expiryTask struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    			done = globalScannerMetrics.time(scannerMetricTierObjSweep)
    			globalExpiryState.enqueueFreeVersion(oi)
    			done()
    		}
    
    		// These are rather expensive. Skip if nobody listens.
    		if globalTrace.NumSubscribers(madmin.TraceScanner) > 0 {
    			if len(fivs.FreeVersions) > 0 {
    				res["free-versions"] = strconv.Itoa(len(fivs.FreeVersions))
    			}
    
    			if sizeS.versions > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top