@Test public void testReset() { reapPodLookupFilter.withPodPhases(PodPhase.SUCCEEDED); reapPodLookupFilter.produce(END_PROCESSING_TIME); verify(mockKubernetesPodFacade, times(1)).lookupPods(any(), any()); reapPodLookupFilter.produce(END_PROCESSING_TIME); verify(mockKubernetesPodFacade, times(1)).lookupPods(any(), any()); reapPodLookupFilter.reset(); reapPodLookupFilter.produce(END_PROCESSING_TIME); verify(mockKubernetesPodFacade, times(2)).lookupPods(any(), any()); }
@Override public void reset() { lookupComplete = false; }
ReapPodLookupFilter implements Producer<Pod> { @Override public void reset() { lookupComplete = false; } }
ReapPodLookupFilter implements Producer<Pod> { @Override public void reset() { lookupComplete = false; } ReapPodLookupFilter(KubernetesPodFacade kubernetesPodFacade, Instant reapUpperBoundUTC); }
ReapPodLookupFilter implements Producer<Pod> { @Override public void reset() { lookupComplete = false; } ReapPodLookupFilter(KubernetesPodFacade kubernetesPodFacade, Instant reapUpperBoundUTC); ReapPodLookupFilter withPodPhases(PodPhase... podPhases); ReapPodLookupFilter withNamespace(String namespace); @Override ProducerResult<Pod> produce(Instant processEndTime); @Override void reset(); @Override String toString(); }
ReapPodLookupFilter implements Producer<Pod> { @Override public void reset() { lookupComplete = false; } ReapPodLookupFilter(KubernetesPodFacade kubernetesPodFacade, Instant reapUpperBoundUTC); ReapPodLookupFilter withPodPhases(PodPhase... podPhases); ReapPodLookupFilter withNamespace(String namespace); @Override ProducerResult<Pod> produce(Instant processEndTime); @Override void reset(); @Override String toString(); static final int DEFAULT_POD_REAP_AGE_MINUTES; }