- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NumSubscribers (0.05 sec)
-
internal/pubsub/pubsub.go
func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers { atomic.AddInt32(&ps.numSubscribers, -1) return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers) } ps.Lock() defer ps.Unlock()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
if len(ps.subs) != 2 { t.Fatalf("expected 2 subscribers") } if want, got := int32(2), ps.NumSubscribers(Mask(1)); got != want { t.Fatalf("want %d subscribers, got %d", want, got) } if want, got := int32(2), ps.NumSubscribers(Mask(2)); got != want { t.Fatalf("want %d subscribers, got %d", want, got) } if want, got := int32(2), ps.NumSubscribers(Mask(1|2)); got != want { t.Fatalf("want %d subscribers, got %d", want, got) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 5.8K bytes - Viewed (0) -
internal/grid/trace.go
} const ( httpScheme = "http://" httpsScheme = "https://" ) func (c *muxClient) traceRoundtrip(ctx context.Context, t *tracer, h HandlerID, req []byte) ([]byte, error) { if t == nil || t.Publisher.NumSubscribers(t.TraceType) == 0 { return c.roundtrip(h, req) } // Following trimming is needed for consistency between outputs with other internode traces.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 4.1K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.2K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 01 06:06:01 UTC 2025 - 9.4K bytes - Viewed (0)