26
26
public class Operator {
27
27
28
28
private final static Logger log = LoggerFactory .getLogger (Operator .class );
29
-
30
- private final Retry defaultRetry = GenericRetry .defaultLimitedExponentialRetry ();
31
29
private final KubernetesClient k8sClient ;
32
30
private Map <Class <? extends CustomResource >, CustomResourceOperationsImpl > customResourceClients = new HashMap <>();
33
31
@@ -37,15 +35,15 @@ public Operator(KubernetesClient k8sClient) {
37
35
38
36
39
37
public <R extends CustomResource > void registerControllerForAllNamespaces (ResourceController <R > controller ) throws OperatorException {
40
- registerController (controller , true , defaultRetry );
38
+ registerController (controller , true , GenericRetry . defaultLimitedExponentialRetry () );
41
39
}
42
40
43
41
public <R extends CustomResource > void registerControllerForAllNamespaces (ResourceController <R > controller , Retry retry ) throws OperatorException {
44
42
registerController (controller , true , retry );
45
43
}
46
44
47
45
public <R extends CustomResource > void registerController (ResourceController <R > controller , String ... targetNamespaces ) throws OperatorException {
48
- registerController (controller , false , defaultRetry , targetNamespaces );
46
+ registerController (controller , false , GenericRetry . defaultLimitedExponentialRetry () , targetNamespaces );
49
47
}
50
48
51
49
public <R extends CustomResource > void registerController (ResourceController <R > controller , Retry retry , String ... targetNamespaces ) throws OperatorException {
@@ -99,7 +97,7 @@ public Map<Class<? extends CustomResource>, CustomResourceOperationsImpl> getCus
99
97
return customResourceClients ;
100
98
}
101
99
102
- public <T extends CustomResource , L extends CustomResourceList <T >, D extends CustomResourceDoneable <T >> CustomResourceOperationsImpl <T , L , D >
100
+ public <T extends CustomResource , L extends CustomResourceList <T >, D extends CustomResourceDoneable <T >> CustomResourceOperationsImpl <T , L , D >
103
101
getCustomResourceClients (Class <T > customResourceClass ) {
104
102
return customResourceClients .get (customResourceClass );
105
103
}
0 commit comments