- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newStorageRESTClient (0.11 sec)
-
cmd/object-api-common.go
if endpoint.IsLocal { storage, err := newXLStorage(endpoint, opts.cleanUp) if err != nil { return nil, err } return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil } return newStorageRESTClient(endpoint, opts.healthCheck, globalGrid.Load())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2.1K bytes - Viewed (0) -
cmd/storage-rest_test.go
t.Fatalf("unexpected error %v", err) } if err = storage.MakeVol(context.Background(), "bar"); err != nil { t.Fatalf("unexpected error %v", err) } restClient, err := newStorageRESTClient(endpoint, false, tg.Managers[0]) if err != nil { t.Fatal(err) } for { _, err := restClient.DiskInfo(context.Background(), DiskInfoOptions{})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 11.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
// Close - marks the client as closed. func (client *storageRESTClient) Close() error { client.restClient.Close() return nil } var emptyDiskID = "" // Returns a storage rest client. func newStorageRESTClient(endpoint Endpoint, healthCheck bool, gm *grid.Manager) (*storageRESTClient, error) { serverURL := &url.URL{ Scheme: endpoint.Scheme, Host: endpoint.Host,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/erasure-sets.go
go xldisk.monitorDiskWritable(xldisk.diskCtx) } } } else { disk.Close() // Close the remote storage client, re-initialize with healthchecks. disk, err = newStorageRESTClient(disk.Endpoint(), true, globalGrid.Load()) if err != nil { continue } } s.erasureDisks[m][n] = disk if disk.IsLocal() { globalLocalDrivesMu.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1)