1
1
package fr .epsilon .exporter .listener ;
2
2
3
3
import fr .epsilon .common .Epsilon ;
4
- import fr .epsilon .common .crd .EpsilonInstance ;
5
- import fr .epsilon .common .crd .EpsilonInstanceList ;
6
- import fr .epsilon .common .crd .EpsilonInstanceStatus ;
4
+ import fr .epsilon .common .crd .EpsilonInstanceCRD ;
5
+ import fr .epsilon .common .crd .EpsilonInstanceCRDList ;
6
+ import fr .epsilon .common .crd .EpsilonInstanceCRDStatus ;
7
7
import fr .epsilon .common .instance .EState ;
8
8
import fr .epsilon .common .instance .EType ;
9
9
import fr .epsilon .exporter .EpsilonExporter ;
@@ -51,31 +51,31 @@ public EpsilonRegister(EpsilonExporter main) {
51
51
}
52
52
53
53
public void runInformer () {
54
- GenericKubernetesApi <EpsilonInstance , EpsilonInstanceList > epsilonInstanceClient = Epsilon .get ().getEpsilonInstanceClient ();
54
+ GenericKubernetesApi <EpsilonInstanceCRD , EpsilonInstanceCRDList > epsilonInstanceClient = Epsilon .get ().getEpsilonInstanceClient ();
55
55
SharedInformerFactory informerFactory = Epsilon .get ().getInformerFactory ();
56
- SharedInformer <EpsilonInstance > instanceInformer = informerFactory .sharedIndexInformerFor (epsilonInstanceClient ,
57
- EpsilonInstance .class , TimeUnit .MINUTES .toMillis (10 ), namespace );
56
+ SharedInformer <EpsilonInstanceCRD > instanceInformer = informerFactory .sharedIndexInformerFor (epsilonInstanceClient ,
57
+ EpsilonInstanceCRD .class , TimeUnit .MINUTES .toMillis (10 ), namespace );
58
58
59
59
try {
60
- KubernetesApiResponse <EpsilonInstanceList > instanceList = epsilonInstanceClient .list (namespace ).throwsApiException ();
61
- for (EpsilonInstance instance : instanceList .getObject ().getItems ())
60
+ KubernetesApiResponse <EpsilonInstanceCRDList > instanceList = epsilonInstanceClient .list (namespace ).throwsApiException ();
61
+ for (EpsilonInstanceCRD instance : instanceList .getObject ().getItems ())
62
62
registerInstance (instance );
63
63
} catch (ApiException e ) {
64
64
e .printStackTrace ();
65
65
}
66
66
67
- instanceInformer .addEventHandlerWithResyncPeriod (new ResourceEventHandler <EpsilonInstance >() {
67
+ instanceInformer .addEventHandlerWithResyncPeriod (new ResourceEventHandler <EpsilonInstanceCRD >() {
68
68
@ Override
69
- public void onAdd (EpsilonInstance instance ) {
69
+ public void onAdd (EpsilonInstanceCRD instance ) {
70
70
}
71
71
72
72
@ Override
73
- public void onUpdate (EpsilonInstance oldInstance , EpsilonInstance newInstance ) {
73
+ public void onUpdate (EpsilonInstanceCRD oldInstance , EpsilonInstanceCRD newInstance ) {
74
74
registerInstance (newInstance );
75
75
}
76
76
77
77
@ Override
78
- public void onDelete (EpsilonInstance instance , boolean deletedFinalStateUnknown ) {
78
+ public void onDelete (EpsilonInstanceCRD instance , boolean deletedFinalStateUnknown ) {
79
79
V1ObjectMeta metadata = instance .getMetadata ();
80
80
String name = metadata .getName ();
81
81
@@ -92,8 +92,8 @@ public List<ServerInfo> getHubs() {
92
92
.collect (Collectors .toList ());
93
93
}
94
94
95
- private void registerInstance (EpsilonInstance instance ) {
96
- EpsilonInstanceStatus status = instance .getStatus ();
95
+ private void registerInstance (EpsilonInstanceCRD instance ) {
96
+ EpsilonInstanceCRDStatus status = instance .getStatus ();
97
97
98
98
if (status != null ) {
99
99
String name = instance .getName ();
0 commit comments