object CouchbaseFlow
- Source
- CouchbaseFlow.scala
- Alphabetic
- By Inheritance
- CouchbaseFlow
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- 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.
- 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 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.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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)
- 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
- 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
- def getAllReplicasJson(options: GetAllReplicasOptions = GetAllReplicasOptions.getAllReplicasOptions)(implicit asyncCollection: AsyncCollection): Flow[String, JsonObject, NotUsed]
reference to CouchbaseFlow.getAllReplicas, deserialize to Couchbase JsonObject
- 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
- 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
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getJson(options: GetOptions = GetOptions.getOptions)(implicit asyncCollection: AsyncCollection): Flow[String, JsonObject, NotUsed]
reference to CouchbaseFlow.get deserialize to Couchbase JsonObject
- 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
- 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
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- 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.
- 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
- 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) - final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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.
- 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)
- 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 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.
- 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)
- 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
- 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)
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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.
- 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
- 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.
- 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
- 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)
- 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]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])