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

Method Flush

write.go:157–162  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

155}
156
157func (wb *writeBuffer) Flush() error {
158 if x, ok := wb.w.(interface{ Flush() error }); ok {
159 return x.Flush()
160 }
161 return nil
162}
163
164type writable interface {
165 writeTo(*writeBuffer)

Callers 11

writeFetchRequestV2Method · 0.95
writeFetchRequestV5Method · 0.95
writeFetchRequestV10Method · 0.95
writeProduceRequestV2Method · 0.95
writeProduceRequestV3Method · 0.95
writeProduceRequestV7Method · 0.95
writeRequestMethod · 0.45
ApiVersionsMethod · 0.45
saslAuthenticateMethod · 0.45
FormatMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected