Packages

object CouchbaseSink

Scala API: Factory methods for Couchbase sinks.

Source
CouchbaseSink.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CouchbaseSink
  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): Sink[String, Future[Done]]

    Create a sink to delete documents from Couchbase by id.

  2. def upsert(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[JsonDocument, Future[Done]]

    Create a sink to update or insert a Couchbase JsonDocument.

  3. def upsertDoc[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[T, Future[Done]]

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