Module org.neo4j.bolt.connection.routed

Package org.neo4j.bolt.connection.routed.impl.cluster

Class RoutingTableRegistryImpl

java.lang.Object

org.neo4j.bolt.connection.routed.impl.cluster.RoutingTableRegistryImpl

All Implemented Interfaces:

RoutingTableRegistry

public class RoutingTableRegistryImpl
extends Object
implements RoutingTableRegistry

Constructor Summary

Constructors

Constructor	Description
RoutingTableRegistryImpl(Function<BoltServerAddress,BoltConnectionProvider> connectionProviderGetter, Rediscovery rediscovery, Clock clock, LoggingProvider logging, long routingTablePurgeDelayMs, Consumer<Set<BoltServerAddress>> addressesToRetainConsumer)

Method Summary

Modifier and Type	Method	Description
Set<BoltServerAddress>	allServers()
boolean	contains(DatabaseName databaseName)
CompletionStage<RoutingTableHandler>	ensureRoutingTable(SecurityPlan securityPlan, CompletableFuture<DatabaseName> databaseNameFuture, AccessMode mode, Set<String> rediscoveryBookmarks, String impersonatedUser, Supplier<CompletionStage<AuthToken>> authTokenStageSupplier, BoltProtocolVersion minVersion, String homeDatabaseHint)	Ensures the routing table for the database with given access mode.
Optional<RoutingTableHandler>	getRoutingTableHandler(DatabaseName databaseName)	Returns routing table handler for the given database name if it exists in the registry.
void	remove(DatabaseName databaseName)	Removes a routing table of the given database from registry.
void	removeAged()	Removes all routing tables that has been not used for a long time.

Methods inherited from class java.lang.Object

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

Constructor Details

RoutingTableRegistryImpl

public RoutingTableRegistryImpl(Function<BoltServerAddress,BoltConnectionProvider> connectionProviderGetter,
 Rediscovery rediscovery,
 Clock clock,
 LoggingProvider logging,
 long routingTablePurgeDelayMs,
 Consumer<Set<BoltServerAddress>> addressesToRetainConsumer)

Method Details

ensureRoutingTable

public CompletionStage<RoutingTableHandler> ensureRoutingTable(SecurityPlan securityPlan,
 CompletableFuture<DatabaseName> databaseNameFuture,
 AccessMode mode,
 Set<String> rediscoveryBookmarks,
 String impersonatedUser,
 Supplier<CompletionStage<AuthToken>> authTokenStageSupplier,
 BoltProtocolVersion minVersion,
 String homeDatabaseHint)

Description copied from interface: RoutingTableRegistry

Ensures the routing table for the database with given access mode. For server version lower than 4.0, the database name will be ignored while refreshing routing table.

Specified by:

ensureRoutingTable in interface RoutingTableRegistry

Returns:

The future of a new routing table handler.

allServers

public Set<BoltServerAddress> allServers()

Specified by:

allServers in interface RoutingTableRegistry

Returns:

all servers in the registry

remove

public void remove(DatabaseName databaseName)

Description copied from interface: RoutingTableRegistry

Removes a routing table of the given database from registry.

Specified by:

remove in interface RoutingTableRegistry

removeAged

public void removeAged()

Description copied from interface: RoutingTableRegistry

Removes all routing tables that has been not used for a long time.

Specified by:

removeAged in interface RoutingTableRegistry

getRoutingTableHandler

public Optional<RoutingTableHandler> getRoutingTableHandler(DatabaseName databaseName)

Description copied from interface: RoutingTableRegistry

Returns routing table handler for the given database name if it exists in the registry.

Specified by:

getRoutingTableHandler in interface RoutingTableRegistry

Parameters:

databaseName - the database name

Returns:

the routing table handler for the requested database name

contains

public boolean contains(DatabaseName databaseName)