Packages

c

com.couchbase.client.scala.manager.query

AsyncQueryIndexManager

class AsyncQueryIndexManager extends AnyRef

Allows query indexes to be managed.

Annotations
@Volatile()
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncQueryIndexManager
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AsyncQueryIndexManager(cluster: AsyncCluster)(implicit ec: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def buildDeferredIndexes(bucketName: String, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Build all deferred indexes.

    Build all deferred indexes.

    bucketName

    the bucket to build indexes on.

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. def createIndex(bucketName: String, indexName: String, fields: Iterable[String], ignoreIfExists: Boolean = false, numReplicas: Option[Int] = None, deferred: Option[Boolean] = None, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Creates a new query index with the specified parameters.

    Creates a new query index with the specified parameters.

    bucketName

    the bucket to create the index on.

    indexName

    the name of the index.

    ignoreIfExists

    if an index with the same name already exists, the operation will fail.

    numReplicas

    how many replicas of the index to create.

    deferred

    set to true to defer building the index until buildDeferredIndexes is called. This can provide improved performance when creating multiple indexes.

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  8. def createPrimaryIndex(bucketName: String, indexName: Option[String] = None, ignoreIfExists: Boolean = false, numReplicas: Option[Int] = None, deferred: Option[Boolean] = None, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Creates a new primary query index with the specified parameters.

    Creates a new primary query index with the specified parameters.

    bucketName

    the bucket to create the index on.

    indexName

    the name of the index. If not set the server assigns the default primary index name.

    ignoreIfExists

    if a primary index already exists, the operation will fail.

    numReplicas

    how many replicas of the index to create.

    deferred

    set to true to defer building the index until buildDeferredIndexes is called. This can provide improved performance when creating multiple indexes.

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  9. def dropIndex(bucketName: String, indexName: String, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Drops an existing index.

    Drops an existing index.

    bucketName

    the bucket to remove the index from.

    indexName

    the name of the index.

    ignoreIfNotExists

    sets whether the operation should fail if the index does not exists

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  10. def dropPrimaryIndex(bucketName: String, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Drops an existing primary index.

    Drops an existing primary index.

    bucketName

    the bucket to remove the index from.

    ignoreIfNotExists

    sets whether the operation should fail if the index does not exists

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  11. implicit val ec: ExecutionContext
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. def getAllIndexes(bucketName: String, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Seq[QueryIndex]]

    Retries all indexes on a bucket.

    Retries all indexes on a bucket.

    bucketName

    the bucket to get indexes on

    timeout

    when the operation will timeout. This will default to timeoutConfig().managementTimeout () in the provided com.couchbase.client.scala.env.ClusterEnvironment.

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  27. def watchIndexes(bucketName: String, indexNames: Iterable[String], timeout: Duration, watchPrimary: Boolean = false, retryStrategy: RetryStrategy = DefaultRetryStrategy): Future[Unit]

    Polls the specified indexes until they are all online.

    Polls the specified indexes until they are all online.

    bucketName

    the bucket to remove the index from.

    indexNames

    the indexes to poll.

    timeout

    when the operation will timeout.

    watchPrimary

    include the bucket's primary index. If the bucket has no primary index, the operation will fail with IndexNotFoundException

    retryStrategy

    provides some control over how the SDK handles failures. Will default to retryStrategy() in the provided com.couchbase.client.scala.env.ClusterEnvironment.

  28. def wrap(in: Future[QueryResult], ignoreIfExists: Boolean, ignoreIfNotExists: Boolean): Future[Unit]

Inherited from AnyRef

Inherited from Any

Ungrouped