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

Method writeTo

write.go:165–165  ·  view source on GitHub ↗
(*writeBuffer)

Source from the content-addressed store, hash-verified

163
164type writable interface {
165 writeTo(*writeBuffer)
166}
167
168func (wb *writeBuffer) writeFetchRequestV2(correlationID int32, clientID, topic string, partition int32, offset int64, minBytes, maxBytes int, maxWait time.Duration) error {

Callers 15

writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeRequestMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65
writeToMethod · 0.65

Implementers 15

heartbeatRequestV0heartbeat.go
leaveGroupRequestV0leavegroup.go
saslAuthenticateRequestV0saslauthenticate.go
saslAuthenticateResponseV0saslauthenticate.go
listGroupsRequestV1listgroups.go
messagemessage.go
messageSetItemmessage.go
requestHeaderprotocol.go

Calls

no outgoing calls

Tested by 1

testWriteOptimizationFunction · 0.52