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