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 append(options: AppendOptions = AppendOptions.appendOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationBinaryDocument, MutationResult, NotUsed]

   Appends binary content to the document with custom options.

   Appends binary content to the document with custom options.

   See also

   com.couchbase.client.java.AsyncBinaryCollection#append

5.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

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

7.  def decrement(options: DecrementOptions = DecrementOptions.decrementOptions())(implicit asyncCollection: AsyncCollection): Flow[String, CounterResult, NotUsed]

   Decrements the counter document by one or the number defined in the options.

   Decrements the counter document by one or the number defined in the options.

   See also

   com.couchbase.client.java.AsyncBinaryCollection#decrement

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

   Definition Classes

   AnyRef

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

   Definition Classes

   AnyRef → Any

10.  def exists[T](applyId: (T) => String, existsOptions: ExistsOptions = ExistsOptions.existsOptions())(implicit asyncCollection: AsyncCollection): Flow[T, Boolean, NotUsed]

    Checks if the given document ID exists on the active partition with custom options.

    Checks if the given document ID exists on the active partition with custom options.

    applyId

    parse id function, which is the document id, id streams can use exists[String](e => e)

    See also

    com.couchbase.client.java.AsyncCollection#exists

11.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    get a document by id from Couchbase collection

    get a document by id from Couchbase collection

    options

    reference to Couchbase options doc

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

    same to Get option, but reads from all replicas on the active node

    same to Get option, but reads from all replicas on the active node

    See also

    CouchbaseFlow#get

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

    reference to CouchbaseFlow.getAllReplicas, deserialize to Couchbase JsonObject

15.  def getAllReplicasObject[T](target: Class[T], getOptions: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Flow[String, T, NotUsed]

    reference to CouchbaseFlow.getAllReplicas, deserialize to class

16.  def getAllReplicasType[T](target: TypeRef[T], getOptions: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Flow[String, T, NotUsed]

    reference to CouchbaseFlow.getAllReplicasObject, deserialize to class with Generics

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

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

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

    reference to CouchbaseFlow.get deserialize to Couchbase JsonObject

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

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

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

    reference to CouchbaseSource.getObject,deserialize to class with Generics

21.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

22.  def increment(options: IncrementOptions = IncrementOptions.incrementOptions())(implicit asyncCollection: AsyncCollection): Flow[String, CounterResult, NotUsed]

    Increments the counter document by one or the number defined in the options.

    Increments the counter document by one or the number defined in the options.

    See also

    com.couchbase.client.java.AsyncBinaryCollection#increment

23.  def insert[T](applyId: (T) => String, insertOptions: InsertOptions = InsertOptions.insertOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Inserts a full document which does not exist yet with custom options.

    Inserts a full document which does not exist yet with custom options.

    applyId

    parse id function, which is the document id

    See also

    com.couchbase.client.java.AsyncCollection#insert

24.  def insertDoc[T](insertOptions: InsertOptions = InsertOptions.insertOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationDocument[T], MutationDocument[T], NotUsed]

    reference to CouchbaseFlow.insert
    use MutationDocument to wrapper id, document and result(MutationResult)

25.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

26.  def mutateIn(specs: List[MutateInSpec], options: MutateInOptions = MutateInOptions.mutateInOptions())(implicit asyncCollection: AsyncCollection): Flow[String, MutateInResult, NotUsed]

    Performs mutations to document fragments with custom options.

    Performs mutations to document fragments with custom options.

    See also

    com.couchbase.client.java.AsyncCollection#mutateIn

27.  def mutateInDoc[T](specs: List[MutateInSpec], options: MutateInOptions = MutateInOptions.mutateInOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationDocument[T], MutationDocument[T], NotUsed]

    reference to CouchbaseFlow.mutateIn use MutationDocument to wrapper id, document and result(MutationResult)

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

    Definition Classes

    AnyRef

29.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

30.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

31.  def prepend(options: PrependOptions = PrependOptions.prependOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationBinaryDocument, MutationResult, NotUsed]

    Prepends binary content to the document with custom options.

    Prepends binary content to the document with custom options.

    See also

    com.couchbase.client.java.AsyncBinaryCollection#prepend

32.  def remove[T](applyId: (T) => String, removeOptions: RemoveOptions = RemoveOptions.removeOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Removes a Document from a collection with custom options.

    Removes a Document from a collection with custom options.

    applyId

    parse id function, which is the document id, id streams can use remove[String](e => e)

    See also

    com.couchbase.client.java.AsyncCollection#remove

33.  def replace[T](applyId: (T) => String, replaceOptions: ReplaceOptions = ReplaceOptions.replaceOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Replaces a full document which already exists with custom options.

    Replaces a full document which already exists with custom options.

    applyId

    parse id function, which is the document id

    See also

    com.couchbase.client.java.AsyncCollection#replace

34.  def replaceDoc[T](replaceOptions: ReplaceOptions = ReplaceOptions.replaceOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationDocument[T], MutationDocument[T], NotUsed]

    reference to CouchbaseFlow.replace use MutationDocument to wrapper id, document and result(MutationResult)

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

    Definition Classes

    AnyRef

36.  def toString(): String

    Definition Classes

    AnyRef → Any

37.  def touch(expiry: Duration, options: TouchOptions = TouchOptions.touchOptions())(implicit asyncCollection: AsyncCollection): Flow[String, MutationResult, NotUsed]

    Updates the expiry of the document with the given id with custom options.

    Updates the expiry of the document with the given id with custom options.

    See also

    com.couchbase.client.java.AsyncCollection#touch

38.  def touchDuration[T](applyId: (T) => String, expiry: Duration, touchOptions: TouchOptions = TouchOptions.touchOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Updates the expiry of the document with the given id with custom options.

    Updates the expiry of the document with the given id with custom options.

    applyId

    parse id function, which is the document id

39.  def touchInstant[T](applyId: (T) => String, expiry: Instant, touchOptions: TouchOptions = TouchOptions.touchOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Updates the expiry of the document with the given id with custom options.

    Updates the expiry of the document with the given id with custom options.

    See also

    com.couchbase.client.java.AsyncCollection#touch

40.  def upsert[T](applyId: (T) => String, upsertOptions: UpsertOptions = UpsertOptions.upsertOptions())(implicit asyncCollection: AsyncCollection): Flow[T, T, NotUsed]

    Upsert a full document which might or might not exist yet with custom options.

    Upsert a full document which might or might not exist yet with custom options.

    applyId

    parse id function, which is the document id

    See also

    com.couchbase.client.java.AsyncCollection#upsert

41.  def upsertDoc[T](upsertOptions: UpsertOptions = UpsertOptions.upsertOptions())(implicit asyncCollection: AsyncCollection): Flow[MutationDocument[T], MutationDocument[T], NotUsed]

    reference to CouchbaseFlow.upsert use MutationDocument to wrapper id, document and result(MutationResult)

42.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef

    Annotations

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