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

Method Unmarshal

pkg/cortexpb/cortex.pb.go:4535–4725  ·  view source on GitHub ↗
(dAtA []byte)

Source from the content-addressed store, hash-verified

4533 return nil
4534}
4535func (m *WriteRequestV2) Unmarshal(dAtA []byte) error {
4536 l := len(dAtA)
4537 iNdEx := 0
4538 for iNdEx < l {
4539 preIndex := iNdEx
4540 var wire uint64
4541 for shift := uint(0); ; shift += 7 {
4542 if shift >= 64 {
4543 return ErrIntOverflowCortex
4544 }
4545 if iNdEx >= l {
4546 return io.ErrUnexpectedEOF
4547 }
4548 b := dAtA[iNdEx]
4549 iNdEx++
4550 wire |= uint64(b&0x7F) << shift
4551 if b < 0x80 {
4552 break
4553 }
4554 }
4555 fieldNum := int32(wire >> 3)
4556 wireType := int(wire & 0x7)
4557 if wireType == 4 {
4558 return fmt.Errorf("proto: WriteRequestV2: wiretype end group for non-group")
4559 }
4560 if fieldNum <= 0 {
4561 return fmt.Errorf("proto: WriteRequestV2: illegal tag %d (wire type %d)", fieldNum, wire)
4562 }
4563 switch fieldNum {
4564 case 4:
4565 if wireType != 2 {
4566 return fmt.Errorf("proto: wrong wireType = %d for field Symbols", wireType)
4567 }
4568 var stringLen uint64
4569 for shift := uint(0); ; shift += 7 {
4570 if shift >= 64 {
4571 return ErrIntOverflowCortex
4572 }
4573 if iNdEx >= l {
4574 return io.ErrUnexpectedEOF
4575 }
4576 b := dAtA[iNdEx]
4577 iNdEx++
4578 stringLen |= uint64(b&0x7F) << shift
4579 if b < 0x80 {
4580 break
4581 }
4582 }
4583 intStringLen := int(stringLen)
4584 if intStringLen < 0 {
4585 return ErrInvalidLengthCortex
4586 }
4587 postIndex := iNdEx + intStringLen
4588 if postIndex < 0 {
4589 return ErrInvalidLengthCortex
4590 }
4591 if postIndex > l {
4592 return io.ErrUnexpectedEOF

Callers 1

XXX_UnmarshalMethod · 0.95

Calls 3

SourceEnumTypeAlias · 0.85
skipCortexFunction · 0.85
UnmarshalMethod · 0.45

Tested by

no test coverage detected