(cw *crc32Writer)
| 31 | } |
| 32 | |
| 33 | func (msg Message) message(cw *crc32Writer) message { |
| 34 | m := message{ |
| 35 | MagicByte: 1, |
| 36 | Key: msg.Key, |
| 37 | Value: msg.Value, |
| 38 | Timestamp: timestamp(msg.Time), |
| 39 | } |
| 40 | if cw != nil { |
| 41 | m.CRC = m.crc32(cw) |
| 42 | } |
| 43 | return m |
| 44 | } |
| 45 | |
| 46 | const timestampSize = 8 |
| 47 |