Module org.neo4j.bolt.connection.netty

Package org.neo4j.bolt.connection.netty.impl

Class BoltConnectionImpl

java.lang.Object

org.neo4j.bolt.connection.netty.impl.BoltConnectionImpl

All Implemented Interfaces:

BoltConnection

public final class BoltConnectionImpl
extends Object
implements BoltConnection

Constructor Summary

Constructors

Constructor	Description
BoltConnectionImpl(BoltProtocol protocol, Connection connection, io.netty.channel.EventLoop eventLoop, AuthToken authToken, CompletableFuture<Long> latestAuthMillisFuture, RoutingContext routingContext, Clock clock, LoggingProvider logging, ValueFactory valueFactory)

Method Summary

Modifier and Type	Method	Description
CompletionStage<AuthInfo>	authInfo()
CompletionStage<BoltConnection>	beginTransaction(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, TransactionType transactionType, Duration txTimeout, Map<String,Value> txMetadata, String txType, NotificationConfig notificationConfig)
CompletionStage<BoltConnection>	clear()
CompletionStage<Void>	close()
CompletionStage<BoltConnection>	commit()
Optional<Duration>	defaultReadTimeout()
CompletionStage<BoltConnection>	discard(long qid, long number)
CompletionStage<Void>	flush(ResponseHandler handler)
CompletionStage<Void>	forceClose(String reason)
CompletionStage<BoltConnection>	logoff()
CompletionStage<BoltConnection>	logon(AuthToken authToken)
<T> CompletionStage<T>	onLoop(Supplier<T> supplier)
BoltProtocolVersion	protocolVersion()
CompletionStage<BoltConnection>	pull(long qid, long request)
CompletionStage<BoltConnection>	reset()
CompletionStage<BoltConnection>	rollback()
CompletionStage<BoltConnection>	route(DatabaseName databaseName, String impersonatedUser, Set<String> bookmarks)
CompletionStage<BoltConnection>	run(String query, Map<String,Value> parameters)
CompletionStage<BoltConnection>	runInAutoCommitTransaction(DatabaseName databaseName, AccessMode accessMode, String impersonatedUser, Set<String> bookmarks, String query, Map<String,Value> parameters, Duration txTimeout, Map<String,Value> txMetadata, NotificationConfig notificationConfig)
BoltServerAddress	serverAddress()
String	serverAgent()
boolean	serverSideRoutingEnabled()
CompletionStage<Void>	setReadTimeout(Duration duration)
BoltConnectionState	state()
CompletionStage<BoltConnection>	telemetry(TelemetryApi telemetryApi)
boolean	telemetrySupported()

Methods inherited from class java.lang.Object

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

Constructor Details

BoltConnectionImpl

public BoltConnectionImpl(BoltProtocol protocol,
 Connection connection,
 io.netty.channel.EventLoop eventLoop,
 AuthToken authToken,
 CompletableFuture<Long> latestAuthMillisFuture,
 RoutingContext routingContext,
 Clock clock,
 LoggingProvider logging,
 ValueFactory valueFactory)

Method Details

onLoop

public <T> CompletionStage<T> onLoop(Supplier<T> supplier)

Specified by:

onLoop in interface BoltConnection

route

public CompletionStage<BoltConnection> route(DatabaseName databaseName,
 String impersonatedUser,
 Set<String> bookmarks)

Specified by:

route in interface BoltConnection

beginTransaction

public CompletionStage<BoltConnection> beginTransaction(DatabaseName databaseName,
 AccessMode accessMode,
 String impersonatedUser,
 Set<String> bookmarks,
 TransactionType transactionType,
 Duration txTimeout,
 Map<String,Value> txMetadata,
 String txType,
 NotificationConfig notificationConfig)

Specified by:

beginTransaction in interface BoltConnection

runInAutoCommitTransaction

public CompletionStage<BoltConnection> runInAutoCommitTransaction(DatabaseName databaseName,
 AccessMode accessMode,
 String impersonatedUser,
 Set<String> bookmarks,
 String query,
 Map<String,Value> parameters,
 Duration txTimeout,
 Map<String,Value> txMetadata,
 NotificationConfig notificationConfig)

Specified by:

runInAutoCommitTransaction in interface BoltConnection

run

public CompletionStage<BoltConnection> run(String query,
 Map<String,Value> parameters)

Specified by:

run in interface BoltConnection

pull

public CompletionStage<BoltConnection> pull(long qid,
 long request)

Specified by:

pull in interface BoltConnection

discard

public CompletionStage<BoltConnection> discard(long qid,
 long number)

Specified by:

discard in interface BoltConnection

commit

public CompletionStage<BoltConnection> commit()

Specified by:

commit in interface BoltConnection

rollback

public CompletionStage<BoltConnection> rollback()

Specified by:

rollback in interface BoltConnection

reset

public CompletionStage<BoltConnection> reset()

Specified by:

reset in interface BoltConnection

logoff

public CompletionStage<BoltConnection> logoff()

Specified by:

logoff in interface BoltConnection

logon

public CompletionStage<BoltConnection> logon(AuthToken authToken)

Specified by:

logon in interface BoltConnection

telemetry

public CompletionStage<BoltConnection> telemetry(TelemetryApi telemetryApi)

Specified by:

telemetry in interface BoltConnection

clear

public CompletionStage<BoltConnection> clear()

Specified by:

clear in interface BoltConnection

flush

public CompletionStage<Void> flush(ResponseHandler handler)

Specified by:

flush in interface BoltConnection

forceClose

public CompletionStage<Void> forceClose(String reason)

Specified by:

forceClose in interface BoltConnection

close

public CompletionStage<Void> close()

Specified by:

close in interface BoltConnection

setReadTimeout

public CompletionStage<Void> setReadTimeout(Duration duration)

Specified by:

setReadTimeout in interface BoltConnection

state

public BoltConnectionState state()

Specified by:

state in interface BoltConnection

authInfo

public CompletionStage<AuthInfo> authInfo()

Specified by:

authInfo in interface BoltConnection

serverAgent

public String serverAgent()

Specified by:

serverAgent in interface BoltConnection

serverAddress

public BoltServerAddress serverAddress()

Specified by:

serverAddress in interface BoltConnection

protocolVersion

public BoltProtocolVersion protocolVersion()

Specified by:

protocolVersion in interface BoltConnection

telemetrySupported

public boolean telemetrySupported()

Specified by:

telemetrySupported in interface BoltConnection

serverSideRoutingEnabled

public boolean serverSideRoutingEnabled()

Specified by:

serverSideRoutingEnabled in interface BoltConnection

defaultReadTimeout

public Optional<Duration> defaultReadTimeout()

Specified by:

defaultReadTimeout in interface BoltConnection