Package io.smallrye.graphql.execution.datafetcher

Class AbstractDataFetcher<K,T>

java.lang.Object

io.smallrye.graphql.execution.datafetcher.AbstractDataFetcher<K,T>

Type Parameters:

K -

T -

All Implemented Interfaces:

graphql.schema.DataFetcher<T>, PlugableBatchableDataFetcher<K,T>, PlugableDataFetcher<T>, org.dataloader.BatchLoaderWithContext<K,T>

Direct Known Subclasses:

AbstractAsyncDataFetcher, AbstractStreamingDataFetcher, DefaultDataFetcher

public abstract class AbstractDataFetcher<K,T>
extends Object
implements PlugableBatchableDataFetcher<K,T>

The abstract data fetcher

Author:

Phillip Kruger (phillip.kruger@redhat.com)

Field Summary

Fields

Modifier and Type	Field	Description
protected ArgumentHelper	argumentHelper
protected BatchLoaderHelper	batchLoaderHelper
protected ErrorResultHelper	errorResultHelper
protected EventEmitter	eventEmitter
protected FieldHelper	fieldHelper
protected LinkedBlockingQueue<Long>	measurementIds
protected MetricsEmitter	metricsEmitter
protected io.smallrye.graphql.schema.model.Operation	operation
protected OperationInvoker	operationInvoker
protected io.smallrye.graphql.schema.model.Type	type

Constructor Summary

Constructors

Constructor	Description
AbstractDataFetcher(io.smallrye.graphql.schema.model.Operation operation, io.smallrye.graphql.schema.model.Type type)

Method Summary

Modifier and Type	Method	Description
T	get(graphql.schema.DataFetchingEnvironment dfe)
protected abstract <T> T	invokeAndTransform(io.smallrye.graphql.api.Context c, graphql.schema.DataFetchingEnvironment dfe, graphql.execution.DataFetcherResult.Builder<Object> resultBuilder, Object[] transformedArguments)
protected abstract CompletionStage<List<T>>	invokeBatch(graphql.schema.DataFetchingEnvironment dfe, Object[] arguments)
protected abstract <T> T	invokeFailure(graphql.execution.DataFetcherResult.Builder<Object> resultBuilder)
CompletionStage<List<T>>	load(List<K> keys, org.dataloader.BatchLoaderEnvironment ble)

Methods inherited from class java.lang.Object

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

Field Details

operation

protected io.smallrye.graphql.schema.model.Operation operation

type

protected io.smallrye.graphql.schema.model.Type type

fieldHelper

protected FieldHelper fieldHelper

operationInvoker

protected OperationInvoker operationInvoker

errorResultHelper

protected ErrorResultHelper errorResultHelper

argumentHelper

protected ArgumentHelper argumentHelper

eventEmitter

protected EventEmitter eventEmitter

metricsEmitter

protected MetricsEmitter metricsEmitter

batchLoaderHelper

protected BatchLoaderHelper batchLoaderHelper

measurementIds

protected LinkedBlockingQueue<Long> measurementIds

Constructor Details

AbstractDataFetcher

public AbstractDataFetcher(io.smallrye.graphql.schema.model.Operation operation,
 io.smallrye.graphql.schema.model.Type type)

Method Details

get

public T get(graphql.schema.DataFetchingEnvironment dfe)
      throws Exception

Specified by:

get in interface graphql.schema.DataFetcher<K>

Throws:

Exception

load

public CompletionStage<List<T>> load(List<K> keys,
 org.dataloader.BatchLoaderEnvironment ble)

Specified by:

load in interface org.dataloader.BatchLoaderWithContext<K,T>

invokeAndTransform

protected abstract <T> T invokeAndTransform(io.smallrye.graphql.api.Context c,
 graphql.schema.DataFetchingEnvironment dfe,
 graphql.execution.DataFetcherResult.Builder<Object> resultBuilder,
 Object[] transformedArguments)
                                     throws AbstractDataFetcherException,
Exception

Throws:

AbstractDataFetcherException

Exception

invokeFailure

protected abstract <T> T invokeFailure(graphql.execution.DataFetcherResult.Builder<Object> resultBuilder)

invokeBatch

protected abstract CompletionStage<List<T>> invokeBatch(graphql.schema.DataFetchingEnvironment dfe,
 Object[] arguments)