Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- add(ProxyExecutionListener) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
-
Add a
ProxyExecutionListener
. - addAll(Collection<ProxyExecutionListener>) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
-
Add a list of
ProxyExecutionListener
. - addConsumer(BiConsumer<MethodExecutionInfo, StringBuilder>) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter
-
Register a consumer that converts
MethodExecutionInfo
to aString
. - addConsumer(BiConsumer<QueryExecutionInfo, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
- addIndexBinding(Bindings.IndexBinding) - Method in class io.r2dbc.proxy.core.Bindings
-
Add an index binding.
- addListener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Register
ProxyExecutionListener
. - addNamedBinding(Bindings.NamedBinding) - Method in class io.r2dbc.proxy.core.Bindings
-
Add a named binding.
- AFTER_METHOD - Enum constant in enum class io.r2dbc.proxy.core.ProxyEventType
- AFTER_QUERY - Enum constant in enum class io.r2dbc.proxy.core.ProxyEventType
- afterAddOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Batch.add(String)
is called. - afterAddOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.add()
is called. - afterBeginTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.beginTransaction()
is called. - afterBindNullOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.bindNull(int, Class)
orStatement.bindNull(String, Class)
are called. - afterBindOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.bind(int, Object)
orStatement.bind(String, Object)
are called. - afterCloseOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.close()
is called. - afterCommitTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.commitTransaction()
is called. - afterCreateBatchOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.createBatch()
is called. - afterCreateOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
ConnectionFactory.create()
is called. - afterCreateSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.createSavepoint(String)
is called. - afterCreateStatementOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.createStatement(String)
is called. - afterExecuteOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Batch.execute()
is called. - afterExecuteOnBatch(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Query execution callback that is invoked after
Batch.execute()
is called. - afterExecuteOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.execute()
is called. - afterExecuteOnStatement(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Query execution callback that is invoked after
Statement.execute()
is called. - afterFetchSizeOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.fetchSize(int)
is called. - afterFilterOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Result.filter(Predicate)
is called. - afterFlatMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Result.flatMap(Function)
is called. - afterGetMetadataOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.getMetadata()
is called. - afterGetMetadataOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
ConnectionFactory.getMetadata()
is called. - afterGetMetadataOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Row#getMetadata(...)
is called. - afterGetOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Row#get(...)
is called. - afterGetRowsUpdatedOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Result.getRowsUpdated()
is called. - afterGetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.getTransactionIsolationLevel()
is called. - afterIsAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.isAutoCommit()
is called. - afterMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Result.map(BiFunction)
orResult.map(Function)
is called. - afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
- afterMethod(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener
-
Called after every invocation of methods.
- afterMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
- afterQuery(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener
-
Called after executing a query (
Batch.execute()
orStatement.execute()
). - afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- afterQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- afterReleaseSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.releaseSavepoint(String)
is called. - afterReturnGeneratedValuesOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Statement.returnGeneratedValues(String...)
is called. - afterRollbackTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.rollbackTransaction()
is called. - afterRollbackTransactionToSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.rollbackTransactionToSavepoint(String)
is called. - afterSetAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.setAutoCommit(boolean)
is called. - afterSetLockWaitTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.setLockWaitTimeout(Duration)
is called. - afterSetStatementTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.setStatementTimeout(Duration)
is called. - afterSetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.setTransactionIsolationLevel(IsolationLevel)
is called. - afterValidateOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked after
Connection.validate(ValidationDepth)
is called. - apply(MethodExecutionInfo) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter
- apply(QueryExecutionInfo) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
- Assert - Class in io.r2dbc.proxy.util
-
Assertion library for the implementation.
B
- BATCH - Enum constant in enum class io.r2dbc.proxy.core.ExecutionType
- BatchCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Batch
. - BatchCallbackHandler(Batch, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.BatchCallbackHandler
- batchSize(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- BEFORE_METHOD - Enum constant in enum class io.r2dbc.proxy.core.ProxyEventType
- BEFORE_QUERY - Enum constant in enum class io.r2dbc.proxy.core.ProxyEventType
- beforeAddOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Batch.add(String)
is called. - beforeAddOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.add()
is called. - beforeBeginTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.beginTransaction()
is called. - beforeBindNullOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.bindNull(int, Class)
orStatement.bindNull(String, Class)
are called. - beforeBindOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.bind(int, Object)
orStatement.bind(String, Object)
are called. - beforeCloseOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.close()
is called. - beforeCommitTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.commitTransaction()
is called. - beforeCreateBatchOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.createBatch()
is called. - beforeCreateOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
ConnectionFactory.create()
is called. - beforeCreateSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.createSavepoint(String)
is called. - beforeCreateStatementOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.createStatement(String)
is called. - beforeExecuteOnBatch(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Batch.execute()
is called. - beforeExecuteOnBatch(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Query execution callback that is invoked before
Batch.execute()
is called. - beforeExecuteOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.execute()
is called. - beforeExecuteOnStatement(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Query execution callback that is invoked before
Statement.execute()
is called. - beforeFetchSizeOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.fetchSize(int)
is called. - beforeFilterOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Result.filter(Predicate)
is called. - beforeFlatMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Result.flatMap(Function)
is called. - beforeGetMetadataOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.getMetadata()
is called. - beforeGetMetadataOnConnectionFactory(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
ConnectionFactory.getMetadata()
is called. - beforeGetMetadataOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Row#getMetadata(...)
is called. - beforeGetOnRow(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Row#get(...)
is called. - beforeGetRowsUpdatedOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Result.getRowsUpdated()
is called. - beforeGetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.getTransactionIsolationLevel()
is called. - beforeIsAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.isAutoCommit()
is called. - beforeMapOnResult(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Result.map(BiFunction)
orResult.map(Function)
is called. - beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
- beforeMethod(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener
-
Called before every invocation of methods.
- beforeMethod(MethodExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
- beforeQuery(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener
-
Called before executing a query (
Batch.execute()
orStatement.execute()
). - beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- beforeQuery(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- beforeReleaseSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.releaseSavepoint(String)
is called. - beforeReturnGeneratedValuesOnStatement(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Statement.returnGeneratedValues(String...)
is called. - beforeRollbackTransactionOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.rollbackTransaction()
is called. - beforeRollbackTransactionToSavepointOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.rollbackTransactionToSavepoint(String)
is called. - beforeSetAutoCommitOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.setAutoCommit(boolean)
is called. - beforeSetLockWaitTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.setLockWaitTimeout(Duration)
is called. - beforeSetStatementTimeoutOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.setStatementTimeout(Duration)
is called. - beforeSetTransactionIsolationLevelOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.setTransactionIsolationLevel(IsolationLevel)
is called. - beforeValidateOnConnection(MethodExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyMethodExecutionListener
-
Callback that is invoked before
Connection.validate(ValidationDepth)
is called. - BindInfo - Interface in io.r2dbc.proxy.core
-
Hold contextual information for bind operations(
bind
andbindNull
). - Binding - Interface in io.r2dbc.proxy.core
-
Represent an operation of
Statement.bind(int, java.lang.Object)
andStatement.bindNull(int, java.lang.Class<?>)
. - Bindings - Class in io.r2dbc.proxy.core
-
Represent set of
Binding
for each batch. - Bindings() - Constructor for class io.r2dbc.proxy.core.Bindings
- Bindings.IndexBinding - Class in io.r2dbc.proxy.core
-
Represents index binding.
- Bindings.NamedBinding - Class in io.r2dbc.proxy.core
-
Represents named(String) binding.
- bindingsSize(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- bindParameterConverter(BindParameterConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
- BindParameterConverter - Interface in io.r2dbc.proxy.listener
- BindParameterConverter.BindOperation - Interface in io.r2dbc.proxy.listener
-
Represent bind operation(
bind
andbindNull
). - boundValue(BiConsumer<BoundValue, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Set a consumer for converting
BoundValue
. - BoundValue - Interface in io.r2dbc.proxy.core
-
Represent a value for
Statement.bind(int, java.lang.Object)
andStatement.bindNull(int, java.lang.Class<?>)
operations. - BoundValue.DefaultBoundValue - Class in io.r2dbc.proxy.core
-
Default implementation of
BoundValue
. - build() - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Build a
ProxyConfig
. - build() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Build a proxy
ConnectionFactory
. - build() - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- build() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- build() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- build() - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
- builder() - Static method in class io.r2dbc.proxy.callback.ProxyConfig
-
Create a new
ProxyConfig.Builder
. - builder() - Static method in class io.r2dbc.proxy.test.MockConnectionInfo
-
Provides a builder for
MockConnectionInfo
. - builder() - Static method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
-
Provides a builder for
MockMethodExecutionInfo
. - builder() - Static method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
-
Provides a builder for
MockQueryExecutionInfo
. - builder() - Static method in class io.r2dbc.proxy.test.MockStatementInfo
-
Provide a builder for
MockStatementInfo
. - builder(ConnectionFactory) - Static method in class io.r2dbc.proxy.ProxyConnectionFactory
-
Create a new
ProxyConnectionFactory.Builder
. - builder(ConnectionFactory, ProxyConfig) - Static method in class io.r2dbc.proxy.ProxyConnectionFactory
-
Create a new
ProxyConnectionFactory.Builder
. - Builder() - Constructor for class io.r2dbc.proxy.callback.ProxyConfig.Builder
- Builder() - Constructor for class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- Builder() - Constructor for class io.r2dbc.proxy.test.MockStatementInfo.Builder
C
- CallbackHandler - Interface in io.r2dbc.proxy.callback
-
Callback logic for proxy invocation.
- chompIfEndWith(StringBuilder, char) - Method in class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider
- clock(Clock) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Set
Clock
. - commitCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- compareTo(Bindings.IndexBinding) - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding
- compareTo(Bindings.NamedBinding) - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding
- CompositeProxyExecutionListener - Class in io.r2dbc.proxy.listener
-
Delegate to multiple of
ProxyExecutionListeners
. - CompositeProxyExecutionListener(ProxyExecutionListener...) - Constructor for class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- CONNECTION - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.LowCardinalityKeys
-
Name of the R2DBC connection.
- ConnectionCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Connection
. - ConnectionCallbackHandler(Connection, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- ConnectionFactoryCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
ConnectionFactory
. - ConnectionFactoryCallbackHandler(ConnectionFactory, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- ConnectionHolder - Interface in io.r2dbc.proxy.callback
-
Provide methods to retrieve original
Connection
from proxy object. - connectionId(String) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- connectionIdManager(ConnectionIdManager) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Set
ConnectionIdManager
. - ConnectionIdManager - Interface in io.r2dbc.proxy.callback
-
Connection
ID manager interface. - connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- connectionInfo(ConnectionInfo) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
- ConnectionInfo - Interface in io.r2dbc.proxy.core
-
Hold
Connection
related information. - create() - Static method in interface io.r2dbc.proxy.callback.ConnectionIdManager
-
Create a default
ConnectionIdManager
. - create() - Static method in interface io.r2dbc.proxy.core.ValueStore
-
Create default
ValueStore
. - create() - Static method in interface io.r2dbc.proxy.listener.BindParameterConverter
-
Create default
BindParameterConverter
. - create() - Static method in interface io.r2dbc.proxy.listener.ResultRowConverter
-
Create a default
ResultRowConverter
. - create(ProxyConfig) - Method in interface io.r2dbc.proxy.callback.ProxyFactoryFactory
-
Create
ProxyFactory
with givenProxyConfig
. - create(ConnectionFactoryOptions) - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider
-
Create a new proxy
ConnectionFactory
from givenConnectionFactoryOptions
. - currentMappedResult(Object) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- currentResultCount(int) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- customValue(Object, Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- customValue(Object, Object) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- customValues(Map<Object, Object>) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- customValues(Map<Object, Object>) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
D
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.BatchCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.ResultCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.RowCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- DEFAULT_INVOCATION_STRATEGY - Static variable in class io.r2dbc.proxy.callback.StatementCallbackHandler
- DefaultBoundValue() - Constructor for class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue
- DefaultQueryParametersTagProvider - Class in io.r2dbc.proxy.observation
-
Default implementation for
QueryParametersTagProvider
. - DefaultQueryParametersTagProvider() - Constructor for class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider
- DefaultValueStore - Class in io.r2dbc.proxy.core
-
Default implementation of
ValueStore
. - DefaultValueStore() - Constructor for class io.r2dbc.proxy.core.DefaultValueStore
- DelegatingContextView - Class in io.r2dbc.proxy.callback
-
ContextView
implementation that delegates to the givenContextView
in constructor. - DelegatingContextView(ContextView) - Constructor for class io.r2dbc.proxy.callback.DelegatingContextView
- delimiter(String) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Set a delimiter between each consumer
E
- EACH_QUERY_RESULT - Enum constant in enum class io.r2dbc.proxy.core.ProxyEventType
- eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
- eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
- eachQueryResult(QueryExecutionInfo) - Method in interface io.r2dbc.proxy.listener.ProxyExecutionListener
-
Called on processing each query
Result
. - eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- eachQueryResult(QueryExecutionInfo) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- empty() - Static method in class io.r2dbc.proxy.test.MockConnectionInfo
-
Provide an empty
MockConnectionInfo
. - empty() - Static method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
-
Provide an empty
MockMethodExecutionInfo
. - empty() - Static method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
-
Provide an empty
MockMethodExecutionInfo
. - empty() - Static method in class io.r2dbc.proxy.test.MockStatementInfo
-
Provide an empty
MockStatementInfo
. - executeDuration(Duration) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- executeDuration(Duration) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- ExecutionType - Enum Class in io.r2dbc.proxy.core
-
Query execution type.
F
- format(MethodExecutionInfo) - Method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter
-
Convert the given
MethodExecutionInfo
toString
using registered consumers. - format(QueryExecutionInfo) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Convert the given
QueryExecutionInfo
toString
using registered consumers. - from(MockQueryExecutionInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
G
- get(Object) - Method in class io.r2dbc.proxy.callback.DelegatingContextView
- get(Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- get(Object) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Get the value associated to the key.
- get(Object, Class<T>) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- get(Object, Class<T>) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Get the value associated to the key and cast to the type.
- getAfterMethodExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
-
Get the last used
MethodExecutionInfo
inProxyExecutionListener.afterMethod(MethodExecutionInfo)
. - getAfterQueryExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
-
Get the last used
QueryExecutionInfo
inProxyExecutionListener.afterQuery(QueryExecutionInfo)
. - getBatchSize() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the size of the batch query.
- getBatchSize() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getBeforeMethodExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
-
Get the last used
MethodExecutionInfo
inProxyExecutionListener.beforeMethod(MethodExecutionInfo)
. - getBeforeQueryExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
-
Get the last used
QueryExecutionInfo
inProxyExecutionListener.beforeQuery(QueryExecutionInfo)
. - getBinding() - Method in interface io.r2dbc.proxy.core.BindInfo
-
Get invoked bind operation details.
- getBindingsList() - Method in class io.r2dbc.proxy.core.QueryInfo
-
Get the list of
Bindings
. - getBindingsSize() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the number of the binding.
- getBindingsSize() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getBindParameterConverter() - Method in class io.r2dbc.proxy.callback.ProxyConfig
- getBoundValue() - Method in interface io.r2dbc.proxy.core.Binding
-
Get a
BoundValue
. - getBoundValue() - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding
- getBoundValue() - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding
- getClock() - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Get
Clock
. - getCommitCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Returns how many times
Connection.commitTransaction()
method is called. - getCommitCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getConnectionFactory() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Return the
ConnectionFactory
passed at creation. - getConnectionId() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Get ID for the connection.
- getConnectionId() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getConnectionIdManager() - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Get
ConnectionIdManager
. - getConnectionInfo() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the
ConnectionInfo
. - getConnectionInfo() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the associated
ConnectionInfo
. - getConnectionInfo() - Method in interface io.r2dbc.proxy.core.StatementInfo
-
Get
ConnectionInfo
associated to thisStatement
. - getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
- getConnectionInfo() - Method in class io.r2dbc.proxy.test.MockStatementInfo
- getConnectionName() - Method in class io.r2dbc.proxy.observation.QueryContext
- getContextualName(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention
- getCurrentMappedResult() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Mapped query result available for each-query-result-callback(
ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)
). - getCurrentMappedResult() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getCurrentResultCount() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Represent Nth
Result
. - getCurrentResultCount() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getDelegate() - Method in class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- getDriver() - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider
- getEachQueryResultExecutionInfo() - Method in class io.r2dbc.proxy.listener.LastExecutionAwareListener
-
Get the last used
QueryExecutionInfo
inProxyExecutionListener.eachQueryResult(QueryExecutionInfo)
. - getElapsedDuration() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Retrieve the elapsed time from the stopwatch that has started by
QueriesExecutionContext.startStopwatch()
. - getExecuteDuration() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the duration of the method invocation.
- getExecuteDuration() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the time that took queries to execute.
- getExecuteDuration() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getExecuteDuration() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getHighCardinalityKeyValues(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention
- getId(Connection) - Method in interface io.r2dbc.proxy.callback.ConnectionIdManager
-
Get ID for the input
Connection
. - getIndexBindings() - Method in class io.r2dbc.proxy.core.Bindings
-
Get a sorted set of index bindings.
- getKey() - Method in interface io.r2dbc.proxy.core.Binding
-
Get a key which represents index or name of the binding.
- getKey() - Method in class io.r2dbc.proxy.core.Bindings.IndexBinding
- getKey() - Method in class io.r2dbc.proxy.core.Bindings.NamedBinding
- getListeners() - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Returns
CompositeProxyExecutionListener
that contains registeredProxyExecutionListener
. - getListeners() - Method in class io.r2dbc.proxy.listener.CompositeProxyExecutionListener
-
Get registered listeners.
- getLowCardinalityKeyValues(QueryContext) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention
- getLowCardinalityKeyValues(QueryContext) - Method in interface io.r2dbc.proxy.observation.VirtualThreadQueryObservationConvention
- getMethod() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the invoked
Method
. - getMethod() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the invoked query execution
Method
. - getMethod() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getMethod() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getMethodArgs() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the arguments of the invocation.
- getMethodArgs() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the arguments of the invocation.
- getMethodArgs() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getMethodArgs() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getName() - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention
- getNamedBindings() - Method in class io.r2dbc.proxy.core.Bindings
-
Get a sorted set of named bindings.
- getNullType() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue
- getNullType() - Method in interface io.r2dbc.proxy.core.BoundValue
-
Get the bound
null
type byStatement.bindNull(int, java.lang.Class<?>)
. - getOrDefault(Object, T) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- getOrDefault(Object, T) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Get the value associated to the key; otherwise returns specified value.
- getOriginalConnection() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Retrieve original
Connection
. - getOriginalConnection() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getOriginalQuery() - Method in interface io.r2dbc.proxy.core.StatementInfo
-
Get the sql statement that has originally specified on
Connection.createStatement(String)
. - getOriginalQuery() - Method in class io.r2dbc.proxy.test.MockStatementInfo
- getParams() - Method in class io.r2dbc.proxy.observation.QueryContext
- getProxyConfig() - Method in interface io.r2dbc.proxy.callback.ProxyConfigHolder
-
Retrieve
ProxyConfig
. - getProxyConfig() - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Return the
ProxyConfig
. - getProxyEventType() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the proxy event type.
- getProxyEventType() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the proxy event type for query execution.
- getProxyEventType() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getProxyEventType() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getProxyFactory() - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Get
ProxyFactory
which is generated from the specifiedProxyFactoryFactory
. - getQueries() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the list of
QueryInfo
. - getQueries() - Method in class io.r2dbc.proxy.observation.QueryContext
- getQueries() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getQuery() - Method in class io.r2dbc.proxy.core.QueryInfo
-
Get the query.
- getResult() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the result of invocation.
- getResult() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getResultRowConverter() - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Get
ResultRowConverter
. - getRollbackCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Returns how many times
Connection.rollbackTransaction()
method is called. - getRollbackCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getStatementInfo() - Method in interface io.r2dbc.proxy.core.BindInfo
-
Get
StatementInfo
where bind operation has happened. - getTagValue(List<Bindings>) - Method in class io.r2dbc.proxy.observation.DefaultQueryParametersTagProvider
- getTagValue(List<Bindings>) - Method in interface io.r2dbc.proxy.observation.QueryParametersTagProvider
-
Provide query parameter values.
- getTarget() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the invoked object.
- getTarget() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getThreadId() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the thread ID.
- getThreadId() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the currently executed thread ID.
- getThreadId() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getThreadId() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getThreadName() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the thread name.
- getThreadName() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the currently executed thread name.
- getThreadName() - Method in class io.r2dbc.proxy.observation.QueryContext
- getThreadName() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getThreadName() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getThrowable() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the thrown exception.
- getThrowable() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getThrown() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Get the thrown exception.
- getThrown() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getTransactionCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Returns how many times
Connection.beginTransaction()
method is called. - getTransactionCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getType() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Get the type of query execution.
- getType() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getUpdatedQuery() - Method in interface io.r2dbc.proxy.core.StatementInfo
-
Get the updated sql statement by
BindParameterConverter.onCreateStatement(String, StatementInfo)
. - getUpdatedQuery() - Method in class io.r2dbc.proxy.test.MockStatementInfo
- getValue() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue
- getValue() - Method in interface io.r2dbc.proxy.core.BoundValue
-
Get the bound value by
Statement.bind(int, java.lang.Object)
. - getValueStore() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Retrieve
ValueStore
which is associated to the scope of logical connection. - getValueStore() - Method in interface io.r2dbc.proxy.core.MethodExecutionInfo
-
Retrieve
ValueStore
which is associated to the scope of before/after method execution. - getValueStore() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Retrieve
ValueStore
which is associated to the scope of before/after method execution. - getValueStore() - Method in interface io.r2dbc.proxy.core.StatementInfo
-
Retrieve
ValueStore
which is associated to the scope of logical statement. - getValueStore() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- getValueStore() - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo
- getValueStore() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- getValueStore() - Method in class io.r2dbc.proxy.test.MockStatementInfo
H
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- handleCommonMethod(String, Object, Object[], Connection) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
- hasKey(Object) - Method in class io.r2dbc.proxy.callback.DelegatingContextView
I
- incrementCommitCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Increment commit count.
- incrementCommitCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- incrementConsumedCount() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Increment the count of consumptions from
Result#[map|getRowsUpdated]
. - incrementProducedCount() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Increment the count of produced
Result
fromStatement#execute
. - incrementRollbackCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Increment rollback count.
- incrementRollbackCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- incrementTransactionCount() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Increment transaction count.
- incrementTransactionCount() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- indexBinding(int, BoundValue) - Static method in class io.r2dbc.proxy.core.Bindings
-
Factory method to create
Bindings.IndexBinding
. - indexBindings(BiConsumer<SortedSet<Binding>, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- interceptQueryExecution(Publisher<? extends Result>, MutableQueryExecutionInfo) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
-
Augment query execution result to hook up listener lifecycle.
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
- invoke(Object, Method, Object[]) - Method in interface io.r2dbc.proxy.callback.CallbackHandler
-
When proxy is invoked, actual implementation of the proxy handler delegates the invocation to this method.
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- invoke(Object, Method, Object[]) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
- io.r2dbc.proxy - package io.r2dbc.proxy
- io.r2dbc.proxy.callback - package io.r2dbc.proxy.callback
-
Proxy related classes
- io.r2dbc.proxy.core - package io.r2dbc.proxy.core
-
Domain classes
- io.r2dbc.proxy.listener - package io.r2dbc.proxy.listener
-
Listener classes
- io.r2dbc.proxy.observation - package io.r2dbc.proxy.observation
- io.r2dbc.proxy.support - package io.r2dbc.proxy.support
-
Misc support classes
- io.r2dbc.proxy.test - package io.r2dbc.proxy.test
-
Utility classes for testing
- io.r2dbc.proxy.util - package io.r2dbc.proxy.util
-
Utility code used throughout the project.
- isAllConsumed() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Whether currently all produced
Result
s are consumed. - isClosed() - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Returns whether connection is closed or not.
- isClosed() - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- isClosed(boolean) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- isCommonMethod(String) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
- isNull() - Method in class io.r2dbc.proxy.core.BoundValue.DefaultBoundValue
- isNull() - Method in interface io.r2dbc.proxy.core.BoundValue
-
Distinguish between the bound value is for
Statement.bind(int, java.lang.Object)
orStatement.bindNull(int, java.lang.Class<?>)
operation. - isQueryFinished() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Whether the executed queries have finished and results are consumed.
- isSuccess() - Method in interface io.r2dbc.proxy.core.QueryExecutionInfo
-
Indicate whether the query execution was successful or not.
- isSuccess() - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo
- isSuccess(boolean) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
L
- LastExecutionAwareListener - Class in io.r2dbc.proxy.listener
-
Keep the last invoked execution.
- LastExecutionAwareListener() - Constructor for class io.r2dbc.proxy.listener.LastExecutionAwareListener
- listener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Add a
ProxyExecutionListener
. - listener(ProxyExecutionListener) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a
ProxyExecutionListener
.
M
- markAllProduced() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
When
QueryInvocationSubscriber
produced allResult
objects. - method(Method) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- method(Method) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- methodArgs(Object[]) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- methodArgs(Object[]) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- MethodExecutionInfo - Interface in io.r2dbc.proxy.core
-
Hold method execution related information.
- MethodExecutionInfoFormatter - Class in io.r2dbc.proxy.support
-
Convert
MethodExecutionInfo
toString
. - MethodExecutionInfoFormatter() - Constructor for class io.r2dbc.proxy.support.MethodExecutionInfoFormatter
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.BatchCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.ResultCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.RowCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- methodInvocationStrategy - Variable in class io.r2dbc.proxy.callback.StatementCallbackHandler
- MockConnectionInfo - Class in io.r2dbc.proxy.test
-
Mock implementation of
ConnectionInfo
for testing. - MockConnectionInfo.Builder - Class in io.r2dbc.proxy.test
- MockMethodExecutionInfo - Class in io.r2dbc.proxy.test
-
Mock implementation of
MethodExecutionInfo
for testing. - MockMethodExecutionInfo.Builder - Class in io.r2dbc.proxy.test
- MockQueryExecutionInfo - Class in io.r2dbc.proxy.test
-
Mock implementation of
QueryExecutionInfo
for testing. - MockQueryExecutionInfo.Builder - Class in io.r2dbc.proxy.test
- MockStatementInfo - Class in io.r2dbc.proxy.test
-
Mock implementation of
StatementInfo
. - MockStatementInfo.Builder - Class in io.r2dbc.proxy.test
N
- namedBinding(String, BoundValue) - Static method in class io.r2dbc.proxy.core.Bindings
-
Factory method to create
Bindings.NamedBinding
. - namedBindings(BiConsumer<SortedSet<Binding>, StringBuilder>) - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
- newLine() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Change the line
- nullValue(Class<?>) - Static method in interface io.r2dbc.proxy.core.BoundValue
-
Create a
BoundValue
that representsStatement.bindNull(int, java.lang.Class<?>)
.
O
- ObservationProxyExecutionListener - Class in io.r2dbc.proxy.observation
-
Create Micrometer Observations.
- ObservationProxyExecutionListener(ObservationRegistry, ConnectionFactory, String) - Constructor for class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
-
Constructor that takes a connection url.
- ObservationProxyExecutionListener(ObservationRegistry, ConnectionFactory, String, Integer) - Constructor for class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
-
Constructor that takes host and port.
- onAfterMethod(Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a callback consumer for after method execution.
- onAfterQuery(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a callback consumer for after query execution.
- onBeforeMethod(Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a callback consumer for before method execution
- onBeforeQuery(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a callback consumer for before query execution.
- onBind(BindInfo, Statement, BindParameterConverter.BindOperation) - Method in interface io.r2dbc.proxy.listener.BindParameterConverter
-
Callback method for bind operations(
bind
andbindNull
) onStatement
before actually performing those methods. - onBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting bindings.
- onBoundValue - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting bound value.
- onBoundValueParameter - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting
Parameter
value. - onBoundValueRaw - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting actual value of bound value.
- onCreateStatement(String, StatementInfo) - Method in interface io.r2dbc.proxy.listener.BindParameterConverter
-
Convert the given query to another one at
Connection.createStatement(String)
. - onEachQueryResult(Consumer<QueryExecutionInfo>) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Register a callback consumer for processing each query result.
- onGet(Row, Method, Object[], ResultRowConverter.GetOperation) - Method in interface io.r2dbc.proxy.listener.ResultRowConverter
-
Callback method for
Row#get(...)
before performing the originalRow#get(...)
method. - onIndexBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting bindings by index.
- onNamedBindings - Variable in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Default implementation for formatting bindings by name.
- originalConnection(Connection) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- originalQuery(String) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
P
- proceed() - Method in interface io.r2dbc.proxy.listener.BindParameterConverter.BindOperation
-
Perform the bind operation.
- proceed() - Method in interface io.r2dbc.proxy.listener.ResultRowConverter.GetOperation
-
Perform the original
Row#get(...)
operation. - proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
-
Augment method invocation and call method listener.
- proceedExecution(Method, Object, Object[], ProxyExecutionListener, ConnectionInfo, Consumer<MethodExecutionInfo>) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
-
Augment method invocation and call method listener.
- PROXY_DRIVER - Static variable in class io.r2dbc.proxy.ProxyConnectionFactoryProvider
-
Driver option value.
- PROXY_LISTENERS - Static variable in class io.r2dbc.proxy.ProxyConnectionFactoryProvider
-
Proxy listener
Option
. - proxyConfig - Variable in class io.r2dbc.proxy.callback.BatchCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.ResultCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.RowCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
- proxyConfig - Variable in class io.r2dbc.proxy.callback.StatementCallbackHandler
- proxyConfig(ProxyConfig) - Method in class io.r2dbc.proxy.ProxyConnectionFactory.Builder
-
Set a
ProxyConfig
to use. - ProxyConfig - Class in io.r2dbc.proxy.callback
-
Central configuration object for proxy.
- ProxyConfig() - Constructor for class io.r2dbc.proxy.callback.ProxyConfig
- ProxyConfig.Builder - Class in io.r2dbc.proxy.callback
-
Builder to create a
ProxyConfig
. - ProxyConfigHolder - Interface in io.r2dbc.proxy.callback
-
Provide a method to retrieve
ProxyConfig
from proxy object. - ProxyConnectionFactory - Class in io.r2dbc.proxy
-
Entry point to create a proxy for the given
ConnectionFactory
. - ProxyConnectionFactory.Builder - Class in io.r2dbc.proxy
-
Builder to create a proxy
ConnectionFactory
. - ProxyConnectionFactoryProvider - Class in io.r2dbc.proxy
-
An implementation of
ConnectionFactoryProvider
for creating proxyConnectionFactory
. - ProxyConnectionFactoryProvider() - Constructor for class io.r2dbc.proxy.ProxyConnectionFactoryProvider
- proxyEventType(ProxyEventType) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- proxyEventType(ProxyEventType) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- ProxyEventType - Enum Class in io.r2dbc.proxy.core
-
Proxy callback event type.
- ProxyExecutionListener - Interface in io.r2dbc.proxy.listener
-
Listener interface that is called when proxy is invoked.
- ProxyFactory - Interface in io.r2dbc.proxy.callback
-
Defines factory methods to create proxy of SPI classes.
- proxyFactoryFactory(ProxyFactoryFactory) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Set
ProxyFactoryFactory
. - ProxyFactoryFactory - Interface in io.r2dbc.proxy.callback
-
Factory to create a
ProxyFactory
. - ProxyMethodExecutionListener - Interface in io.r2dbc.proxy.listener
-
Listener interface called back when corresponding method on proxy is invoked.
- ProxyMethodExecutionListenerAdapter - Class in io.r2dbc.proxy.listener
-
Adapter to make
ProxyMethodExecutionListener
work asProxyExecutionListener
. - ProxyMethodExecutionListenerAdapter(ProxyMethodExecutionListener) - Constructor for class io.r2dbc.proxy.listener.ProxyMethodExecutionListenerAdapter
- ProxyUtils - Class in io.r2dbc.proxy.callback
-
Utility methods to obtain original
Connection
from proxy class. - put(Object, Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- put(Object, Object) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Store a value associating the provided key.
- putAll(Map<Object, Object>) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- putAll(Map<Object, Object>) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Store all key value pairs from provided map.
Q
- queries(List<QueryInfo>) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- QueriesExecutionContext - Class in io.r2dbc.proxy.callback
-
The context of queries execution.
- QueriesExecutionContext(Clock) - Constructor for class io.r2dbc.proxy.callback.QueriesExecutionContext
- QUERY - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.HighCardinalityKeys
-
Name of the R2DBC query.
- QUERY_PARAMETERS - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.HighCardinalityKeys
-
Query parameter values.
- QUERY_RESULT - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.Events
-
Retrieving query result.
- QueryContext - Class in io.r2dbc.proxy.observation
-
Observation.Context
for r2dbc query. - QueryContext() - Constructor for class io.r2dbc.proxy.observation.QueryContext
- QueryExecutionInfo - Interface in io.r2dbc.proxy.core
-
Hold query execution related information.
- QueryExecutionInfoFormatter - Class in io.r2dbc.proxy.support
-
Convert
QueryExecutionInfo
toString
. - QueryExecutionInfoFormatter() - Constructor for class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
- queryInfo(QueryInfo) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- QueryInfo - Class in io.r2dbc.proxy.core
-
Hold each query related info.
- QueryInfo(String) - Constructor for class io.r2dbc.proxy.core.QueryInfo
-
Construct the
QueryInfo
with query. - QueryObservationConvention - Interface in io.r2dbc.proxy.observation
-
Default
ObservationConvention
for R2DBC query execution. - QueryParametersTagProvider - Interface in io.r2dbc.proxy.observation
-
Construct a tag value for query parameters.
R
- R2DBC_QUERY_OBSERVATION - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation
-
R2DBC Query Observation.
- R2dbcObservationDocumentation - Enum Class in io.r2dbc.proxy.observation
-
ObservationConvention
for r2dbc operations. - R2dbcObservationDocumentation.Events - Enum Class in io.r2dbc.proxy.observation
- R2dbcObservationDocumentation.HighCardinalityKeys - Enum Class in io.r2dbc.proxy.observation
- R2dbcObservationDocumentation.LowCardinalityKeys - Enum Class in io.r2dbc.proxy.observation
- R2dbcProxyException - Exception Class in io.r2dbc.proxy.core
-
Generic r2dbc-proxy exception.
- R2dbcProxyException() - Constructor for exception class io.r2dbc.proxy.core.R2dbcProxyException
-
Create a new
R2dbcProxyException
. - R2dbcProxyException(String) - Constructor for exception class io.r2dbc.proxy.core.R2dbcProxyException
-
Create a new
R2dbcProxyException
. - R2dbcProxyException(String, Throwable) - Constructor for exception class io.r2dbc.proxy.core.R2dbcProxyException
-
Create a new
R2dbcProxyException
. - remove(Object) - Method in class io.r2dbc.proxy.core.DefaultValueStore
- remove(Object) - Method in interface io.r2dbc.proxy.core.ValueStore
-
Remove the value associated to the provided key.
- requireNonNull(T, String) - Static method in class io.r2dbc.proxy.util.Assert
-
Checks that a specified object reference is not
null
and throws a customizedIllegalArgumentException
if it is. - requireType(Object, Class<T>, String) - Static method in class io.r2dbc.proxy.util.Assert
-
Checks that the specified value is of a specific type.
- result(Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- ResultCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Result
. - ResultCallbackHandler(Result, QueryExecutionInfo, ProxyConfig, QueriesExecutionContext) - Constructor for class io.r2dbc.proxy.callback.ResultCallbackHandler
-
Callback handler logic for
Result
. - resultRowConverter(ResultRowConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig.Builder
-
Set
ResultRowConverter
. - ResultRowConverter - Interface in io.r2dbc.proxy.listener
-
Callback for
Row#get(...)
methods. - ResultRowConverter.GetOperation - Interface in io.r2dbc.proxy.listener
-
Represent
Row#get(...)
operation. - rollbackCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- RowCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Row
. - RowCallbackHandler(Row, QueryExecutionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.RowCallbackHandler
-
Callback handler logic for
Row
. - RowSegmentCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Result.RowSegment
. - RowSegmentCallbackHandler(Result.RowSegment, QueryExecutionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
-
Callback handler logic for
Row
.
S
- setBindParameterConverter(BindParameterConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig
- setClock(Clock) - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Set
Clock
to use to calculate the elapsed time. - setClosed(boolean) - Method in interface io.r2dbc.proxy.core.ConnectionInfo
-
Set
boolean
to indicate whether the connection is closed or not. - setClosed(boolean) - Method in class io.r2dbc.proxy.test.MockConnectionInfo
- setConnectionIdManager(ConnectionIdManager) - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Set
ConnectionIdManager
. - setConnectionName(String) - Method in class io.r2dbc.proxy.observation.QueryContext
- setIncludeParameterValues(boolean) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.BatchCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.ConnectionCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.ConnectionFactoryCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.ResultCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.RowCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.RowSegmentCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setMethodInvocationStrategy(CallbackHandlerSupport.MethodInvocationStrategy) - Method in class io.r2dbc.proxy.callback.StatementCallbackHandler
-
Set
CallbackHandlerSupport.MethodInvocationStrategy
to invoke the original instance(non-proxy) and retrieve result. - setParams(List<String>) - Method in class io.r2dbc.proxy.observation.QueryContext
- setProxyFactoryFactory(ProxyFactoryFactory) - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Set
ProxyFactoryFactory
. - setQueries(List<String>) - Method in class io.r2dbc.proxy.observation.QueryContext
- setQueryObservationConvention(QueryObservationConvention) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- setQueryParametersTagProvider(QueryParametersTagProvider) - Method in class io.r2dbc.proxy.observation.ObservationProxyExecutionListener
- setResultRowConverter(ResultRowConverter) - Method in class io.r2dbc.proxy.callback.ProxyConfig
-
Set
ResultRowConverter
. - setThreadName(String) - Method in class io.r2dbc.proxy.observation.QueryContext
- setThrown(Throwable) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- showAll() - Static method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Create a
QueryExecutionInfoFormatter
which writes out all attributes onQueryExecutionInfo
. - showBatchSize() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show batch size with default format.
- showBindings() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show bindings with default format.
- showBindingsSize() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show binding size with default format.
- showConnection() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show connection information with default format.
- showQuery() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show query with default format.
- showSuccess() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show query success with default format.
- showThread() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show thread information with default format.
- showTime() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show query execution duration with default format.
- showTransaction() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show transaction information with default format.
- showType() - Method in class io.r2dbc.proxy.support.QueryExecutionInfoFormatter
-
Show statement type(batch or statement) with default format.
- size() - Method in class io.r2dbc.proxy.callback.DelegatingContextView
- startStopwatch() - Method in class io.r2dbc.proxy.callback.QueriesExecutionContext
-
Start the stopwatch.
- STATEMENT - Enum constant in enum class io.r2dbc.proxy.core.ExecutionType
- StatementCallbackHandler - Class in io.r2dbc.proxy.callback
-
Proxy callback handler for
Statement
. - StatementCallbackHandler(Statement, StatementInfo, ConnectionInfo, ProxyConfig) - Constructor for class io.r2dbc.proxy.callback.StatementCallbackHandler
- StatementInfo - Interface in io.r2dbc.proxy.core
-
Hold
Statement
related information. - stream() - Method in class io.r2dbc.proxy.callback.DelegatingContextView
- supports(ConnectionFactoryOptions) - Method in class io.r2dbc.proxy.ProxyConnectionFactoryProvider
- supportsContext(Observation.Context) - Method in interface io.r2dbc.proxy.observation.QueryObservationConvention
T
- target(Object) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- THREAD - Enum constant in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.LowCardinalityKeys
-
Name of the R2DBC thread.
- threadId(long) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- threadId(long) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- threadName(String) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- threadName(String) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- throwable(Throwable) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- toString() - Method in class io.r2dbc.proxy.callback.DelegatingContextView
- transactionCount(int) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- type(ExecutionType) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
U
- unwrapConnection() - Method in interface io.r2dbc.proxy.callback.ConnectionHolder
-
Retrieve original
Connection
. - unwrapConnection(Batch) - Static method in class io.r2dbc.proxy.callback.ProxyUtils
-
Get original
Connection
from proxyBatch
. - unwrapConnection(Connection) - Static method in class io.r2dbc.proxy.callback.ProxyUtils
- unwrapConnection(Result) - Static method in class io.r2dbc.proxy.callback.ProxyUtils
-
Get original
Connection
from proxyResult
. - unwrapConnection(Statement) - Static method in class io.r2dbc.proxy.callback.ProxyUtils
-
Get original
Connection
from proxyStatement
. - updatedQuery(String) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
V
- value(Object) - Static method in interface io.r2dbc.proxy.core.BoundValue
-
Create a
BoundValue
that representsStatement.bind(int, java.lang.Object)
. - valueOf(String) - Static method in enum class io.r2dbc.proxy.core.ExecutionType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.r2dbc.proxy.core.ProxyEventType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.Events
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.HighCardinalityKeys
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.LowCardinalityKeys
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.r2dbc.proxy.core.ExecutionType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.r2dbc.proxy.core.ProxyEventType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.Events
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.HighCardinalityKeys
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation.LowCardinalityKeys
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.r2dbc.proxy.observation.R2dbcObservationDocumentation
-
Returns an array containing the constants of this enum class, in the order they are declared.
- valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockConnectionInfo.Builder
- valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockMethodExecutionInfo.Builder
- valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockQueryExecutionInfo.Builder
- valueStore(ValueStore) - Method in class io.r2dbc.proxy.test.MockStatementInfo.Builder
- ValueStore - Interface in io.r2dbc.proxy.core
-
Custom value store.
- VirtualThreadQueryObservationConvention - Interface in io.r2dbc.proxy.observation
-
An extended
QueryObservationConvention
that excludes the thread name from low cardinality tags.
W
- withDefault() - Static method in class io.r2dbc.proxy.support.MethodExecutionInfoFormatter
-
Create a
MethodExecutionInfoFormatter
with default consumers that format theMethodExecutionInfo
. - wrapBatch(Batch, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Batch
. - wrapConnection(Connection, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Connection
. - wrapConnectionFactory(ConnectionFactory) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
ConnectionFactory
. - wrapResult(Result, QueryExecutionInfo, QueriesExecutionContext) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Result
. - wrapRow(Row, QueryExecutionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Row
. - wrapRowSegment(Result.RowSegment, QueryExecutionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Result.RowSegment
. - wrapStatement(Statement, StatementInfo, ConnectionInfo) - Method in interface io.r2dbc.proxy.callback.ProxyFactory
-
Create a proxy
Statement
.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form