- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 102 for Bytes (0.23 sec)
-
internal/grid/types.go
// remainder of bytes. func (b *Bytes) UnmarshalMsg(bytes []byte) ([]byte, error) { if b == nil { return bytes, errors.New("Bytes: UnmarshalMsg on nil pointer") } if bytes, err := msgp.ReadNilBytes(bytes); err == nil { if *b != nil { PutByteBuffer(*b) } *b = nil return bytes, nil } val, bytes, err := msgp.ReadBytesZC(bytes) if err != nil { return bytes, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/erasure-object_test.go
} gr.Close() if !bytes.Equal(output.Bytes(), smallData) { t.Fatalf("Corrupted data is found") } // Test: Upload a file bigger than the small file threshold // under the same bucket & key name and try to read it again. output.Reset() bigData := bytes.Repeat([]byte{'b'}, smallFileThreshold*numberOfDisks/2)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/object_api_suite_test.go
if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } if len(bytesBuffer1.Bytes()) != len(content) { t.Errorf("%s: Expected content length to be `%d`, but instead found `%d`", instanceType, len(content), len(bytesBuffer1.Bytes())) } var bytesBuffer2 bytes.Buffer _, err = obj.PutObject(context.Background(), "bucket", "object", mustGetPutObjReader(t, readerNoEOF, length, "", ""), opts)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} b, _, minor, err := checkXL2V1(b) if err != nil { return nil, err } filemap[file] = make(map[string]string) buf := bytes.NewBuffer(nil) v0 := "" var data xlMetaInlineData switch minor { case 0: _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)) if err != nil { return nil, err } case 1, 2: v, b, err := msgp.ReadBytesZC(b) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/site-replication-metrics_gen.go
switch msgp.UnsafeString(field) { case "Count": z.Count, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Count") return } case "Bytes": z.Bytes, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Bytes") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 40.6K bytes - Viewed (0) -
cmd/metrics.go
prometheus.BuildFQName(interNodeNamespace, "rx", "bytes_total"), "Total number of internode bytes received by current MinIO server instance", nil, nil), prometheus.CounterValue, float64(connStats.internodeInputBytes), ) // Network Sent/Received Bytes (Outbound) ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(s3Namespace, "tx", "bytes_total"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/crypto/metadata_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/metrics-v2_gen.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 19.2K bytes - Viewed (0) -
cmd/data-usage_test.go
FailedSize: 3, FailedCount: 5, PendingCount: 6, }, }, } want.replace("abucket/dir2", "", *e) var buf bytes.Buffer err = want.serializeTo(&buf) if err != nil { t.Fatal(err) } t.Log("serialized size:", buf.Len(), "bytes") var got dataUsageCache err = got.deserialize(&buf) if err != nil { t.Fatal(err) } if got.Info.LastUpdate.IsZero() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/batch-job-common-types_gen.go
bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z BatchJobKV) Msgsize() (s int) { s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value) return } // DecodeMsg implements msgp.Decodable
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 21.9K bytes - Viewed (0)