Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for poolEps (0.04 seconds)

  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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool.go

    		})
    		if err != nil {
    			return nil, err
    		}
    
    		if deploymentID == "" {
    			// all pools should have same deployment ID
    			deploymentID = formats[i].ID
    		}
    
    		// Validate if users brought different DeploymentID pools.
    		if deploymentID != formats[i].ID {
    			return nil, fmt.Errorf("all pools must have same deployment ID - expected %s, got %s for pool(%s)", deploymentID, formats[i].ID, humanize.Ordinal(i+1))
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  4. 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:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool-rebalance.go

    	for i, ps := range z.rebalMeta.PoolStats {
    		// skip pools which have completed rebalancing
    		if ps.Info.Status != rebalStarted {
    			continue
    		}
    
    		participants[i] = ps.Participating
    	}
    	z.rebalMu.RUnlock()
    
    	for poolIdx, doRebalance := range participants {
    		if !doRebalance {
    			continue
    		}
    		// nothing to do if this node is not pool's first node (i.e pool's rebalance 'leader').
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (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):
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. 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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  8. cmd/peer-rest-server.go

    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return np, grid.NewRemoteErr(errServerNotInitialized)
    	}
    
    	pools, ok := objAPI.(*erasureServerPools)
    	if !ok {
    		return np, nerr
    	}
    
    	if err := pools.ReloadPoolMeta(context.Background()); err != nil {
    		return np, grid.NewRemoteErr(err)
    	}
    
    	return np, nerr
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (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:.*}")
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  10. cmd/object-api-interface.go

    	SkipDecommissioned bool
    	// SkipRebalancing should be set to 'true' if the call should skip pools
    	// participating in a rebalance operation. Typically set for 'write' operations.
    	SkipRebalancing bool
    
    	SrcPoolIdx int // set by PutObject/CompleteMultipart operations due to rebalance; used to prevent rebalance src, dst pools to be the same
    
    	DataMovement bool // indicates an going decommisionning or rebalacing
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
Back to Top