- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 242 for start (0.34 sec)
-
internal/bucket/bandwidth/monitor_test.go
type fields struct { activeBuckets map[BucketOptions]*bucketMeasurement endTime time.Time update2 uint64 endTime2 time.Time } start := time.Now() m0 := newBucketMeasurement(start) m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/kms/context.go
if c == '\u2028' || c == '\u2029' { if start < i { dst.WriteString(s[start:i]) } dst.WriteString(`\u202`) dst.WriteByte(hexTable[c&0xF]) i += size start = i continue } i += size } if start < len(s) { dst.WriteString(s[start:]) } } // htmlSafeSet holds the value true if the ASCII character with the given
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 6K bytes - Viewed (0) -
cmd/httprange.go
return 0, 0, err } start = h.Start if h.IsSuffixLength { start = resourceSize + h.Start if start < 0 { start = 0 } } return start, length, nil } // Parse a HTTP range header value into a HTTPRangeSpec func parseRequestRangeSpec(rangeString string) (hrange *HTTPRangeSpec, err error) { // Return error if given range string doesn't start with byte range prefix.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 24 14:56:28 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/ftp-server.go
if len(tokens) != 2 { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s", arg), "unable to start FTP server") } switch tokens[0] { case "address": host, portStr, err := net.SplitHostPort(tokens[1]) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server") } port, err = strconv.Atoi(portStr) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 4.8K bytes - Viewed (2) -
cmd/api-resources_test.go
"continuation-token": []string{"dG9rZW4="}, "start-after": []string{"start-after"}, "delimiter": []string{SlashSeparator}, "fetch-owner": []string{"true"}, "max-keys": []string{"100"}, "encoding-type": []string{"gzip"}, }, prefix: "photos/", token: "token", startAfter: "start-after", delimiter: SlashSeparator, fetchOwner: true,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 7.1K bytes - Viewed (0) -
src/archive/zip/writer.go
return err } if _, err := io.WriteString(w.cw, h.Comment); err != nil { return err } } end := w.cw.count records := uint64(len(w.dir)) size := uint64(end - start) offset := uint64(start) if f := w.testHookCloseSizeOffset; f != nil { f(size, offset) } if records >= uint16max || size >= uint32max || offset >= uint32max { var buf [directory64EndLen + directory64LocLen]byte
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
internal/event/config.go
func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if filter.isEmpty() { return nil } type filterRuleWrapper FilterRule return e.EncodeElement(filterRuleWrapper(filter), start) } // UnmarshalXML - decodes XML data. func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { // Make subtype to avoid recursive UnmarshalXML().
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/grid/grid_test.go
start := time.Now() resp, err := remoteConn.Request(context.Background(), handlerTest2, []byte(testPayload)) t.Log("Roundtrip:", time.Since(start)) if len(resp) != 0 { t.Errorf("want nil, got %q", string(resp)) } if err != RemoteErr(testPayload) { t.Errorf("want error %v(%T), got %v(%T)", RemoteErr(testPayload), RemoteErr(testPayload), err, err) } t.Log("Roundtrip:", time.Since(start)) })
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
} // UnmarshalXML - decodes XML data. func (l *ObjectLegalHold) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { switch start.Name.Local { case "LegalHold", "ObjectLockLegalHold": default: return xml.UnmarshalError(fmt.Sprintf("expected element type <LegalHold>/<ObjectLockLegalHold> but have <%s>", start.Name.Local)) } for { // Read tokens from the XML document in a stream. t, err := d.Token()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
cmd/local-locker_test.go
Quorum: 0, }) if !ok || err != nil { t.Fatal("failed:", err, ok) } } } start := time.Now() l.expireOldLocks(time.Hour) t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap)) if len(l.lockMap) != locks { t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0)