Packages

  • package root
    Definition Classes
    root
  • package com
    Definition Classes
    root
  • package couchbase
    Definition Classes
    com
  • package client
    Definition Classes
    couchbase
  • package scala
    Definition Classes
    client
  • package env
    Definition Classes
    scala
  • object ClusterEnvironment

    Functions to create a ClusterEnvironment, which provides configuration options for connecting to a Couchbase cluster.

    Functions to create a ClusterEnvironment, which provides configuration options for connecting to a Couchbase cluster.

    This environment also contains long-lived resources such as a thread-pool, so the application should take care to only create one of these. The same environment can be shared by multiple cluster connections.

    Definition Classes
    env
  • 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, maxNumRequestsInRetry: Option[Int] = None, transcoder: Option[Transcoder] = None) extends Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Builder
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. 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, maxNumRequestsInRetry: Option[Int] = None, transcoder: Option[Transcoder] = None)

Value Members

  1. def build: Try[ClusterEnvironment]
  2. def compressionConfig(config: CompressionConfig): Builder

    Sets the CompressionConfig config.

    Sets the CompressionConfig config.

    returns

    this, for chaining

  3. def eventBus(eventBus: EventBus): Builder

    Sets the EventBus.

    Sets the EventBus.

    returns

    this, for chaining

    Annotations
    @Uncommitted()
  4. def ioConfig(config: IoConfig): Builder

    Sets the IoConfig config.

    Sets the IoConfig config.

    returns

    this, for chaining

  5. def ioEnvironment(config: IoEnvironment): Builder

    Sets the IoEnvironment config.

    Sets the IoEnvironment config.

    returns

    this, for chaining

  6. def loggerConfig(config: LoggerConfig): Builder

    Sets the IoConfig config.

    Sets the IoConfig config.

    returns

    this, for chaining

  7. 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

  8. def orphanReporterConfig(config: OrphanReporterConfig): Builder

    Sets the OrphanReporterConfig config.

    Sets the OrphanReporterConfig config.

    returns

    this, for chaining

  9. 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()
  10. 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

  11. 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()
  12. def securityConfig(config: SecurityConfig): Builder

    Sets the SecurityConfig config.

    Sets the SecurityConfig config.

    returns

    this, for chaining

  13. def timeoutConfig(config: TimeoutConfig): Builder

    Sets the TimeoutConfig config.

    Sets the TimeoutConfig config.

    returns

    this, for chaining

  14. 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.