- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for EncodeMsg (0.32 sec)
-
cmd/storage-rest-common_gen.go
} } } return } // EncodeMsg implements msgp.Encodable func (z *nsScannerResp) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "u" err = en.Append(0x82, 0xa1, 0x75) if err != nil { return } if z.Update == nil { err = en.WriteNil() if err != nil { return } } else { err = z.Update.EncodeMsg(en) if err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.9K bytes - Viewed (0) -
internal/bucket/replication/datatypes_gen.go
{ var zb0001 string zb0001, err = dc.ReadString() if err != nil { err = msgp.WrapError(err) return } (*z) = StatusType(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteString(string(z)) if err != nil { err = msgp.WrapError(err) return } return } // MarshalMsg implements msgp.MarshalerRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 3.4K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, zb0001) return } } } (*z)[zb0001] = zb0002 } return } // EncodeMsg implements msgp.Encodable func (z DailyAllTierStats) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteMapHeader(uint32(len(z))) if err != nil { err = msgp.WrapError(err) return } for zb0007, zb0008 := range z {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 9.2K bytes - Viewed (0) -
cmd/tier_gen.go
} z.Tiers[za0001] = za0002 } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *TierConfigMgr) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 1 // write "Tiers" err = en.Append(0x81, 0xa5, 0x54, 0x69, 0x65, 0x72, 0x73) if err != nil { return }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 3.9K bytes - Viewed (0) -
internal/grid/grid_types_msgp_test.go
return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z testRequest) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Num" err = en.Append(0x82, 0xa3, 0x4e, 0x75, 0x6d) if err != nil { return } err = en.WriteInt(z.Num)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 8.1K bytes - Viewed (0) -
cmd/site-replication-utils_gen.go
return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *SiteResyncStatus) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 6 // write "v" err = en.Append(0x86, 0xa1, 0x76) if err != nil { return } err = en.WriteInt(z.Version)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.1K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen.go
} switch msgp.UnsafeString(field) { default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 0 _ = z err = en.Append(0x80) if err != nil { return } return } // MarshalMsg implements msgp.Marshaler
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.4K bytes - Viewed (0) -
cmd/batch-handlers_gen_test.go
v := BatchJobPrefix{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeBatchJobPrefix(b *testing.B) { v := BatchJobPrefix{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.7K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
v := localLockMap{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodelocalLockMap(b *testing.B) { v := localLockMap{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.7K bytes - Viewed (0) -
internal/dsync/lock-args_gen_test.go
v := LockArgs{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeLockArgs(b *testing.B) { v := LockArgs{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 4.4K bytes - Viewed (0)