Skip to content
Snippets Groups Projects

Introduce new Benchmark class and Patcher

5 files
+ 7
8
Compare changes
  • Side-by-side
  • Inline
Files
5
@@ -17,12 +17,12 @@ class KubernetesBenchmarkDeployment(
): BenchmarkDeployment {
private val workloadGeneratorStateCleaner = WorkloadGeneratorStateCleaner(this.zookeeperConfig)
private val kafkaController = TopicManager(this.kafkaConfig)
private val kubernetesManager = K8sManager(DefaultKubernetesClient().inNamespace("default")) // Maybe per resource type
private val kubernetesManager = K8sManager(DefaultKubernetesClient().inNamespace("theodolite-she")) // Maybe per resource type
override fun setup() {
this.workloadGeneratorStateCleaner.deleteState()
kafkaController.createTopics(this.topics)
resources.forEach {
resources.forEach {
kubernetesManager.deploy(it)
}
}
Loading