com.couchbase.client.scala.env.ClusterEnvironment

Builder

case class Builder(owned: Boolean, connectionString: Option[String] = None, ioEnvironment: Option[IoEnvironment] = None, ioConfig: Option[IoConfig] = None, compressionConfig: Option[CompressionConfig] = None, securityConfig: Option[SecurityConfig] = None, timeoutConfig: Option[TimeoutConfig] = None, loggerConfig: Option[LoggerConfig] = None, orphanReporterConfig: Option[OrphanReporterConfig] = None, eventBus: Option[EventBus] = None, scheduler: Option[Scheduler] = None, retryStrategy: Option[RetryStrategy] = None, requestTracer: Option[RequestTracer] = None, meter: Option[Meter] = None, maxNumRequestsInRetry: Option[Int] = None, transcoder: Option[Transcoder] = None, propertyLoaders: Seq[PropertyLoader[core.env.CoreEnvironment.Builder[SELF] forSome {type SELF <: core.env.CoreEnvironment.Builder[SELF]}]] = Seq(), thresholdRequestTracerConfig: Option[ThresholdRequestTracerConfig] = None, loggingMeterConfig: Option[LoggingMeterConfig] = None, transactionsConfig: Option[TransactionsConfig] = None, error: Option[Throwable] = None) extends Product with Serializable

Linear Supertypes

Serializable, Product, Equals, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

Builder
Serializable
Product
Equals
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Instance Constructors

new Builder(owned: Boolean, connectionString: Option[String] = None, ioEnvironment: Option[IoEnvironment] = None, ioConfig: Option[IoConfig] = None, compressionConfig: Option[CompressionConfig] = None, securityConfig: Option[SecurityConfig] = None, timeoutConfig: Option[TimeoutConfig] = None, loggerConfig: Option[LoggerConfig] = None, orphanReporterConfig: Option[OrphanReporterConfig] = None, eventBus: Option[EventBus] = None, scheduler: Option[Scheduler] = None, retryStrategy: Option[RetryStrategy] = None, requestTracer: Option[RequestTracer] = None, meter: Option[Meter] = None, maxNumRequestsInRetry: Option[Int] = None, transcoder: Option[Transcoder] = None, propertyLoaders: Seq[PropertyLoader[core.env.CoreEnvironment.Builder[SELF] forSome {type SELF <: core.env.CoreEnvironment.Builder[SELF]}]] = Seq(), thresholdRequestTracerConfig: Option[ThresholdRequestTracerConfig] = None, loggingMeterConfig: Option[LoggingMeterConfig] = None, transactionsConfig: Option[TransactionsConfig] = None, error: Option[Throwable] = None)

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
def applyProfile(profileName: String): Builder
Applies custom properties based on a profile name.
Applies custom properties based on a profile name.
At the moment only the "wan-development" profile is supported.
returns
this, for chaining purposes.
Annotations
@Volatile()
final def asInstanceOf[T0]: T0
Definition Classes
Any
def build: Try[ClusterEnvironment]
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
def compressionConfig(config: CompressionConfig): Builder
Sets the CompressionConfig config.
Sets the CompressionConfig config.
returns
this, for chaining
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def eventBus(eventBus: EventBus): Builder
Sets the EventBus.
Sets the EventBus.
returns
this, for chaining
Annotations
@Uncommitted()
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
def ioConfig(config: IoConfig): Builder
Sets the IoConfig config.
Sets the IoConfig config.
returns
this, for chaining
def ioEnvironment(config: IoEnvironment): Builder
Sets the IoEnvironment config.
Sets the IoEnvironment config.
returns
this, for chaining
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
def loaders(propertyLoaders: Seq[PropertyLoader[core.env.CoreEnvironment.Builder[SELF] forSome {type SELF <: core.env.CoreEnvironment.Builder[SELF]}]]): Builder
Allows to provide custom property loaders into the environment.
Allows to provide custom property loaders into the environment.
propertyLoaders
the custom property loaders.
returns
this, for chaining purposes.
def loggerConfig(config: LoggerConfig): Builder
Sets the IoConfig config.
Sets the IoConfig config.
returns
this, for chaining
def loggingMeterConfig(config: LoggingMeterConfig): Builder
Allows configuring the logging meter.
Allows configuring the logging meter.
returns
this, for chaining purposes.
def maxNumRequestsInRetry(value: Int): Builder
Customize the maximum number of requests allowed in the retry timer.
Customize the maximum number of requests allowed in the retry timer.
If the limit is reached, each request that would be queued for retry is instead cancelled with a CancellationReason of TOO_MANY_REQUESTS_IN_RETRY. This acts as a form of backpressure.
returns
this, for chaining
def meter(meter: Meter): Builder
Sets the default Meter to use for all operations.
Sets the default Meter to use for all operations.
returns
this, for chaining
Annotations
@Volatile()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
def orphanReporterConfig(config: OrphanReporterConfig): Builder
Sets the OrphanReporterConfig config.
Sets the OrphanReporterConfig config.
returns
this, for chaining
def productElementNames: Iterator[String]
Definition Classes
Product
def requestTracer(requestTracer: RequestTracer): Builder
Sets the default RequestTracer to use for all operations.
Sets the default RequestTracer to use for all operations.
returns
this, for chaining
Annotations
@Volatile()
def retryStrategy(value: RetryStrategy): Builder
Sets the default com.couchbase.client.core.retry.RetryStrategy to use for all operations.
Sets the default com.couchbase.client.core.retry.RetryStrategy to use for all operations.
returns
this, for chaining
def scheduler(scheduler: Scheduler): Builder
Sets the reactive Scheduler to use for operations.
Sets the reactive Scheduler to use for operations.
returns
this, for chaining
Annotations
@Uncommitted()
def securityConfig(config: SecurityConfig): Builder
Sets the SecurityConfig config.
Sets the SecurityConfig config.
returns
this, for chaining
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def thresholdRequestTracerConfig(config: ThresholdRequestTracerConfig): Builder
Allows configuring the threshold request tracer.
Allows configuring the threshold request tracer.
returns
this, for chaining purposes.
def timeoutConfig(config: TimeoutConfig): Builder
Sets the TimeoutConfig config.
Sets the TimeoutConfig config.
returns
this, for chaining
def transactionsConfig(config: TransactionsConfig): Builder
Configurations transactions.
Configurations transactions.
returns
this, for chaining purposes.
def transcoder(transcoder: Transcoder): Builder
Allows to override the default transcoder to be used for all KV operations.
Allows to override the default transcoder to be used for all KV operations.
returns
this, for chaining purposes.
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])

Ungrouped

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
def applyProfile(profileName: String): Builder
Applies custom properties based on a profile name.
Applies custom properties based on a profile name.
At the moment only the "wan-development" profile is supported.
returns
this, for chaining purposes.
Annotations
@Volatile()
final def asInstanceOf[T0]: T0
Definition Classes
Any
def build: Try[ClusterEnvironment]
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
def compressionConfig(config: CompressionConfig): Builder
Sets the CompressionConfig config.
Sets the CompressionConfig config.
returns
this, for chaining
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def eventBus(eventBus: EventBus): Builder
Sets the EventBus.
Sets the EventBus.
returns
this, for chaining
Annotations
@Uncommitted()
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
def ioConfig(config: IoConfig): Builder
Sets the IoConfig config.
Sets the IoConfig config.
returns
this, for chaining
def ioEnvironment(config: IoEnvironment): Builder
Sets the IoEnvironment config.
Sets the IoEnvironment config.
returns
this, for chaining
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
def loaders(propertyLoaders: Seq[PropertyLoader[core.env.CoreEnvironment.Builder[SELF] forSome {type SELF <: core.env.CoreEnvironment.Builder[SELF]}]]): Builder
Allows to provide custom property loaders into the environment.
Allows to provide custom property loaders into the environment.
propertyLoaders
the custom property loaders.
returns
this, for chaining purposes.
def loggerConfig(config: LoggerConfig): Builder
Sets the IoConfig config.
Sets the IoConfig config.
returns
this, for chaining
def loggingMeterConfig(config: LoggingMeterConfig): Builder
Allows configuring the logging meter.
Allows configuring the logging meter.
returns
this, for chaining purposes.
def maxNumRequestsInRetry(value: Int): Builder
Customize the maximum number of requests allowed in the retry timer.
Customize the maximum number of requests allowed in the retry timer.
If the limit is reached, each request that would be queued for retry is instead cancelled with a CancellationReason of TOO_MANY_REQUESTS_IN_RETRY. This acts as a form of backpressure.
returns
this, for chaining
def meter(meter: Meter): Builder
Sets the default Meter to use for all operations.
Sets the default Meter to use for all operations.
returns
this, for chaining
Annotations
@Volatile()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
def orphanReporterConfig(config: OrphanReporterConfig): Builder
Sets the OrphanReporterConfig config.
Sets the OrphanReporterConfig config.
returns
this, for chaining
def productElementNames: Iterator[String]
Definition Classes
Product
def requestTracer(requestTracer: RequestTracer): Builder
Sets the default RequestTracer to use for all operations.
Sets the default RequestTracer to use for all operations.
returns
this, for chaining
Annotations
@Volatile()
def retryStrategy(value: RetryStrategy): Builder
Sets the default com.couchbase.client.core.retry.RetryStrategy to use for all operations.
Sets the default com.couchbase.client.core.retry.RetryStrategy to use for all operations.
returns
this, for chaining
def scheduler(scheduler: Scheduler): Builder
Sets the reactive Scheduler to use for operations.
Sets the reactive Scheduler to use for operations.
returns
this, for chaining
Annotations
@Uncommitted()
def securityConfig(config: SecurityConfig): Builder
Sets the SecurityConfig config.
Sets the SecurityConfig config.
returns
this, for chaining
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def thresholdRequestTracerConfig(config: ThresholdRequestTracerConfig): Builder
Allows configuring the threshold request tracer.
Allows configuring the threshold request tracer.
returns
this, for chaining purposes.
def timeoutConfig(config: TimeoutConfig): Builder
Sets the TimeoutConfig config.
Sets the TimeoutConfig config.
returns
this, for chaining
def transactionsConfig(config: TransactionsConfig): Builder
Configurations transactions.
Configurations transactions.
returns
this, for chaining purposes.
def transcoder(transcoder: Transcoder): Builder
Allows to override the default transcoder to be used for all KV operations.
Allows to override the default transcoder to be used for all KV operations.
returns
this, for chaining purposes.
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])
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
Deprecated

Packages

Builder

Instance Constructors

Value Members

Deprecated Value Members

Inherited from Product

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Packages

Builder

Instance Constructors

Value Members

Deprecated Value Members

Inherited from Product

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Builder