Packages

object CouchbaseFlow

Source
CouchbaseFlow.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CouchbaseFlow
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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)(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]

    similar to CouchbaseFlow.get, but reads from all replicas on the active node

    similar to CouchbaseFlow.get, 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 If you add DefaultScalaModule to jackson of couchbase, it could deserialize to scala 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()

Inherited from AnyRef

Inherited from Any

Ungrouped