events-processor: with single event at a time implementation
diff --git a/events/event.go b/events/event.go
new file mode 100644
index 0000000..427427b
--- /dev/null
+++ b/events/event.go
@@ -0,0 +1,19 @@
+package events
+
+type EventState string
+
+const (
+ EventStateNew EventState = "NEW"
+ EventStateProcessing EventState = "PROCESSING"
+ EventStateDone EventState = "DONE"
+)
+
+type Event struct {
+ Id string
+ State EventState
+ NodeId string
+}
+
+type EventStore interface {
+ GetEventsInState(state EventState) ([]Event, error)
+}