Package com.linkedin.alpini.router.api

Class ScatterGatherHelper.Builder<H,P extends ResourcePath<K>,K,R,HTTP_REQUEST extends BasicRequest,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>

java.lang.Object

com.linkedin.alpini.router.api.ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>

Enclosing class:

ScatterGatherHelper<H,P extends ResourcePath<K>,K,R,BASIC_HTTP_REQUEST extends BasicRequest,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>

public static class ScatterGatherHelper.Builder<H,P extends ResourcePath<K>,K,R,HTTP_REQUEST extends BasicRequest,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>
extends Object

Method Summary

Modifier and Type	Method	Description
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	addBeforeChunkAggregator(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	addBeforeHttpRequestHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	addBeforeHttpServerCodec(String name, Supplier<?> supplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	addBeforeIdleStateHandler(String name, Supplier<? extends io.netty.channel.ChannelHandler> supplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	broadcastMode(ScatterGatherMode broadcastMode)
ScatterGatherHelper<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	build()
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	defaultTimeoutMillis(long defaultTimeoutMillis)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	disableRetryOnTimeout(BooleanSupplier disableRetryOnTimeout)
<DISPATCH_REQUEST extends BasicRequest, DISPATCH_RESPONSE, DISPATCH_RESPONSE_STATUS> ScatterGatherHelper.Builder<H,P,K,R,DISPATCH_REQUEST,DISPATCH_RESPONSE,DISPATCH_RESPONSE_STATUS>	dispatchHandler(PartitionDispatchHandler<H,P,K,DISPATCH_REQUEST,DISPATCH_RESPONSE,DISPATCH_RESPONSE_STATUS> dispatchHandler)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	dispatchMinimumMillis(long dispatchMinimumMillis)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	enableRetryRequestAlwaysUseADifferentHost(boolean enableRetryRequestAlwaysUseADifferentHost)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	enableRetryRequestAlwaysUseADifferentHost(BooleanSupplier enableRetryRequestAlwaysUseADifferentHost)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	enableStackTraceResponseForException(boolean enableStackTraceResponseForException)
<HOST> ScatterGatherHelper.Builder<HOST,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	hostFinder(HostFinder<HOST,R> hostFinder)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	hostHealthMonitor(HostHealthMonitor<H> hostHealthMonitor)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	longTailMinimumMillis(long longTailMinimumMillis)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	longTailRetrySupplier(LongTailRetrySupplier<P,K> longTailRetrySupplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	metricsProvider(BiFunction<Headers,Metrics,Headers> metricsDecorator)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	metricsProvider(Function<HTTP_REQUEST,Metrics> metricsProvider)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	partitionFinder(AsyncPartitionFinder<K> partitionFinder)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	partitionFinder(PartitionFinder<K> partitionFinder)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	partitionFinder(PartitionFinder<K> partitionFinder, Executor executor)
<PATH extends ResourcePath<KEY>, KEY> ScatterGatherHelper.Builder<H,PATH,KEY,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	pathParser(ResourcePathParser<PATH,KEY> pathParser)
<PATH extends ResourcePath<KEY>, KEY> ScatterGatherHelper.Builder<H,PATH,KEY,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	pathParserExtended(ExtendedResourcePathParser<PATH,KEY,HTTP_REQUEST> pathParser)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	requestTimeout(Function<Headers,Long> requestTimeout)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	responseAggregatorFactory(ResponseAggregatorFactory<HTTP_REQUEST,HTTP_RESPONSE> responseFactory)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	responseMetrics(Function<Headers,Metrics> responseMetrics)
<ROLE> ScatterGatherHelper.Builder<H,P,K,ROLE,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	roleFinder(RoleFinder<ROLE> roleFinder)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	scatterGatherStatsProvider(Function<P,ScatterGatherStats> scatterGatherStatsProvider)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	scatterMode(ScatterGatherMode scatterMode)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	setIsReqRedirectionAllowedForQuery(BooleanSupplier isReqRedirectionAllowedForQuery)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	setRequestCollectionSupplier(Supplier<Collection> requestCollectionSupplier)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	setRequestRetriableChecker(RequestRetriableChecker<P,R,HTTP_RESPONSE_STATUS> requestRetriableChecker)
ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS>	setSuccessCodePredicate(IntPredicate successCodePredicate)

Methods inherited from class java.lang.Object

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

Method Details

pathParser

public <PATH extends ResourcePath<KEY>,
KEY>
ScatterGatherHelper.Builder<H,PATH,KEY,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> pathParser(@Nonnull
 ResourcePathParser<PATH,KEY> pathParser)

pathParserExtended

public <PATH extends ResourcePath<KEY>,
KEY>
ScatterGatherHelper.Builder<H,PATH,KEY,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> pathParserExtended(@Nonnull
 ExtendedResourcePathParser<PATH,KEY,HTTP_REQUEST> pathParser)

roleFinder

public <ROLE>
ScatterGatherHelper.Builder<H,P,K,ROLE,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> roleFinder(@Nonnull
 RoleFinder<ROLE> roleFinder)

hostFinder

public <HOST>
ScatterGatherHelper.Builder<HOST,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> hostFinder(@Nonnull
 HostFinder<HOST,R> hostFinder)

partitionFinder

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> partitionFinder(@Nonnull
 AsyncPartitionFinder<K> partitionFinder)

partitionFinder

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> partitionFinder(@Nonnull
 PartitionFinder<K> partitionFinder)

partitionFinder

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> partitionFinder(@Nonnull
 PartitionFinder<K> partitionFinder,
 Executor executor)

hostHealthMonitor

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> hostHealthMonitor(@Nonnull
 HostHealthMonitor<H> hostHealthMonitor)

broadcastMode

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> broadcastMode(@Nonnull
 ScatterGatherMode broadcastMode)

scatterMode

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> scatterMode(@Nonnull
 ScatterGatherMode scatterMode)

dispatchHandler

public <DISPATCH_REQUEST extends BasicRequest,
DISPATCH_RESPONSE,
DISPATCH_RESPONSE_STATUS>
ScatterGatherHelper.Builder<H,P,K,R,DISPATCH_REQUEST,DISPATCH_RESPONSE,DISPATCH_RESPONSE_STATUS> dispatchHandler(@Nonnull
 PartitionDispatchHandler<H,P,K,DISPATCH_REQUEST,DISPATCH_RESPONSE,DISPATCH_RESPONSE_STATUS> dispatchHandler)

responseAggregatorFactory

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> responseAggregatorFactory(@Nonnull
 ResponseAggregatorFactory<HTTP_REQUEST,HTTP_RESPONSE> responseFactory)

requestTimeout

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> requestTimeout(@Nonnull
 Function<Headers,Long> requestTimeout)

longTailRetrySupplier

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> longTailRetrySupplier(@Nonnull
 LongTailRetrySupplier<P,K> longTailRetrySupplier)

metricsProvider

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> metricsProvider(@Nonnull
 Function<HTTP_REQUEST,Metrics> metricsProvider)

metricsProvider

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> metricsProvider(@Nonnull
 BiFunction<Headers,Metrics,Headers> metricsDecorator)

responseMetrics

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> responseMetrics(@Nonnull
 Function<Headers,Metrics> responseMetrics)

scatterGatherStatsProvider

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> scatterGatherStatsProvider(@Nonnull
 Function<P,ScatterGatherStats> scatterGatherStatsProvider)

defaultTimeoutMillis

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> defaultTimeoutMillis(long defaultTimeoutMillis)

dispatchMinimumMillis

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> dispatchMinimumMillis(long dispatchMinimumMillis)

longTailMinimumMillis

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> longTailMinimumMillis(long longTailMinimumMillis)

enableStackTraceResponseForException

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> enableStackTraceResponseForException(boolean enableStackTraceResponseForException)

enableRetryRequestAlwaysUseADifferentHost

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> enableRetryRequestAlwaysUseADifferentHost(boolean enableRetryRequestAlwaysUseADifferentHost)

enableRetryRequestAlwaysUseADifferentHost

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> enableRetryRequestAlwaysUseADifferentHost(@Nonnull
 BooleanSupplier enableRetryRequestAlwaysUseADifferentHost)

disableRetryOnTimeout

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> disableRetryOnTimeout(@Nonnull
 BooleanSupplier disableRetryOnTimeout)

setIsReqRedirectionAllowedForQuery

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> setIsReqRedirectionAllowedForQuery(@Nonnull
 BooleanSupplier isReqRedirectionAllowedForQuery)

setRequestCollectionSupplier

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> setRequestCollectionSupplier(@Nonnull
 Supplier<Collection> requestCollectionSupplier)

setSuccessCodePredicate

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> setSuccessCodePredicate(@Nonnull
 IntPredicate successCodePredicate)

setRequestRetriableChecker

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> setRequestRetriableChecker(@Nonnull
 RequestRetriableChecker<P,R,HTTP_RESPONSE_STATUS> requestRetriableChecker)

addBeforeHttpServerCodec

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> addBeforeHttpServerCodec(String name,
 Supplier<?> supplier)

addBeforeChunkAggregator

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> addBeforeChunkAggregator(String name,
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

addBeforeIdleStateHandler

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> addBeforeIdleStateHandler(String name,
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

addBeforeHttpRequestHandler

public ScatterGatherHelper.Builder<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> addBeforeHttpRequestHandler(String name,
 Supplier<? extends io.netty.channel.ChannelHandler> supplier)

build

public ScatterGatherHelper<H,P,K,R,HTTP_REQUEST,HTTP_RESPONSE,HTTP_RESPONSE_STATUS> build()