Skip to content

Commit 6e7f63b

Browse files
committed
Add decimal serialization benchmark
1 parent 8405773 commit 6e7f63b

File tree

1 file changed

+27
-0
lines changed

1 file changed

+27
-0
lines changed

tcp_sender_test.go

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -459,3 +459,30 @@ func BenchmarkLineSenderNoFlush(b *testing.B) {
459459
}
460460
sender.Flush(ctx)
461461
}
462+
463+
func BenchmarkHttpLineSenderDecimal(b *testing.B) {
464+
const decimalStr = "123456.789"
465+
466+
ctx := context.Background()
467+
468+
srv, err := newTestHttpServer(readAndDiscard)
469+
assert.NoError(b, err)
470+
defer srv.Close()
471+
472+
sender, err := qdb.NewLineSender(ctx, qdb.WithHttp(), qdb.WithAddress(srv.Addr()))
473+
assert.NoError(b, err)
474+
475+
b.ResetTimer()
476+
for i := 0; i < b.N; i++ {
477+
for j := 0; j < 1000; j++ {
478+
d := qdb.NewDecimalFromInt64(int64(i), 3)
479+
sender.
480+
Table(testTable).
481+
DecimalColumnScaled("dec_col", d).
482+
DecimalColumnString("dec_col2", decimalStr).
483+
At(ctx, time.UnixMicro(int64(1000*i)))
484+
}
485+
sender.Flush(ctx)
486+
sender.Close(ctx)
487+
}
488+
}

0 commit comments

Comments
 (0)