Skip to content

Commit

Permalink
Merge branch 'main' into add_shotover_metrics_profiler
Browse files Browse the repository at this point in the history
  • Loading branch information
rukai authored Dec 4, 2023
2 parents d0d5840 + c42cb9c commit c77b733
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 c77b733

Please sign in to comment.