Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Subscribe (0.17 sec)

  1. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    	}()
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && bucketName != "" {
    			if ev.S3.Bucket.Name != bucketName {
    				return false
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && values.Get(peerRESTListenBucket) != "" {
    			if ev.S3.Bucket.Name != values.Get(peerRESTListenBucket) {
    				return false
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	}, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Publish bootstrap events that have already occurred before client could subscribe.
    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	for _, peer := range peers {
    		if peer == nil {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top