MCPcopy
hub / github.com/segmentio/kafka-go / writeTo

Method writeTo

protocol.go:180–186  ·  view source on GitHub ↗
(wb *writeBuffer)

Source from the content-addressed store, hash-verified

178}
179
180func (h requestHeader) writeTo(wb *writeBuffer) {
181 wb.writeInt32(h.Size)
182 wb.writeInt16(h.ApiKey)
183 wb.writeInt16(h.ApiVersion)
184 wb.writeInt32(h.CorrelationID)
185 wb.writeString(h.ClientID)
186}
187
188type request interface {
189 size() int32

Callers 8

ApiVersionsMethod · 0.95
writeFetchRequestV2Method · 0.95
writeFetchRequestV5Method · 0.95
writeFetchRequestV10Method · 0.95
writeProduceRequestV2Method · 0.95
writeProduceRequestV3Method · 0.95
writeProduceRequestV7Method · 0.95

Calls 3

writeInt32Method · 0.45
writeInt16Method · 0.45
writeStringMethod · 0.45

Tested by

no test coverage detected