Packages

object CouchbaseFlow

Scala API: Factory methods for Couchbase flows.

Source
CouchbaseFlow.scala
Linear Supertypes
AnyRef, Any
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. def delete(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[String, String, NotUsed]

    Create a flow to delete documents from Couchbase by id.

    Create a flow to delete documents from Couchbase by id. Emits the same id.

  2. def deleteWithResult(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[String, CouchbaseDeleteResult, NotUsed]

    Create a flow to delete documents from Couchbase by id and emit operation outcome containing the same id.

  3. def fromId[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, bucketName: String, target: Class[T]): Flow[String, T, NotUsed]

    Create a flow to query Couchbase for by id and emit documents of the given class.

  4. def fromId(sessionSettings: CouchbaseSessionSettings, bucketName: String): Flow[String, JsonDocument, NotUsed]

    Create a flow to query Couchbase for by id and emit JsonDocuments.

  5. def replace(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[JsonDocument, JsonDocument, NotUsed]

    Create a flow to replace a Couchbase JsonDocument.

  6. def replaceDoc[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[T, T, NotUsed]

    Create a flow to replace a Couchbase document of the given class.

  7. def replaceDocWithResult[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[T, CouchbaseWriteResult[T], NotUsed]

    Create a flow to replace a Couchbase document of the given class and emit a result so that write failures can be handled in-stream.

  8. def upsert(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[JsonDocument, JsonDocument, NotUsed]

    Create a flow to update or insert a Couchbase JsonDocument.

  9. def upsertDoc[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[T, T, NotUsed]

    Create a flow to update or insert a Couchbase document of the given class.

  10. def upsertDocWithResult[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Flow[T, CouchbaseWriteResult[T], NotUsed]

    Create a flow to update or insert a Couchbase document of the given class and emit a result so that write failures can be handled in-stream.