Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/erasure-healing.go

    	storageDisks := er.getDisks()
    	storageEndpoints := er.getEndpoints()
    
    	defer func() {
    		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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  3. cmd/bucket-lifecycle.go

    	}
    }
    
    func (sys *LifecycleSys) trace(oi ObjectInfo) func(event string) {
    	startTime := time.Now()
    	return func(event string) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
    			globalTrace.Publish(ilmTrace(startTime, duration, oi, event))
    		}
    	}
    }
    
    type expiryTask struct {
    	objInfo ObjectInfo
    	event   lifecycle.Event
    	src     lcEventSrc
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    	}
    }
    
    func (p *rebalanceMetrics) log(r rebalanceMetric, poolIdx int, paths ...string) func(err error) {
    	startTime := time.Now()
    	return func(err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    			globalTrace.Publish(rebalanceTrace(r, poolIdx, startTime, duration, err, strings.Join(paths, " ")))
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    		Custom:    custom,
    	}
    }
    
    // Update storage metrics
    func (p *xlStorageDiskIDCheck) updateStorageMetrics(s storageMetric, paths ...string) func(err *error) {
    	startTime := time.Now()
    	trace := globalTrace.NumSubscribers(madmin.TraceStorage) > 0
    	return func(errp *error) {
    		duration := time.Since(startTime)
    
    		var err error
    		if errp != nil && *errp != nil {
    			err = *errp
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	}
    }
    
    func (m *decomMetrics) log(d decomMetric, poolIdx int, paths ...string) func(err error) {
    	startTime := time.Now()
    	return func(err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceDecommission) > 0 {
    			globalTrace.Publish(decomTrace(d, poolIdx, startTime, duration, strings.Join(paths, " "), err))
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
Back to top