- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 467 for Uint64 (0.14 sec)
-
docs/bucket/versioning/DESIGN.md
xlHeaderVersion version == 1: ``` //msgp:tuple xlMetaV2VersionHeader type xlMetaV2VersionHeader struct { VersionID [16]byte // Version UUID, raw. ModTime int64 // Unix nanoseconds. Signature [4]byte // Signature of metadata. Type uint8 // Type if the version Flags uint8 } ``` The following flags are defined: ``` const (
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jul 17 15:43:14 UTC 2022 - 5.8K bytes - Viewed (0) -
cmd/warm-backend-s3.go
destObj := object if s3.Prefix != "" { destObj = fmt.Sprintf("%s/%s", s3.Prefix, object) } return destObj } func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { res, err := s3.client.PutObject(ctx, s3.Bucket, s3.getDest(object), r, length, minio.PutObjectOptions{ SendContentMd5: true, StorageClass: s3.StorageClass, })
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.5K bytes - Viewed (0) -
src/bufio/example_test.go
fmt.Fprint(w, "Hello, ") fmt.Fprint(w, "world!") w.Flush() // Don't forget to flush! // Output: Hello, world! } func ExampleWriter_AvailableBuffer() { w := bufio.NewWriter(os.Stdout) for _, i := range []int64{1, 2, 3, 4} { b := w.AvailableBuffer() b = strconv.AppendInt(b, i, 10) b = append(b, ' ') w.Write(b) } w.Flush() // Output: 1 2 3 4 }
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Oct 23 09:06:30 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/batch-job-common-types_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "testing" ) func TestBatchJobSizeInRange(t *testing.T) { tests := []struct { objSize int64 sizeFilter BatchJobSizeFilter want bool }{ { // 1Mib < 2Mib < 10MiB -> in range objSize: 2 << 20, sizeFilter: BatchJobSizeFilter{ UpperBound: 10 << 20, LowerBound: 1 << 20,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jan 08 23:22:28 UTC 2024 - 3.3K bytes - Viewed (0) -
internal/grid/trace.go
TraceType: t.TraceType, FuncName: prefix + "." + h.String(), NodeName: remote, Time: start, Duration: end.Sub(start), Path: t.Subroute, Error: errString, Bytes: int64(len(req) + len(resp)), HTTP: &madmin.TraceHTTPStats{ ReqInfo: madmin.TraceRequestInfo{ Time: start, Proto: "grid", Method: "REQ", Client: local, Headers: nil,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 4.1K bytes - Viewed (0) -
internal/s3select/select_benchmark_test.go
<RequestProgress> <Enabled>FALSE</Enabled> </RequestProgress> </SelectObjectContentRequest> `) csvData := genSampleCSVData(count) b.ResetTimer() b.ReportAllocs() b.SetBytes(int64(count)) b.RunParallel(func(pb *testing.PB) { for pb.Next() { s3Select, err := NewS3Select(bytes.NewReader(requestXML)) if err != nil { b.Fatal(err) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Apr 14 13:54:47 UTC 2022 - 5K bytes - Viewed (0) -
internal/cachevalue/cache.go
opts Opts // Once can be used to initialize values for lazy initialization. // Should be set before calling Get(). Once sync.Once // Managed values. val atomic.Pointer[T] lastUpdateMs atomic.Int64 updating sync.Mutex } // New allocates a new cached value instance. Tt must be initialized with // `.TnitOnce`. func New[T any]() *Cache[T] { return &Cache[T]{} }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
docs/debugging/healing-bin/main.go
if !c.Args().Present() { cli.ShowAppHelpAndExit(c, 1) // last argument is exit code } ht := make(map[string]map[string]interface{}) file := c.Args().Get(0) if strings.HasSuffix(file, ".zip") { var sz int64 f, err := os.Open(file) if err != nil { return err } if st, err := f.Stat(); err == nil { sz = st.Size() } defer f.Close() zr, err := zip.NewReader(f, sz) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.2K bytes - Viewed (0) -
src/bufio/bufio.go
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
cmd/warm-backend-azure.go
destObj := object if az.Prefix != "" { destObj = fmt.Sprintf("%s/%s", az.Prefix, object) } return destObj } func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{ Concurrency: 4, AccessTier: az.tier(), // set tier if specified })
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 18:21:34 UTC 2024 - 6.6K bytes - Viewed (0)