Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for LocalStorageInfo (0.14 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure.go

    	disks := er.getDisks()
    	endpoints := er.getEndpoints()
    	return getStorageInfo(disks, endpoints, true)
    }
    
    // LocalStorageInfo - returns underlying local storage statistics.
    func (er erasureObjects) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo {
    	disks := er.getDisks()
    	endpoints := er.getEndpoints()
    
    	var localDisks []StorageAPI
    	var localEndpoints []Endpoint
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  2. cmd/peer-rest-client.go

    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    	resp, err := localStorageInfoRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/object-api-interface.go

    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    	StorageInfo(ctx context.Context, metrics bool) StorageInfo
    	LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo
    
    	// Bucket operations.
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  4. cmd/admin-server-info.go

    			props.MinioEnvVars[key] = "*** EXISTS, REDACTED ***"
    			continue
    		}
    		props.MinioEnvVars[key] = value
    	}
    
    	objLayer := newObjectLayerFn()
    	if objLayer != nil {
    		storageInfo := objLayer.LocalStorageInfo(GlobalContext, metrics)
    		props.State = string(madmin.ItemOnline)
    		props.Disks = storageInfo.Disks
    	} else {
    		props.State = string(madmin.ItemInitializing)
    		props.Disks = getOfflineDisks("", globalEndpoints)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.9K bytes
    - Click Count (1)
  5. cmd/global-heal.go

    		healing := globalBackgroundHealState.getLocalHealingDisks()
    		for _, disk := range healing {
    			status.HealDisks = append(status.HealDisks, disk.Endpoint)
    		}
    
    		return status, true
    	}
    
    	si := o.LocalStorageInfo(ctx, true)
    
    	indexed := make(map[string][]madmin.Disk)
    	for _, disk := range si.Disks {
    		setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex)
    		indexed[setIdx] = append(indexed[setIdx], disk)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  6. cmd/metrics-v2.go

    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		objLayer := newObjectLayerFn()
    
    		metrics = make([]MetricV2, 0, 50)
    		storageInfo := objLayer.LocalStorageInfo(ctx, true)
    		onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks)
    		totalDrives := onlineDrives.Merge(offlineDrives)
    
    		for _, disk := range storageInfo.Disks {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
Back to Top