Class EventRecorder
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.utils.EventRecorder
-
public class EventRecorder extends java.lang.Object
Helper class for creating Kubernetes events for Flink resources.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
EventRecorder.Component
The component of events.static class
EventRecorder.Reason
The reason codes of events.static class
EventRecorder.Type
The type of the events.
-
Constructor Summary
Constructors Constructor Description EventRecorder(io.fabric8.kubernetes.client.KubernetesClient client, java.util.function.BiConsumer<AbstractFlinkResource<?,?>,io.fabric8.kubernetes.api.model.Event> eventListener)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static EventRecorder
create(io.fabric8.kubernetes.client.KubernetesClient client, java.util.Collection<FlinkResourceListener> listeners)
boolean
triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component)
boolean
triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, EventRecorder.Component component, java.lang.String message)
-
-
-
Constructor Detail
-
EventRecorder
public EventRecorder(io.fabric8.kubernetes.client.KubernetesClient client, java.util.function.BiConsumer<AbstractFlinkResource<?,?>,io.fabric8.kubernetes.api.model.Event> eventListener)
-
-
Method Detail
-
triggerEvent
public boolean triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, EventRecorder.Reason reason, EventRecorder.Component component, java.lang.String message)
-
triggerEvent
public boolean triggerEvent(AbstractFlinkResource<?,?> resource, EventRecorder.Type type, java.lang.String reason, java.lang.String message, EventRecorder.Component component)
-
create
public static EventRecorder create(io.fabric8.kubernetes.client.KubernetesClient client, java.util.Collection<FlinkResourceListener> listeners)
-
-