Uses of Interface
org.springframework.data.cassandra.ReactiveSession
Packages that use 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
Methods in org.springframework.data.cassandra that return types with arguments of type ReactiveSessionModifier 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
Methods in org.springframework.data.cassandra.config that return ReactiveSessionModifier and TypeMethodDescriptionAbstractReactiveCassandraConfiguration.reactiveCassandraSession()
Creates aReactiveSession
object. -
Uses of ReactiveSession in org.springframework.data.cassandra.core
Methods in org.springframework.data.cassandra.core with parameters of type ReactiveSessionModifier and TypeMethodDescriptionreactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.PreparedStatement>
ReactiveCassandraTemplate.PreparedStatementHandler.createPreparedStatement
(ReactiveSession session) Constructors in org.springframework.data.cassandra.core with parameters of type ReactiveSessionModifierConstructorDescriptionReactiveCassandraTemplate
(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
Methods in org.springframework.data.cassandra.core.cql with parameters of type ReactiveSessionModifier 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.Constructors in org.springframework.data.cassandra.core.cql with parameters of type ReactiveSessionModifierConstructorDescriptionReactiveCqlTemplate
(ReactiveSession reactiveSession) Construct a newReactiveCqlTemplate
, given aReactiveSession
. -
Uses of ReactiveSession in org.springframework.data.cassandra.core.cql.session
Classes in org.springframework.data.cassandra.core.cql.session that implement ReactiveSessionMethods in org.springframework.data.cassandra.core.cql.session that return types with arguments of type ReactiveSessionModifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveSession>
DefaultReactiveSessionFactory.getSession()
Constructors in org.springframework.data.cassandra.core.cql.session with parameters of type ReactiveSession -
Uses of ReactiveSession in org.springframework.data.cassandra.observability
Classes in org.springframework.data.cassandra.observability that implement ReactiveSessionMethods in org.springframework.data.cassandra.observability that return ReactiveSessionModifier 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
.Methods in org.springframework.data.cassandra.observability with parameters of type ReactiveSessionModifier 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
.