Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NumSubscribers (0.08 sec)

  1. cmd/event-notification.go

    	// remove sensitive encryption entries in metadata.
    	crypto.RemoveSensitiveEntries(args.Object.UserDefined)
    	crypto.RemoveInternalEntries(args.Object.UserDefined)
    
    	if globalHTTPListen.NumSubscribers(pubsub.MaskFromMaskable(args.EventName)) > 0 {
    		globalHTTPListen.Publish(args.ToEvent(false))
    	}
    
    	globalEventNotifier.Send(args)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. cmd/http-tracer.go

    		}
    
    		r = r.WithContext(context.WithValue(r.Context(), mcontext.ContextTraceKey, &tc))
    
    		reqStartTime := time.Now().UTC()
    		h.ServeHTTP(respRecorder, r)
    		reqEndTime := time.Now().UTC()
    
    		if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 {
    			// no subscribers nothing to trace.
    			return
    		}
    
    		tt := madmin.TraceInternal
    		if strings.HasPrefix(tc.FuncName, "s3.") {
    			tt = madmin.TraceS3
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/os-instrumented.go

    		FuncName:  "os." + s.String(),
    		Duration:  duration,
    		Path:      path,
    		Error:     errStr,
    	}
    }
    
    func updateOSMetrics(s osMetric, paths ...string) func(err error) {
    	if globalTrace.NumSubscribers(madmin.TraceOS) == 0 {
    		osAction := globalOSMetrics.time(s)
    		return func(err error) { osAction() }
    	}
    
    	startTime := time.Now()
    	return func(err error) {
    		duration := time.Since(startTime)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  4. cmd/data-scanner-metric.go

    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&p.operations[s], 1)
    		if s < scannerMetricLastRealtime {
    			p.latency[s].add(duration)
    		}
    
    		if s > scannerMetricStartTrace && globalTrace.NumSubscribers(madmin.TraceScanner) > 0 {
    			globalTrace.Publish(scannerTrace(s, startTime, duration, strings.Join(paths, " "), custom))
    		}
    	}
    }
    
    // time n scanner actions.
    // Use for s < scannerMetricLastRealtime
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
Back to top