com.github.containersolutions.operator

Class EventDispatcher<R extends io.fabric8.kubernetes.client.CustomResource>

java.lang.Object

com.github.containersolutions.operator.EventDispatcher<R>

All Implemented Interfaces:

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

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

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

EventDispatcher(ResourceController<R> controller, io.fabric8.kubernetes.client.dsl.internal.CustomResourceOperationsImpl<R,io.fabric8.kubernetes.client.CustomResourceList<R>,io.fabric8.kubernetes.client.CustomResourceDoneable<R>> resourceOperation, io.fabric8.kubernetes.client.dsl.NonNamespaceOperation<R,io.fabric8.kubernetes.client.CustomResourceList<R>,io.fabric8.kubernetes.client.CustomResourceDoneable<R>,io.fabric8.kubernetes.client.dsl.Resource<R,io.fabric8.kubernetes.client.CustomResourceDoneable<R>>> resourceClient, io.fabric8.kubernetes.client.KubernetesClient k8sClient, String defaultFinalizer)

Method Summary

Modifier and Type	Method and Description
void	eventReceived(io.fabric8.kubernetes.client.Watcher.Action action, R 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

EventDispatcher

public EventDispatcher(ResourceController<R> controller,
                       io.fabric8.kubernetes.client.dsl.internal.CustomResourceOperationsImpl<R,io.fabric8.kubernetes.client.CustomResourceList<R>,io.fabric8.kubernetes.client.CustomResourceDoneable<R>> resourceOperation,
                       io.fabric8.kubernetes.client.dsl.NonNamespaceOperation<R,io.fabric8.kubernetes.client.CustomResourceList<R>,io.fabric8.kubernetes.client.CustomResourceDoneable<R>,io.fabric8.kubernetes.client.dsl.Resource<R,io.fabric8.kubernetes.client.CustomResourceDoneable<R>>> resourceClient,
                       io.fabric8.kubernetes.client.KubernetesClient k8sClient,
                       String defaultFinalizer)

Method Detail

eventReceived

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

Specified by:

eventReceived in interface io.fabric8.kubernetes.client.Watcher<R extends 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<R extends io.fabric8.kubernetes.client.CustomResource>