public class EventStore extends Object
| Constructor and Description |
|---|
EventStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
addEventUnderProcessingAndUpdateLastGeneration(CustomResourceEvent event) |
void |
addLastEventForGenerationAwareRetry(CustomResourceEvent event) |
void |
addOrReplaceEventAsNotScheduledAndUpdateLastGeneration(CustomResourceEvent event) |
void |
cleanup(String uuid) |
boolean |
containsEventUnderProcessing(String uuid) |
boolean |
containsNotScheduledEvent(String uuid) |
Long |
getLastStoredGeneration(CustomResourceEvent event) |
CustomResourceEvent |
getReceivedLastEventForGenerationAwareRetry(String uuid) |
boolean |
hasLargerGenerationThanLastStored(CustomResourceEvent event) |
CustomResourceEvent |
removeEventNotScheduled(String uid) |
CustomResourceEvent |
removeEventUnderProcessing(String uid) |
public boolean containsNotScheduledEvent(String uuid)
public CustomResourceEvent removeEventNotScheduled(String uid)
public void addOrReplaceEventAsNotScheduledAndUpdateLastGeneration(CustomResourceEvent event)
public boolean containsEventUnderProcessing(String uuid)
public void addEventUnderProcessingAndUpdateLastGeneration(CustomResourceEvent event)
public CustomResourceEvent removeEventUnderProcessing(String uid)
public boolean hasLargerGenerationThanLastStored(CustomResourceEvent event)
public Long getLastStoredGeneration(CustomResourceEvent event)
public void addLastEventForGenerationAwareRetry(CustomResourceEvent event)
public CustomResourceEvent getReceivedLastEventForGenerationAwareRetry(String uuid)
public void cleanup(String uuid)
Copyright © 2020. All rights reserved.