c
org.apache.pekko.stream.connectors.cassandra
CassandraSessionSettings
Companion object CassandraSessionSettings
class CassandraSessionSettings extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CassandraSessionSettings
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- val configPath: String
- val init: Option[(CqlSession) => Future[Done]]
- def metricsCategory: String
- def toString(): String
- Definition Classes
- CassandraSessionSettings → AnyRef → Any
- def withInit(value: (CqlSession) => Future[Done]): CassandraSessionSettings
The
init
function will be performed once when the session is created, i.e.The
init
function will be performed once when the session is created, i.e. ifCassandraSessionRegistry.sessionFor
is called from multiple places with differentinit
it will only execute the first. - def withInit(value: Function[CqlSession, CompletionStage[Done]]): CassandraSessionSettings
Java API:
Java API:
The
init
function will be performed once when the session is created, i.e. ifCassandraSessionRegistry.sessionFor
is called from multiple places with differentinit
it will only execute the first. - def withMetricCategory(value: String): CassandraSessionSettings