Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 133 for Pools (0.02 sec)

  1. cmd/admin-handlers-pools.go

    	}
    
    	vars := mux.Vars(r)
    	v := vars["pool"]
    	byID := vars["by-id"] == "true"
    
    	pools := strings.Split(v, ",")
    	poolIndices := make([]int, 0, len(pools))
    
    	for _, pool := range pools {
    		var idx int
    		if byID {
    			var err error
    			idx, err = strconv.Atoi(pool)
    			if err != nil {
    				// We didn't find any matching pools, invalid input
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "Pools")
    				return
    			}
    			if cap(z.Pools) >= int(zb0002) {
    				z.Pools = (z.Pools)[:zb0002]
    			} else {
    				z.Pools = make([]PoolStatus, zb0002)
    			}
    			for za0001 := range z.Pools {
    				err = z.Pools[za0001].DecodeMsg(dc)
    				if err != nil {
    					err = msgp.WrapError(err, "Pools", za0001)
    					return
    				}
    			}
    		default:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    		p.Pools[idx].LastUpdate = UTCNow()
    		p.Pools[idx].Decommission.StartTime = time.Time{}
    		p.Pools[idx].Decommission.Complete = false
    		p.Pools[idx].Decommission.Failed = true
    		p.Pools[idx].Decommission.Canceled = false
    		return true
    	}
    	return false
    }
    
    func (p *poolMeta) DecommissionCancel(idx int) bool {
    	if p.Pools[idx].Decommission != nil && !p.Pools[idx].Decommission.Canceled {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  4. cmd/globals.go

    	// diskFillFraction is the fraction of a disk we allow to be filled.
    	diskFillFraction = 0.99
    
    	// diskReserveFraction is the fraction of a disk where we will fill other server pools first.
    	// If all pools reach this, we will use all pools with regular placement.
    	diskReserveFraction = 0.15
    
    	// diskAssumeUnknownSize is the size to assume when an unknown size upload is requested.
    	diskAssumeUnknownSize = 1 << 30
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  5. cmd/peer-s3-client.go

    	GetPools() []int
    }
    
    type localPeerS3Client struct {
    	node  Node
    	pools []int
    }
    
    func (l *localPeerS3Client) GetHost() string {
    	return l.node.Host
    }
    
    func (l *localPeerS3Client) SetPools(p []int) {
    	l.pools = make([]int, len(p))
    	copy(l.pools, p)
    }
    
    func (l localPeerS3Client) GetPools() []int {
    	return l.pools
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    	setDriveCount uint64
    }
    
    // buildDisksLayoutFromConfFile supports with and without ellipses transparently.
    func buildDisksLayoutFromConfFile(pools []poolArgs) (layout disksLayout, err error) {
    	if len(pools) == 0 {
    		return layout, errInvalidArgument
    	}
    
    	for _, list := range pools {
    		var endpointsList endpointsList
    
    		for _, arg := range list.args {
    			switch {
    			case ellipses.HasList(arg):
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  7. cmd/server-main.go

    	if err != nil {
    		return err
    	}
    	setDriveCount := uint64(v)
    
    	var pools []poolArgs
    	switch cv.Version {
    	case "v1":
    		cfV1 := config.ServerConfigV1{}
    		if err = yaml.Unmarshal(rd, &cfV1); err != nil {
    			return err
    		}
    
    		pools = make([]poolArgs, 0, len(cfV1.Pools))
    		for _, list := range cfV1.Pools {
    			pools = append(pools, poolArgs{
    				args:          list,
    				setDriveCount: setDriveCount,
    			})
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  8. cmd/endpoint.go

    	if peer == "" {
    		return nil
    	}
    
    	var pools []int
    	for _, ep := range l {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				continue
    			}
    
    			if !slices.Contains(pools, endpoint.PoolIdx) {
    				pools = append(pools, endpoint.PoolIdx)
    			}
    		}
    	}
    
    	return pools
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  9. cmd/admin-router.go

    			// Pool operations
    			adminRouter.Methods(http.MethodGet).Path(adminVersion + "/pools/list").HandlerFunc(adminMiddleware(adminAPI.ListPools, traceAllFlag))
    			adminRouter.Methods(http.MethodGet).Path(adminVersion+"/pools/status").HandlerFunc(adminMiddleware(adminAPI.StatusPool, traceAllFlag)).Queries("pool", "{pool:.*}")
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  10. cmd/endpoint_test.go

    			err := mergeDisksLayoutFromArgs(testCase.args, &srvCtxt)
    			if err != nil && testCase.expectedErr == nil {
    				t.Errorf("Test %d: unexpected error: %v", i+1, err)
    			}
    			pools, setupType, err := CreatePoolEndpoints(testCase.serverAddr, srvCtxt.Layout.pools...)
    			if err == nil && testCase.expectedErr != nil {
    				t.Errorf("Test %d: expected = %v, got = <nil>", i+1, testCase.expectedErr)
    			}
    			if err == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 18.9K bytes
    - Viewed (0)
Back to top