27
27
public class PrimaryUpdateAndCacheUtils {
28
28
29
29
public static final int DEFAULT_MAX_RETRY = 10 ;
30
- public static final int RESOURCE_CACHE_POLL_TIMEOUT = 10000 ;
31
- public static final int DEFAULT_SLEEP_FOR_CACHE_POLL_MILLIS = 50 ;
30
+ public static final int DEFAULT_RESOURCE_CACHE_TIMEOUT_MILLIS = 10000 ;
31
+ public static final int DEFAULT_RESOURCE_CACHE_POLL_PERIOD_MILLIS = 50 ;
32
32
33
33
private PrimaryUpdateAndCacheUtils () {}
34
34
@@ -115,8 +115,8 @@ public static <P extends HasMetadata> P updateAndCacheResource(
115
115
modificationFunction ,
116
116
updateMethod ,
117
117
DEFAULT_MAX_RETRY ,
118
- RESOURCE_CACHE_POLL_TIMEOUT ,
119
- DEFAULT_SLEEP_FOR_CACHE_POLL_MILLIS );
118
+ DEFAULT_RESOURCE_CACHE_TIMEOUT_MILLIS ,
119
+ DEFAULT_RESOURCE_CACHE_POLL_PERIOD_MILLIS );
120
120
}
121
121
122
122
/**
@@ -134,12 +134,12 @@ public static <P extends HasMetadata> P updateAndCacheResource(
134
134
* @param modificationFunction modifications to make on primary
135
135
* @param updateMethod the update method implementation
136
136
* @param maxRetry maximum number of retries before giving up
137
- * @param cachePollTimeoutMillis maximum amount of milliseconds to wait for the updated resource to appear in cache
137
+ * @param cachePollTimeoutMillis maximum amount of milliseconds to wait for the updated resource
138
+ * to appear in cache
138
139
* @param cachePollPeriodMillis cache polling period, in milliseconds
139
140
* @param <P> primary type
140
141
* @return the updated resource
141
142
*/
142
- @ SuppressWarnings ("unchecked" )
143
143
public static <P extends HasMetadata > P updateAndCacheResource (
144
144
P resourceToUpdate ,
145
145
Context <P > context ,
@@ -194,7 +194,8 @@ public static <P extends HasMetadata> P updateAndCacheResource(
194
194
resourceToUpdate .getMetadata ().getNamespace (),
195
195
e .getCode ());
196
196
resourceToUpdate =
197
- pollLocalCache (context , resourceToUpdate , cachePollTimeoutMillis , cachePollPeriodMillis );
197
+ pollLocalCache (
198
+ context , resourceToUpdate , cachePollTimeoutMillis , cachePollPeriodMillis );
198
199
}
199
200
}
200
201
}
0 commit comments