(dAtA []byte)
| 4134 | return nil |
| 4135 | } |
| 4136 | func (m *SampleStream) Unmarshal(dAtA []byte) error { |
| 4137 | l := len(dAtA) |
| 4138 | iNdEx := 0 |
| 4139 | for iNdEx < l { |
| 4140 | preIndex := iNdEx |
| 4141 | var wire uint64 |
| 4142 | for shift := uint(0); ; shift += 7 { |
| 4143 | if shift >= 64 { |
| 4144 | return ErrIntOverflowQuery |
| 4145 | } |
| 4146 | if iNdEx >= l { |
| 4147 | return io.ErrUnexpectedEOF |
| 4148 | } |
| 4149 | b := dAtA[iNdEx] |
| 4150 | iNdEx++ |
| 4151 | wire |= uint64(b&0x7F) << shift |
| 4152 | if b < 0x80 { |
| 4153 | break |
| 4154 | } |
| 4155 | } |
| 4156 | fieldNum := int32(wire >> 3) |
| 4157 | wireType := int(wire & 0x7) |
| 4158 | if wireType == 4 { |
| 4159 | return fmt.Errorf("proto: SampleStream: wiretype end group for non-group") |
| 4160 | } |
| 4161 | if fieldNum <= 0 { |
| 4162 | return fmt.Errorf("proto: SampleStream: illegal tag %d (wire type %d)", fieldNum, wire) |
| 4163 | } |
| 4164 | switch fieldNum { |
| 4165 | case 1: |
| 4166 | if wireType != 2 { |
| 4167 | return fmt.Errorf("proto: wrong wireType = %d for field Labels", wireType) |
| 4168 | } |
| 4169 | var msglen int |
| 4170 | for shift := uint(0); ; shift += 7 { |
| 4171 | if shift >= 64 { |
| 4172 | return ErrIntOverflowQuery |
| 4173 | } |
| 4174 | if iNdEx >= l { |
| 4175 | return io.ErrUnexpectedEOF |
| 4176 | } |
| 4177 | b := dAtA[iNdEx] |
| 4178 | iNdEx++ |
| 4179 | msglen |= int(b&0x7F) << shift |
| 4180 | if b < 0x80 { |
| 4181 | break |
| 4182 | } |
| 4183 | } |
| 4184 | if msglen < 0 { |
| 4185 | return ErrInvalidLengthQuery |
| 4186 | } |
| 4187 | postIndex := iNdEx + msglen |
| 4188 | if postIndex < 0 { |
| 4189 | return ErrInvalidLengthQuery |
| 4190 | } |
| 4191 | if postIndex > l { |
| 4192 | return io.ErrUnexpectedEOF |
| 4193 | } |
no test coverage detected