Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 44 of 44 for mock (0.12 sec)

  1. cmd/metrics-v3-cache.go

    			totalDrives:   totalDrives.Sum(),
    			ioStats:       map[string]driveIOStatMetrics{},
    		}
    
    		currentStats := getCurrentDriveIOStats()
    		now := time.Now().UTC()
    
    		prevDriveIOStatsMu.Lock()
    		if prevDriveIOStats != nil {
    			duration := now.Sub(prevDriveIOStatsRefreshedAt)
    			if duration.Seconds() > 1 {
    				for d, cs := range currentStats {
    					if ps, found := prevDriveIOStats[d]; found {
    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)
  2. cmd/global-heal.go

    	"runtime"
    	"sort"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	objectlock "github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/color"
    	"github.com/minio/minio/internal/config/storageclass"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  3. cmd/utils.go

    	return p.ext
    }
    
    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  4. cmd/metrics-v3-types.go

    	}
    }
    
    // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns
    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top