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

Method Reset

protocol/encode.go:36–42  ·  view source on GitHub ↗
(w io.Writer)

Source from the content-addressed store, hash-verified

34}
35
36func (e *encoder) Reset(w io.Writer) {
37 e.writer = w
38 e.err = nil
39 e.table = nil
40 e.crc32 = 0
41 e.buffer = [32]byte{}
42}
43
44func (e *encoder) ReadFrom(r io.Reader) (int64, error) {
45 if e.table != nil {

Callers 13

BalanceMethod · 0.45
BalanceMethod · 0.45
readMessageV1Method · 0.45
readMessageV2Method · 0.45
BenchmarkReadVarIntFunction · 0.45
discoverMethod · 0.45
releaseConnMethod · 0.45
releaseBufferFunction · 0.45
ReadRecordMethod · 0.45
MarshalFunction · 0.45
NewBytesFunction · 0.45
BenchmarkRequestFunction · 0.45

Calls

no outgoing calls

Tested by 1

BenchmarkReadVarIntFunction · 0.36