- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for reporters (0.2 sec)
-
internal/bucket/bandwidth/measurement.go
func newBucketMeasurement(initTime time.Time) *bucketMeasurement { return &bucketMeasurement{ startTime: initTime, } } // incrementBytes add bytes reported for a bucket. func (m *bucketMeasurement) incrementBytes(bytes uint64) { atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type MonitoredReader struct { r io.Reader throttle *bucketThrottle ctx context.Context // request context lastErr error // last error reported, if this non-nil all reads will fail. m *Monitor opts *MonitorReaderOptions } // BucketOptions represents the bucket and optionally its replication target pair. type BucketOptions struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
src/cmd/asm/main.go
diag = true log.Printf(format, args...) } if *flags.SymABIs { ok = parser.ParseSymABIs(buf) } else { pList := new(obj.Plist) pList.Firstpc, ok = parser.Parse() // reports errors to parser.Errorf if ok { obj.Flushplist(ctxt, pList, nil) } } if !ok { failedFile = f break } } if ok && !*flags.SymABIs { ctxt.NumberSyms()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 2.7K bytes - Viewed (0) -
src/bufio/scan.go
} // SplitFunc is the signature of the split function used to tokenize the // input. The arguments are an initial substring of the remaining unprocessed // data and a flag, atEOF, that reports whether the [Reader] has no more data // to give. The return values are the number of bytes to advance the input // and the next token to return to the user, if any, plus an error, if any. //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
operator/cmd/mesh/operator-common.go
// outputFormat controls the format of operator dumps outputFormat string } const ( operatorResourceName = "istio-operator" operatorDefaultNamespace = "istio-operator" ) // isControllerInstalled reports whether an operator deployment exists in the given namespace. func isControllerInstalled(cs kubernetes.Interface, operatorNamespace string, revision string) (bool, error) { orn := operatorResourceName if revision != "" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Dec 17 02:25:04 GMT 2022 - 3.8K bytes - Viewed (0) -
src/archive/tar/format.go
// sub-second times | no | yes | no // sparse files | no | yes | yes // // The table's upper portion shows the [Header] fields, where each format reports // the maximum number of bytes allowed for each string field and // the integer type used to store each numeric field // (where timestamps are stored as the number of seconds since the Unix epoch). //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 11.3K bytes - Viewed (0) -
src/archive/zip/struct.go
// set MSDOS attributes too, as the original zip does. if mode&fs.ModeDir != 0 { h.ExternalAttrs |= msdosDir } if mode&0200 == 0 { h.ExternalAttrs |= msdosReadOnly } } // isZip64 reports whether the file size exceeds the 32 bit limit func (h *FileHeader) isZip64() bool { return h.CompressedSize64 >= uint32max || h.UncompressedSize64 >= uint32max } func (h *FileHeader) hasDataDescriptor() bool {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
src/bytes/bytes_test.go
{"012abcba210", "\xffb", 6}, {"012\x80bcb\x80210", "\xffb", 7}, {"0123456\xcf\x80abc", "\xcfb\x80", 10}, } // Execute f on each test case. funcName should be the name of f; it's used // in failure reports. func runIndexTests(t *testing.T, f func(s, sep []byte) int, funcName string, testCases []BinOpTest) { for _, test := range testCases { a := []byte(test.a) b := []byte(test.b) actual := f(a, b)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 24 16:07:25 GMT 2024 - 56.2K bytes - Viewed (0) -
cmd/bucket-replication.go
// only at bucket level instead. VersionSuspended: globalBucketVersioningSys.Suspended(bucket), }) if err != nil && !isErrVersionNotFound(err) { // VersionNotFound would be reported by pool that object version is missing on. sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{ Bucket: bucket, Name: dobj.ObjectName, VersionID: versionID,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
src/cmd/asm/internal/lex/lex.go
// Text returns the original string representation of the token. Text() string // File reports the source file name of the token. File() string // Base reports the position base of the token. Base() *src.PosBase // SetBase sets the position base. SetBase(*src.PosBase) // Line reports the source line number of the token. Line() int // Col reports the source column number of the token. Col() int // Close does any teardown required.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 4.1K bytes - Viewed (0)