- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for mustGetPoolEndpoints (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)