Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for LoadTransitionTierConfig (0.92 sec)

  1. cmd/tier-handlers.go

    		return
    	}
    
    	err = globalTierConfigMgr.Save(ctx, objAPI)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	globalNotificationSys.LoadTransitionTierConfig(ctx)
    
    	writeSuccessNoContent(w)
    }
    
    func (api adminAPIHandlers) ListTierHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/notification.go

    		if nErr.Err != nil {
    			peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String())
    		}
    	}
    }
    
    // LoadTransitionTierConfig notifies remote peers to load their remote tier
    // configs from config store.
    func (sys *NotificationSys) LoadTransitionTierConfig(ctx context.Context) {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	}
    	_, err := loadRebalanceMetaRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{
    		peerRESTStartRebalance: strconv.FormatBool(startRebalance),
    	}))
    	return err
    }
    
    func (client *peerRESTClient) LoadTransitionTierConfig(ctx context.Context) error {
    	conn := client.gridConn()
    	if conn == nil {
    		return nil
    	}
    	_, err := loadTransitionTierConfigRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{}))
    	return 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)
Back to top