Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for LocalStorageInfo (0.2 sec)

  1. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  2. cmd/metrics-realtime.go

    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    		return nil
    	}
    
    	metrics := make(map[string]madmin.DiskMetric)
    	storageInfo := objLayer.LocalStorageInfo(GlobalContext, true)
    	for _, d := range storageInfo.Disks {
    		if len(disks) != 0 {
    			_, ok := disks[d.Endpoint]
    			if !ok {
    				continue
    			}
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 10 16:28:08 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(metrics bool) (info StorageInfo, err error) {
    	resp, err := localStorageInfoRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  4. 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 {
    		index := index
    		g.Go(func() error {
    			storageInfos[index] = z.serverPools[index].LocalStorageInfo(ctx, metrics)
    			return nil
    		}, index)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  6. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  7. cmd/peer-rest-server.go

    		return nil, grid.NewRemoteErr(errServerNotInitialized)
    	}
    
    	metrics, err := strconv.ParseBool(mss.Get(peerRESTMetrics))
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    	info := objLayer.LocalStorageInfo(context.Background(), metrics)
    	return madminStorageInfo.NewJSONWith(&info), nil
    }
    
    // ServerInfoHandler - returns Server Info
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  8. cmd/metrics-v3-cache.go

    	)
    
    	loadDriveMetrics := func() (v storageMetrics, err error) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    		storageInfo := objLayer.LocalStorageInfo(GlobalContext, true)
    		onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks)
    		totalDrives := onlineDrives.Merge(offlineDrives)
    
    		v = storageMetrics{
    			storageInfo:   storageInfo,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  9. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  10. 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)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
Back to top