Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newStorageRESTClient (0.35 sec)

  1. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  4. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 37.7K bytes
    - Viewed (0)
Back to top