(dAtA []byte)
| 4320 | return nil |
| 4321 | } |
| 4322 | func (m *WriteRequest) Unmarshal(dAtA []byte) error { |
| 4323 | l := len(dAtA) |
| 4324 | iNdEx := 0 |
| 4325 | for iNdEx < l { |
| 4326 | preIndex := iNdEx |
| 4327 | var wire uint64 |
| 4328 | for shift := uint(0); ; shift += 7 { |
| 4329 | if shift >= 64 { |
| 4330 | return ErrIntOverflowCortex |
| 4331 | } |
| 4332 | if iNdEx >= l { |
| 4333 | return io.ErrUnexpectedEOF |
| 4334 | } |
| 4335 | b := dAtA[iNdEx] |
| 4336 | iNdEx++ |
| 4337 | wire |= uint64(b&0x7F) << shift |
| 4338 | if b < 0x80 { |
| 4339 | break |
| 4340 | } |
| 4341 | } |
| 4342 | fieldNum := int32(wire >> 3) |
| 4343 | wireType := int(wire & 0x7) |
| 4344 | if wireType == 4 { |
| 4345 | return fmt.Errorf("proto: WriteRequest: wiretype end group for non-group") |
| 4346 | } |
| 4347 | if fieldNum <= 0 { |
| 4348 | return fmt.Errorf("proto: WriteRequest: illegal tag %d (wire type %d)", fieldNum, wire) |
| 4349 | } |
| 4350 | switch fieldNum { |
| 4351 | case 1: |
| 4352 | if wireType != 2 { |
| 4353 | return fmt.Errorf("proto: wrong wireType = %d for field Timeseries", wireType) |
| 4354 | } |
| 4355 | var msglen int |
| 4356 | for shift := uint(0); ; shift += 7 { |
| 4357 | if shift >= 64 { |
| 4358 | return ErrIntOverflowCortex |
| 4359 | } |
| 4360 | if iNdEx >= l { |
| 4361 | return io.ErrUnexpectedEOF |
| 4362 | } |
| 4363 | b := dAtA[iNdEx] |
| 4364 | iNdEx++ |
| 4365 | msglen |= int(b&0x7F) << shift |
| 4366 | if b < 0x80 { |
| 4367 | break |
| 4368 | } |
| 4369 | } |
| 4370 | if msglen < 0 { |
| 4371 | return ErrInvalidLengthCortex |
| 4372 | } |
| 4373 | postIndex := iNdEx + msglen |
| 4374 | if postIndex < 0 { |
| 4375 | return ErrInvalidLengthCortex |
| 4376 | } |
| 4377 | if postIndex > l { |
| 4378 | return io.ErrUnexpectedEOF |
| 4379 | } |
no test coverage detected