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

Class ChannelFinder

java.lang.Object

com.google.cloud.spanner.spi.v1.ChannelFinder

@InternalApi
public final class ChannelFinder
extends Object

Finds a server for a request using location-aware routing metadata.

This component is per-database and maintains both recipe and range caches.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ChannelEndpoint	fillRoutingHint(CommitRequest.Builder reqBuilder)
ChannelEndpoint	fillRoutingHint(CommitRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
ChannelEndpoint	findServer(BeginTransactionRequest.Builder reqBuilder)
ChannelEndpoint	findServer(BeginTransactionRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
ChannelEndpoint	findServer(ExecuteSqlRequest.Builder reqBuilder)
ChannelEndpoint	findServer(ExecuteSqlRequest.Builder reqBuilder, boolean preferLeader)
ChannelEndpoint	findServer(ExecuteSqlRequest.Builder reqBuilder, boolean preferLeader, Predicate<String> excludedEndpoints)
ChannelEndpoint	findServer(ExecuteSqlRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
ChannelEndpoint	findServer(ReadRequest.Builder reqBuilder)
ChannelEndpoint	findServer(ReadRequest.Builder reqBuilder, boolean preferLeader)
ChannelEndpoint	findServer(ReadRequest.Builder reqBuilder, boolean preferLeader, Predicate<String> excludedEndpoints)
ChannelEndpoint	findServer(ReadRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
void	update(CacheUpdate update)
void	updateAsync(CacheUpdate update)

Methods inherited from class java.lang.Object

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

Constructor Details

ChannelFinder

public ChannelFinder(ChannelEndpointCache endpointCache)

ChannelFinder

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

Method Details

update

public void update(CacheUpdate update)

updateAsync

public void updateAsync(CacheUpdate update)

findServer

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder)

findServer

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder,
 Predicate<String> excludedEndpoints)

findServer

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder,
 boolean preferLeader)

findServer

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder,
 boolean preferLeader,
 Predicate<String> excludedEndpoints)

findServer

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder)

findServer

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder,
 Predicate<String> excludedEndpoints)

findServer

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder,
 boolean preferLeader)

findServer

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder,
 boolean preferLeader,
 Predicate<String> excludedEndpoints)

findServer

public ChannelEndpoint findServer(BeginTransactionRequest.Builder reqBuilder)

findServer

public ChannelEndpoint findServer(BeginTransactionRequest.Builder reqBuilder,
 Predicate<String> excludedEndpoints)

fillRoutingHint

public ChannelEndpoint fillRoutingHint(CommitRequest.Builder reqBuilder)

fillRoutingHint

public ChannelEndpoint fillRoutingHint(CommitRequest.Builder reqBuilder,
 Predicate<String> excludedEndpoints)