Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for pool_id (0.21 sec)

  1. cmd/object-api-interface.go

    	CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error)
    
    	GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) // return the disks belonging to pool and set.
    	SetDriveCounts() []int                              // list of erasure stripe size for each pool in order.
    
    	// Healing operations.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	result.Delimiter = delimiter
    
    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    	if len(disks) == 0 {
    		// using er.getOnlineLocalDisks() has one side-affect where
    		// on a pooled setup all disks are remote, add a fallback
    		disks = er.getOnlineDisks()
    	}
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  3. cmd/notification.go

    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    					SetIndex:  ep.SetIdx,
    					DiskIndex: ep.DiskIdx,
    				})
    			}
    		}
    	}
    	return offlineDisks
    }
    
    // StorageInfo returns disk information across all peers
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	hostAnonymizer := map[string]string{}
    	hosts := set.NewStringSet()
    	srvrIdx := 0
    
    	for poolIdx, pool := range globalEndpoints {
    		for _, endpoint := range pool.Endpoints {
    			if !hosts.Contains(endpoint.Host) {
    				hosts.Add(endpoint.Host)
    				srvrIdx++
    			}
    			anonymizeHost(hostAnonymizer, endpoint, poolIdx+1, srvrIdx)
    		}
    	}
    	return hostAnonymizer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. cmd/endpoint.go

    	GridHost string
    }
    
    // Endpoint - any type of endpoint.
    type Endpoint struct {
    	*url.URL
    	IsLocal bool
    
    	PoolIdx, SetIdx, DiskIdx int
    }
    
    // Equal returns true if endpoint == ep
    func (endpoint Endpoint) Equal(ep Endpoint) bool {
    	if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx {
    		if endpoint.Path == ep.Path && endpoint.Host == ep.Host {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    // Initialize a new storage disk.
    func newLocalXLStorageWithDiskIdx(path string, diskIdx int) (*xlStorage, error) {
    	u := url.URL{Path: path}
    	return newXLStorage(Endpoint{
    		URL:     &u,
    		IsLocal: true,
    		PoolIdx: 0,
    		SetIdx:  0,
    		DiskIdx: diskIdx,
    	}, true)
    }
    
    // creates a temp dir and sets up xlStorage layer.
    // returns xlStorage layer, temp dir path to be used for the purpose of tests.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top