feat: InboundEventSource wip

csviri · csviri · commit d372f30ee305 · 2021-11-10T16:12:16.000+01:00
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/InboundEventSource.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/InboundEventSource.java
@@ -0,0 +1,12 @@
+package io.javaoperatorsdk.operator.processing.event.internal;
+
+import io.javaoperatorsdk.operator.OperatorException;
+import io.javaoperatorsdk.operator.processing.event.AbstractEventSource;
+
+public class InboundEventSource<T> extends LifecycleAwareEventSource {
+
+    public void receiveEvent(T event) {
+
+    }
+
+}
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/LifecycleAwareEventSource.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/LifecycleAwareEventSource.java
@@ -0,0 +1,19 @@
+package io.javaoperatorsdk.operator.processing.event.internal;
+
+import io.javaoperatorsdk.operator.OperatorException;
+import io.javaoperatorsdk.operator.processing.event.AbstractEventSource;
+
+public abstract class LifecycleAwareEventSource extends AbstractEventSource {
+
+  protected volatile boolean started = false;
+
+  @Override
+  public void start() throws OperatorException {
+    started = true;
+  }
+
+  @Override
+  public void stop() throws OperatorException {
+    started = false;
+  }
+}
