Package com.linkedin.alpini.router.api

Class ScatterGatherMode

java.lang.Object

com.linkedin.alpini.router.api.ScatterGatherMode

Direct Known Subclasses:

VeniceDelegateMode

public abstract class ScatterGatherMode
extends Object

Created by acurtis on 6/20/17.

Field Summary

Fields

Modifier and Type	Field	Description
static final ScatterGatherMode	BROADCAST_BY_PARTITION	Sends request to every partition.
static final ScatterGatherMode	BROADCAST_BY_PRIMARY_HOST	Sends request to the first host found for every partition, grouped by host.
static final ScatterGatherMode	GROUP_BY_GREEDY_HOST	Sends request for minimal group of hosts.
static final ScatterGatherMode	GROUP_BY_PARTITION	One request per partition.
static final ScatterGatherMode	GROUP_BY_PRIMARY_HOST	Sends request for first host for each partition in request, grouped by host

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ScatterGatherMode(String name, boolean broadcast)

Method Summary

Modifier and Type	Method	Description
final ScatterGatherMode	asBroadcast()
final ScatterGatherMode	asScatter()
boolean	equals(Object o)
int	hashCode()
<H, P extends ResourcePath<K>, K, R> CompletionStage<Scatter<H,P,K>>	scatter(Scatter<H,P,K> scatter, String requestMethod, String resourceName, AsyncPartitionFinder<K> partitionFinder, HostFinder<H,R> hostFinder, HostHealthMonitor<H> hostHealthMonitor, R roles)
<H, P extends ResourcePath<K>, K, R> Scatter<H,P,K>	scatter(Scatter<H,P,K> scatter, String requestMethod, String resourceName, PartitionFinder<K> partitionFinder, HostFinder<H,R> hostFinder, HostHealthMonitor<H> hostHealthMonitor, R roles)	Deprecated.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

BROADCAST_BY_PARTITION

public static final ScatterGatherMode BROADCAST_BY_PARTITION

Sends request to every partition.

BROADCAST_BY_PRIMARY_HOST

public static final ScatterGatherMode BROADCAST_BY_PRIMARY_HOST

Sends request to the first host found for every partition, grouped by host.

GROUP_BY_PARTITION

public static final ScatterGatherMode GROUP_BY_PARTITION

One request per partition.

GROUP_BY_PRIMARY_HOST

public static final ScatterGatherMode GROUP_BY_PRIMARY_HOST

Sends request for first host for each partition in request, grouped by host

GROUP_BY_GREEDY_HOST

public static final ScatterGatherMode GROUP_BY_GREEDY_HOST

Sends request for minimal group of hosts. When multiple hosts can serve the same partition, try to use maximal munch to select the smallest number of hosts to handle the partitions.

Constructor Details

ScatterGatherMode

protected ScatterGatherMode(@Nonnull
 String name,
 boolean broadcast)

Method Details

asBroadcast

@Nonnull
public final ScatterGatherMode asBroadcast()

asScatter

@Nonnull
public final ScatterGatherMode asScatter()

scatter

@Deprecated
@Nonnull
public <H,
P extends ResourcePath<K>,
K,
R>
Scatter<H,P,K> scatter(@Nonnull
 Scatter<H,P,K> scatter,
 @Nonnull
 String requestMethod,
 @Nonnull
 String resourceName,
 @Nonnull
 PartitionFinder<K> partitionFinder,
 @Nonnull
 HostFinder<H,R> hostFinder,
 @Nonnull
 HostHealthMonitor<H> hostHealthMonitor,
 @Nonnull
 R roles)
                throws RouterException

Deprecated.

Deprecated method is compatible to old method signature.

Throws:

RouterException

scatter

@Nonnull
public <H,
P extends ResourcePath<K>,
K,
R>
CompletionStage<Scatter<H,P,K>> scatter(@Nonnull
 Scatter<H,P,K> scatter,
 @Nonnull
 String requestMethod,
 @Nonnull
 String resourceName,
 @Nonnull
 AsyncPartitionFinder<K> partitionFinder,
 @Nonnull
 HostFinder<H,R> hostFinder,
 @Nonnull
 HostHealthMonitor<H> hostHealthMonitor,
 @Nonnull
 R roles)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object