Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newStorageRESTClient (0.18 sec)

  1. 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)
  2. 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)
  3. 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 (0)
Back to top