- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetReplicationMRF (0.12 sec)
-
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) -
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) -
cmd/notification.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
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) -
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)