@@ -26,33 +26,29 @@ public class InstanceInformer extends EInstanceInformer {
26
26
27
27
public InstanceInformer (String namespace , SharedInformerFactory informerFactory , GenericKubernetesApi <EpsilonInstanceCRD , EpsilonInstanceCRDList > epsilonInstanceClient ) {
28
28
this .instanceInformer = informerFactory .sharedIndexInformerFor (epsilonInstanceClient ,
29
- EpsilonInstanceCRD .class , TimeUnit .MINUTES .toMillis (10 ), namespace );
29
+ EpsilonInstanceCRD .class , TimeUnit .SECONDS .toMillis (1 ), namespace );
30
30
31
31
this .instanceStore = new Lister <>(instanceInformer .getIndexer ());
32
32
33
33
this .listeners = new ArrayList <>();
34
34
35
35
instanceInformer .addEventHandlerWithResyncPeriod (new ResourceEventHandler <EpsilonInstanceCRD >() {
36
36
@ Override
37
- public void onAdd (EpsilonInstanceCRD instance ) {
38
- }
37
+ public void onAdd (EpsilonInstanceCRD instance ) {}
39
38
40
39
@ Override
41
40
public void onUpdate (EpsilonInstanceCRD oldInstance , EpsilonInstanceCRD newInstance ) {
42
- if (newInstance .getStatus () != null ) {
43
- for (EInstanceInformerListener listener : listeners ) {
41
+ if (newInstance .getStatus () != null )
42
+ for (EInstanceInformerListener listener : listeners )
44
43
listener .onInstanceUpdate (newInstance .getInstance ());
45
- }
46
- }
47
44
}
48
45
49
46
@ Override
50
47
public void onDelete (EpsilonInstanceCRD instance , boolean deletedFinalStateUnknown ) {
51
- for (EInstanceInformerListener listener : listeners ) {
48
+ for (EInstanceInformerListener listener : listeners )
52
49
listener .onInstanceRemove (instance .getInstance ());
53
- }
54
50
}
55
- }, TimeUnit .MINUTES .toMillis (5 ));
51
+ }, TimeUnit .SECONDS .toMillis (1 ));
56
52
}
57
53
58
54
@ Override
0 commit comments