Package com.cloudimpl.outstack.runtime

Class EntityContext<T extends Entity>

java.lang.Object

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

Type Parameters:

T -

All Implemented Interfaces:

Context

Direct Known Subclasses:

ChildEntityContext, RootEntityContext

public abstract class EntityContext<T extends Entity>
extends java.lang.Object
implements Context

Author:

nuwansa

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Optional<CRUDOperations>	crudOperations
protected java.util.Optional<EntityProvider<? extends RootEntity>>	entitySupplier
protected java.lang.Class<T>	entityType
protected java.util.Optional<java.util.function.Consumer<Event>>	eventPublisher
protected java.util.function.Supplier<java.lang.String>	idGenerator
protected QueryOperations<?>	queryOperation
protected java.util.function.Function<java.lang.Class<? extends RootEntity>,QueryOperations<?>>	queryOperationSelector
protected EntityQueryContextProvider.ReadOnlyTransaction	tx
protected java.util.function.Consumer<java.lang.Object>	validator
protected java.lang.String	version

Constructor Summary

Constructors

Constructor

Description

EntityContext(java.lang.Class<T> entityType, java.lang.String tenantId, java.util.Optional<EntityProvider<? extends RootEntity>> entitySupplier, java.util.function.Supplier<java.lang.String> idGenerator, java.util.Optional<CRUDOperations> crudOperations, QueryOperations<?> queryOperation, java.util.Optional<java.util.function.Consumer<Event>> eventPublisher, java.util.function.Consumer<java.lang.Object> validator, java.util.function.Function<java.lang.Class<? extends RootEntity>,QueryOperations<?>> queryOperationSelector, java.lang.String version)

Method Summary

Modifier and Type	Method	Description
protected void	addEvent(Event<T> event)
abstract <R extends RootEntity> AsyncEntityContext<R>	asAsyncEntityContext()
abstract <R extends RootEntity, K extends ChildEntity<R>> ChildEntityContext<R,K>	asChildContext()
abstract <R extends RootEntity> RootEntityContext<R>	asRootContext()
abstract T	create(java.lang.String id, Event<T> event)
abstract T	delete(java.lang.String id)
protected CRUDOperations	getCrudOperations()
protected <R extends RootEntity> EntityProvider<R>	getEntityProvider()
<R extends RootEntity> ExternalEntityQueryProvider<R>	getEntityQueryProvider(java.lang.Class<R> rootType, java.lang.String id)
java.util.function.Consumer<Event>	getEventPublisher()
java.util.List<Event>	getEvents()
protected <R extends RootEntity> QueryOperations<R>	getQueryOperations()
java.lang.String	getTenantId()
protected EntityQueryContextProvider.ReadOnlyTransaction	getTx()
protected java.lang.String	getVersion()
abstract T	rename(java.lang.String id, java.lang.String newId)
void	setTx(EntityQueryContextProvider.ReadOnlyTransaction tx)
abstract T	update(java.lang.String id, Event<T> event)

Methods inherited from class java.lang.Object

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

Field Details

entityType

protected final java.lang.Class<T extends Entity> entityType

entitySupplier

protected final java.util.Optional<EntityProvider<? extends RootEntity>> entitySupplier

idGenerator

protected final java.util.function.Supplier<java.lang.String> idGenerator

crudOperations

protected final java.util.Optional<CRUDOperations> crudOperations

queryOperation

protected final QueryOperations<?> queryOperation

eventPublisher

protected final java.util.Optional<java.util.function.Consumer<Event>> eventPublisher

tx

protected EntityQueryContextProvider.ReadOnlyTransaction tx

validator

protected final java.util.function.Consumer<java.lang.Object> validator

queryOperationSelector

protected final java.util.function.Function<java.lang.Class<? extends RootEntity>,QueryOperations<?>> queryOperationSelector

version

protected final java.lang.String version

Constructor Details

EntityContext

public EntityContext(java.lang.Class<T> entityType,
java.lang.String tenantId,
java.util.Optional<EntityProvider<? extends RootEntity>> entitySupplier,
java.util.function.Supplier<java.lang.String> idGenerator,
java.util.Optional<CRUDOperations> crudOperations,
QueryOperations<?> queryOperation,
java.util.Optional<java.util.function.Consumer<Event>> eventPublisher,
java.util.function.Consumer<java.lang.Object> validator,
java.util.function.Function<java.lang.Class<? extends RootEntity>,QueryOperations<?>> queryOperationSelector,
java.lang.String version)

Method Details

getTx

protected EntityQueryContextProvider.ReadOnlyTransaction getTx()

getVersion

protected java.lang.String getVersion()

getEntityProvider

protected <R extends RootEntity> EntityProvider<R> getEntityProvider()

getQueryOperations

protected <R extends RootEntity> QueryOperations<R> getQueryOperations()

setTx

public void setTx(EntityQueryContextProvider.ReadOnlyTransaction tx)

getEventPublisher

public java.util.function.Consumer<Event> getEventPublisher()

getTenantId

public java.lang.String getTenantId()

getEvents

public java.util.List<Event> getEvents()

getCrudOperations

protected CRUDOperations getCrudOperations()

addEvent

protected void addEvent(Event<T> event)

create

public abstract T create(java.lang.String id,
Event<T> event)

update

public abstract T update(java.lang.String id,
Event<T> event)

delete

public abstract T delete(java.lang.String id)

rename

public abstract T rename(java.lang.String id,
java.lang.String newId)

asRootContext

public abstract <R extends RootEntity>
RootEntityContext<R> asRootContext()

asAsyncEntityContext

public abstract <R extends RootEntity>
AsyncEntityContext<R> asAsyncEntityContext()

asChildContext

public abstract <R extends RootEntity,
K extends ChildEntity<R>>
ChildEntityContext<R,K> asChildContext()

getEntityQueryProvider

public <R extends RootEntity>
ExternalEntityQueryProvider<R> getEntityQueryProvider(java.lang.Class<R> rootType,
java.lang.String id)