- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for mrfCh (0.03 sec)
-
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
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)