(reader protocol.RecordReader, version int8, attr protocol.Attributes)
| 131 | } |
| 132 | |
| 133 | func NewRawRecordSet(reader protocol.RecordReader, version int8, attr protocol.Attributes) protocol.RawRecordSet { |
| 134 | rs := protocol.RecordSet{Version: version, Attributes: attr, Records: reader} |
| 135 | buf := &bytes.Buffer{} |
| 136 | rs.WriteTo(buf) |
| 137 | |
| 138 | return protocol.RawRecordSet{ |
| 139 | Reader: buf, |
| 140 | } |
| 141 | } |
| 142 | |
| 143 | func BenchmarkProduceRequest(b *testing.B) { |
| 144 | t0 := time.Now().Truncate(time.Millisecond) |
no test coverage detected