Package com.cloudimpl.outstack.runtime.repo

Class MemEventRepository<T extends RootEntity>

java.lang.Object

com.cloudimpl.outstack.runtime.EventRepositoy<T>

com.cloudimpl.outstack.runtime.repo.MemEventRepository<T>

Type Parameters:

T -

All Implemented Interfaces:

QueryOperations<T>

public class MemEventRepository<T extends RootEntity>
extends EventRepositoy<T>

Author:

nuwan

Field Summary

Fields inherited from class com.cloudimpl.outstack.runtime.EventRepositoy

resourceHelper, rootType, TID_PREFIX, version

Constructor Summary

Constructors

Constructor	Description
MemEventRepository(java.lang.Class<T> rootType, ResourceHelper resourceHelper, EventStream eventStream)

Method Summary

Modifier and Type	Method	Description
<T extends Entity> T	applyEvent(Event event)
ResultSet<T>	getAllByRootType(java.lang.Class<T> rootType, java.lang.String tenantId, Query.PagingRequest paging)
<K extends ChildEntity<T>> ResultSet<K>	getAllChildByType(java.lang.Class<T> rootType, java.lang.String id, java.lang.Class<K> childType, java.lang.String tenantId, Query.PagingRequest paging)
<C extends ChildEntity<T>> java.util.Optional<C>	getChildById(java.lang.Class<T> rootType, java.lang.String id, java.lang.Class<C> childType, java.lang.String childId, java.lang.String tenantId)
<K extends ChildEntity<T>> ResultSet<Event<K>>	getEventsByChildId(java.lang.Class<T> rootType, java.lang.String id, java.lang.Class<K> childType, java.lang.String childId, java.lang.String tenantId, Query.PagingRequest paging)
ResultSet<Event<T>>	getEventsByRootId(java.lang.Class<T> rootType, java.lang.String rootId, java.lang.String tenantId, Query.PagingRequest paging)
java.util.Optional<T>	getRootById(java.lang.Class<T> rootType, java.lang.String id, java.lang.String tenantId)
void	saveTx(EntityContextProvider.Transaction transaction)

Methods inherited from class com.cloudimpl.outstack.runtime.EventRepositoy

generateTid, loadEntityWithClone

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MemEventRepository

public MemEventRepository(java.lang.Class<T> rootType,
ResourceHelper resourceHelper,
EventStream eventStream)

Method Details

saveTx

public void saveTx(EntityContextProvider.Transaction transaction)

Specified by:

saveTx in class EventRepositoy<T extends RootEntity>

applyEvent

public <T extends Entity> T applyEvent(Event event)

Specified by:

applyEvent in class EventRepositoy<T extends RootEntity>

getAllChildByType

public <K extends ChildEntity<T>> ResultSet<K> getAllChildByType(java.lang.Class<T> rootType,
java.lang.String id,
java.lang.Class<K> childType,
java.lang.String tenantId,
Query.PagingRequest paging)

getRootById

public java.util.Optional<T> getRootById(java.lang.Class<T> rootType,
java.lang.String id,
java.lang.String tenantId)

getChildById

public <C extends ChildEntity<T>>
java.util.Optional<C> getChildById(java.lang.Class<T> rootType,
java.lang.String id,
java.lang.Class<C> childType,
java.lang.String childId,
java.lang.String tenantId)

getAllByRootType

public ResultSet<T> getAllByRootType(java.lang.Class<T> rootType,
java.lang.String tenantId,
Query.PagingRequest paging)

getEventsByRootId

public ResultSet<Event<T>> getEventsByRootId(java.lang.Class<T> rootType,
java.lang.String rootId,
java.lang.String tenantId,
Query.PagingRequest paging)

getEventsByChildId

public <K extends ChildEntity<T>>
ResultSet<Event<K>> getEventsByChildId(java.lang.Class<T> rootType,
java.lang.String id,
java.lang.Class<K> childType,
java.lang.String childId,
java.lang.String tenantId,
Query.PagingRequest paging)