Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NumSubscribers (0.11 sec)

  1. cmd/erasure-healing.go

    	storageDisks := er.getDisks()
    	storageEndpoints := er.getEndpoints()
    
    	defer func() {
    		er.auditHealObject(ctx, bucket, object, versionID, result, err)
    	}()
    
    	if globalTrace.NumSubscribers(madmin.TraceHealing) > 0 {
    		startTime := time.Now()
    		defer func() {
    			healTrace(healingMetricObject, startTime, bucket, object, &opts, err, &result)
    		}()
    	}
    
    	// Initialize heal result object
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  2. cmd/server-main.go

    	}
    	globalBootstrapTracer.Record(info)
    
    	if serverDebugLog {
    		fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg)
    	}
    
    	noSubs := globalTrace.NumSubscribers(madmin.TraceBootstrap) == 0
    	if noSubs {
    		return
    	}
    
    	globalTrace.Publish(info)
    }
    
    func bootstrapTrace(msg string, worker func()) {
    	if serverDebugLog {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  3. 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)
  4. cmd/erasure-server-pool-rebalance.go

    func (p *rebalanceMetrics) log(r rebalanceMetric, poolIdx int, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    			globalTrace.Publish(rebalanceTrace(r, poolIdx, startTime, duration, err, strings.Join(paths, " "), sz))
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. 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)
  6. cmd/erasure-server-pool-decom.go

    func (m *decomMetrics) log(d decomMetric, poolIdx int, paths ...string) func(z int64, err error) {
    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceDecommission) > 0 {
    			globalTrace.Publish(decomTrace(d, poolIdx, startTime, duration, strings.Join(paths, " "), err, sz))
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top