Skip to content

Commit ba33f62

Browse files
committed
Add a simple benchmark
1 parent dddfcca commit ba33f62

File tree

2 files changed

+22
-0
lines changed

2 files changed

+22
-0
lines changed

.readygo

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
{"readygo_file_format_version":1,"benchmark_results":[["message serialization decoding",[0.00777734375,0.007609375,0.00721875,0.00836328125,0.007546875,0.0088046875,0.0069414062500000005,0.007550781249999999,0.0072734374999999995,0.009625,0.007867187500000001,0.01226953125,0.0073984375,0.007292968750000001,0.00937890625,0.0073750000000000005]]]}

benchmarks/message_encoding.rb

+21
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
require "kafka"
2+
3+
ready "message serialization" do
4+
before do
5+
message = Kafka::Protocol::Message.new(
6+
value: "hello",
7+
key: "world",
8+
)
9+
10+
@io = StringIO.new
11+
encoder = Kafka::Protocol::Encoder.new(@io)
12+
message.encode(encoder)
13+
14+
@decoder = Kafka::Protocol::Decoder.new(@io)
15+
end
16+
17+
go "decoding" do
18+
@io.rewind
19+
Kafka::Protocol::Message.decode(@decoder)
20+
end
21+
end

0 commit comments

Comments
 (0)