1
1
package io .javaoperatorsdk .operator .processing .dependent ;
2
2
3
3
import io .fabric8 .kubernetes .api .model .HasMetadata ;
4
- import io .fabric8 .kubernetes .client .KubernetesClient ;
5
4
import io .javaoperatorsdk .operator .api .reconciler .Context ;
6
5
import io .javaoperatorsdk .operator .api .reconciler .dependent .RecentOperationCacheFiller ;
7
6
import io .javaoperatorsdk .operator .processing .event .EventSourceRetriever ;
@@ -13,12 +12,11 @@ public abstract class AbstractExternalDependentResource<R, P extends HasMetadata
13
12
extends AbstractEventSourceHolderDependentResource <R , P , T > {
14
13
15
14
private final boolean isDependentResourceWithExplicitState =
16
- this instanceof DependentResourceWithExplicitState ;
15
+ this instanceof DependentResourceWithExplicitState ;
17
16
private final boolean isBulkDependentResource = this instanceof BulkDependentResource ;
18
17
@ SuppressWarnings ("rawtypes" )
19
18
private DependentResourceWithExplicitState dependentResourceWithExplicitState ;
20
19
private InformerEventSource <?, P > externalStateEventSource ;
21
- private KubernetesClient kubernetesClient ;
22
20
23
21
@ SuppressWarnings ("unchecked" )
24
22
protected AbstractExternalDependentResource (Class <R > resourceType ) {
@@ -34,10 +32,10 @@ public void resolveEventSource(EventSourceRetriever<P> eventSourceRetriever) {
34
32
super .resolveEventSource (eventSourceRetriever );
35
33
if (isDependentResourceWithExplicitState ) {
36
34
final var eventSourceName = (String ) dependentResourceWithExplicitState
37
- .eventSourceName ().orElse (null );
35
+ .eventSourceName ().orElse (null );
38
36
externalStateEventSource = (InformerEventSource <?, P >) eventSourceRetriever
39
- .getResourceEventSourceFor (dependentResourceWithExplicitState .stateResourceClass (),
40
- eventSourceName );
37
+ .getResourceEventSourceFor (dependentResourceWithExplicitState .stateResourceClass (),
38
+ eventSourceName );
41
39
}
42
40
43
41
}
@@ -74,43 +72,29 @@ protected void handleExplicitStateCreation(P primary, R created, Context<P> cont
74
72
var stateResource = context .getClient ().resource (resource ).create ();
75
73
if (externalStateEventSource != null ) {
76
74
((RecentOperationCacheFiller ) externalStateEventSource )
77
- .handleRecentResourceCreate (ResourceID .fromResource (primary ), stateResource );
75
+ .handleRecentResourceCreate (ResourceID .fromResource (primary ), stateResource );
78
76
}
79
77
}
80
78
81
79
82
80
@ SuppressWarnings ("unchecked" )
83
81
public void deleteTargetResource (P primary , R resource , String key ,
84
- Context <P > context ) {
82
+ Context <P > context ) {
85
83
if (isDependentResourceWithExplicitState ) {
86
- getKubernetesClient ()
87
- .resource (dependentResourceWithExplicitState .stateResource (primary , resource ))
88
- .delete ();
84
+ context . getClient ()
85
+ .resource (dependentResourceWithExplicitState .stateResource (primary , resource ))
86
+ .delete ();
89
87
}
90
88
handleDeleteTargetResource (primary , resource , key , context );
91
89
}
92
90
93
91
public void handleDeleteTargetResource (P primary , R resource , String key ,
94
- Context <P > context ) {
92
+ Context <P > context ) {
95
93
throw new IllegalStateException ("Override this method in case you manage an bulk resource" );
96
94
}
97
95
98
96
@ SuppressWarnings ("rawtypes" )
99
97
protected InformerEventSource getExternalStateEventSource () {
100
98
return externalStateEventSource ;
101
99
}
102
-
103
- /**
104
- * It's here just to manage the explicit state resource in case the dependent resource implements
105
- * {@link RecentOperationCacheFiller}.
106
- *
107
- * @return kubernetes client.
108
- */
109
- public KubernetesClient getKubernetesClient () {
110
- return kubernetesClient ;
111
- }
112
-
113
- public void setKubernetesClient (KubernetesClient kubernetesClient ) {
114
- this .kubernetesClient = kubernetesClient ;
115
- }
116
100
}
0 commit comments