Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for LocalStorageInfo (0.32 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  2. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  3. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 10 16:28:08 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  6. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  7. cmd/object-api-interface.go

    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  8. cmd/notification.go

    			defer wg.Done()
    			info, err := client.LocalStorageInfo(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(GlobalContext, metrics))
    
    	storageInfo.Backend = objLayer.BackendInfo()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  9. 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 {
    		index := index
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].LocalStorageInfo(ctx, metrics)
    			return nil
    		}, index)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  10. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
Back to top