Skip to content
Snippets Groups Projects
Commit 438949d1 authored by Benedikt Wetzel's avatar Benedikt Wetzel
Browse files

Fix: Start informer before run the operator

parent 87d70619
No related branches found
No related tags found
2 merge requests!163Fix start informer correctly,!159Re-implementation of Theodolite with Kotlin/Quarkus
...@@ -67,15 +67,16 @@ class TheodoliteOperator { ...@@ -67,15 +67,16 @@ class TheodoliteOperator {
client = client client = client
).clearClusterState() ).clearClusterState()
getController( controller = getController(
client = client, client = client,
executionStateHandler = getExecutionStateHandler(client = client) executionStateHandler = getExecutionStateHandler(client = client)
).run() )
getExecutionEventHandler(client).startAllRegisteredInformers() getExecutionEventHandler(controller, client).startAllRegisteredInformers()
controller.run()
} }
} }
fun getExecutionEventHandler(client: NamespacedKubernetesClient): SharedInformerFactory { fun getExecutionEventHandler(controller: TheodoliteController, client: NamespacedKubernetesClient): SharedInformerFactory {
val factory = client.informers() val factory = client.informers()
.inNamespace(client.namespace) .inNamespace(client.namespace)
......
...@@ -39,7 +39,7 @@ class ExecutionEventHandlerTest { ...@@ -39,7 +39,7 @@ class ExecutionEventHandlerTest {
executionStateHandler = ExecutionStateHandler(client = server.client) executionStateHandler = ExecutionStateHandler(client = server.client)
) )
this.factory = operator.getExecutionEventHandler(server.client) this.factory = operator.getExecutionEventHandler(this.controller,server.client)
this.stateHandler = TheodoliteOperator().getExecutionStateHandler(client = server.client) this.stateHandler = TheodoliteOperator().getExecutionStateHandler(client = server.client)
this.executionVersion1 = K8sResourceLoader(server.client) this.executionVersion1 = K8sResourceLoader(server.client)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment