Skip to content

Commit 8c7f490

Browse files
committed
fix: formatting
1 parent e4b0a11 commit 8c7f490

File tree

6 files changed

+172
-165
lines changed

6 files changed

+172
-165
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/Event.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,10 @@ public String toString() {
2323

2424
@Override
2525
public boolean equals(Object o) {
26-
if (this == o) return true;
27-
if (o == null || getClass() != o.getClass()) return false;
26+
if (this == o)
27+
return true;
28+
if (o == null || getClass() != o.getClass())
29+
return false;
2830
Event event = (Event) o;
2931
return Objects.equals(relatedCustomResource, event.relatedCustomResource);
3032
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/ControllerResourceEventSource.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import java.util.Optional;
77
import java.util.concurrent.ConcurrentHashMap;
88

9-
import io.javaoperatorsdk.operator.processing.event.EventSourceManager;
109
import org.slf4j.Logger;
1110
import org.slf4j.LoggerFactory;
1211

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSource.java

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@
77
import java.util.concurrent.ConcurrentHashMap;
88
import java.util.function.Predicate;
99

10+
import javax.cache.Cache;
11+
1012
import org.slf4j.Logger;
1113
import org.slf4j.LoggerFactory;
1214

@@ -18,8 +20,6 @@
1820
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventAware;
1921
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
2022

21-
import javax.cache.Cache;
22-
2323
public class PerResourcePollingEventSource<T, R extends HasMetadata>
2424
extends CachingFilteringEventSource<T>
2525
implements ResourceEventAware<R> {
@@ -34,23 +34,25 @@ public class PerResourcePollingEventSource<T, R extends HasMetadata>
3434
private final long period;
3535

3636
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
37-
ResourceCache<R> resourceCache, long period, Cache<ResourceID,T> cache, EventFilter<T> eventFilter) {
37+
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache,
38+
EventFilter<T> eventFilter) {
3839
this(resourceSupplier, resourceCache, period, cache, eventFilter, null);
3940
}
4041

4142
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
42-
ResourceCache<R> resourceCache, long period, Cache<ResourceID,T> cache, Predicate<R> registerPredicate) {
43-
this(resourceSupplier, resourceCache, period, cache,null, registerPredicate);
43+
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache,
44+
Predicate<R> registerPredicate) {
45+
this(resourceSupplier, resourceCache, period, cache, null, registerPredicate);
4446
}
4547

4648
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
47-
ResourceCache<R> resourceCache, long period,Cache<ResourceID,T> cache) {
48-
this(resourceSupplier, resourceCache, period, cache, null,null);
49+
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache) {
50+
this(resourceSupplier, resourceCache, period, cache, null, null);
4951
}
5052

5153
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
52-
ResourceCache<R> resourceCache, long period,Cache<ResourceID,T> cache,
53-
EventFilter<T> eventFilter, Predicate<R> registerPredicate) {
54+
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache,
55+
EventFilter<T> eventFilter, Predicate<R> registerPredicate) {
5456
super(cache, eventFilter);
5557
this.resourceSupplier = resourceSupplier;
5658
this.resourceCache = resourceCache;

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PollingEventSource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public class PollingEventSource<T> extends CachingFilteringEventSource<T> {
2424
private final long period;
2525

2626
public PollingEventSource(Supplier<Map<ResourceID, T>> supplier,
27-
long period, EventFilter<T> eventFilter, Cache<ResourceID,T> cache) {
27+
long period, EventFilter<T> eventFilter, Cache<ResourceID, T> cache) {
2828
super(cache, eventFilter);
2929
this.supplierToPoll = supplier;
3030
this.period = period;

0 commit comments

Comments
 (0)