Uses of Interface
org.springframework.data.cassandra.ReactiveSession
Package
Description
Spring Data's Cassandra abstraction.
Spring Data Cassandra
factory beans
and configuration.Apache Cassandra core support.
CQL core support.
Provides utility classes for simple
CqlSession
access and various session
implementations.Infrastructure to provide driver observability using Micrometer.
-
Uses of ReactiveSession in org.springframework.data.cassandra
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveSession>
ReactiveSessionFactory.getSession()
Return aReactiveSession
to be used directly or inside a callback insideReactiveCqlTemplate
. -
Uses of ReactiveSession in org.springframework.data.cassandra.config
Modifier and TypeMethodDescriptionAbstractReactiveCassandraConfiguration.reactiveCassandraSession()
Creates aReactiveSession
object. -
Uses of ReactiveSession in org.springframework.data.cassandra.core
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.PreparedStatement>
ReactiveCassandraTemplate.PreparedStatementHandler.createPreparedStatement
(ReactiveSession session) ModifierConstructorDescriptionReactiveCassandraTemplate
(ReactiveSession session) Creates an instance ofReactiveCassandraTemplate
initialized with the givenReactiveSession
and a defaultMappingCassandraConverter
.ReactiveCassandraTemplate
(ReactiveSession session, CassandraConverter converter) Create an instance ofCassandraTemplate
initialized with the givenReactiveSession
andCassandraConverter
. -
Uses of ReactiveSession in org.springframework.data.cassandra.core.cql
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.PreparedStatement>
ReactivePreparedStatementCreator.createPreparedStatement
(ReactiveSession session) Create a statement in this session.org.reactivestreams.Publisher<T>
ReactivePreparedStatementCallback.doInPreparedStatement
(ReactiveSession session, com.datastax.oss.driver.api.core.cql.PreparedStatement ps) Gets called byReactiveCqlTemplate.execute(String, ReactivePreparedStatementCallback)
with an active CQL session andPreparedStatement
.org.reactivestreams.Publisher<T>
ReactiveSessionCallback.doInSession
(ReactiveSession session) Gets called byReactiveCqlTemplate.execute(ReactiveSessionCallback)
with an active Cassandra session.org.reactivestreams.Publisher<T>
ReactiveStatementCallback.doInStatement
(ReactiveSession session, com.datastax.oss.driver.api.core.cql.Statement<?> stmt) Gets called byReactiveCqlTemplate.execute(String)
with an active Cassandra session.ModifierConstructorDescriptionReactiveCqlTemplate
(ReactiveSession reactiveSession) Construct a newReactiveCqlTemplate
, given aReactiveSession
. -
Uses of ReactiveSession in org.springframework.data.cassandra.core.cql.session
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveSession>
DefaultReactiveSessionFactory.getSession()
-
Uses of ReactiveSession in org.springframework.data.cassandra.observability
Modifier and TypeMethodDescriptionstatic ReactiveSession
ObservableReactiveSession.create
(ReactiveSession session, io.micrometer.observation.ObservationRegistry observationRegistry) Factory method for creation of aObservableReactiveSession
.static ReactiveSession
ObservableReactiveSession.create
(ReactiveSession session, String remoteServiceName, io.micrometer.observation.ObservationRegistry observationRegistry) Factory method for creation of aObservableReactiveSession
.protected ReactiveSession
ObservableReactiveSessionFactoryBean.createInstance()
static ReactiveSession
ObservableReactiveSessionFactory.wrap
(ReactiveSession session, io.micrometer.observation.ObservationRegistry observationRegistry) Wrap theCqlSession
with aCqlSessionObservationInterceptor
.static ReactiveSession
ObservableReactiveSessionFactory.wrap
(ReactiveSession session, String remoteServiceName, io.micrometer.observation.ObservationRegistry observationRegistry) Wrap theCqlSession
with aCqlSessionObservationInterceptor
.Modifier and TypeMethodDescriptionstatic ReactiveSession
ObservableReactiveSession.create
(ReactiveSession session, io.micrometer.observation.ObservationRegistry observationRegistry) Factory method for creation of aObservableReactiveSession
.static ReactiveSession
ObservableReactiveSession.create
(ReactiveSession session, String remoteServiceName, io.micrometer.observation.ObservationRegistry observationRegistry) Factory method for creation of aObservableReactiveSession
.static ReactiveSession
ObservableReactiveSessionFactory.wrap
(ReactiveSession session, io.micrometer.observation.ObservationRegistry observationRegistry) Wrap theCqlSession
with aCqlSessionObservationInterceptor
.static ReactiveSession
ObservableReactiveSessionFactory.wrap
(ReactiveSession session, String remoteServiceName, io.micrometer.observation.ObservationRegistry observationRegistry) Wrap theCqlSession
with aCqlSessionObservationInterceptor
.