(msgs ...Message)
| 600 | } |
| 601 | |
| 602 | func messageSetSize(msgs ...Message) (size int32) { |
| 603 | for _, msg := range msgs { |
| 604 | size += 8 + // offset |
| 605 | 4 + // message size |
| 606 | 4 + // crc |
| 607 | 1 + // magic byte |
| 608 | 1 + // attributes |
| 609 | 8 + // timestamp |
| 610 | sizeofBytes(msg.Key) + |
| 611 | sizeofBytes(msg.Value) |
| 612 | } |
| 613 | return |
| 614 | } |
no test coverage detected