msg count
(msgs ...Message)
| 21 | 4 // msg count |
| 22 | |
| 23 | func recordBatchSize(msgs ...Message) (size int32) { |
| 24 | size = recordBatchHeaderSize |
| 25 | baseTime := msgs[0].Time |
| 26 | |
| 27 | for i := range msgs { |
| 28 | msg := &msgs[i] |
| 29 | msz := recordSize(msg, msg.Time.Sub(baseTime), int64(i)) |
| 30 | size += int32(msz + varIntLen(int64(msz))) |
| 31 | } |
| 32 | |
| 33 | return |
| 34 | } |
| 35 | |
| 36 | func compressRecordBatch(codec CompressionCodec, msgs ...Message) (compressed *bytes.Buffer, attributes int16, size int32, err error) { |
| 37 | compressed = acquireBuffer() |
no test coverage detected