Module org.neo4j.driver

Package org.neo4j.driver.internal.async

Class NetworkSession

java.lang.Object

org.neo4j.driver.internal.async.NetworkSession

Direct Known Subclasses:

LeakLoggingNetworkSession

public class NetworkSession
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NetworkSession.RunRxResponseHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final Logger	log

Constructor Summary

Constructors

Constructor

Description

NetworkSession(DriverBoltConnectionSource boltConnectionProvider, RetryLogic retryLogic, org.neo4j.bolt.connection.DatabaseName databaseName, AccessMode mode, Set<Bookmark> bookmarks, String impersonatedUser, long fetchSize, Logging logging, BookmarkManager bookmarkManager, NotificationConfig notificationConfig, AuthToken overrideAuthToken, boolean telemetryDisabled, AuthTokenManager authTokenManager, HomeDatabaseCache homeDatabaseCache, DriverObservationProvider observationProvider)

Method Summary

Modifier and Type	Method	Description
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(AccessMode mode, TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, boolean flush, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(AccessMode mode, TransactionConfig config, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(TransactionConfig config, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<Void>	closeAsync(Observation parentObservation)
CompletionStage<DriverBoltConnection>	connectionAsync()
protected CompletionStage<Boolean>	currentConnectionIsOpen()
boolean	isOpen()
Set<Bookmark>	lastBookmarks()
CompletionStage<Void>	releaseConnectionAsync()
CompletionStage<Void>	resetAsync()
RetryLogic	retryLogic()
CompletionStage<ResultCursor>	runAsync(Query query, TransactionConfig config, Observation parentObservation, Class<?> resultType)
CompletionStage<RxResultCursor>	runRx(Query query, TransactionConfig config, CompletionStage<RxResultCursor> cursorPublishStage, Observation parentObservation)

Methods inherited from class java.lang.Object

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

Field Details

log

protected final Logger log

Constructor Details

NetworkSession

public NetworkSession(DriverBoltConnectionSource boltConnectionProvider,
 RetryLogic retryLogic,
 org.neo4j.bolt.connection.DatabaseName databaseName,
 AccessMode mode,
 Set<Bookmark> bookmarks,
 String impersonatedUser,
 long fetchSize,
 Logging logging,
 BookmarkManager bookmarkManager,
 NotificationConfig notificationConfig,
 AuthToken overrideAuthToken,
 boolean telemetryDisabled,
 AuthTokenManager authTokenManager,
 HomeDatabaseCache homeDatabaseCache,
 DriverObservationProvider observationProvider)

Method Details

runAsync

public CompletionStage<ResultCursor> runAsync(Query query,
 TransactionConfig config,
 Observation parentObservation,
 Class<?> resultType)

runRx

public CompletionStage<RxResultCursor> runRx(Query query,
 TransactionConfig config,
 CompletionStage<RxResultCursor> cursorPublishStage,
 Observation parentObservation)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(TransactionConfig config,
 ApiTelemetryWork apiTelemetryWork,
 Observation parentObservation)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(TransactionConfig config,
 String txType,
 ApiTelemetryWork apiTelemetryWork,
 Observation parentObservation)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(AccessMode mode,
 TransactionConfig config,
 ApiTelemetryWork apiTelemetryWork,
 Observation parentObservation)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(AccessMode mode,
 TransactionConfig config,
 String txType,
 ApiTelemetryWork apiTelemetryWork,
 boolean flush,
 Observation parentObservation)

resetAsync

public CompletionStage<Void> resetAsync()

retryLogic

public RetryLogic retryLogic()

lastBookmarks

public Set<Bookmark> lastBookmarks()

releaseConnectionAsync

public CompletionStage<Void> releaseConnectionAsync()

connectionAsync

public CompletionStage<DriverBoltConnection> connectionAsync()

isOpen

public boolean isOpen()

closeAsync

public CompletionStage<Void> closeAsync(Observation parentObservation)

currentConnectionIsOpen

protected CompletionStage<Boolean> currentConnectionIsOpen()