|
37 | 37 | import io.javaoperatorsdk.operator.api.config.InformerStoppedHandler; |
38 | 38 | import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration; |
39 | 39 | import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration; |
| 40 | +import io.javaoperatorsdk.operator.api.reconciler.Constants; |
40 | 41 | import io.javaoperatorsdk.operator.processing.event.EventHandler; |
41 | 42 | import io.javaoperatorsdk.operator.processing.event.ResourceID; |
42 | 43 | import io.javaoperatorsdk.operator.processing.event.source.EventFilterTestUtils; |
@@ -87,6 +88,8 @@ void setup() { |
87 | 88 | when(informerEventSourceConfiguration.getInformerConfig()).thenReturn(informerConfig); |
88 | 89 | when(informerConfig.getEffectiveNamespaces(any())).thenReturn(DEFAULT_NAMESPACES_SET); |
89 | 90 | when(informerEventSourceConfiguration.getResourceClass()).thenReturn(Deployment.class); |
| 91 | + when(informerConfig.getObsoleteResourceCacheCheckInterval()) |
| 92 | + .thenReturn(Constants.DEFAULT_OBSOLETE_RESOURCE_CHECK_INTERVAL); |
90 | 93 | informerEventSource = |
91 | 94 | spy( |
92 | 95 | new InformerEventSource<>(informerEventSourceConfiguration, clientMock) { |
@@ -383,7 +386,7 @@ private void withRealTemporaryResourceCache() { |
383 | 386 | when(mim.lastSyncResourceVersion(any())).thenReturn("1"); |
384 | 387 |
|
385 | 388 | temporaryResourceCache = |
386 | | - spy(new TemporaryResourceCache<>(true, 0, mock(ScheduledExecutorService.class), mes)); |
| 389 | + spy(new TemporaryResourceCache<>(true, 100, mock(ScheduledExecutorService.class), mes)); |
387 | 390 | informerEventSource.setTemporalResourceCache(temporaryResourceCache); |
388 | 391 | } |
389 | 392 |
|
|
0 commit comments