Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for mrfCh (0.06 sec)

  1. cmd/notification.go

    			return err
    		}
    		for e := range mCh {
    			select {
    			case <-ctx.Done():
    				return err
    			case mrfCh <- e:
    			}
    		}
    		return nil
    	}(mrfCh)
    	go func(wg *sync.WaitGroup) {
    		wg.Wait()
    		xioutil.SafeClose(mrfCh)
    	}(&wg)
    	return mrfCh, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    
    	mrfCh, err := globalNotificationSys.GetReplicationMRF(ctx, bucket, node)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case entry, ok := <-mrfCh:
    			if !ok {
    				return
    			}
    			if err := enc.Encode(entry); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	mrfRec, err := p.loadMRF()
    	if err != nil {
    		return nil, err
    	}
    
    	mrfCh := make(chan madmin.ReplicationMRF, 100)
    	go func() {
    		defer xioutil.SafeClose(mrfCh)
    		for vID, e := range mrfRec.Entries {
    			if bucket != "" && e.Bucket != bucket {
    				continue
    			}
    			select {
    			case mrfCh <- madmin.ReplicationMRF{
    				NodeName:   globalLocalNodeName,
    				Object:     e.Object,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top