Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
323
func
writeXerialHeader(b []byte) {
324
copy(b[:8], xerialHeader[:])
325
copy(b[8:], xerialVersionInfo[:])
326
}
327
328
func
writeXerialFrame(b []byte, n int) {
329
binary.BigEndian.PutUint32(b, uint32(n))
Callers
1
Flush
Method · 0.85
Calls
no outgoing calls
Tested by
no test coverage detected