(pd packetDecoder, version int16)
| 10 | } |
| 11 | |
| 12 | func (b *OffsetFetchResponseBlock) decode(pd packetDecoder, version int16) (err error) { |
| 13 | b.Offset, err = pd.getInt64() |
| 14 | if err != nil { |
| 15 | return err |
| 16 | } |
| 17 | |
| 18 | if version >= 5 { |
| 19 | b.LeaderEpoch, err = pd.getInt32() |
| 20 | if err != nil { |
| 21 | return err |
| 22 | } |
| 23 | } else { |
| 24 | b.LeaderEpoch = -1 |
| 25 | } |
| 26 | |
| 27 | metadata, err := pd.getNullableString() |
| 28 | if err != nil { |
| 29 | return err |
| 30 | } |
| 31 | if metadata != nil { |
| 32 | b.Metadata = *metadata |
| 33 | } |
| 34 | |
| 35 | b.Err, err = pd.getKError() |
| 36 | if err != nil { |
| 37 | return err |
| 38 | } |
| 39 | |
| 40 | _, err = pd.getEmptyTaggedFieldArray() |
| 41 | return err |
| 42 | } |
| 43 | |
| 44 | func (b *OffsetFetchResponseBlock) encode(pe packetEncoder, version int16) (err error) { |
| 45 | pe.putInt64(b.Offset) |
nothing calls this directly
no test coverage detected