Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for BackgroundHealStatus (0.13 sec)

  1. cmd/notification.go

    				return errPeerNotReachable
    			}
    			return client.LoadServiceAccount(ctx, accessKey)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // BackgroundHealStatus - returns background heal status of all peers
    func (sys *NotificationSys) BackgroundHealStatus(ctx context.Context) ([]madmin.BgHealState, []NotificationPeerErr) {
    	ng := WithNPeers(len(sys.peerClients))
    	states := make([]madmin.BgHealState, len(sys.peerClients))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    		values.Set(peerRESTExecAt, execAt.Format(time.RFC3339Nano))
    	}
    	_, err := signalServiceRPC.Call(context.Background(), client.gridConn(), values)
    	return err
    }
    
    func (client *peerRESTClient) BackgroundHealStatus(ctx context.Context) (madmin.BgHealState, error) {
    	resp, err := getBackgroundHealStatusRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    	if !ok {
    		return bgHealStates, errServerNotInitialized
    	}
    
    	if globalIsDistErasure {
    		// Get heal status from other peers
    		peersHealStates, nerrs := globalNotificationSys.BackgroundHealStatus(ctx)
    		var errCount int
    		for _, nerr := range nerrs {
    			if nerr.Err != nil {
    				adminLogIf(ctx, nerr.Err)
    				errCount++
    			}
    		}
    		if errCount == len(nerrs) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top