Skip to content
Snippets Groups Projects
Commit 9808367c authored by Sören Henning's avatar Sören Henning
Browse files

Merge branch 'fix-start-informer' into 'theodolite-kotlin'

Fix start informer correctly

See merge request !163
parents 87d70619 438949d1
No related branches found
No related tags found
2 merge requests!163Fix start informer correctly,!159Re-implementation of Theodolite with Kotlin/Quarkus
Pipeline #3853 passed
......@@ -67,15 +67,16 @@ class TheodoliteOperator {
client = client
).clearClusterState()
getController(
controller = getController(
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()
.inNamespace(client.namespace)
......
......@@ -39,7 +39,7 @@ class ExecutionEventHandlerTest {
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.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