(pe packetEncoder, version int16)
| 18 | } |
| 19 | |
| 20 | func (b *fetchRequestBlock) encode(pe packetEncoder, version int16) error { |
| 21 | b.Version = version |
| 22 | if b.Version >= 9 { |
| 23 | pe.putInt32(b.currentLeaderEpoch) |
| 24 | } |
| 25 | pe.putInt64(b.fetchOffset) |
| 26 | if b.Version >= 12 { |
| 27 | pe.putInt32(b.lastFetchedEpoch) |
| 28 | } |
| 29 | if b.Version >= 5 { |
| 30 | pe.putInt64(b.logStartOffset) |
| 31 | } |
| 32 | pe.putInt32(b.maxBytes) |
| 33 | pe.putEmptyTaggedFieldArray() |
| 34 | return nil |
| 35 | } |
| 36 | |
| 37 | func (b *fetchRequestBlock) decode(pd packetDecoder, version int16) (err error) { |
| 38 | b.Version = version |
nothing calls this directly
no test coverage detected