Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for LocalStorageInfo (1.04 sec)

  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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    func (s *erasureSets) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo {
    	var storageInfo StorageInfo
    
    	storageInfos := make([]StorageInfo, len(s.sets))
    
    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].LocalStorageInfo(ctx, metrics)
    			return nil
    		}, index)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/notification.go

    			defer wg.Done()
    			info, err := client.LocalStorageInfo(ctx, metrics)
    			if err != nil {
    				info.Disks = getOfflineDisks(client.host.String(), globalEndpoints)
    			}
    			replies[idx] = info
    		}(client, i)
    	}
    	wg.Wait()
    
    	// Add local to this server.
    	replies = append(replies, objLayer.LocalStorageInfo(ctx, metrics))
    
    	storageInfo.Backend = objLayer.BackendInfo()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    	return
    }
    
    func (z *erasureServerPools) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo {
    	var storageInfo StorageInfo
    
    	storageInfos := make([]StorageInfo, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		g.Go(func() error {
    			storageInfos[index] = z.serverPools[index].LocalStorageInfo(ctx, metrics)
    			return nil
    		}, index)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top