Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for metric (0.16 sec)

  1. cmd/batch-handlers.go

    func (m *batchJobMetrics) report(jobID string) (metrics *madmin.BatchJobMetrics) {
    	metrics = &madmin.BatchJobMetrics{CollectedAt: time.Now(), Jobs: make(map[string]madmin.JobMetric)}
    	m.RLock()
    	defer m.RUnlock()
    
    	if jobID != "" {
    		if job, ok := m.metrics[jobID]; ok {
    			metrics.Jobs[jobID] = job.metric()
    		}
    		return metrics
    	}
    
    	for id, job := range m.metrics {
    		metrics.Jobs[id] = job.metric()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    // GetPeerMetrics gets the metrics to be federated across peers.
    func (s *peerRESTServer) GetPeerMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) {
    	res := make([]*MetricV2, 0, len(peerMetricsGroups))
    	populateAndPublish(peerMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    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)
  3. cmd/erasure-server-pool.go

    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)
  4. cmd/iam.go

    	inheritedPolicyType = "inherited-policy"
    )
    
    // IAMSys - config system.
    type IAMSys struct {
    	// Need to keep them here to keep alignment - ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	// metrics
    	LastRefreshTimeUnixNano         uint64
    	LastRefreshDurationMilliseconds uint64
    	TotalRefreshSuccesses           uint64
    	TotalRefreshFailures            uint64
    
    	sync.Mutex
    
    	iamRefreshInterval time.Duration
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
Back to top