| giolekva | f89e046 | 2020-05-02 17:47:06 +0400 | [diff] [blame] | 1 | package events |
| 2 | |
| 3 | type EventState string |
| 4 | |
| giolekva | ede6d2b | 2020-05-05 22:14:16 +0400 | [diff] [blame] | 5 | // TODO(giolekva): add FAILED |
| giolekva | f89e046 | 2020-05-02 17:47:06 +0400 | [diff] [blame] | 6 | const ( |
| 7 | EventStateNew EventState = "NEW" |
| 8 | EventStateProcessing EventState = "PROCESSING" |
| 9 | EventStateDone EventState = "DONE" |
| 10 | ) |
| 11 | |
| 12 | type Event struct { |
| 13 | Id string |
| 14 | State EventState |
| 15 | NodeId string |
| 16 | } |
| 17 | |
| 18 | type EventStore interface { |
| 19 | GetEventsInState(state EventState) ([]Event, error) |
| giolekva | ede6d2b | 2020-05-05 22:14:16 +0400 | [diff] [blame] | 20 | MarkEventDone(event Event) error |
| giolekva | f89e046 | 2020-05-02 17:47:06 +0400 | [diff] [blame] | 21 | } |