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

Method writeTo

message.go:92–101  ·  view source on GitHub ↗
(wb *writeBuffer)

Source from the content-addressed store, hash-verified

90}
91
92func (m message) writeTo(wb *writeBuffer) {
93 wb.writeInt32(m.CRC)
94 wb.writeInt8(m.MagicByte)
95 wb.writeInt8(m.Attributes)
96 if m.MagicByte != 0 {
97 wb.writeInt64(m.Timestamp)
98 }
99 wb.writeBytes(m.Key)
100 wb.writeBytes(m.Value)
101}
102
103type messageSetItem struct {
104 Offset int64

Callers

nothing calls this directly

Calls 4

writeInt32Method · 0.45
writeInt8Method · 0.45
writeInt64Method · 0.45
writeBytesMethod · 0.45

Tested by

no test coverage detected