Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for mustGetPoolEndpoints (0.16 sec)

  1. cmd/erasure-server-pool-decom_test.go

    )
    
    func prepareErasurePools() (ObjectLayer, []string, error) {
    	nDisks := 32
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	pools := mustGetPoolEndpoints(0, fsDirs[:16]...)
    	pools = append(pools, mustGetPoolEndpoints(1, fsDirs[16:]...)...)
    
    	// Everything is fine, should return nil
    	objLayer, err := newErasureServerPools(context.Background(), pools)
    	if err != nil {
    		return nil, nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 01 14:38:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. cmd/server-main_test.go

    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    	defer removeRoots(disks)
    
    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		t.Fatal("Unexpected object layer initialization error", err)
    	}
    
    	_, ok := obj.(*erasureServerPools)
    	if !ok {
    		t.Fatal("Unexpected object layer detected", reflect.TypeOf(obj))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils_test.go

    	defer cancel()
    
    	nDisks := 16
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/admin-handlers_test.go

    	if err := newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    		cancel()
    		return nil, err
    	}
    
    	// Initialize boot time
    	globalBootTime = UTCNow()
    
    	globalEndpoints = mustGetPoolEndpoints(0, erasureDirs...)
    
    	initAllSubsystems(ctx)
    
    	initConfigSubsystem(ctx, objLayer)
    
    	globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second)
    
    	// Setup admin mgmt REST API handlers.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  5. cmd/erasure-healing_test.go

    	nDisks := 32
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	defer removeRoots(fsDirs)
    
    	pools := mustGetPoolEndpoints(0, fsDirs[:16]...)
    	pools = append(pools, mustGetPoolEndpoints(1, fsDirs[16:]...)...)
    
    	// Everything is fine, should return nil
    	objLayer, _, err := initObjectLayer(ctx, pools)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  6. cmd/endpoint_test.go

    			[]string{"http://localhost:9000/d1", "http://localhost:9001/d2", "http://localhost:9002/d3", "http://localhost:9003/d4"},
    			"localhost:9000",
    		},
    	}
    
    	for i, testCase := range testCases {
    		zendpoints := mustGetPoolEndpoints(0, testCase.endpointArgs...)
    		if !zendpoints[0].Endpoints[0].IsLocal {
    			if err := zendpoints[0].Endpoints.UpdateIsLocal(); err != nil {
    				t.Fatalf("error: expected = <nil>, got = %v", err)
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jan 13 07:53:03 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	nDisks := 1
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, "", err
    	}
    	obj, _, err := initObjectLayer(context.Background(), mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		return nil, "", err
    	}
    
    	initAllSubsystems(ctx)
    
    	globalIAMSys.Init(ctx, obj, globalEtcdClient, 2*time.Second)
    	return obj, fsDirs[0], nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. cmd/erasure-object_test.go

    	path := t.TempDir()
    
    	var fsDirs []string
    	for i := 1; i <= numDisks; i++ {
    		fsDirs = append(fsDirs, filepath.Join(path, fmt.Sprintf("disk%d", i)))
    	}
    
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		removeRoots(fsDirs)
    		t.Fatal(err)
    	}
    
    	// cleaning up of temporary test directories
    	defer objLayer.Shutdown(context.Background())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    				}
    			}
    		})
    	}
    }
    
    // Initialize FS backend for the benchmark.
    func initFSObjectsB(disk string, t *testing.B) (obj ObjectLayer) {
    	obj, _, err := initObjectLayer(context.Background(), mustGetPoolEndpoints(0, disk))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	newTestConfig(globalMinioDefaultRegion, obj)
    
    	initAllSubsystems(GlobalContext)
    	return obj
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
Back to top