final case class AdvancedConfig(connection: ConnectionConfig = AdvancedConfig.Default.connection, reconnectOnInit: Boolean = AdvancedConfig.Default.reconnectOnInit, reconnectionPolicy: ReconnectionPolicyConfig = AdvancedConfig.Default.reconnectionPolicy, retryPolicy: RetryPolicyConfig = AdvancedConfig.Default.retryPolicy, speculativeExecutionPolicy: SpeculativeExecutionPolicyConfig = AdvancedConfig.Default.speculativeExecutionPolicy, authProvider: Option[AuthProviderConfig] = AdvancedConfig.Default.authProvider, timestampGenerator: TimestampGeneratorConfig = AdvancedConfig.Default.timestampGenerator, requestTracker: RequestTrackerConfig = AdvancedConfig.Default.requestTracker, throttler: ThrottlerConfig = AdvancedConfig.Default.throttler, nodeStateListener: NodeStateListenerConfig = AdvancedConfig.Default.nodeStateListener, schemaChangeListener: SchemaChangeListenerConfig = AdvancedConfig.Default.schemaChangeListener, addressTranslator: AddressTranslatorConfig = AdvancedConfig.Default.addressTranslator, resolveContactPoints: Boolean = AdvancedConfig.Default.resolveContactPoints, protocol: ProtocolConfig = AdvancedConfig.Default.protocol, request: AdvancedRequestConfig = AdvancedConfig.Default.request, metrics: MetricsConfig = AdvancedConfig.Default.metrics, heartbeat: HeartbeatConfig = AdvancedConfig.Default.heartbeat, socket: SocketConfig = AdvancedConfig.Default.socket, metadata: MetadataConfig = AdvancedConfig.Default.metadata, controlConnection: ControlConnectionConfig = AdvancedConfig.Default.controlConnection, preparedStatements: PreparedStatementsConfig = AdvancedConfig.Default.preparedStatements, netty: NettyConfig = AdvancedConfig.Default.netty, coalescer: CoalescerConfig = AdvancedConfig.Default.coalescer) extends Product with Serializable
Advanced datastax driver configuration
- connection
Configures query connection.
- reconnectOnInit
Whether to schedule reconnection attempts if all contact points are unreachable on the first initialization attempt. If this is true, the driver will retry according to the reconnection policy. The
SessionBuilder.build()call -- or the future returned bySessionBuilder.buildAsync()-- won't complete until a contact point has been reached. If this is false and no contact points are available, the driver will fail.- reconnectionPolicy
The policy that controls how often the driver tries to re-establish connections to down nodes.
- retryPolicy
The policy that controls if the driver retries requests that have failed on one node.
- speculativeExecutionPolicy
The policy that controls if the driver pre-emptively tries other nodes if a node takes too long to respond.
- authProvider
if
Noneno authentication will occur.- timestampGenerator
The generator that assigns a microsecond timestamp to each request.
- requestTracker
A session-wide component that tracks the outcome of requests. By default
com.datastax.oss.driver.internal.core.trackerNoopRequestTrackeris used.- throttler
A session-wide component that controls the rate at which requests are executed. By default
PassThroughRequestThrottleris used.- nodeStateListener
A session-wide component that listens for node state changes. By default
com.datastax.oss.driver.internal.core.metadata.NoopNodeStateListeneris used.- schemaChangeListener
A session-wide component that listens for node state changes. By default
com.datastax.oss.driver.internal.core.metadata.schema.NoopSchemaChangeListeneris used.- addressTranslator
The address translator to use to convert the addresses sent by Cassandra nodes into ones that the driver uses to connect. By default
com.datastax.oss.driver.internal.core.addresstranslation.PassThroughAddressTranslatoris used.- resolveContactPoints
Whether to resolve the addresses passed to
Basic.contactPoints. If this is true, addresses are created withInetSocketAddress(String, int): the host name will be resolved the first time, and the driver will use the resolved IP address for all subsequent connection attempts. If this is false, addresses are created withInetSocketAddress.createUnresolved(): the host name will be resolved again every time the driver opens a new connection. This is useful for containerized environments where DNS records are more likely to change over time (note that the JVM and OS have their own DNS caching mechanisms, so you might need additional configuration beyond the driver).- protocol
The native protocol to use which defines the format of the binary messages between driver and Cassandra.
- request
Request configuration.
- metrics
Metrics configuration. Disabled by default.
- heartbeat
Heartbeat configuration to check if node is alive.
- socket
Socket configuration.
- metadata
Metadata about the Cassandra cluster.
- controlConnection
Configures dedicated administrative connection.
- preparedStatements
Prepared statements configuration.
- netty
Netty configuration which is used internally by driver.
- coalescer
The component that coalesces writes on the connections.
- Alphabetic
- By Inheritance
- AdvancedConfig
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AdvancedConfig(connection: ConnectionConfig = AdvancedConfig.Default.connection, reconnectOnInit: Boolean = AdvancedConfig.Default.reconnectOnInit, reconnectionPolicy: ReconnectionPolicyConfig = AdvancedConfig.Default.reconnectionPolicy, retryPolicy: RetryPolicyConfig = AdvancedConfig.Default.retryPolicy, speculativeExecutionPolicy: SpeculativeExecutionPolicyConfig = AdvancedConfig.Default.speculativeExecutionPolicy, authProvider: Option[AuthProviderConfig] = AdvancedConfig.Default.authProvider, timestampGenerator: TimestampGeneratorConfig = AdvancedConfig.Default.timestampGenerator, requestTracker: RequestTrackerConfig = AdvancedConfig.Default.requestTracker, throttler: ThrottlerConfig = AdvancedConfig.Default.throttler, nodeStateListener: NodeStateListenerConfig = AdvancedConfig.Default.nodeStateListener, schemaChangeListener: SchemaChangeListenerConfig = AdvancedConfig.Default.schemaChangeListener, addressTranslator: AddressTranslatorConfig = AdvancedConfig.Default.addressTranslator, resolveContactPoints: Boolean = AdvancedConfig.Default.resolveContactPoints, protocol: ProtocolConfig = AdvancedConfig.Default.protocol, request: AdvancedRequestConfig = AdvancedConfig.Default.request, metrics: MetricsConfig = AdvancedConfig.Default.metrics, heartbeat: HeartbeatConfig = AdvancedConfig.Default.heartbeat, socket: SocketConfig = AdvancedConfig.Default.socket, metadata: MetadataConfig = AdvancedConfig.Default.metadata, controlConnection: ControlConnectionConfig = AdvancedConfig.Default.controlConnection, preparedStatements: PreparedStatementsConfig = AdvancedConfig.Default.preparedStatements, netty: NettyConfig = AdvancedConfig.Default.netty, coalescer: CoalescerConfig = AdvancedConfig.Default.coalescer)
- connection
Configures query connection.
- reconnectOnInit
Whether to schedule reconnection attempts if all contact points are unreachable on the first initialization attempt. If this is true, the driver will retry according to the reconnection policy. The
SessionBuilder.build()call -- or the future returned bySessionBuilder.buildAsync()-- won't complete until a contact point has been reached. If this is false and no contact points are available, the driver will fail.- reconnectionPolicy
The policy that controls how often the driver tries to re-establish connections to down nodes.
- retryPolicy
The policy that controls if the driver retries requests that have failed on one node.
- speculativeExecutionPolicy
The policy that controls if the driver pre-emptively tries other nodes if a node takes too long to respond.
- authProvider
if
Noneno authentication will occur.- timestampGenerator
The generator that assigns a microsecond timestamp to each request.
- requestTracker
A session-wide component that tracks the outcome of requests. By default
com.datastax.oss.driver.internal.core.trackerNoopRequestTrackeris used.- throttler
A session-wide component that controls the rate at which requests are executed. By default
PassThroughRequestThrottleris used.- nodeStateListener
A session-wide component that listens for node state changes. By default
com.datastax.oss.driver.internal.core.metadata.NoopNodeStateListeneris used.- schemaChangeListener
A session-wide component that listens for node state changes. By default
com.datastax.oss.driver.internal.core.metadata.schema.NoopSchemaChangeListeneris used.- addressTranslator
The address translator to use to convert the addresses sent by Cassandra nodes into ones that the driver uses to connect. By default
com.datastax.oss.driver.internal.core.addresstranslation.PassThroughAddressTranslatoris used.- resolveContactPoints
Whether to resolve the addresses passed to
Basic.contactPoints. If this is true, addresses are created withInetSocketAddress(String, int): the host name will be resolved the first time, and the driver will use the resolved IP address for all subsequent connection attempts. If this is false, addresses are created withInetSocketAddress.createUnresolved(): the host name will be resolved again every time the driver opens a new connection. This is useful for containerized environments where DNS records are more likely to change over time (note that the JVM and OS have their own DNS caching mechanisms, so you might need additional configuration beyond the driver).- protocol
The native protocol to use which defines the format of the binary messages between driver and Cassandra.
- request
Request configuration.
- metrics
Metrics configuration. Disabled by default.
- heartbeat
Heartbeat configuration to check if node is alive.
- socket
Socket configuration.
- metadata
Metadata about the Cassandra cluster.
- controlConnection
Configures dedicated administrative connection.
- preparedStatements
Prepared statements configuration.
- netty
Netty configuration which is used internally by driver.
- coalescer
The component that coalesces writes on the connections.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val addressTranslator: AddressTranslatorConfig
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val authProvider: Option[AuthProviderConfig]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val coalescer: CoalescerConfig
- val connection: ConnectionConfig
- val controlConnection: ControlConnectionConfig
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- val heartbeat: HeartbeatConfig
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val metadata: MetadataConfig
- val metrics: MetricsConfig
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val netty: NettyConfig
- val nodeStateListener: NodeStateListenerConfig
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- val preparedStatements: PreparedStatementsConfig
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val protocol: ProtocolConfig
- val reconnectOnInit: Boolean
- val reconnectionPolicy: ReconnectionPolicyConfig
- val request: AdvancedRequestConfig
- val requestTracker: RequestTrackerConfig
- val resolveContactPoints: Boolean
- val retryPolicy: RetryPolicyConfig
- val schemaChangeListener: SchemaChangeListenerConfig
- val socket: SocketConfig
- val speculativeExecutionPolicy: SpeculativeExecutionPolicyConfig
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val throttler: ThrottlerConfig
- val timestampGenerator: TimestampGeneratorConfig
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])