From 830a4874b6462af01b54eb83fa19539ea342323b Mon Sep 17 00:00:00 2001 From: "stu126940@mail.uni-kiel.de" <stu126940@mail.uni-kiel.de> Date: Wed, 2 Jun 2021 14:04:10 +0200 Subject: [PATCH] delete file / clean up --- .../execution/operator/LeaderElector.kt | 44 ------------------- 1 file changed, 44 deletions(-) delete mode 100644 theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/LeaderElector.kt diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/LeaderElector.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/LeaderElector.kt deleted file mode 100644 index b887f5e9a..000000000 --- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/LeaderElector.kt +++ /dev/null @@ -1,44 +0,0 @@ -package theodolite.execution.operator - -import io.fabric8.kubernetes.client.DefaultKubernetesClient -import io.fabric8.kubernetes.client.NamespacedKubernetesClient -import io.fabric8.kubernetes.client.extended.leaderelection.LeaderCallbacks -import io.fabric8.kubernetes.client.extended.leaderelection.LeaderElectionConfigBuilder -import io.fabric8.kubernetes.client.extended.leaderelection.resourcelock.LeaseLock -import mu.KotlinLogging -import java.time.Duration -import java.util.* -import kotlin.reflect.KFunction0 -import kotlin.reflect.KFunction1 - -private val logger = KotlinLogging.logger {} - -class LeaderElector( - val client: NamespacedKubernetesClient, - val name: String - ) { - - fun getLeadership(leader: KFunction1<NamespacedKubernetesClient, Unit>) { - val lockIdentity: String = UUID.randomUUID().toString() - DefaultKubernetesClient().use { kc -> - kc.leaderElector() - .withConfig( - LeaderElectionConfigBuilder() - .withName("Theodolite") - .withLeaseDuration(Duration.ofSeconds(15L)) - .withLock(LeaseLock(client.namespace, name, lockIdentity)) - .withRenewDeadline(Duration.ofSeconds(10L)) - .withRetryPeriod(Duration.ofSeconds(2L)) - .withLeaderCallbacks(LeaderCallbacks( - leader, - { logger.info { "STOPPED LEADERSHIP " } } - ) { newLeader: String? -> - logger.info { "New leader elected $newLeader" } - }) - .build() - ) - .build().run() - } - } - -} \ No newline at end of file -- GitLab