Package org.dotwebstack.framework.backend.postgres

Class PostgresBackendLoader

java.lang.Object

org.dotwebstack.framework.backend.postgres.PostgresBackendLoader

All Implemented Interfaces:

BackendLoader

public class PostgresBackendLoader
extends Object
implements BackendLoader

Field Summary

Fields inherited from interface org.dotwebstack.framework.core.backend.BackendLoader

NILL_MAP

Constructor Summary

Constructors

Constructor	Description
PostgresBackendLoader(PostgresClient postgresClient)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>>	batchLoadMany(CollectionBatchRequest collectionBatchRequest, RequestContext requestContext)
reactor.core.publisher.Flux<reactor.util.function.Tuple2<Map<String,Object>,Map<String,Object>>>	batchLoadSingle(BatchRequest batchRequest, RequestContext requestContext)
reactor.core.publisher.Flux<Map<String,Object>>	loadMany(CollectionRequest collectionRequest, RequestContext requestContext)
reactor.core.publisher.Mono<Map<String,Object>>	loadSingle(ObjectRequest objectRequest, RequestContext requestContext)

Methods inherited from class java.lang.Object

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

Constructor Details

PostgresBackendLoader

public PostgresBackendLoader(PostgresClient postgresClient)

Method Details

loadSingle

public reactor.core.publisher.Mono<Map<String,Object>> loadSingle(ObjectRequest objectRequest,
 RequestContext requestContext)

Specified by:

loadSingle in interface BackendLoader

loadMany

public reactor.core.publisher.Flux<Map<String,Object>> loadMany(CollectionRequest collectionRequest,
 RequestContext requestContext)

Specified by:

loadMany in interface BackendLoader

batchLoadMany

public reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>> batchLoadMany(CollectionBatchRequest collectionBatchRequest,
 RequestContext requestContext)

Specified by:

batchLoadMany in interface BackendLoader

batchLoadSingle

public reactor.core.publisher.Flux<reactor.util.function.Tuple2<Map<String,Object>,Map<String,Object>>> batchLoadSingle(BatchRequest batchRequest,
 RequestContext requestContext)

Specified by:

batchLoadSingle in interface BackendLoader