Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for poolArgs (0.13 sec)

  1. cmd/endpoint-ellipses.go

    // both ellipses and without ellipses transparently.
    func createServerEndpoints(serverAddr string, poolArgs []poolDisksLayout, legacy bool) (
    	endpointServerPools EndpointServerPools, setupType SetupType, err error,
    ) {
    	if len(poolArgs) == 0 {
    		return nil, -1, errInvalidArgument
    	}
    
    	poolEndpoints, setupType, err := CreatePoolEndpoints(serverAddr, poolArgs...)
    	if err != nil {
    		return nil, -1, err
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. cmd/server-main.go

    		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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    	}
    
    	errs := g.Wait()
    
    	var poolErrs []error
    	for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ {
    		perPoolErrs := make([]error, 0, len(sys.peerClients))
    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    				perPoolErrs = append(perPoolErrs, errs[i])
    			}
    		}
    		quorum := len(perPoolErrs) / 2
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    type PoolObjInfo struct {
    	Index   int
    	ObjInfo ObjectInfo
    	Err     error
    }
    
    type poolErrs struct {
    	Index int
    	Err   error
    }
    
    func (z *erasureServerPools) getPoolInfoExistingWithOpts(ctx context.Context, bucket, object string, opts ObjectOptions) (PoolObjInfo, []poolErrs, error) {
    	var noReadQuorumPools []poolErrs
    	poolObjInfos := make([]PoolObjInfo, len(z.serverPools))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    		cmdLineWithoutPools := re.ReplaceAllString(cmdLine, `$1$2`)
    
    		// to be anonymized
    		poolsArgs := re.ReplaceAllString(cmdLine, `$3`)
    		var anonPools []string
    
    		if !(strings.Contains(poolsArgs, "{") && strings.Contains(poolsArgs, "}")) {
    			// No ellipses pattern. Anonymize host name from every pool arg
    			pools := strings.Fields(poolsArgs)
    			anonPools = make([]string, len(pools))
    			for index, arg := range pools {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
Back to top