io.javaoperatorsdk.operator.processing

Class EventScheduler

java.lang.Object

io.javaoperatorsdk.operator.processing.EventScheduler

All Implemented Interfaces:

io.fabric8.kubernetes.client.Watcher<io.fabric8.kubernetes.client.CustomResource>

public class EventScheduler
extends Object
implements io.fabric8.kubernetes.client.Watcher<io.fabric8.kubernetes.client.CustomResource>

Requirements:

• Only 1 event should be processed at a time for same custom resource (metadata.name is the id, but kind and api should be taken into account)
• If event processing fails it should be rescheduled with retry - with limited number of retried and exponential time slacks (pluggable reschedule strategy in future?)
• if there are multiple events received for the same resource process only the last one. (Others can be discarded) User resourceVersion to check which is the latest. Put the new one at the and of the queue?
• Done - Avoid starvation, so on retry put back resource at the end of the queue.
• The selecting event from a queue should not be naive. So for example: If we cannot pick the last event because an event for that resource is currently processing just gor for the next one.
• Threading approach thus thread pool size and/or implementation should be configurable

Nested Class Summary

Nested classes/interfaces inherited from interface io.fabric8.kubernetes.client.Watcher

io.fabric8.kubernetes.client.Watcher.Action

Constructor Summary

Constructors

Constructor and Description
EventScheduler(EventDispatcher eventDispatcher, Retry retry)

Method Summary

Modifier and Type	Method and Description
void	eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, io.fabric8.kubernetes.client.CustomResource resource)
void	onClose(io.fabric8.kubernetes.client.KubernetesClientException e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventScheduler

public EventScheduler(EventDispatcher eventDispatcher,
                      Retry retry)

Method Detail

eventReceived

public void eventReceived(io.fabric8.kubernetes.client.Watcher.Action action,
                          io.fabric8.kubernetes.client.CustomResource resource)

Specified by:

eventReceived in interface io.fabric8.kubernetes.client.Watcher<io.fabric8.kubernetes.client.CustomResource>

onClose

public void onClose(io.fabric8.kubernetes.client.KubernetesClientException e)

Specified by:

onClose in interface io.fabric8.kubernetes.client.Watcher<io.fabric8.kubernetes.client.CustomResource>