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

Function writeXerialHeader

compress/snappy/xerial.go:323–326  ·  view source on GitHub ↗
(b []byte)

Source from the content-addressed store, hash-verified

321}
322
323func writeXerialHeader(b []byte) {
324 copy(b[:8], xerialHeader[:])
325 copy(b[8:], xerialVersionInfo[:])
326}
327
328func writeXerialFrame(b []byte, n int) {
329 binary.BigEndian.PutUint32(b, uint32(n))

Callers 1

FlushMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected