trait ConfluentLike[Tx <: lucre.confluent.Txn[Tx]] extends lucre.confluent.Sys
- Alphabetic
- By Inheritance
- ConfluentLike
- Sys
- Sys
- Base
- Closeable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract type D <: DurableLike.Txn[D]
- Definition Classes
- Sys
- abstract type I <: InMemoryLike.Txn[I]
- Definition Classes
- Sys
- type T = Tx
The transaction type of the system.
The transaction type of the system.
- Definition Classes
- ConfluentLike → Sys → Sys
Abstract Value Members
- abstract def close(): Unit
Closes the underlying database (if the system is durable).
Closes the underlying database (if the system is durable). The STM cannot be used beyond this call. An in-memory system should have a no-op implementation.
- Definition Classes
- Base → Closeable → AutoCloseable
- abstract def cursorRoot[A, B](init: (T) => A)(result: (T) => (A) => B)(implicit format: TFormat[T, A]): (confluent.Ref[T, A], B)
Initializes the data structure, by either reading an existing entry or generating the root entry with the
initfunction.Initializes the data structure, by either reading an existing entry or generating the root entry with the
initfunction. The method than allows the execution of another function within the same transaction, passing it the data structure root of typeA. This is typically used to generate access mechanisms, such as extracting a cursor from the data structure, or instantiating a new cursor. The method then returns both the access point to the data structure and the result of the second function.- A
type of data structure
- B
type of result from the second function. typically this is an
stm.Cursor[S]- init
a function to initialize the data structure (if the database is fresh)
- result
a function to process the data structure
- format
a format to read or write the data structure
- returns
the access to the data structure along with the result of the second function.
- Definition Classes
- Sys
- abstract def debugPrintIndex(index: Access[T])(implicit tx: T): String
- Definition Classes
- Sys
- abstract def durable: DurableLike[D]
- Definition Classes
- Sys
- abstract def durableTx(tx: T): D
- Definition Classes
- Sys
- abstract def inMemory: InMemoryLike[I]
- Definition Classes
- Sys
- abstract def newCursor(init: Access[T])(implicit tx: T): confluent.Cursor[T, D]
- Definition Classes
- Sys
- abstract def newCursor()(implicit tx: T): confluent.Cursor[T, D]
- Definition Classes
- Sys
- abstract def readCursor(in: DataInput)(implicit tx: T): confluent.Cursor[T, D]
- Definition Classes
- Sys
- abstract def readPath(in: DataInput): Access[T]
- Definition Classes
- Sys
- abstract def root[A](init: (T) => A)(implicit format: TFormat[T, A]): Source[T, A]
Reads the root object representing the stored data structure, or provides a newly initialized one via the
initargument, if no root has been stored yet.Reads the root object representing the stored data structure, or provides a newly initialized one via the
initargument, if no root has been stored yet.- Definition Classes
- Sys
- abstract def rootWithDurable[A, B](confluent: (T) => A)(durable: (D) => B)(implicit aFmt: TFormat[T, A], bFmt: TFormat[D, B]): (confluent.Source[T, A], B)
Initializes the data structure both with a confluently persisted and an ephemeral-durable value.
Initializes the data structure both with a confluently persisted and an ephemeral-durable value.
- A
type of confluent data structure
- B
type of ephemeral data structure
- confluent
a function that provides the initial confluent data (if the database is fresh)
- durable
a function that provides the initial ephemeral data (if the database is fresh)
- aFmt
a format to read or write the confluent data structure
- bFmt
a format to read or write the ephemeral data structure
- returns
a tuple consisting of a handle to the confluent structure and the ephemeral datum. The ephemeral datum, although written to disk, does not require an
stm.SourcebecauseD#AccisUnitand does not need refresh.
- Definition Classes
- Sys
Concrete 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated