Skip to content

Commit 10e11e5

Browse files
committed
format
1 parent 857868f commit 10e11e5

File tree

3 files changed

+15
-10
lines changed

3 files changed

+15
-10
lines changed

caffein-bounded-cache-support/src/main/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCache.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44

55
/**
66
* Caffein cache wrapper to be used in a {@link BoundedItemStore}
7-
* */
7+
*/
88
public class CaffeinBoundedCache<K, R> implements BoundedCache<K, R> {
99

1010
private Cache<K, R> cache;

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/BoundedCacheTestBase.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,10 +38,11 @@ void reconciliationWorksWithLimitedCache() {
3838
}
3939

4040
private void assertConfigMapsDeleted() {
41-
await().atMost(Duration.ofSeconds(20)).untilAsserted(() -> IntStream.range(0, NUMBER_OF_RESOURCE_TO_TEST).forEach(i -> {
42-
var cm = extension().get(ConfigMap.class, RESOURCE_NAME_PREFIX + i);
43-
assertThat(cm).isNull();
44-
}));
41+
await().atMost(Duration.ofSeconds(20))
42+
.untilAsserted(() -> IntStream.range(0, NUMBER_OF_RESOURCE_TO_TEST).forEach(i -> {
43+
var cm = extension().get(ConfigMap.class, RESOURCE_NAME_PREFIX + i);
44+
assertThat(cm).isNull();
45+
}));
4546
}
4647

4748
private void deleteTestResources() {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ResourceConfiguration.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -125,15 +125,19 @@ default Set<String> getEffectiveNamespaces() {
125125
}
126126

127127
/**
128-
* See <a href="https://github.com/fabric8io/kubernetes-client/blob/43b67939fde91046ab7fb0c362f500c2b46eb59e/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/impl/DefaultSharedIndexInformer.java#L273">related method</a>
129-
* in fabric8 client.
128+
* See <a href=
129+
* "https://github.com/fabric8io/kubernetes-client/blob/43b67939fde91046ab7fb0c362f500c2b46eb59e/kubernetes-client/src/main/java/io/fabric8/kubernetes/client/informers/impl/DefaultSharedIndexInformer.java#L273">related
130+
* method</a> in fabric8 client.
130131
*
131132
* The main goal, is to be able to use limited caches.
132133
*
133-
* See {@link io.javaoperatorsdk.operator.processing.event.source.cache.BoundedItemStore} and <a href="https://github.com/java-operator-sdk/java-operator-sdk/blob/d6eda0138dba6d93c0ff22a5ffcaa7663fa65ca2/caffein-bounded-cache-support/src/main/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCache.java">
134-
* CaffeinBoundedCache</a>
134+
* See {@link io.javaoperatorsdk.operator.processing.event.source.cache.BoundedItemStore} and
135+
* <a href=
136+
* "https://github.com/java-operator-sdk/java-operator-sdk/blob/d6eda0138dba6d93c0ff22a5ffcaa7663fa65ca2/caffein-bounded-cache-support/src/main/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCache.java">
137+
* CaffeinBoundedCache</a>
135138
*
136-
* @return Optional ItemStore implementation. If present this item store will be used inside the informers.
139+
* @return Optional ItemStore implementation. If present this item store will be used inside the
140+
* informers.
137141
*/
138142
default Optional<ItemStore<R>> getItemStore() {
139143
return Optional.empty();

0 commit comments

Comments
 (0)