| 2495 | return nil |
| 2496 | } |
| 2497 | func (m *SqlSourcePb) Unmarshal(data []byte) error { |
| 2498 | var hasFields [1]uint64 |
| 2499 | l := len(data) |
| 2500 | iNdEx := 0 |
| 2501 | for iNdEx < l { |
| 2502 | preIndex := iNdEx |
| 2503 | var wire uint64 |
| 2504 | for shift := uint(0); ; shift += 7 { |
| 2505 | if shift >= 64 { |
| 2506 | return ErrIntOverflowSql |
| 2507 | } |
| 2508 | if iNdEx >= l { |
| 2509 | return io.ErrUnexpectedEOF |
| 2510 | } |
| 2511 | b := data[iNdEx] |
| 2512 | iNdEx++ |
| 2513 | wire |= (uint64(b) & 0x7F) << shift |
| 2514 | if b < 0x80 { |
| 2515 | break |
| 2516 | } |
| 2517 | } |
| 2518 | fieldNum := int32(wire >> 3) |
| 2519 | wireType := int(wire & 0x7) |
| 2520 | if wireType == 4 { |
| 2521 | return fmt.Errorf("proto: SqlSourcePb: wiretype end group for non-group") |
| 2522 | } |
| 2523 | if fieldNum <= 0 { |
| 2524 | return fmt.Errorf("proto: SqlSourcePb: illegal tag %d (wire type %d)", fieldNum, wire) |
| 2525 | } |
| 2526 | switch fieldNum { |
| 2527 | case 1: |
| 2528 | if wireType != 0 { |
| 2529 | return fmt.Errorf("proto: wrong wireType = %d for field Final", wireType) |
| 2530 | } |
| 2531 | var v int |
| 2532 | for shift := uint(0); ; shift += 7 { |
| 2533 | if shift >= 64 { |
| 2534 | return ErrIntOverflowSql |
| 2535 | } |
| 2536 | if iNdEx >= l { |
| 2537 | return io.ErrUnexpectedEOF |
| 2538 | } |
| 2539 | b := data[iNdEx] |
| 2540 | iNdEx++ |
| 2541 | v |= (int(b) & 0x7F) << shift |
| 2542 | if b < 0x80 { |
| 2543 | break |
| 2544 | } |
| 2545 | } |
| 2546 | m.Final = bool(v != 0) |
| 2547 | case 2: |
| 2548 | if wireType != 2 { |
| 2549 | return fmt.Errorf("proto: wrong wireType = %d for field AliasInner", wireType) |
| 2550 | } |
| 2551 | var stringLen uint64 |
| 2552 | for shift := uint(0); ; shift += 7 { |
| 2553 | if shift >= 64 { |
| 2554 | return ErrIntOverflowSql |