Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def analyticsQuery(statement: String, options: AnalyticsOptions = AnalyticsOptions.analyticsOptions())(implicit scope: AsyncScope): Source[AnalyticsResult, NotUsed]

   Performs an Analytics query , QueryResult contains List<Row>

   Performs an Analytics query , QueryResult contains List<Row>

   val rows: List[JsonObject] = QueryResult.rowsAsObject, every Row is a json with CollectionName key

      {
        "collectionName": Document
      }
   

   Warning: couchbase-community not support analyticsQuery, we not test this API https://www.couchbase.com/products/editions/server/

   statement

   Analytics query sql

5.  def analyticsQueryJson(statement: String, options: AnalyticsOptions = AnalyticsOptions.analyticsOptions())(implicit scope: AsyncScope): Source[JsonObject, NotUsed]

   Warning: couchbase-community not support analyticsQuery, we not test this API

   Warning: couchbase-community not support analyticsQuery, we not test this API

   Performs an Analytics query and convert document row to jsonObject
   different with analyticsQuery, jsonObject not has the collection Key, but is Document directly
   

   See also

   CouchbaseSource.analyticsQuery

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

8.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

9.  def equals(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef → Any

10.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

11.  def get(id: String, options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[GetResult, NotUsed]

    get a document by id from Couchbase collection

    get a document by id from Couchbase collection

    id

    document id

    options

    reference to Couchbase options doc

12.  def getAllReplicas(id: String, options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[GetReplicaResult, NotUsed]

    similar to CouchbaseSource.get .Reads from replicas or the active node based on the options and returns the results as a list

    similar to CouchbaseSource.get .Reads from replicas or the active node based on the options and returns the results as a list

    options

    reference to Couchbase options doc

    See also

    CouchbaseSource#get

13.  def getAllReplicasJson(id: String, options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]

    reference to CouchbaseSource.getAllReplicas, deserialize to Couchbase JsonObject

14.  def getAllReplicasObject[T](id: String, target: Class[T], options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.getAllReplicas, deserialize to class If you add DefaultScalaModule to jackson of couchbase, it could deserialize to scala class

15.  def getAllReplicasType[T](id: String, target: TypeRef[T], options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.getAllReplicasObject, deserialize to class with Generics

16.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

17.  def getJson(id: String, options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]

    reference to CouchbaseSource.get deserialize to Couchbase JsonObject

18.  def getObject[T](id: String, target: Class[T], options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.get,deserialize to class

19.  def getType[T](id: String, target: TypeRef[T], options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.getObject,deserialize to class with Generics

20.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

21.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

22.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

23.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

24.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

25.  def query(statement: String, options: QueryOptions = QueryOptions.queryOptions())(implicit scope: AsyncScope): Source[QueryResult, NotUsed]

    N1QL query in a Scope.

    N1QL query in a Scope.

    QueryResult contains List<Row>, every Row is a json like

      {
        "collectionName": Document
      }
    

26.  def queryAllIndex(options: GetAllQueryIndexesOptions = GetAllQueryIndexesOptions.getAllQueryIndexesOptions)(implicit asyncCollection: AsyncCollection): Source[QueryIndex, NotUsed]

    Fetches all indexes from this collection with custom options.

    Fetches all indexes from this collection with custom options.

    See also

    com.couchbase.client.java.manager.query.AsyncCollectionQueryIndexManager#getAllIndexes

27.  def queryJson(statement: String, options: QueryOptions = QueryOptions.queryOptions())(implicit scope: AsyncScope): Source[JsonObject, NotUsed]

    N1QL query in a Scope.

    N1QL query in a Scope.

    statement

    N1QL query sql

    See also

    CouchbaseSource.query

28.  def scan(scanType: ScanType, options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[ScanResult, NotUsed]

    similar to GetCouchbaseSource.get, batch get documents from collection by ScanTypeScanType

29.  def scanJson(scanType: ScanType, options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[JsonObject, NotUsed]

    reference to CouchbaseSource.scan, deserialize to Couchbase JsonObject

30.  def scanObject[T](scanType: ScanType, target: Class[T], options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.scan, deserialize to class If you add DefaultScalaModule to jackson of couchbase, it could deserialize to scala class

31.  def scanType[T](scanType: ScanType, target: TypeRef[T], options: ScanOptions = ScanOptions.scanOptions())(implicit asyncCollection: AsyncCollection): Source[T, NotUsed]

    reference to CouchbaseSource.scan, CouchbaseSource.scanObject, deserialize to class with Generics

32.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

33.  def toString(): String

    Definition Classes

    AnyRef → Any

34.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

35.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

36.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()