@@ -49,7 +49,6 @@ import kotlinx.coroutines.channels.Channel
4949import kotlinx.coroutines.channels.SendChannel
5050import mu.KotlinLogging
5151import org.slf4j.LoggerFactory
52- import java.lang.IllegalStateException
5352import kotlin.system.exitProcess
5453
5554
@@ -74,11 +73,11 @@ class Operator(client: NamespacedKubernetesClient? = null,
7473 val startupProbeInitialDelay: Int
7574
7675 private val podSetCustomResourceDefinitionContext = CustomResourceDefinitionContext .Builder ()
77- .withVersion(" v1alpha1" )
78- .withScope(" Namespaced" )
79- .withGroup(" openanalytics.eu" )
80- .withPlural(" shinyproxies" )
81- .build()
76+ .withVersion(" v1alpha1" )
77+ .withScope(" Namespaced" )
78+ .withGroup(" openanalytics.eu" )
79+ .withPlural(" shinyproxies" )
80+ .build()
8281
8382 private val informerFactory: SharedInformerFactory
8483 private val replicaSetInformer: SharedIndexInformer <ReplicaSet >
@@ -238,7 +237,7 @@ class Operator(client: NamespacedKubernetesClient? = null,
238237
239238 fun setOperatorInstance (operator : Operator ) {
240239 this ._operatorInstance = operator
241- }
240+ }
242241
243242 fun getOperatorInstance (): Operator {
244243 _operatorInstance .let {
@@ -251,7 +250,7 @@ class Operator(client: NamespacedKubernetesClient? = null,
251250 }
252251 }
253252
254- private fun <T > readConfigValue (constructorValue : T ? , default : T , envVarName : String , convertor : (String ) -> T ): T {
253+ private fun <T > readConfigValue (constructorValue : T ? , default : T , envVarName : String , convertor : (String ) -> T ): T {
255254 val e = System .getenv(envVarName)
256255 val res = when {
257256 constructorValue != null -> constructorValue
@@ -267,4 +266,4 @@ class Operator(client: NamespacedKubernetesClient? = null,
267266enum class Mode {
268267 CLUSTERED ,
269268 NAMESPACED
270- }
269+ }
0 commit comments