Package com.google.cloud.spanner.spi.v1

Class KeyRangeCache

java.lang.Object

com.google.cloud.spanner.spi.v1.KeyRangeCache

@InternalApi
public final class KeyRangeCache
extends Object

Cache for routing information used by location-aware routing.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	KeyRangeCache.RangeMode	Determines how to handle ranges that span multiple splits.

Constructor Summary

Constructors

Constructor	Description
KeyRangeCache(ChannelEndpointCache endpointCache)
KeyRangeCache(ChannelEndpointCache endpointCache, com.google.cloud.spanner.spi.v1.EndpointLifecycleManager lifecycleManager)

Method Summary

Modifier and Type	Method	Description
void	addRanges(CacheUpdate cacheUpdate)	Applies cache updates.
void	clear()
String	debugString()
ChannelEndpoint	fillRoutingHint(boolean preferLeader, KeyRangeCache.RangeMode rangeMode, DirectedReadOptions directedReadOptions, RoutingHint.Builder hintBuilder)	Fills routing hint and returns the server to use, or null if no routing decision can be made.
ChannelEndpoint	fillRoutingHint(boolean preferLeader, KeyRangeCache.RangeMode rangeMode, DirectedReadOptions directedReadOptions, RoutingHint.Builder hintBuilder, Predicate<String> excludedEndpoints)
void	shrinkTo(int newSize)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

KeyRangeCache

public KeyRangeCache(ChannelEndpointCache endpointCache)

KeyRangeCache

public KeyRangeCache(ChannelEndpointCache endpointCache,
 @Nullable
 com.google.cloud.spanner.spi.v1.EndpointLifecycleManager lifecycleManager)

Method Details

addRanges

public void addRanges(CacheUpdate cacheUpdate)

Applies cache updates. Tablets are processed inside group updates.

fillRoutingHint

public ChannelEndpoint fillRoutingHint(boolean preferLeader,
 KeyRangeCache.RangeMode rangeMode,
 DirectedReadOptions directedReadOptions,
 RoutingHint.Builder hintBuilder)

Fills routing hint and returns the server to use, or null if no routing decision can be made.

fillRoutingHint

public ChannelEndpoint fillRoutingHint(boolean preferLeader,
 KeyRangeCache.RangeMode rangeMode,
 DirectedReadOptions directedReadOptions,
 RoutingHint.Builder hintBuilder,
 Predicate<String> excludedEndpoints)

clear

public void clear()

size

public int size()

shrinkTo

public void shrinkTo(int newSize)

debugString

public String debugString()