Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetReplicationMRF (0.12 sec)

  1. cmd/peer-rest-common.go

    	peerRESTMethodDriveSpeedTest        = "/drivespeedtest"
    	peerRESTMethodDevNull               = "/devnull"
    	peerRESTMethodNetperf               = "/netperf"
    	peerRESTMethodGetReplicationMRF     = "/getreplicationmrf"
    )
    
    const (
    	peerRESTBucket          = "bucket"
    	peerRESTBuckets         = "buckets"
    	peerRESTUser            = "user"
    	peerRESTGroup           = "group"
    	peerRESTUserTemp        = "user-temp"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/peer-rest-server.go

    	if !s.IsValid(w, r) {
    		s.writeErrorResponse(w, errors.New("invalid request"))
    		return
    	}
    
    	vars := mux.Vars(r)
    	bucketName := vars[peerRESTBucket]
    	ctx := newContext(r, w, "GetReplicationMRF")
    	re, err := globalReplicationPool.Get().getMRF(ctx, bucketName)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	enc := gob.NewEncoder(w)
    
    	for m := range re {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top