Class/Object

com.rbmhtechnology.eventuate

ConcurrentVersionsTree

Related Docs: object ConcurrentVersionsTree | package eventuate

Permalink

class ConcurrentVersionsTree[A, B] extends ConcurrentVersions[A, B]

A ConcurrentVersions implementation that shall be used if updates are incremental. ConcurrentVersionsTree is a mutable data structure. Therefore, it is recommended not to share instances of ConcurrentVersionsTree directly but rather the Versioned sequence returned by ConcurrentVersionsTree#all. Later releases will be based on an immutable data structure.

Please note: This implementation does not purge old versions at the moment (which shouldn't be a problem if the number of incremental updates to a versioned aggregate is rather small). In later releases, manual and automated purging of old versions will be supported.

Linear Supertypes
ConcurrentVersions[A, B], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConcurrentVersionsTree
  2. ConcurrentVersions
  3. Serializable
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ConcurrentVersionsTree(root: Node[A])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. def all: Seq[Versioned[A]]

    Permalink

    Returns all (un-resolved) concurrent versions.

    Returns all (un-resolved) concurrent versions.

    Definition Classes
    ConcurrentVersionsTree → ConcurrentVersions

  5. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  6. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  7. def conflict: Boolean

    Permalink

    Returns true if there is more than one version available i.e.

    Returns true if there is more than one version available i.e. if there are multiple concurrent (= conflicting) versions.

    Definition Classes
    ConcurrentVersions

  8. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  9. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  10. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  11. def getAll: List[Versioned[A]]

    Permalink

    Java API of all.

    Java API of all.

    Definition Classes
    ConcurrentVersions

  12. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  13. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  14. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  15. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  16. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  17. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  18. def owner: String

    Permalink

    Owner of versioned values.

    Owner of versioned values.

    Definition Classes
    ConcurrentVersionsTree → ConcurrentVersions

  19. def resolve(selectedTimestamp: VectorTime, vectorTimestamp: VectorTime, systemTimestamp: Long = 0L): ConcurrentVersionsTree[A, B]

    Permalink

    Resolves multiple concurrent versions to a single version.

    Resolves multiple concurrent versions to a single version. For the resolution to be successful, one of the concurrent versions must have a vectorTimestamp that is equal to selectedTimestamp. Only those concurrent versions with a vectorTimestamp less than the given vectorTimestamp participate in the resolution process (which allows for resolutions to be concurrent to other updates).

    Definition Classes
    ConcurrentVersionsTree → ConcurrentVersions

  20. def resolve(selectedTimestamp: VectorTime): ConcurrentVersions[A, B]

    Permalink

    Experimental ...

    Experimental ...

    Definition Classes
    ConcurrentVersions

  21. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  22. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  23. def update(b: B, vectorTimestamp: VectorTime, systemTimestamp: Long = 0L, creator: String = ""): ConcurrentVersionsTree[A, B]

    Permalink

    Updates that Versioned value with b that is a predecessor of vectorTimestamp.

    Updates that Versioned value with b that is a predecessor of vectorTimestamp. If there is no such predecessor, a new concurrent version is created (optionally derived from an older entry in the version history, in case of incremental updates).

    Definition Classes
    ConcurrentVersionsTree → ConcurrentVersions

  24. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  25. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  27. def withOwner(owner: String): ConcurrentVersionsTree[A, B]

    Permalink

    Updates the owner.

    Updates the owner.

    Definition Classes
    ConcurrentVersionsTree → ConcurrentVersions

  28. def withProjection(f: BiFunction[A, B, A]): ConcurrentVersionsTree[A, B]

    Permalink

  29. def withProjection(f: (A, B) ⇒ A): ConcurrentVersionsTree[A, B]

    Permalink

Inherited from ConcurrentVersions[A, B]

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped