c

com.couchbase.client.scala.transactions

AsyncTransactionAttemptContext

class AsyncTransactionAttemptContext extends AnyRef

Provides methods to allow an application's transaction logic to read, mutate, insert and delete documents.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncTransactionAttemptContext
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. implicit val executionContext: ExecutionContext
  9. def get(collection: AsyncCollection, id: String): Future[TransactionGetResult]

    Gets a document with the specified id and from the specified Couchbase collection.

    Gets a document with the specified id and from the specified Couchbase collection.

    If the document does not exist it will raise a com.couchbase.client.core.error.DocumentNotFoundException.

    collection

    the Couchbase collection the document exists on

    id

    the document's ID

    returns

    a TransactionGetResult containing the document

  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def getReplicaFromPreferredServerGroup(collection: AsyncCollection, id: String): Future[TransactionGetResult]

    Gets a document from the specified Couchbase collection matching the specified id.

    Gets a document from the specified Couchbase collection matching the specified id.

    It will be fetched only from document copies that on nodes in the preferred server group, which can be configured with com.couchbase.client.scala.env.ClusterEnvironment.Builder.preferredServerGroup.

    If no replica can be retrieved, which can include for reasons such as this preferredServerGroup not being set, and misconfigured server groups, then com.couchbase.client.core.error.DocumentUnretrievableException can be raised. It is strongly recommended that this method always be used with a fallback strategy to use ctx.get() on failure.

    collection

    the Couchbase collection the document exists on

    id

    the document's ID

    returns

    a TransactionGetResult containing the document

  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  13. def insert[T](collection: AsyncCollection, id: String, content: T)(implicit serializer: JsonSerializer[T]): Future[TransactionGetResult]

    Inserts a new document into the specified Couchbase collection.

    Inserts a new document into the specified Couchbase collection.

    collection

    the Couchbase collection in which to insert the doc

    id

    the document's unique ID

    content

    this can be of any type for which an implicit com.couchbase.client.scala.codec.Conversions.JsonSerializer can be found: a list of types that are supported 'out of the box' is available at these JSON docs

    returns

    the doc, updated with its new CAS value and ID, and converted to a TransactionGetResult

  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  18. def query(scope: AsyncScope, statement: String, options: TransactionQueryOptions): Future[TransactionQueryResult]

    Runs a N1QL query and returns the result.

    Runs a N1QL query and returns the result.

    All rows are buffered in-memory.

    This overload performs a 'scope-level query': that is, one in which a collection may be referenced by name in the query statement, without needing to specify the full bucket.scope.collection syntax.

    Raises com.couchbase.client.core.error.CouchbaseException or an error derived from it on failure. The application can choose to catch and ignore this error, and the transaction attempt is allowed to continue. This differs from Key-Value operations, whose failure will cause the attempt to fail.

  19. def query(scope: AsyncScope, statement: String): Future[TransactionQueryResult]

    Runs a N1QL query and returns the result.

    Runs a N1QL query and returns the result.

    All rows are buffered in-memory.

    This overload performs a 'scope-level query': that is, one in which a collection may be referenced by name in the query statement, without needing to specify the full bucket.scope.collection syntax.

    Raises com.couchbase.client.core.error.CouchbaseException or an error derived from it on failure. The application can choose to catch and ignore this error, and the transaction attempt is allowed to continue. This differs from Key-Value operations, whose failure will cause the attempt to fail.

  20. def query(statement: String, options: TransactionQueryOptions): Future[TransactionQueryResult]

    Runs a N1QL query and returns the result.

    Runs a N1QL query and returns the result.

    All rows are buffered in-memory.

    Raises com.couchbase.client.core.error.CouchbaseException or an error derived from it on failure. The application can choose to catch and ignore this error, and the transaction attempt is allowed to continue. This differs from Key-Value operations, whose failure will cause the attempt to fail.

  21. def query(statement: String): Future[TransactionQueryResult]

    Runs a N1QL query and returns the result.

    Runs a N1QL query and returns the result.

    All rows are buffered in-memory.

    Raises com.couchbase.client.core.error.CouchbaseException or an error derived from it on failure. The application can choose to catch and ignore this error, and the transaction attempt is allowed to continue. This differs from Key-Value operations, whose failure will cause the attempt to fail.

  22. def remove(doc: TransactionGetResult): Future[Unit]

    Removes the specified doc.

    Removes the specified doc.

    doc

    - the doc to be removed

  23. def replace[T](doc: TransactionGetResult, content: T)(implicit serializer: JsonSerializer[T]): Future[TransactionGetResult]

    Mutates the specified doc with new content.

    Mutates the specified doc with new content.

    doc

    the doc to be mutated

    content

    this can be of any type for which an implicit com.couchbase.client.scala.codec.Conversions.JsonSerializer can be found: a list of types that are supported 'out of the box' is available at these JSON docs

    returns

    the doc, updated with its new CAS value. For performance a copy is not created and the original doc object is modified.

  24. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped