(wb *writeBuffer)
| 90 | } |
| 91 | |
| 92 | func (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 | |
| 103 | type messageSetItem struct { |
| 104 | Offset int64 |
nothing calls this directly
no test coverage detected