Skip to content

Commit 4a02218

Browse files
committed
docs: new event sources
1 parent 292d913 commit 4a02218

File tree

2 files changed

+23
-0
lines changed

2 files changed

+23
-0
lines changed

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,18 @@
1111
import io.javaoperatorsdk.operator.processing.event.Event;
1212
import io.javaoperatorsdk.operator.processing.event.ResourceID;
1313

14+
/**
15+
* Base class for event sources with filtering and caching capabilities.
16+
* <p>
17+
* {@link #handleDelete(ResourceID)} - if the related resource is present in the cache it is
18+
* removed. and event propagated. There is no event propagated if the resource is not in the cache.
19+
* <p>
20+
* {@link #handleEvent(Object, ResourceID)} - caches the resource if changed (or nto present
21+
* before). Propagates an event if the resource is new or not equals to the one in the cache, and if
22+
* accepted by the filter if one is present.
23+
*
24+
* @param <T> represents the resource (usually external non-kubernetes one) handled.
25+
*/
1426
public abstract class CachingFilteringEventSource<T> extends LifecycleAwareEventSource {
1527

1628
private static final Logger log = LoggerFactory.getLogger(CachingFilteringEventSource.class);

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

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,17 @@
2020
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventAware;
2121
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
2222

23+
/**
24+
*
25+
* Polls the supplier for each controlled resource registered. Resource is registered when created
26+
* if there is no registerPredicate provided. If register predicate provided it is evaluated on
27+
* resource create and/or update to register polling for the event source.
28+
* <p>
29+
* For other behavior see {@link CachingFilteringEventSource}
30+
*
31+
* @param <T> the resource polled by the event source
32+
* @param <R> related custom resource
33+
*/
2334
public class PerResourcePollingEventSource<T, R extends HasMetadata>
2435
extends CachingFilteringEventSource<T>
2536
implements ResourceEventAware<R> {

0 commit comments

Comments
 (0)