Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for PubSub (0.14 sec)

  1. cmd/bootstrap-messages.go

    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    }
    
    func (bs *bootstrapTracer) Publish(ctx context.Context, trace *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	for _, bsEvent := range bs.Events() {
    		if bsEvent.Message != "" {
    			select {
    			case <-ctx.Done():
    			default:
    				trace.Publish(bsEvent)
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 1.7K bytes
    - Viewed (0)
Back to top