Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for poolEndpoints (0.19 sec)

  1. cmd/endpoint.go

    		}
    
    		poolEndpoints[poolIdx] = endpoints
    	}
    
    	if err := poolEndpoints.UpdateIsLocal(); err != nil {
    		return nil, setupType, config.ErrInvalidErasureEndpoints(nil).Msg(err.Error())
    	}
    
    	for i, endpoints := range poolEndpoints {
    		// Here all endpoints are URL style.
    		endpointPathSet := set.NewStringSet()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  2. cmd/lock-rest-client_test.go

    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    	err = initGlobalLockGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	lkClient := newlockRESTClient(endpoint)
    	if lkClient.IsOnline() {
    		t.Fatalf("unexpected result. connection was online")
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2K bytes
    - Viewed (0)
  3. cmd/endpoint-ellipses.go

    ) {
    	if len(poolArgs) == 0 {
    		return nil, -1, errInvalidArgument
    	}
    
    	poolEndpoints, setupType, err := CreatePoolEndpoints(serverAddr, poolArgs...)
    	if err != nil {
    		return nil, -1, err
    	}
    
    	for i, endpointList := range poolEndpoints {
    		if err = endpointServerPools.Add(PoolEndpoints{
    			Legacy:       legacy,
    			SetCount:     len(poolArgs[i].layout),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  4. cmd/erasure-sets_test.go

    	// Initializes all erasure disks
    	storageDisks, format, err := waitForFormatErasure(true, endpoints, 1, 1, 16, "")
    	if err != nil {
    		t.Fatalf("Unable to format drives for erasure, %s", err)
    	}
    
    	ep := PoolEndpoints{Endpoints: endpoints}
    
    	parity, err := ecDrivesNoConfig(16)
    	if err != nil {
    		t.Fatalf("Unexpected error during EC drive config: %v", err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    	}
    
    	if err = endpoint.UpdateIsLocal(); err != nil {
    		t.Fatalf("UpdateIsLocal failed %v", err)
    	}
    
    	endpoint.PoolIdx = 0
    	endpoint.SetIdx = 0
    	endpoint.DiskIdx = 0
    
    	poolEps := []PoolEndpoints{{
    		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])
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    	// Distributed locker clients.
    	erasureLockers setsDsyncLockers
    
    	// Distributed lock owner (constant per running instance).
    	erasureLockOwner string
    
    	// List of endpoints provided on the command line.
    	endpoints PoolEndpoints
    
    	// String version of all the endpoints, an optimization
    	// to avoid url.String() conversion taking CPU on
    	// large disk setups.
    	endpointStrings []string
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  7. cmd/test-utils_test.go

    	drivesPerSet := len(args)
    	setCount := 1
    	if len(args) >= 16 {
    		drivesPerSet = 16
    		setCount = len(args) / 16
    	}
    	endpoints := mustGetNewEndpoints(poolIdx, drivesPerSet, args...)
    	return []PoolEndpoints{{
    		SetCount:     setCount,
    		DrivesPerSet: drivesPerSet,
    		Endpoints:    endpoints,
    		CmdLine:      strings.Join(args, " "),
    	}}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top