class ReactiveQueryIndexManager extends AnyRef
Allows query indexes to be managed.
Operations take a bucketName, scopeName and collectionName.
If only bucketName is provided, the indexes affected will be those on the bucket's default scope and collection. If bucketName and scopeName are provided, the indexes affected will be all those on collections under that scope. If bucketName, scopeName and collectionName are provided, the affected fetched will be on that specific collection.
- Alphabetic
- By Inheritance
- ReactiveQueryIndexManager
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ReactiveQueryIndexManager(async: AsyncQueryIndexManager, cluster: ReactiveCluster)(implicit ec: ExecutionContext)
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def buildDeferredIndexes(bucketName: String, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- 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, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
- 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, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
- def dropIndex(bucketName: String, indexName: String, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
- def dropPrimaryIndex(bucketName: String, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
- implicit val ec: ExecutionContext
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getAllIndexes(bucketName: String, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, scopeName: Option[String] = None, collectionName: Option[String] = None): SFlux[QueryIndex]
Gets all indexes.
Gets all indexes.
If only bucketName is provided, all indexes for that bucket will be fetched, for all scopes and collections. If bucketName and scopeName are provided, the indexes fetched will be all those on collections under that scope. If bucketName, scopeName and collectionName are provided, the indexes fetched will be on that specific collection.
- 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.- scopeName
if specified, the indexes fetched will be limited to those on collections under this com.couchbase.client.scala.Scope
- collectionName
if specified, the indexes fetched will be limited to those on this specific com.couchbase.client.scala.Collection
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def watchIndexes(bucketName: String, indexNames: Iterable[String], timeout: Duration, watchPrimary: Boolean = false, retryStrategy: RetryStrategy = DefaultRetryStrategy, scopeName: Option[String] = None, collectionName: Option[String] = None): SMono[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.- scopeName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
collectionNamemust also be specified.- collectionName
if specified, this operation will work on a given com.couchbase.client.scala.Scope and com.couchbase.client.scala.Collection. If specified,
scopeNamemust also be specified.
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)