Event sources M1 #235
Event sources M1 #235
Conversation
# Conflicts: # operator-framework/src/main/java/com/github/containersolutions/operator/Operator.java
# Conflicts: # operator-framework/src/main/java/io/javaoperatorsdk/operator/Operator.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/api/DeleteControl.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/CustomResourceEvent.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventBuffer.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventConsumer.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventScheduler.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventStore.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/ExecutionConsumer.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/ExecutionScope.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/PostExecutionControl.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/ProcessingUtils.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/ResourceCache.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/AbstractEvent.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/AbstractEventSource.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/DefaultEventSourceManager.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/Event.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/EventHandler.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSource.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/ExecutionDescriptor.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/CustomResourceEvent.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/CustomResourceEventSource.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/DelayedEventSource.java # operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/DelayedReprocessEvent.java # operator-framework/src/test/java/io/javaoperatorsdk/operator/EventDispatcherTest.java # operator-framework/src/test/java/io/javaoperatorsdk/operator/EventSchedulerTest.java # operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/TestCustomResourceController.java # operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/subresource/SubResourceTestCustomResourceController.java # samples/common/src/main/java/io/javaoperatorsdk/operator/sample/CustomServiceController.java # samples/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/SchemaController.java # samples/tomcat/src/main/java/io/javaoperatorsdk/operator/sample/TomcatController.java # samples/tomcat/src/main/java/io/javaoperatorsdk/operator/sample/WebappController.java # samples/webserver/src/main/java/io/javaoperatorsdk/operator/sample/WebServerController.java # spring-boot-starter/src/test/java/io/javaoperatorsdk/operator/spingboot/starter/TestController.java
* EventList class introduced for convenient helper methods
* Event becomes non generic
make internal list in EventList public
operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventDispatcher.java
Outdated
Show resolved
Hide resolved
What will the retry mechanism look like when it is released? |
Pls take a look on the changes on this branch: https://github.com/java-operator-sdk/java-operator-sdk/tree/retry-experiment |
Hi @csviri, could you elaborate a bit more on where these exceptions would be caught and what I would have to reschedule? Many thanks |
|
@Mallington it's released, so you have just to specify a retry when registering a controller. |
This is the core of the new extensible approach for the framework. Where an user can register and de-register sources of events other than custom resource events. This PR intends to be the first Milestone. But the intention is to merge it into the master, so all the upcoming work is already based on this approach.
Current state is that it builds, tests are passing. Will work on further tests, and improvements. But please review, also we can have a call and discussion with bugger audience.