Packages

c

com.couchbase.client.scala.manager.query

CollectionQueryIndexManager

class CollectionQueryIndexManager extends AnyRef

Allows query indexes to be managed, at the Collection level.

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

Instance Constructors

  1. new CollectionQueryIndexManager(async: AsyncCollectionQueryIndexManager)(implicit ec: ExecutionContext)

Value Members

  1. def buildDeferredIndexes(timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Try[Unit]

    Build all deferred indexes on this collection .

    Build all deferred indexes on this collection .

    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.

  2. def createIndex(indexName: String, fields: Iterable[String], ignoreIfExists: Boolean = false, numReplicas: Option[Int] = None, deferred: Option[Boolean] = None, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Try[Unit]

    Creates a new query index on this collection, with the specified parameters.

    Creates a new query index on this collection, with the specified parameters.

    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.

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

    Creates a new primary query index on this collection, with the specified parameters.

    Creates a new primary query index on this collection, with the specified parameters.

    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.

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

    Drops an existing index on this collection.

    Drops an existing index on this collection.

    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.

  5. def dropPrimaryIndex(ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Try[Unit]

    Drops an existing primary index on this collection.

    Drops an existing primary index on this collection.

    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.

  6. implicit val ec: ExecutionContext
  7. def getAllIndexes(timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): Try[Seq[QueryIndex]]

    Gets all indexes on this collection.

    Gets all indexes on this collection.

    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 watchIndexes(indexNames: Iterable[String], timeout: Duration, watchPrimary: Boolean = false, retryStrategy: RetryStrategy = DefaultRetryStrategy): Try[Unit]

    Polls the specified indexes on this collection until they are all online.

    Polls the specified indexes on this collection until they are all online.

    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.