MCPcopy Create free account
hub / github.com/cortexproject/cortex / MarshalToSizedBuffer

Method MarshalToSizedBuffer

pkg/ingester/client/ingester.pb.go:3595–3637  ·  view source on GitHub ↗
(dAtA []byte)

Source from the content-addressed store, hash-verified

3593}
3594
3595func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
3596 i := len(dAtA)
3597 _ = i
3598 var l int
3599 _ = l
3600 {
3601 size := m.MessageWithBufRef.Size()
3602 i -= size
3603 if _, err := m.MessageWithBufRef.MarshalTo(dAtA[i:]); err != nil {
3604 return 0, err
3605 }
3606 i = encodeVarintIngester(dAtA, i, uint64(size))
3607 }
3608 i--
3609 dAtA[i] = 0x3e
3610 i--
3611 dAtA[i] = 0xca
3612 if len(m.Matchers) > 0 {
3613 for iNdEx := len(m.Matchers) - 1; iNdEx >= 0; iNdEx-- {
3614 {
3615 size, err := m.Matchers[iNdEx].MarshalToSizedBuffer(dAtA[:i])
3616 if err != nil {
3617 return 0, err
3618 }
3619 i -= size
3620 i = encodeVarintIngester(dAtA, i, uint64(size))
3621 }
3622 i--
3623 dAtA[i] = 0x1a
3624 }
3625 }
3626 if m.EndTimestampMs != 0 {
3627 i = encodeVarintIngester(dAtA, i, uint64(m.EndTimestampMs))
3628 i--
3629 dAtA[i] = 0x10
3630 }
3631 if m.StartTimestampMs != 0 {
3632 i = encodeVarintIngester(dAtA, i, uint64(m.StartTimestampMs))
3633 i--
3634 dAtA[i] = 0x8
3635 }
3636 return len(dAtA) - i, nil
3637}
3638
3639func (m *ExemplarQueryRequest) Marshal() (dAtA []byte, err error) {
3640 size := m.Size()

Callers 3

XXX_MarshalMethod · 0.95
MarshalMethod · 0.95
MarshalToMethod · 0.95

Calls 4

encodeVarintIngesterFunction · 0.85
SizeMethod · 0.65
MarshalToMethod · 0.65
MarshalToSizedBufferMethod · 0.65

Tested by

no test coverage detected