Packages

c

com.couchbase.client.scala.manager.collection

ReactiveCollectionManager

class ReactiveCollectionManager extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReactiveCollectionManager
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ReactiveCollectionManager(async: AsyncCollectionManager)(implicit ec: ExecutionContext)

Value Members

  1. def createCollection(scopeName: String, collectionName: String, settings: CreateCollectionSettings, timeout: Duration, retryStrategy: RetryStrategy): SMono[Unit]
    Annotations
    @Volatile()
  2. def createCollection(scopeName: String, collectionName: String, settings: CreateCollectionSettings): SMono[Unit]
    Annotations
    @Volatile()
  3. def createScope(scopeName: String, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[Unit]
  4. def dropCollection(scopeName: String, collectionName: String, timeout: Duration, retryStrategy: RetryStrategy): SMono[Unit]
    Annotations
    @Volatile()
  5. def dropCollection(scopeName: String, collectionName: String): SMono[Unit]
    Annotations
    @Volatile()
  6. def dropScope(scopeName: String, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[Unit]
  7. implicit val ec: ExecutionContext
  8. def getAllScopes(timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SFlux[ScopeSpec]
  9. def updateCollection(scopeName: String, collectionName: String, settings: UpdateCollectionSettings, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[Unit]
    Annotations
    @Volatile()

Deprecated Value Members

  1. def createCollection(collection: CollectionSpec, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[Unit]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.4.11) Please use the overload that takes a CreateCollectionSettings

  2. def dropCollection(collection: CollectionSpec, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[Unit]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.4.11) Please use the overload that takes separate scopeName and collectionName

  3. def getScope(scopeName: String, timeout: Duration = defaultManagerTimeout, retryStrategy: RetryStrategy = defaultRetryStrategy): SMono[ScopeSpec]
    Annotations
    @deprecated
    Deprecated

    (Since version 1.1.2) use getAllScopes instead