- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for healthInfoCh (0.23 sec)
-
cmd/callhome.go
Info: madmin.MinioInfo{ DeploymentID: globalDeploymentID(), }, }, } go fetchHealthInfo(healthCtx, objectAPI, &query, healthInfoCh, healthInfo) for { select { case hi, hasMore := <-healthInfoCh: if !hasMore { // Received all data. Send to SUBNET and return err := sendHealthInfo(ctx, healthInfo) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
cmd/admin-handlers.go
defer healthCancel() go fetchHealthInfo(healthCtx, objectAPI, &query, healthInfoCh, healthInfo) setCommonHeaders(w) setEventStreamHeaders(w) w.WriteHeader(http.StatusOK) ticker := time.NewTicker(5 * time.Second) defer ticker.Stop() for { select { case oinfo, ok := <-healthInfoCh: if !ok { return } if err := enc.Encode(oinfo); err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2)