Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetReplicationMRF (0.25 sec)

  1. cmd/peer-rest-client.go

    	if err != nil {
    		return result, err
    	}
    	defer xhttp.DrainBody(respBody)
    	err = gob.NewDecoder(respBody).Decode(&result)
    	return result, err
    }
    
    // GetReplicationMRF - get replication MRF for bucket
    func (client *peerRESTClient) GetReplicationMRF(ctx context.Context, bucket string) (chan madmin.ReplicationMRF, error) {
    	values := make(url.Values)
    	values.Set(peerRESTBucket, bucket)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. cmd/notification.go

    			continue
    		}
    		merged.merge(stat)
    	}
    	return merged
    }
    
    // GetReplicationMRF - Get replication MRF from all peers.
    func (sys *NotificationSys) GetReplicationMRF(ctx context.Context, bucket, node string) (mrfCh chan madmin.ReplicationMRF, err error) {
    	g := errgroup.WithNErrs(len(sys.peerClients))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. cmd/admin-bucket-handlers.go

    		}
    	}
    
    	q := r.Form
    	node := q.Get("node")
    
    	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:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top