Class ChannelFinder (6.116.0)

public final class ChannelFinder

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

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

Inheritance

java.lang.Object > ChannelFinder

Constructors

ChannelFinder(ChannelEndpointCache endpointCache)

public ChannelFinder(ChannelEndpointCache endpointCache)
Parameter
Name Description
endpointCache ChannelEndpointCache

ChannelFinder(ChannelEndpointCache endpointCache, EndpointLifecycleManager lifecycleManager)

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

Methods

fillRoutingHint(CommitRequest.Builder reqBuilder)

public ChannelEndpoint fillRoutingHint(CommitRequest.Builder reqBuilder)
Parameter
Name Description
reqBuilder CommitRequest.Builder
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint fillRoutingHint(CommitRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder CommitRequest.Builder
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

findServer(BeginTransactionRequest.Builder reqBuilder)

public ChannelEndpoint findServer(BeginTransactionRequest.Builder reqBuilder)
Parameter
Name Description
reqBuilder BeginTransactionRequest.Builder
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint findServer(BeginTransactionRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder BeginTransactionRequest.Builder
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

findServer(ExecuteSqlRequest.Builder reqBuilder)

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder)
Parameter
Name Description
reqBuilder ExecuteSqlRequest.Builder
Returns
Type Description
ChannelEndpoint

findServer(ExecuteSqlRequest.Builder reqBuilder, boolean preferLeader)

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder, boolean preferLeader)
Parameters
Name Description
reqBuilder ExecuteSqlRequest.Builder
preferLeader boolean
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder, boolean preferLeader, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder ExecuteSqlRequest.Builder
preferLeader boolean
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint findServer(ExecuteSqlRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder ExecuteSqlRequest.Builder
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

findServer(ReadRequest.Builder reqBuilder)

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder)
Parameter
Name Description
reqBuilder ReadRequest.Builder
Returns
Type Description
ChannelEndpoint

findServer(ReadRequest.Builder reqBuilder, boolean preferLeader)

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder, boolean preferLeader)
Parameters
Name Description
reqBuilder ReadRequest.Builder
preferLeader boolean
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder, boolean preferLeader, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder ReadRequest.Builder
preferLeader boolean
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

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

public ChannelEndpoint findServer(ReadRequest.Builder reqBuilder, Predicate<String> excludedEndpoints)
Parameters
Name Description
reqBuilder ReadRequest.Builder
excludedEndpoints Predicate<String>
Returns
Type Description
ChannelEndpoint

update(CacheUpdate update)

public void update(CacheUpdate update)
Parameter
Name Description
update CacheUpdate

updateAsync(CacheUpdate update)

public void updateAsync(CacheUpdate update)
Parameter
Name Description
update CacheUpdate