class ReactiveScope extends AnyRef
Represents a Couchbase scope resource.
This is a reactive 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
- ReactiveScope
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ReactiveScope(async: AsyncScope, bucketName: String)
- bucketName
the name of the bucket this scope is on
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): SMono[ReactiveAnalyticsResult]
Performs an Analytics query against the cluster.
Performs an Analytics query against the cluster.
This is a blocking API. See Scope.async for an Future-based async version of this API, and Scope.reactive for a reactive version. The reactive version includes backpressure-aware row streaming.
The reason to use this Scope-based variant over
ReactiveCluster.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
ReactiveAnalyticsResult
- 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]) @native() @IntrinsicCandidate()
- def collection(collectionName: String): ReactiveCollection
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: ReactiveScopeEventingFunctionManager
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.ReactiveEventingFunctionManager, accessed from ReactiveCluster.eventingFunctions.
- Annotations
- @Uncommitted() @SinceCouchbase()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- 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
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def query(statement: String, options: QueryOptions = QueryOptions()): SMono[ReactiveQueryResult]
Performs a N1QL query against the cluster.
Performs a N1QL query against the cluster.
This is a reactive API. See Scope.async for an Future-based async version of this API, and Scope for a blocking version.
The reason to use this Scope-based variant over
ReactiveCluster.queryis that it will automatically provide the "query_context" parameter to the query service, allowing queries to be specified on scopes and collections without having to fully reference them 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
ReactiveQueryResult
- def search(indexName: String, request: SearchRequest, options: SearchOptions): SMono[ReactiveSearchResult]
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): SMono[ReactiveSearchResult]
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: ReactiveScopeSearchIndexManager
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]) @native()
- 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
- Deprecated