com.couchbase.client.scala.manager.analytics
ReactiveAnalyticsIndexManager
Companion object ReactiveAnalyticsIndexManager
class ReactiveAnalyticsIndexManager extends AnyRef
- Alphabetic
- By Inheritance
- ReactiveAnalyticsIndexManager
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ReactiveAnalyticsIndexManager(cluster: ReactiveCluster, async: => AsyncAnalyticsIndexManager)
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 clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def createDataset(datasetName: String, bucketName: String, dataverseName: Option[String] = None, condition: Option[String] = None, ignoreIfExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def createDataverse(dataverseName: String, ignoreIfExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def createIndex(indexName: String, datasetName: String, fields: Map[String, AnalyticsDataType], dataverseName: Option[String] = None, ignoreIfExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def createLink(link: AnalyticsLink, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, parentSpan: Option[RequestSpan] = None): SMono[Void]
Create an analytics link.
Create an analytics link. See the AnalyticsLink documentation for the types of links that can be created.
If a link with the same name already exists, a
LinkExistsException
will be raised. - def dropDataset(datasetName: String, dataverseName: Option[String] = None, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def dropDataverse(dataverseName: String, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def dropIndex(indexName: String, datasetName: String, dataverseName: Option[String] = None, ignoreIfNotExists: Boolean = false, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SMono[Unit]
- def dropLink(linkName: String, dataverse: String, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, parentSpan: Option[RequestSpan] = None): SMono[Void]
Drops (deletes) an existing analytics link.
Drops (deletes) an existing analytics link.
If no such link exists, a
LinkNotFoundException
will be raised. - final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getAllDatasets(timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SFlux[AnalyticsDataset]
- def getAllIndexes(timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy): SFlux[AnalyticsIndex]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getLinks(dataverse: Option[String] = None, name: Option[String] = None, linkType: Option[AnalyticsLinkType] = None, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, parentSpan: Option[RequestSpan] = None): SFlux[AnalyticsLink]
Gets analytics links.
Gets analytics links.
If
dataverse
,name
andlinkType
are allNone
, then all links are returned. Ifdataverse
is specified then links returned will all be from that dataverse. Ifdataverse
andname
specified then a maximum of one link will be returned, matching that name. (It is illegal to specifyname
but notdataverse
- a InvalidArgumentException will be raised in this situation.) IflinkType
is specified then links returned will all match that link type.It is legal to combine
linkType
anddataverse
. - 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()
- def replaceLink(link: AnalyticsLink, timeout: Duration = DefaultTimeout, retryStrategy: RetryStrategy = DefaultRetryStrategy, parentSpan: Option[RequestSpan] = None): SMono[Void]
Replaces an existing analytics link.
Replaces an existing analytics link.
Note that on fetching an existing link e.g. with GetAllLinks, some returned fields will intentionally be blanked out (empty strings) for security reasons. It may be necessarily to reconstruct the original AnalyticsLink with this security information before calling this method.
If no such link exists, a
LinkNotFoundException
will be raised. - 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)