Uses of Interface
org.neo4j.driver.internal.observation.Observation

Packages that use Observation

Package	Description
org.neo4j.driver.internal.adaptedbolt
org.neo4j.driver.internal.async
org.neo4j.driver.internal.cursor
org.neo4j.driver.internal.observation
org.neo4j.driver.internal.observation.util
org.neo4j.driver.internal.reactive
org.neo4j.driver.internal.reactivestreams

Uses of Observation in org.neo4j.driver.internal.adaptedbolt

Methods in org.neo4j.driver.internal.adaptedbolt with parameters of type Observation

Modifier and Type	Method	Description
CompletionStage<DriverBoltConnection>	AdaptingDriverBoltConnectionSource.getConnection(org.neo4j.bolt.connection.RoutedBoltConnectionParameters parameters, Observation parentObservation)
CompletionStage<DriverBoltConnection>	DriverBoltConnectionSource.getConnection(org.neo4j.bolt.connection.RoutedBoltConnectionParameters parameters, Observation parentObservation)
CompletionStage<Void>	DriverBoltConnection.writeAndFlush(DriverResponseHandler handler, List<org.neo4j.bolt.connection.message.Message> messages, Observation parentObservation)
default CompletionStage<Void>	DriverBoltConnection.writeAndFlush(DriverResponseHandler handler, org.neo4j.bolt.connection.message.Message messages, Observation parentObservation)

Uses of Observation in org.neo4j.driver.internal.async

Methods in org.neo4j.driver.internal.async with parameters of type Observation

Modifier and Type	Method	Description
CompletionStage<UnmanagedTransaction>	UnmanagedTransaction.beginAsync(Set<Bookmark> initialBookmarks, TransactionConfig config, String txType, boolean flush, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	NetworkSession.beginTransactionAsync(AccessMode mode, TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, boolean flush, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	NetworkSession.beginTransactionAsync(AccessMode mode, TransactionConfig config, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	NetworkSession.beginTransactionAsync(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<UnmanagedTransaction>	NetworkSession.beginTransactionAsync(TransactionConfig config, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
CompletionStage<Void>	NetworkSession.closeAsync(Observation parentObservation)
CompletionStage<Void>	UnmanagedTransaction.closeAsync(boolean commit, Observation parentObservation)
CompletionStage<Void>	UnmanagedTransaction.closeAsync(Observation parentObservation)
CompletionStage<Void>	UnmanagedTransaction.commitAsync(Observation parentObservation)
CompletionStage<Void>	UnmanagedTransaction.rollbackAsync(Observation parentObservation)
CompletionStage<ResultCursor>	NetworkSession.runAsync(Query query, TransactionConfig config, Observation parentObservation, Class<?> resultType)
CompletionStage<ResultCursor>	UnmanagedTransaction.runAsync(Query query, Observation parentObservation, Class<?> resultType)
CompletionStage<RxResultCursor>	NetworkSession.runRx(Query query, TransactionConfig config, CompletionStage<RxResultCursor> cursorPublishStage, Observation parentObservation)
CompletionStage<RxResultCursor>	UnmanagedTransaction.runRx(Query query, Observation parentObservation)
CompletionStage<Void>	DelegatingBoltConnection.writeAndFlush(DriverResponseHandler handler, List<org.neo4j.bolt.connection.message.Message> messages, Observation parentObservation)

Constructors in org.neo4j.driver.internal.async with parameters of type Observation

Modifier	Constructor	Description
	InternalAsyncTransaction(UnmanagedTransaction tx, DriverObservationProvider observationProvider, Observation parentObservation)

Uses of Observation in org.neo4j.driver.internal.cursor

Methods in org.neo4j.driver.internal.cursor with parameters of type Observation

Modifier and Type	Method	Description
CompletionStage<Throwable>	DisposableResultCursorImpl.discardAllFailureAsync(Observation parentObservation)
CompletionStage<Throwable>	ResultCursorImpl.discardAllFailureAsync(Observation parentObservation)
CompletionStage<Throwable>	RxResultCursorImpl.discardAllFailureAsync(Observation parentObservation)
void	RxResultCursor.installRecordConsumer(BiConsumer<Record,Throwable> recordConsumer, Observation observation)
void	RxResultCursorImpl.installRecordConsumer(BiConsumer<Record,Throwable> recordConsumer, Observation observation)
CompletionStage<Throwable>	DisposableResultCursorImpl.pullAllFailureAsync(Observation parentObservation)
CompletionStage<Throwable>	ResultCursorImpl.pullAllFailureAsync(Observation parentObservation)
CompletionStage<Throwable>	RxResultCursorImpl.pullAllFailureAsync(Observation parentObservation)
CompletionStage<ResultSummary>	RxResultCursor.summaryAsync(Observation observation)
CompletionStage<ResultSummary>	RxResultCursorImpl.summaryAsync(Observation observation)

Uses of Observation in org.neo4j.driver.internal.observation

Subinterfaces of Observation in org.neo4j.driver.internal.observation

Modifier and Type	Interface	Description
interface	BoltExchangeObservation
interface	BoltHandleObservation
interface	HttpExchangeObservation

Classes in org.neo4j.driver.internal.observation that implement Observation

Modifier and Type	Class	Description
final class	NoopBoltExchangeObservation
final class	NoopBoltHandleObservation
final class	NoopHttpExchangeObservation
class	NoopObservation

Methods in org.neo4j.driver.internal.observation that return Observation

Modifier and Type	Method	Description
Observation	DriverObservationProvider.beginTransaction(Class<?> transactionType)
Observation	NoopObservationProvider.beginTransaction(Class<?> transactionType)
Observation	DriverObservationProvider.connectionPoolClose(String id, URI uri)
Observation	NoopObservationProvider.connectionPoolClose(String id, URI uri)
Observation	DriverObservationProvider.connectionPoolCreate(String id, URI uri, int maxSize)
Observation	NoopObservationProvider.connectionPoolCreate(String id, URI uri, int maxSize)
Observation	NoopObservation.error(Throwable error)
Observation	Observation.error(Throwable error)
Observation	DriverObservationProvider.pooledConnectionAcquire(String id, URI uri)
Observation	NoopObservationProvider.pooledConnectionAcquire(String id, URI uri)
Observation	DriverObservationProvider.pooledConnectionClose(String id, URI uri)
Observation	NoopObservationProvider.pooledConnectionClose(String id, URI uri)
Observation	DriverObservationProvider.pooledConnectionCreate(String id, URI uri)
Observation	NoopObservationProvider.pooledConnectionCreate(String id, URI uri)
Observation	DriverObservationProvider.pooledConnectionInUse(String id, URI uri)
Observation	NoopObservationProvider.pooledConnectionInUse(String id, URI uri)
Observation	DriverObservationProvider.resultConsume(Class<?> resultType)
Observation	NoopObservationProvider.resultConsume(Class<?> resultType)
Observation	DriverObservationProvider.resultList(Class<?> resultType)
Observation	NoopObservationProvider.resultList(Class<?> resultType)
Observation	DriverObservationProvider.resultNext(Class<?> resultType)
Observation	NoopObservationProvider.resultNext(Class<?> resultType)
Observation	DriverObservationProvider.resultPeek(Class<?> resultType)
Observation	NoopObservationProvider.resultPeek(Class<?> resultType)
Observation	DriverObservationProvider.resultRecords(Class<?> resultType)
Observation	NoopObservationProvider.resultRecords(Class<?> resultType)
Observation	DriverObservationProvider.resultSingle(Class<?> resultType)
Observation	NoopObservationProvider.resultSingle(Class<?> resultType)
Observation	DriverObservationProvider.scopedObservation()
Observation	NoopObservationProvider.scopedObservation()
Observation	DriverObservationProvider.sessionClose(Class<? extends BaseSession> sessionType)
Observation	NoopObservationProvider.sessionClose(Class<? extends BaseSession> sessionType)
Observation	DriverObservationProvider.sessionExecute(Class<? extends BaseSession> sessionType, AccessMode mode)
Observation	NoopObservationProvider.sessionExecute(Class<? extends BaseSession> sessionType, AccessMode mode)
Observation	DriverObservationProvider.sessionRun(Class<? extends BaseSession> sessionType, String query, MapAccessor parameters)
Observation	NoopObservationProvider.sessionRun(Class<? extends BaseSession> sessionType, String query, MapAccessor parameters)
Observation	NoopObservation.start()
Observation	Observation.start()
Observation	DriverObservationProvider.transactionClose(Class<?> transactionType)
Observation	NoopObservationProvider.transactionClose(Class<?> transactionType)
Observation	DriverObservationProvider.transactionCommit(Class<?> transactionType)
Observation	NoopObservationProvider.transactionCommit(Class<?> transactionType)
Observation	DriverObservationProvider.transactionRollback(Class<?> transactionType)
Observation	NoopObservationProvider.transactionRollback(Class<?> transactionType)
Observation	DriverObservationProvider.transactionRun(Class<?> transactionType, String query, MapAccessor parameters)
Observation	NoopObservationProvider.transactionRun(Class<?> transactionType, String query, MapAccessor parameters)

Uses of Observation in org.neo4j.driver.internal.observation.util

Methods in org.neo4j.driver.internal.observation.util with parameters of type Observation

Modifier and Type	Method	Description
static void	ObservationUtil.observe(Observation observation, Runnable runnable)
static <T> T	ObservationUtil.observe(Observation observation, Supplier<T> supplier)
static <T> CompletionStage<T>	ObservationUtil.observeAsync(Observation observation, Supplier<CompletionStage<T>> supplier)
static <T> CompletionStage<T>	ObservationUtil.observeAsyncStarted(Observation observation, Supplier<CompletionStage<T>> supplier)
static <T> org.reactivestreams.Publisher<T>	ObservationUtil.observeStreams(Observation observation, org.reactivestreams.Publisher<T> publisher)
static <T> org.reactivestreams.Publisher<T>	ObservationUtil.observeStreams(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean startOnRequest, boolean stopOnCancel)
static <T> org.reactivestreams.Publisher<T>	ObservationUtil.observeStreamsWithoutStart(Observation observation, org.reactivestreams.Publisher<T> publisher, boolean stopOnCancel)
static <T> T	ObservationUtil.scoped(DriverObservationProvider observationProvider, Observation observation, Supplier<T> supplier)

Uses of Observation in org.neo4j.driver.internal.reactive

Methods in org.neo4j.driver.internal.reactive with parameters of type Observation

Modifier and Type	Method	Description
org.reactivestreams.Publisher<ReactiveTransaction>	InternalReactiveSession.beginTransaction(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
org.reactivestreams.Publisher<Void>	AbstractReactiveTransaction.close(boolean commit, Observation parentObservation)
protected abstract org.reactivestreams.Publisher<Void>	AbstractReactiveSession.closeTransaction(S transaction, boolean commit, Observation parentObservation)
protected org.reactivestreams.Publisher<Void>	InternalReactiveSession.closeTransaction(ReactiveTransaction transaction, boolean commit, Observation parentObservation)
protected org.reactivestreams.Publisher<S>	AbstractReactiveSession.doBeginTransaction(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	AbstractReactiveSession.doClose(Observation parentObservation)
protected org.reactivestreams.Publisher<Void>	AbstractReactiveTransaction.doClose(Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	AbstractReactiveTransaction.doCommit(Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	AbstractReactiveTransaction.doRollback(Observation parentObservation)
protected <T> org.reactivestreams.Publisher<T>	AbstractReactiveSession.run(Query query, TransactionConfig config, Function<RxResultCursor,T> cursorToResult, Observation parentObservation)

Uses of Observation in org.neo4j.driver.internal.reactivestreams

Methods in org.neo4j.driver.internal.reactivestreams with parameters of type Observation

Modifier and Type	Method	Description
org.reactivestreams.Publisher<Void>	InternalReactiveSession.closeTransaction(ReactiveTransaction transaction, boolean commit, Observation parentObservation)