Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for qmsg (0.12 sec)

  1. cmd/metrics-v2.go

    	Histogram            map[string]uint64 `json:"Histogram"`
    }
    
    // MetricsGroupV2 are a group of metrics that are initialized together.
    type MetricsGroupV2 struct {
    	metricsCache     *cachevalue.Cache[[]MetricV2] `msg:"-"`
    	cacheInterval    time.Duration
    	metricsGroupOpts MetricsGroupOpts
    }
    
    // MetricsGroupOpts are a group of metrics opts to be used to initialize the metrics group.
    type MetricsGroupOpts struct {
    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)
  2. cmd/object-handlers_test.go

    			cumulativeSum += p
    		}
    		refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length)
    		if ok, msg := cmpReaders(refReader, rec.Body); !ok {
    			t.Fatalf("(%s) Object: %s Case %d ByteRange: %s --> data mismatch! (msg: %s)", instanceType, oi.objectName, i+1, byteRange, msg)
    		}
    	}
    
    	// Iterate over each uploaded object and do a bunch of get
    	// requests on them.
    	caseNumber := 0
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		}
    		encStream, err := stream.AddEncryptedStream("inspect.zip", nil)
    		if err != nil {
    			bugLogIf(ctx, stream.AddError(err.Error()))
    			return
    		}
    		addErr = func(msg string) {
    			inspectZipW.Close()
    			encStream.Close()
    			stream.AddError(msg)
    		}
    		defer encStream.Close()
    
    		inspectZipW = zip.NewWriter(encStream)
    		defer inspectZipW.Close()
    	} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top