Package com.cloudimpl.outstack.runtime

Class UnboundedEntityContext<T extends RootEntity>

java.lang.Object

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

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

All Implemented Interfaces:

Context, EntityQueryContext

public class UnboundedEntityContext<T extends RootEntity>
extends EntityContext<T>
implements EntityQueryContext

Field Summary

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

crudOperations, entityMeta, entitySupplier, entityType, eventPublisher, idGenerator, queryOperation, queryOperationSelector, tx, validator, version

Constructor Summary

Constructors

Constructor

Description

UnboundedEntityContext(EntityContextProvider entityContextProvider, java.lang.Class<T> entityType, java.lang.String tenantId, 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, java.util.function.BiFunction<java.lang.String,java.lang.Object,reactor.core.publisher.Mono> requestHandler)

Method Summary

Modifier and Type	Method	Description
<R extends RootEntity> AsyncEntityContext<R>	asAsyncEntityContext()
AsyncRootEntityQueryContext	asAsyncQueryContext()
<R extends RootEntity, K extends ChildEntity<R>> ChildEntityContext<R,K>	asChildContext()
ChildEntityQueryContext	asChildQueryContext()
<R extends RootEntity> RootEntityContext<R>	asRootContext()
RootEntityQueryContext	asRootQueryContext()
UnboundedEntityContext<T>	asUnboundedEntityContext()
T	create(java.lang.String id, Event<T> event)
T	delete(java.lang.String id)
java.util.Optional<T>	getEntityById(java.lang.String id)
ResultSet<Event>	getEntityEventsById(java.lang.String id, Query.PagingRequest pageRequest)
ExternalEntityQueryProvider	getEntityQueryProvider(java.lang.Class rootType)
ExternalEntityQueryProvider	getEntityQueryProvider(java.lang.Class rootType, java.lang.String tenantId)
T	rename(java.lang.String id, java.lang.String newId)
<T> reactor.core.publisher.Mono<T>	sendRequest(java.lang.String domainOwner, java.lang.String domainContext, java.lang.String version, java.lang.String serviceName, java.lang.Object req)
T	update(java.lang.String id, Event<T> event)

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

addEvent, getCrudOperations, getEntityMeta, getEntityProvider, getEventPublisher, getEvents, getQueryOperations, getTenantId, getTx, getVersion, setTx

Methods inherited from class java.lang.Object

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

Constructor Details

UnboundedEntityContext

public UnboundedEntityContext(EntityContextProvider entityContextProvider,
java.lang.Class<T> entityType,
java.lang.String tenantId,
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,
java.util.function.BiFunction<java.lang.String,java.lang.Object,reactor.core.publisher.Mono> requestHandler)

Method Details

create

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

Specified by:

create in class EntityContext<T extends RootEntity>

update

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

Specified by:

update in class EntityContext<T extends RootEntity>

delete

public T delete(java.lang.String id)

Specified by:

delete in class EntityContext<T extends RootEntity>

rename

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

Specified by:

rename in class EntityContext<T extends RootEntity>

asUnboundedEntityContext

public UnboundedEntityContext<T> asUnboundedEntityContext()

Overrides:

asUnboundedEntityContext in class EntityContext<T extends RootEntity>

getEntityById

public java.util.Optional<T> getEntityById(java.lang.String id)

Specified by:

getEntityById in interface EntityQueryContext<T extends RootEntity>

getEntityEventsById

public ResultSet<Event> getEntityEventsById(java.lang.String id,
Query.PagingRequest pageRequest)

Specified by:

getEntityEventsById in interface EntityQueryContext<T extends RootEntity>

getEntityQueryProvider

public ExternalEntityQueryProvider getEntityQueryProvider(java.lang.Class rootType,
java.lang.String tenantId)

Specified by:

getEntityQueryProvider in interface EntityQueryContext<T extends RootEntity>

Overrides:

getEntityQueryProvider in class EntityContext<T extends RootEntity>

getEntityQueryProvider

public ExternalEntityQueryProvider getEntityQueryProvider(java.lang.Class rootType)

Specified by:

getEntityQueryProvider in interface EntityQueryContext<T extends RootEntity>

Overrides:

getEntityQueryProvider in class EntityContext<T extends RootEntity>

asAsyncQueryContext

public AsyncRootEntityQueryContext asAsyncQueryContext()

Specified by:

asAsyncQueryContext in interface EntityQueryContext<T extends RootEntity>

asChildQueryContext

public ChildEntityQueryContext asChildQueryContext()

Specified by:

asChildQueryContext in interface EntityQueryContext<T extends RootEntity>

asRootQueryContext

public RootEntityQueryContext asRootQueryContext()

Specified by:

asRootQueryContext in interface EntityQueryContext<T extends RootEntity>

asRootContext

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

Specified by:

asRootContext in class EntityContext<T extends RootEntity>

asAsyncEntityContext

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

Specified by:

asAsyncEntityContext in class EntityContext<T extends RootEntity>

asChildContext

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

Specified by:

asChildContext in class EntityContext<T extends RootEntity>

sendRequest

public <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String domainOwner,
java.lang.String domainContext,
java.lang.String version,
java.lang.String serviceName,
java.lang.Object req)