Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 1 of 1 for SubscribeJSON (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/peer-rest-server.go

    	}
    	var wg sync.WaitGroup
    
    	// Trace Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), out, ctx.Done(), func(entry madmin.TraceInfo) bool {
    		return shouldTrace(entry, traceOpts)
    	}, &wg)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
Back to Top