class AsyncScope extends AnyRef
Represents a Couchbase scope resource.
This is an asynchronous version of the Scope interface.
Applications should not create these manually, but instead first open a Cluster and through that a Bucket.
- Since
1.0.0
- Alphabetic
- By Inheritance
- AsyncScope
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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 analyticsQuery(statement: String, options: AnalyticsOptions = AnalyticsOptions.Default): Future[AnalyticsResult]
Performs an Analytics query against the cluster.
Performs an Analytics query against the cluster.
This is asynchronous. See Cluster.reactive for a reactive streaming version of this API, and Cluster for a blocking version. The reactive version includes backpressure-aware row streaming.
The reason to use this Scope-based variant over
AsyncCluster.analyticsQueryis that it will automatically provide the "query_context" parameter to the query service, allowing queries to be performed on collections without having to fully specify their bucket and scope names in the query statement.- statement
the Analytics query to execute
- options
any query options - see com.couchbase.client.scala.analytics.AnalyticsOptions for documentation
- returns
a
Futurecontaining aSuccess(AnalyticsResult)(which includes any returned rows) if successful, else aFailure
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bucketName: String
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def collection(collectionName: String): AsyncCollection
Opens and returns a Couchbase collection resource, that exists on this scope.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- lazy val eventingFunctions: AsyncScopeEventingFunctionManager
Allows managing eventing functions on this scope.
Allows managing eventing functions on this scope.
For managing eventing functions at the admin scope ("*.*") level, see com.couchbase.client.scala.manager.eventing.AsyncEventingFunctionManager, accessed from AsyncCluster.eventingFunctions.
- Annotations
- @Uncommitted() @SinceCouchbase()
- 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
- def name: String
The name of this scope.
- 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()
- def query(statement: String, options: QueryOptions = QueryOptions()): Future[QueryResult]
Performs a N1QL query against the cluster.
Performs a N1QL query against the cluster.
This is asynchronous. See Scope.reactive for a reactive streaming version of this API, and Scope for a blocking version. The reactive version includes backpressure-aware row streaming.
The reason to use this Scope-based variant over
AsyncCluster.queryis that it will automatically provide the "query_context" parameter to the query service, allowing queries to be performed on collections without having to fully specify their bucket and scope names in the query statement.- statement
the N1QL statement to execute
- options
any query options - see com.couchbase.client.scala.query.QueryOptions for documentation
- returns
a
Futurecontaining aSuccess(QueryResult)(which includes any returned rows) if successful, else aFailure
- def search(indexName: String, request: SearchRequest, options: SearchOptions): Future[SearchResult]
Performs a Full Text Search (FTS) query.
Performs a Full Text Search (FTS) query.
This can be used to perform a traditional FTS query, and/or a vector search.
Use this to access scoped FTS indexes, and Cluster.search for global indexes.
- indexName
the name of the search index to use
- request
the request to send to the FTS service.
- options
- returns
a
Trycontaining aSuccess(SearchResult)(which includes any returned rows) if successful, else aFailure
- Annotations
- @SinceCouchbase()
- def search(indexName: String, request: SearchRequest): Future[SearchResult]
Performs a Full Text Search (FTS) query.
Performs a Full Text Search (FTS) query.
This can be used to perform a traditional FTS query, and/or a vector search.
Use this to access scoped FTS indexes, and Cluster.search for global indexes.
- indexName
the name of the search index to use
- request
the request to send to the FTS service.
- returns
a
Trycontaining aSuccess(SearchResult)(which includes any returned rows) if successful, else aFailure
- Annotations
- @SinceCouchbase()
- lazy val searchIndexes: AsyncScopeSearchIndexManager
Allows managing scoped FTS indexes.
Allows managing scoped FTS indexes.
- Annotations
- @SinceCouchbase()
- 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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)