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

Method Close

protocol/conn.go:31–33  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

29}
30
31func (c *Conn) Close() error {
32 return c.conn.Close()
33}
34
35func (c *Conn) Discard(n int) (int, error) {
36 return c.buffer.Discard(n)

Callers 8

readFromVersion1Method · 0.45
readAllFunction · 0.45
writeToVersion2Method · 0.45
handleRecordFunction · 0.45
ReadControlRecordFunction · 0.45
ReadControlRecordMethod · 0.45
closeMessageFunction · 0.45
readAllFunction · 0.45

Calls

no outgoing calls

Tested by 1

readAllFunction · 0.36