Skip to content

Commit 669679d

Browse files
committed
cleanup
1 parent 64d889a commit 669679d

File tree

2 files changed

+2
-8
lines changed

2 files changed

+2
-8
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import io.javaoperatorsdk.operator.ReconcilerUtils;
2121
import io.javaoperatorsdk.operator.api.config.Cloner;
2222
import io.javaoperatorsdk.operator.api.config.ConfigurationServiceProvider;
23-
import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
2423
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
2524
import io.javaoperatorsdk.operator.processing.LifecycleAware;
2625
import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -39,21 +38,18 @@ public class InformerManager<T extends HasMetadata, C extends ResourceConfigurat
3938
private MixedOperation<T, KubernetesResourceList<T>, Resource<T>> client;
4039
private ResourceEventHandler<T> eventHandler;
4140
private final Map<String, Function<T, List<String>>> indexers = new HashMap<>();
42-
protected ControllerConfiguration<?> controllerConfiguration;
4341

4442
@Override
4543
public void start() throws OperatorException {
4644
sources.values().parallelStream().forEach(LifecycleAware::start);
4745
}
4846

4947
void initSources(MixedOperation<T, KubernetesResourceList<T>, Resource<T>> client,
50-
C configuration, ControllerConfiguration<?> controllerConfiguration,
51-
ResourceEventHandler<T> eventHandler) {
48+
C configuration, ResourceEventHandler<T> eventHandler) {
5249
cloner = ConfigurationServiceProvider.instance().getResourceCloner();
5350
this.configuration = configuration;
5451
this.client = client;
5552
this.eventHandler = eventHandler;
56-
this.controllerConfiguration = controllerConfiguration;
5753

5854
final var targetNamespaces = configuration.getEffectiveNamespaces();
5955
final var labelSelector = configuration.getLabelSelector();

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
import io.fabric8.kubernetes.client.dsl.MixedOperation;
1717
import io.fabric8.kubernetes.client.dsl.Resource;
1818
import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
19-
import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
2019
import io.javaoperatorsdk.operator.api.config.NamespaceChangeable;
2120
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
2221
import io.javaoperatorsdk.operator.api.reconciler.dependent.RecentOperationCacheFiller;
@@ -33,12 +32,11 @@ public abstract class ManagedInformerEventSource<R extends HasMetadata, P extend
3332

3433
protected TemporaryResourceCache<R> temporaryResourceCache = new TemporaryResourceCache<>(this);
3534
protected InformerManager<R, C> cache = new InformerManager<>();
36-
protected ControllerConfiguration<P> controllerConfiguration;
3735

3836
protected ManagedInformerEventSource(
3937
MixedOperation<R, KubernetesResourceList<R>, Resource<R>> client, C configuration) {
4038
super(configuration.getResourceClass());
41-
manager().initSources(client, configuration, controllerConfiguration, this);
39+
manager().initSources(client, configuration, this);
4240
}
4341

4442
@Override

0 commit comments

Comments
 (0)