Method encode

fetch_response.go:300–346

(pe packetEncoder, version int16)

}

func (b *FetchResponseBlock) encode(pe packetEncoder, version int16) (err error) {
	pe.putKError(b.Err)

	pe.putInt64(b.HighWaterMarkOffset)

	if version >= 4 {
		pe.putInt64(b.LastStableOffset)

		if version >= 5 {
			pe.putInt64(b.LogStartOffset)
		}

		if err = pe.putArrayLength(len(b.AbortedTransactions)); err != nil {
			return err
		}
		for _, transact := range b.AbortedTransactions {
			if err = transact.encode(pe); err != nil {
				return err
			}
		}
	}

	if version >= 11 {
		pe.putInt32(b.PreferredReadReplica)
	}

	if version >= 12 {
		recordsBytes, err := encode(fetchRecordsSet(b.RecordsSet), nil)
		if err != nil {
			return err
		}
		if err = pe.putBytes(recordsBytes); err != nil {
			return err
		}
		b.encodeTaggedFields(pe)
		return nil
	}

	pe.push(&lengthField{})
	for _, records := range b.RecordsSet {
		err = records.encode(pe)
		if err != nil {
			return err
		}
	}
	return pe.pop()
}

func (b *FetchResponseBlock) encodeTaggedFields(pe packetEncoder) {
	var numTaggedFields uint64