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

Function expectZeroSize

protocol.go:209–214  ·  view source on GitHub ↗
(sz int, err error)

Source from the content-addressed store, hash-verified

207}
208
209func expectZeroSize(sz int, err error) error {
210 if err == nil && sz != 0 {
211 err = fmt.Errorf("reading a response left %d unread bytes", sz)
212 }
213 return err
214}

Callers 15

findCoordinatorMethod · 0.85
heartbeatMethod · 0.85
joinGroupMethod · 0.85
leaveGroupMethod · 0.85
listGroupsMethod · 0.85
offsetCommitMethod · 0.85
offsetFetchMethod · 0.85
syncGroupMethod · 0.85
readOffsetMethod · 0.85
readResponseMethod · 0.85
saslHandshakeMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected