Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for registerStorageRESTHandlers (0.43 sec)

  1. cmd/storage-rest_test.go

    		Endpoints: Endpoints{endpoint},
    	}}
    	poolEps[0].SetCount = 1
    	poolEps[0].DrivesPerSet = 1
    
    	// Register handlers on newly created servers
    	registerStorageRESTHandlers(tg.Mux[0], poolEps, tg.Managers[0])
    	registerStorageRESTHandlers(tg.Mux[1], poolEps, tg.Managers[1])
    
    	storage := globalLocalSetDrives[0][0][0]
    	if err = storage.MakeVol(t.Context(), "foo"); err != nil {
    		t.Fatalf("unexpected error %v", err)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. cmd/routers.go

    	var (
    		lockGrid   = globalLockGrid.Load()
    		commonGrid = globalGrid.Load()
    	)
    
    	// Register storage REST router only if its a distributed setup.
    	registerStorageRESTHandlers(router, endpointServerPools, commonGrid)
    
    	// Register peer REST router only if its a distributed setup.
    	registerPeerRESTHandlers(router, commonGrid)
    
    	// Register bootstrap REST router for distributed setups.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    //
    // Any updates to this must be serialized via globalLocalDrivesMu (locker)
    var globalLocalSetDrives [][][]StorageAPI
    
    // registerStorageRESTHandlers - register storage rpc router.
    func registerStorageRESTHandlers(router *mux.Router, endpointServerPools EndpointServerPools, gm *grid.Manager) {
    	h := func(f http.HandlerFunc) http.HandlerFunc {
    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  4. cmd/utils.go

    		VersionID:    strings.TrimSpace(r.Form.Get(xhttp.VersionID)),
    	}
    
    	return logger.SetReqInfo(r.Context(), reqInfo)
    }
    
    // Used for registering with rest handlers (have a look at registerStorageRESTHandlers for usage example)
    // If it is passed ["aaaa", "bbbb"], it returns ["aaaa", "{aaaa:.*}", "bbbb", "{bbbb:.*}"]
    func restQueries(keys ...string) []string {
    	var accumulator []string
    	for _, key := range keys {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top