Skip to content

Commit

Permalink
windsock: kafka benches only include shotover sys_metrics on benches …
Browse files Browse the repository at this point in the history
…using shotover (#1381)
  • Loading branch information
rukai authored Dec 4, 2023
1 parent 11590c4 commit c42cb9c
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions shotover-proxy/benches/windsock/kafka.rs
Original file line number Diff line number Diff line change
Expand Up @@ -232,16 +232,17 @@ impl Bench for KafkaBench {
[("bencher".to_owned(), &bench_instance.instance)].into();

// only profile instances that we are actually using for this bench
if let Shotover::ForcedMessageParsed | Shotover::Standard = self.shotover {
profiler_instances.insert("shotover".to_owned(), &shotover_instance.instance);
}
match self.topology {
KafkaTopology::Single | KafkaTopology::Cluster1 => {
profiler_instances.insert("kafka".to_owned(), &kafka_instance1.instance);
profiler_instances.insert("shotover".to_owned(), &shotover_instance.instance);
}
KafkaTopology::Cluster3 => {
profiler_instances.insert("kafka1".to_owned(), &kafka_instance1.instance);
profiler_instances.insert("kafka2".to_owned(), &kafka_instance2.instance);
profiler_instances.insert("kafka3".to_owned(), &kafka_instance3.instance);
profiler_instances.insert("shotover".to_owned(), &shotover_instance.instance);
}
}

Expand Down

0 comments on commit c42cb9c

Please sign in to comment.