diff --git a/theodolite-quarkus/build.gradle b/theodolite-quarkus/build.gradle
index 21f65678407568bb8d519e4c7e6f4bacff90205f..3082deaf12fc48c6aca97ffd00b9c74cd7e6c143 100644
--- a/theodolite-quarkus/build.gradle
+++ b/theodolite-quarkus/build.gradle
@@ -21,16 +21,18 @@ dependencies {
implementation 'com.google.code.gson:gson:2.8.5'
implementation 'org.slf4j:slf4j-simple:1.7.29'
implementation 'io.github.microutils:kotlin-logging:1.12.0'
- implementation 'io.fabric8:kubernetes-client:5.0.0-alpha-2'
- implementation 'io.quarkus:quarkus-kubernetes-client'
+ implementation('io.fabric8:kubernetes-client:5.4.1'){force = true}
+ implementation('io.fabric8:kubernetes-model-core:5.4.1'){force = true}
+ implementation('io.fabric8:kubernetes-model-common:5.4.1'){force = true}
implementation 'org.apache.kafka:kafka-clients:2.7.0'
implementation 'khttp:khttp:1.0.0'
+
compile 'junit:junit:4.12'
testImplementation 'io.quarkus:quarkus-junit5'
testImplementation 'io.rest-assured:rest-assured'
testImplementation 'org.junit-pioneer:junit-pioneer:1.4.0'
- testImplementation (group: 'io.fabric8', name: 'kubernetes-server-mock', version: '5.4.1'){force = true}
+ testImplementation ('io.fabric8:kubernetes-server-mock:5.4.1'){force = true}
}
group 'theodolite'
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/AbstractStateHandler.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/AbstractStateHandler.kt
index 75cbcad051e2055f25d876e66e0fffcdc249c4f5..a7a40cd569f8034f3b8e062dad3031d5643a12e3 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/AbstractStateHandler.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/AbstractStateHandler.kt
@@ -1,38 +1,35 @@
package theodolite.execution.operator
+import io.fabric8.kubernetes.api.model.HasMetadata
+import io.fabric8.kubernetes.api.model.KubernetesResourceList
import io.fabric8.kubernetes.api.model.Namespaced
import io.fabric8.kubernetes.client.CustomResource
-import io.fabric8.kubernetes.client.CustomResourceDoneable
-import io.fabric8.kubernetes.client.CustomResourceList
import io.fabric8.kubernetes.client.KubernetesClient
import io.fabric8.kubernetes.client.dsl.MixedOperation
import io.fabric8.kubernetes.client.dsl.Resource
-import io.fabric8.kubernetes.client.dsl.base.CustomResourceDefinitionContext
import java.lang.Thread.sleep
abstract class AbstractStateHandler<T,L,D>(
- private val context: CustomResourceDefinitionContext,
private val client: KubernetesClient,
private val crd: Class<T>,
- private val crdList: Class<L>,
- private val donableCRD: Class<D>
- ): StateHandler where T : CustomResource, T: Namespaced, L: CustomResourceList<T>, D: CustomResourceDoneable<T> {
+ private val crdList: Class<L>
+ ): StateHandler<T> where T : CustomResource<*, *>?, T: HasMetadata, T: Namespaced, L: KubernetesResourceList<T> {
- private val crdClient: MixedOperation<T, L, D, Resource<T, D>> =
- this.client.customResources(this.context, this.crd, this.crdList, this.donableCRD)
+ private val crdClient: MixedOperation<T, L,Resource<T>> =
+ this.client.customResources(this.crd, this.crdList)
@Synchronized
- override fun setState(resourceName: String, f: (CustomResource) -> CustomResource?) {
+ override fun setState(resourceName: String, f: (T) -> T?) {
this.crdClient
.inNamespace(this.client.namespace)
.list().items
.filter { item -> item.metadata.name == resourceName }
.map { customResource -> f(customResource) }
- .forEach { this.crdClient.updateStatus(it as T) }
+ .forEach { this.crdClient.updateStatus(it) }
}
@Synchronized
- override fun getState(resourceName: String, f: (CustomResource) -> String?): String? {
+ override fun getState(resourceName: String, f: (T) -> String?): String? {
return this.crdClient
.inNamespace(this.client.namespace)
.list().items
@@ -42,7 +39,7 @@ abstract class AbstractStateHandler<T,L,D>(
}
@Synchronized
- override fun blockUntilStateIsSet(resourceName: String, desiredStatusString: String, f: (CustomResource) -> String?, maxTries: Int): Boolean {
+ override fun blockUntilStateIsSet(resourceName: String, desiredStatusString: String, f: (T) -> String?, maxTries: Int): Boolean {
for (i in 0.rangeTo(maxTries)) {
val currentStatus = getState(resourceName, f)
if(currentStatus == desiredStatusString) {
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ClusterSetup.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ClusterSetup.kt
index 6c8c48f791543b6d8a7716cf26a80bdb449ee7a7..8fc951d09598187bcaf4cb7e4a39d322be722792 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ClusterSetup.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ClusterSetup.kt
@@ -12,8 +12,8 @@ import theodolite.model.crd.*
private val logger = KotlinLogging.logger {}
class ClusterSetup(
- private val executionCRDClient: MixedOperation<ExecutionCRD, BenchmarkExecutionList, DoneableExecution, Resource<ExecutionCRD, DoneableExecution>>,
- private val benchmarkCRDClient: MixedOperation<BenchmarkCRD, KubernetesBenchmarkList, DoneableBenchmark, Resource<BenchmarkCRD, DoneableBenchmark>>,
+ private val executionCRDClient: MixedOperation<ExecutionCRD, BenchmarkExecutionList, Resource<ExecutionCRD>>,
+ private val benchmarkCRDClient: MixedOperation<BenchmarkCRD, KubernetesBenchmarkList, Resource<BenchmarkCRD>>,
private val client: NamespacedKubernetesClient
) {
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionEventHandler.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionEventHandler.kt
index a1617b4988d500baab7b02bf5fa993f7a4ae76a3..4168bd19b57216722ca5301d42ce5e0df3f6c192 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionEventHandler.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionEventHandler.kt
@@ -33,7 +33,7 @@ class ExecutionHandler(
logger.info { "Add execution ${execution.metadata.name}" }
execution.spec.name = execution.metadata.name
when (this.stateHandler.getExecutionState(execution.metadata.name)) {
- null -> this.stateHandler.setExecutionState(execution.spec.name, States.PENDING)
+ States.NO_STATE -> this.stateHandler.setExecutionState(execution.spec.name, States.PENDING)
States.RUNNING -> {
this.stateHandler.setExecutionState(execution.spec.name, States.RESTART)
if(this.controller.isExecutionRunning(execution.spec.name)){
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionStateHandler.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionStateHandler.kt
index 0367fa40d45ae9e357c43856dc05d19740bd94b9..df5e77695d1beb562408f1b5830f6f4353543c75 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionStateHandler.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/ExecutionStateHandler.kt
@@ -1,55 +1,54 @@
package theodolite.execution.operator
-import io.fabric8.kubernetes.client.CustomResource
import io.fabric8.kubernetes.client.KubernetesClient
-import io.fabric8.kubernetes.client.dsl.base.CustomResourceDefinitionContext
import theodolite.model.crd.BenchmarkExecutionList
import theodolite.model.crd.ExecutionCRD
+import theodolite.model.crd.ExecutionStatus
import theodolite.model.crd.States
import java.lang.Thread.sleep
import java.time.Duration
import java.time.Instant
import java.util.concurrent.atomic.AtomicBoolean
-class ExecutionStateHandler(context: CustomResourceDefinitionContext, val client: KubernetesClient):
- AbstractStateHandler<ExecutionCRD, BenchmarkExecutionList, DoneableExecution>(
- context = context,
+class ExecutionStateHandler(val client: KubernetesClient):
+ AbstractStateHandler<ExecutionCRD, BenchmarkExecutionList, ExecutionStatus >(
client = client,
crd = ExecutionCRD::class.java,
- crdList = BenchmarkExecutionList::class.java,
- donableCRD = DoneableExecution::class.java) {
+ crdList = BenchmarkExecutionList::class.java
+ ) {
private var runExecutionDurationTimer: AtomicBoolean = AtomicBoolean(false)
- private fun getExecutionLambda() = { cr: CustomResource ->
- var execState = ""
- if (cr is ExecutionCRD) { execState = cr.status.executionState }
- execState
- }
+ private fun getExecutionLambda() = { cr: ExecutionCRD -> cr.status.executionState }
- private fun getDurationLambda() = { cr: CustomResource ->
- var execState = ""
- if (cr is ExecutionCRD) { execState = cr.status.executionDuration }
- execState
- }
+ private fun getDurationLambda() = { cr: ExecutionCRD -> cr.status.executionDuration }
fun setExecutionState(resourceName: String, status: States): Boolean {
- setState(resourceName) {cr -> if(cr is ExecutionCRD) cr.status.executionState = status.value; cr}
+ setState(resourceName) {cr -> cr.status.executionState = status.value; cr}
return blockUntilStateIsSet(resourceName, status.value, getExecutionLambda())
}
- fun getExecutionState(resourceName: String) : States? {
+ fun getExecutionState(resourceName: String) : States {
val status = this.getState(resourceName, getExecutionLambda())
- return States.values().firstOrNull { it.value == status }
+ return if(status.isNullOrBlank()){
+ States.NO_STATE
+ } else {
+ States.values().first { it.value == status }
+ }
}
fun setDurationState(resourceName: String, duration: Duration): Boolean {
- setState(resourceName) { cr -> if (cr is ExecutionCRD) cr.status.executionDuration = durationToK8sString(duration); cr }
+ setState(resourceName) { cr -> cr.status.executionDuration = durationToK8sString(duration); cr }
return blockUntilStateIsSet(resourceName, durationToK8sString(duration), getDurationLambda())
}
- fun getDurationState(resourceName: String): String? {
- return this.getState(resourceName, getDurationLambda())
+ fun getDurationState(resourceName: String): String {
+ val status = getState(resourceName, getDurationLambda())
+ return if (status.isNullOrBlank()) {
+ "-"
+ } else {
+ status
+ }
}
private fun durationToK8sString(duration: Duration): String {
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/StateHandler.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/StateHandler.kt
index 0fbd97e5cca4a9be220eb0b0c89ea0af129a7860..cefcf2ec97986375205205fd95ddcd2ff7eacf5a 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/StateHandler.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/StateHandler.kt
@@ -1,15 +1,14 @@
package theodolite.execution.operator
-import io.fabric8.kubernetes.client.CustomResource
private const val MAX_TRIES: Int = 5
-interface StateHandler {
- fun setState(resourceName: String, f: (CustomResource) -> CustomResource?)
- fun getState(resourceName: String, f: (CustomResource) -> String?): String?
+interface StateHandler<T> {
+ fun setState(resourceName: String, f: (T) -> T?)
+ fun getState(resourceName: String, f: (T) -> String?): String?
fun blockUntilStateIsSet(
resourceName: String,
desiredStatusString: String,
- f: (CustomResource) -> String?,
+ f: (T) -> String?,
maxTries: Int = MAX_TRIES): Boolean
}
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteController.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteController.kt
index 3016a1c9d1623d32b1d4df3ab7129b33a9100c08..c49810fc5838e63211b3a796e5d54085219418c8 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteController.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteController.kt
@@ -27,8 +27,8 @@ private val logger = KotlinLogging.logger {}
class TheodoliteController(
private val namespace: String,
val path: String,
- private val executionCRDClient: MixedOperation<ExecutionCRD, BenchmarkExecutionList, DoneableExecution, Resource<ExecutionCRD, DoneableExecution>>,
- private val benchmarkCRDClient: MixedOperation<BenchmarkCRD, KubernetesBenchmarkList, DoneableBenchmark, Resource<BenchmarkCRD, DoneableBenchmark>>,
+ private val executionCRDClient: MixedOperation<ExecutionCRD, BenchmarkExecutionList, Resource<ExecutionCRD>>,
+ private val benchmarkCRDClient: MixedOperation<BenchmarkCRD, KubernetesBenchmarkList, Resource<BenchmarkCRD>>,
private val executionStateHandler: ExecutionStateHandler
) {
lateinit var executor: TheodoliteExecutor
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteOperator.kt b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteOperator.kt
index 0d55b0c1c1c76dba226d34554e0d96a3df77c1c3..60e238c27877c52a55fba307b036f2d498a1f76a 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteOperator.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/execution/operator/TheodoliteOperator.kt
@@ -6,16 +6,15 @@ import io.fabric8.kubernetes.client.dsl.MixedOperation
import io.fabric8.kubernetes.client.dsl.Resource
import io.fabric8.kubernetes.internal.KubernetesDeserializer
import mu.KotlinLogging
-import theodolite.k8s.K8sContextFactory
-import theodolite.model.crd.*
+import theodolite.model.crd.BenchmarkCRD
+import theodolite.model.crd.BenchmarkExecutionList
+import theodolite.model.crd.ExecutionCRD
+import theodolite.model.crd.KubernetesBenchmarkList
private const val DEFAULT_NAMESPACE = "default"
-private const val SCOPE = "Namespaced"
private const val EXECUTION_SINGULAR = "execution"
-private const val EXECUTION_PLURAL = "executions"
private const val BENCHMARK_SINGULAR = "benchmark"
-private const val BENCHMARK_PLURAL = "benchmarks"
private const val API_VERSION = "v1"
private const val RESYNC_PERIOD = 10 * 60 * 1000.toLong()
private const val GROUP = "theodolite.com"
@@ -57,34 +56,25 @@ class TheodoliteOperator {
BenchmarkCRD::class.java
)
- val contextFactory = K8sContextFactory()
- val executionContext = contextFactory.create(API_VERSION, SCOPE, GROUP, EXECUTION_PLURAL)
- val benchmarkContext = contextFactory.create(API_VERSION, SCOPE, GROUP, BENCHMARK_PLURAL)
-
val executionCRDClient: MixedOperation<
ExecutionCRD,
BenchmarkExecutionList,
- DoneableExecution,
- Resource<ExecutionCRD, DoneableExecution>>
+ Resource<ExecutionCRD>>
= client.customResources(
- executionContext,
ExecutionCRD::class.java,
- BenchmarkExecutionList::class.java,
- DoneableExecution::class.java)
+ BenchmarkExecutionList::class.java
+ )
val benchmarkCRDClient: MixedOperation<
BenchmarkCRD,
KubernetesBenchmarkList,
- DoneableBenchmark,
- Resource<BenchmarkCRD, DoneableBenchmark>>
+ Resource<BenchmarkCRD>>
= client.customResources(
- benchmarkContext,
BenchmarkCRD::class.java,
- KubernetesBenchmarkList::class.java,
- DoneableBenchmark::class.java)
+ KubernetesBenchmarkList::class.java
+ )
val executionStateHandler = ExecutionStateHandler(
- context = executionContext,
client = client)
val appResource = System.getenv("THEODOLITE_APP_RESOURCES") ?: "./config"
@@ -98,7 +88,6 @@ class TheodoliteOperator {
val informerFactory = client.informers()
val informerExecution = informerFactory.sharedIndexInformerForCustomResource(
- executionContext,
ExecutionCRD::class.java,
BenchmarkExecutionList::class.java,
RESYNC_PERIOD
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/CustomResourceWrapper.kt b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/CustomResourceWrapper.kt
index 9d879ef131d49c8b4491f94dd89dde5437b0bf6e..31a95be04e3290e0797dca5c588394ea36279b0c 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/k8s/CustomResourceWrapper.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/k8s/CustomResourceWrapper.kt
@@ -1,12 +1,13 @@
package theodolite.k8s
-import io.fabric8.kubernetes.client.CustomResource
+import io.fabric8.kubernetes.api.model.KubernetesResource
import io.fabric8.kubernetes.client.NamespacedKubernetesClient
import io.fabric8.kubernetes.client.dsl.base.CustomResourceDefinitionContext
import mu.KotlinLogging
private val logger = KotlinLogging.logger {}
-class CustomResourceWrapper(val crAsMap: Map<String, String>, private val context: CustomResourceDefinitionContext) : CustomResource() {
+
+class CustomResourceWrapper(val crAsMap: Map<String, String>, private val context: CustomResourceDefinitionContext) : KubernetesResource {
/**
* Deploy a service monitor
*
@@ -15,7 +16,6 @@ class CustomResourceWrapper(val crAsMap: Map<String, String>, private val contex
* @throws java.io.IOException if the resource could not be deployed.
*/
fun deploy(client: NamespacedKubernetesClient) {
-
client.customResource(this.context)
.createOrReplace(client.configuration.namespace, this.crAsMap as Map<String, Any>)
}
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/BenchmarkCRD.kt b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/BenchmarkCRD.kt
index 326aa10a21bebd913eaafcb8315188288ae97ff1..377708af7b7e1a50ae1e33064b2668c364e0685a 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/BenchmarkCRD.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/BenchmarkCRD.kt
@@ -1,11 +1,18 @@
package theodolite.model.crd
import com.fasterxml.jackson.databind.annotation.JsonDeserialize
+import io.fabric8.kubernetes.api.model.HasMetadata
import io.fabric8.kubernetes.api.model.Namespaced
import io.fabric8.kubernetes.client.CustomResource
+import io.fabric8.kubernetes.model.annotation.Group
+import io.fabric8.kubernetes.model.annotation.Kind
+import io.fabric8.kubernetes.model.annotation.Version
import theodolite.benchmark.KubernetesBenchmark
@JsonDeserialize
+@Version("v1")
+@Group("theodolite.com")
+@Kind("benchmark")
class BenchmarkCRD(
var spec: KubernetesBenchmark = KubernetesBenchmark()
-) : CustomResource(), Namespaced
\ No newline at end of file
+) : CustomResource<KubernetesBenchmark, Void>(), Namespaced, HasMetadata
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableBenchmark.kt b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableBenchmark.kt
deleted file mode 100644
index e00e8268b2ec8eba17b3706feb3940eded1b2b0c..0000000000000000000000000000000000000000
--- a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableBenchmark.kt
+++ /dev/null
@@ -1,7 +0,0 @@
-package theodolite.model.crd
-
-import io.fabric8.kubernetes.api.builder.Function
-import io.fabric8.kubernetes.client.CustomResourceDoneable
-
-class DoneableBenchmark(resource: BenchmarkCRD, function: Function<BenchmarkCRD, BenchmarkCRD>) :
- CustomResourceDoneable<BenchmarkCRD>(resource, function)
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableExecution.kt b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableExecution.kt
deleted file mode 100644
index be07725b405c29a0d9000b6e6ec455536ad111fb..0000000000000000000000000000000000000000
--- a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/DoneableExecution.kt
+++ /dev/null
@@ -1,8 +0,0 @@
-package theodolite.execution.operator
-
-import io.fabric8.kubernetes.client.CustomResourceDoneable
-import io.fabric8.kubernetes.api.builder.Function
-import theodolite.model.crd.ExecutionCRD
-
-class DoneableExecution(resource: ExecutionCRD, function: Function<ExecutionCRD, ExecutionCRD>) :
- CustomResourceDoneable<ExecutionCRD>(resource, function)
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionCRD.kt b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionCRD.kt
index 79a387cee250d3abf0fdb576a5f0f33424596792..659621e8c3b1d5308a10d81240575dd3d432b53f 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionCRD.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionCRD.kt
@@ -1,13 +1,18 @@
package theodolite.model.crd
import com.fasterxml.jackson.databind.annotation.JsonDeserialize
-import io.fabric8.kubernetes.api.model.KubernetesResource
import io.fabric8.kubernetes.api.model.Namespaced
import io.fabric8.kubernetes.client.CustomResource
+import io.fabric8.kubernetes.model.annotation.Group
+import io.fabric8.kubernetes.model.annotation.Kind
+import io.fabric8.kubernetes.model.annotation.Version
import theodolite.benchmark.BenchmarkExecution
@JsonDeserialize
+@Version("v1")
+@Group("theodolite.com")
+@Kind("execution")
class ExecutionCRD(
var spec: BenchmarkExecution = BenchmarkExecution(),
var status: ExecutionStatus = ExecutionStatus()
- ) : CustomResource(), Namespaced
\ No newline at end of file
+) : CustomResource<BenchmarkExecution, ExecutionStatus>(), Namespaced
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionStatus.kt b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionStatus.kt
index 43e9035b3120eb22304576f2006092eec376b6d2..51b76fcee8fb35c83dca407691833dbb235b29c5 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionStatus.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/model/crd/ExecutionStatus.kt
@@ -3,11 +3,9 @@ package theodolite.model.crd
import com.fasterxml.jackson.databind.annotation.JsonDeserialize
import io.fabric8.kubernetes.api.model.KubernetesResource
import io.fabric8.kubernetes.api.model.Namespaced
-import io.fabric8.kubernetes.client.CustomResource
@JsonDeserialize
-class ExecutionStatus(): KubernetesResource, CustomResource(), Namespaced {
+class ExecutionStatus(): KubernetesResource, Namespaced {
var executionState: String = ""
var executionDuration: String = "-"
-
}
\ No newline at end of file
diff --git a/theodolite-quarkus/src/main/kotlin/theodolite/patcher/LabelPatcher.kt b/theodolite-quarkus/src/main/kotlin/theodolite/patcher/LabelPatcher.kt
index 5ee5807cd8378c9f2bbd62435203208d61131f15..4fa7fc893cfaf864d935074ff50af8d61f7aac76 100644
--- a/theodolite-quarkus/src/main/kotlin/theodolite/patcher/LabelPatcher.kt
+++ b/theodolite-quarkus/src/main/kotlin/theodolite/patcher/LabelPatcher.kt
@@ -37,7 +37,7 @@ class LabelPatcher(private val k8sResource: KubernetesResource, val variableName
}
k8sResource.metadata.labels[this.variableName] = labelValue
}
- is CustomResource -> {
+ is CustomResource<*,*> -> {
if (k8sResource.metadata.labels == null){
k8sResource.metadata.labels = mutableMapOf()
}
diff --git a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ControllerDummy.kt b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ControllerDummy.kt
index 3ecc2ef422e579b616f304ec8c4b19110941dcea..d87eb7aa85eb3d3155f4af5dabc829b0a4e44c9a 100644
--- a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ControllerDummy.kt
+++ b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ControllerDummy.kt
@@ -5,7 +5,10 @@ import io.fabric8.kubernetes.client.dsl.MixedOperation
import io.fabric8.kubernetes.client.dsl.Resource
import io.fabric8.kubernetes.internal.KubernetesDeserializer
import theodolite.k8s.K8sContextFactory
-import theodolite.model.crd.*
+import theodolite.model.crd.BenchmarkCRD
+import theodolite.model.crd.BenchmarkExecutionList
+import theodolite.model.crd.ExecutionCRD
+import theodolite.model.crd.KubernetesBenchmarkList
private const val SCOPE = "Namespaced"
private const val EXECUTION_SINGULAR = "execution"
@@ -34,7 +37,6 @@ class ControllerDummy(val client: NamespacedKubernetesClient) {
)
val executionStateHandler = ExecutionStateHandler(
- context = executionContext,
client = client
)
@@ -58,19 +60,16 @@ class ControllerDummy(val client: NamespacedKubernetesClient) {
val executionCRDClient: MixedOperation<
ExecutionCRD,
BenchmarkExecutionList,
- DoneableExecution,
- Resource<ExecutionCRD, DoneableExecution>> = client.customResources(
+ Resource<ExecutionCRD>> = client.customResources(
executionContext,
ExecutionCRD::class.java,
- BenchmarkExecutionList::class.java,
- DoneableExecution::class.java
+ BenchmarkExecutionList::class.java
)
val benchmarkCRDClient = client.customResources(
benchmarkContext,
BenchmarkCRD::class.java,
- KubernetesBenchmarkList::class.java,
- DoneableBenchmark::class.java
+ KubernetesBenchmarkList::class.java
)
val appResource = System.getenv("THEODOLITE_APP_RESOURCES") ?: "./config"
diff --git a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ExecutionEventHandlerTest.kt b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ExecutionEventHandlerTest.kt
index 9c3468eaa4df7573a1d909222d6faa7449fd7251..fd192cd3b53db6447a75710d1813e116dc555aeb 100644
--- a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ExecutionEventHandlerTest.kt
+++ b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/ExecutionEventHandlerTest.kt
@@ -39,7 +39,6 @@ class ExecutionEventHandlerTest {
this.factory = server.client.informers()
val informerExecution = factory
.sharedIndexInformerForCustomResource(
- controllerDummy.executionContext,
ExecutionCRD::class.java,
BenchmarkExecutionList::class.java,
RESYNC_PERIOD
@@ -124,7 +123,6 @@ class ExecutionEventHandlerTest {
resourceName = executionName
)
)
-
}
@Test
diff --git a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/StateHandlerTest.kt b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/StateHandlerTest.kt
index 1b92b1e2938df49be2a3a9950d8eb911a7963a40..7537be82c4caf221bdeea7d112df8b6af153c876 100644
--- a/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/StateHandlerTest.kt
+++ b/theodolite-quarkus/src/test/kotlin/theodolite/execution/operator/StateHandlerTest.kt
@@ -38,10 +38,24 @@ class StateHandlerTest {
server.after()
}
+ @Test
+ @DisplayName("Test empty execution state")
+ fun executionWithoutExecutionStatusTest(){
+ val handler = ExecutionStateHandler(client = server.client)
+ assertEquals(States.NO_STATE, handler.getExecutionState("example-execution"))
+ }
+
+ @Test
+ @DisplayName("Test empty duration state")
+ fun executionWithoutDurationStatusTest(){
+ val handler = ExecutionStateHandler(client = server.client)
+ assertEquals("-", handler.getDurationState("example-execution"))
+ }
+
@Test
@DisplayName("Test set and get of the execution state")
fun executionStatusTest() {
- val handler = ExecutionStateHandler(client = server.client, context = context)
+ val handler = ExecutionStateHandler(client = server.client)
assertTrue(handler.setExecutionState("example-execution", States.INTERRUPTED))
assertEquals(States.INTERRUPTED, handler.getExecutionState("example-execution"))
@@ -50,7 +64,7 @@ class StateHandlerTest {
@Test
@DisplayName("Test set and get of the duration state")
fun durationStatusTest() {
- val handler = ExecutionStateHandler(client = server.client, context = context)
+ val handler = ExecutionStateHandler(client = server.client)
assertTrue(handler.setDurationState("example-execution", Duration.ofMillis(100)))
assertEquals("0s", handler.getDurationState("example-execution"))
diff --git a/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sManagerTest.kt b/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sManagerTest.kt
index 931457b0fc65984c35516dca57dbe52e94184064..dc2bf016994d79b1021bebdc751102e291d60682 100644
--- a/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sManagerTest.kt
+++ b/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sManagerTest.kt
@@ -34,7 +34,7 @@ class K8sManagerTest {
.withMetadata(metadata)
.withNewSpec()
.editOrNewSelector()
- .withMatchLabels(mapOf("app" to "test"))
+ .withMatchLabels<String, String>(mapOf("app" to "test"))
.endSelector()
.endSpec()
.build()
@@ -43,7 +43,7 @@ class K8sManagerTest {
.withMetadata(metadata)
.withNewSpec()
.editOrNewSelector()
- .withMatchLabels(mapOf("app" to "test"))
+ .withMatchLabels<String, String>(mapOf("app" to "test"))
.endSelector()
.endSpec()
.build()
diff --git a/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sResourceLoaderTest.kt b/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sResourceLoaderTest.kt
index 5cb6f0c4cf09daeaa95a805ae965f5b592fd9647..7c2aa50007274ff9b4d49f1c0cc05ae45a37d323 100644
--- a/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sResourceLoaderTest.kt
+++ b/theodolite-quarkus/src/test/kotlin/theodolite/k8s/K8sResourceLoaderTest.kt
@@ -82,7 +82,7 @@ class K8sResourceLoaderTest {
}
@Test
- @DisplayName("Test loading of ServiceMonitors")
+ @DisplayName("Test loading of Executions")
fun loadExecutionTest() {
val loader = K8sResourceLoader(server.client)
val resource = loader.loadK8sResource("Execution", testResourcePath + "test-execution.yaml")
@@ -95,7 +95,7 @@ class K8sResourceLoaderTest {
}
@Test
- @DisplayName("Test loading of ServiceMonitors")
+ @DisplayName("Test loading of Benchmarks")
fun loadBenchmarkTest() {
val loader = K8sResourceLoader(server.client)
val resource = loader.loadK8sResource("Benchmark", testResourcePath + "test-benchmark.yaml")