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

Method Write

protocol/encode.go:54–66  ·  view source on GitHub ↗
(b []byte)

Source from the content-addressed store, hash-verified

52}
53
54func (e *encoder) Write(b []byte) (int, error) {
55 if e.err != nil {
56 return 0, e.err
57 }
58 n, err := e.writer.Write(b)
59 if n > 0 {
60 e.update(b[:n])
61 }
62 if err != nil {
63 e.err = err
64 }
65 return n, err
66}
67
68func (e *encoder) WriteByte(b byte) error {
69 e.buffer[0] = b

Callers 14

WriteByteMethod · 0.95
WriteStringMethod · 0.95
writeInt8Method · 0.95
writeInt16Method · 0.95
writeInt32Method · 0.95
writeInt64Method · 0.95
writeFloat64Method · 0.95
writeBytesMethod · 0.95
writeCompactBytesMethod · 0.95
writeNullBytesMethod · 0.95
writeVarNullBytesMethod · 0.95
writeCompactNullBytesMethod · 0.95

Calls 1

updateMethod · 0.95

Tested by

no test coverage detected