Module org.neo4j.bolt.connection.routed

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

Class RoutingTableHandlerImpl

java.lang.Object

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

All Implemented Interfaces:

RoutingTableHandler

public class RoutingTableHandlerImpl
extends Object
implements RoutingTableHandler

Constructor Summary

Constructors

Constructor	Description
RoutingTableHandlerImpl(RoutingTable routingTable, Rediscovery rediscovery, Function<BoltServerAddress,BoltConnectionProvider> connectionProviderGetter, RoutingTableRegistry routingTableRegistry, LoggingProvider logging, long routingTablePurgeDelayMs, Consumer<Set<BoltServerAddress>> addressesToRetainConsumer)

Method Summary

Modifier and Type	Method	Description
CompletionStage<RoutingTable>	ensureRoutingTable(SecurityPlan securityPlan, AccessMode mode, Set<String> rediscoveryBookmarks, Supplier<CompletionStage<AuthToken>> authTokenStageSupplier, BoltProtocolVersion minVersion)
boolean	isRoutingTableAged()
boolean	isStaleFor(AccessMode mode)
void	onConnectionFailure(BoltServerAddress address)
void	onWriteFailure(BoltServerAddress address)
RoutingTable	routingTable()
Set<BoltServerAddress>	servers()
CompletionStage<RoutingTable>	updateRoutingTable(ClusterCompositionLookupResult compositionLookupResult)

Methods inherited from class java.lang.Object

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

Constructor Details

RoutingTableHandlerImpl

public RoutingTableHandlerImpl(RoutingTable routingTable,
 Rediscovery rediscovery,
 Function<BoltServerAddress,BoltConnectionProvider> connectionProviderGetter,
 RoutingTableRegistry routingTableRegistry,
 LoggingProvider logging,
 long routingTablePurgeDelayMs,
 Consumer<Set<BoltServerAddress>> addressesToRetainConsumer)

Method Details

onConnectionFailure

public void onConnectionFailure(BoltServerAddress address)

onWriteFailure

public void onWriteFailure(BoltServerAddress address)

ensureRoutingTable

public CompletionStage<RoutingTable> ensureRoutingTable(SecurityPlan securityPlan,
 AccessMode mode,
 Set<String> rediscoveryBookmarks,
 Supplier<CompletionStage<AuthToken>> authTokenStageSupplier,
 BoltProtocolVersion minVersion)

Specified by:

ensureRoutingTable in interface RoutingTableHandler

updateRoutingTable

public CompletionStage<RoutingTable> updateRoutingTable(ClusterCompositionLookupResult compositionLookupResult)

Specified by:

updateRoutingTable in interface RoutingTableHandler

servers

public Set<BoltServerAddress> servers()

Specified by:

servers in interface RoutingTableHandler

isRoutingTableAged

public boolean isRoutingTableAged()

Specified by:

isRoutingTableAged in interface RoutingTableHandler

routingTable

public RoutingTable routingTable()

Specified by:

routingTable in interface RoutingTableHandler

isStaleFor

public boolean isStaleFor(AccessMode mode)

Specified by:

isStaleFor in interface RoutingTableHandler