trait RegularTxnMixin[S <: Sys[S], D <: DurableLike[D]] extends TxnMixin[S]
- Self Type
- RegularTxnMixin[S, D] with S.Tx
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RegularTxnMixin
- TxnMixin
- Modifiable
- VersionInfo
- BasicTxnImpl
- Txn
- Txn
- TxnLike
- Executor
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def cursorCache: Cache[S.Tx]
- Attributes
- protected
- implicit abstract def durable: Sys.D.Tx
- Definition Classes
- Txn
- abstract def inMemory: Sys.I.Tx
- Definition Classes
- Txn
- abstract def inputAccess: Access[S]
- Definition Classes
- Txn
- abstract def isRetroactive: Boolean
- Definition Classes
- Txn
- abstract def peer: InTxn
- Definition Classes
- TxnLike
- abstract val system: S
- Definition Classes
- Executor
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 addDirtyCache(map: Cache[S.Tx]): Unit
- final def addDirtyLocalCache(map: Cache[S.Tx]): Unit
A local cache is one which is re-created upon application restart.
- final def addInputVersion(path: Access[S]): Unit
- def afterCommit(code: => Unit): Unit
- Definition Classes
- BasicTxnImpl → TxnLike
- final def alloc(pid: Identifier[S]): Identifier[S]
- Attributes
- protected
- Definition Classes
- TxnMixin
- Annotations
- @inline()
- final def allocPartial(pid: Identifier[S]): Identifier[S]
- Attributes
- protected
- Definition Classes
- TxnMixin
- Annotations
- @inline()
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def attrMap(obj: Obj[S]): AttrMap[S]
- Definition Classes
- TxnMixin → Txn
- final def beforeCommit(fun: (S.Tx) => Unit): Unit
- Definition Classes
- TxnMixin → BasicTxnImpl → Txn
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def flushCaches(meldInfo: MeldInfo[S], newVersion: Boolean, caches: IndexedSeq[Cache[S.Tx]]): Unit
- Attributes
- protected
- Definition Classes
- RegularTxnMixin → TxnMixin
- final def fullCache: Durable[S, Int, DurablePersistentMap[S, Int]]
- Attributes
- protected
- Definition Classes
- TxnMixin
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def getNonTxn[A](id: Identifier[S])(implicit ser: ImmutableSerializer[A]): A
- final def getTxn[A](id: Identifier[S])(implicit ser: Serializer[S.Tx, Access[S], A]): A
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def info: Modifiable
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def meldInfo: MeldInfo[S]
- Attributes
- protected
- Definition Classes
- TxnMixin
- final val message: String
(Possibly empty) message describing the associated transaction.
(Possibly empty) message describing the associated transaction. This can be seen as similar to a commit message, the difference being that it must be given (currently) at the moment the transaction is opened and not at the moment when it is closed.
- Definition Classes
- TxnMixin → Modifiable → VersionInfo
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def newBooleanVar(pid: Identifier[S], init: Boolean): Var[S, Boolean]
- Definition Classes
- TxnMixin → Executor
- final def newHandle[A](value: A)(implicit serializer: Serializer[S.Tx, Access[S], A]): Source[S, A]
- Definition Classes
- TxnMixin → Executor
- final def newHandleM[A](value: A)(implicit serializer: Serializer[S.Tx, Access[S], A]): Source[S, A]
The confluent handle is enhanced with the
meldmethod. - final def newId(): Identifier[S]
- Definition Classes
- TxnMixin → Executor
- final def newInMemoryIdMap[A]: IdentifierMap[Identifier[S], S.Tx, A]
- Definition Classes
- TxnMixin → Executor
- def newInMemoryMap[K, V]: RefMap[S, K, V]
- Definition Classes
- BasicTxnImpl → Executor
- def newInMemorySet[A]: RefSet[S, A]
- Definition Classes
- BasicTxnImpl → Executor
- final def newIntVar(pid: Identifier[S], init: Int): Var[S, Int]
- Definition Classes
- TxnMixin → Executor
- final def newLongVar(pid: Identifier[S], init: Long): Var[S, Long]
- Definition Classes
- TxnMixin → Executor
- def newRef[A](init: A): Ref[S.Tx, A]
- Definition Classes
- BasicTxnImpl → Executor
- final def newVar[A](pid: Identifier[S], init: A)(implicit ser: Serializer[S.Tx, Access[S], A]): Var[S, A]
- Definition Classes
- TxnMixin → Executor
- final def newVarArray[A](size: Int): Array[Var[S, A]]
- Definition Classes
- TxnMixin → Executor
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def putNonTxn[A](id: Identifier[S], value: A)(implicit ser: ImmutableSerializer[A]): Unit
- final def putTxn[A](id: Identifier[S], value: A)(implicit ser: Serializer[S.Tx, Access[S], A]): Unit
- final def readBooleanVar(pid: Identifier[S], in: DataInput): Var[S, Boolean]
- Definition Classes
- TxnMixin → Executor
- final def readId(in: DataInput, acc: Access[S]): Identifier[S]
- Definition Classes
- TxnMixin → Executor
- final def readIntVar(pid: Identifier[S], in: DataInput): Var[S, Int]
- Definition Classes
- TxnMixin → Executor
- final def readLongVar(pid: Identifier[S], in: DataInput): Var[S, Long]
- Definition Classes
- TxnMixin → Executor
- final def readPartialSource(in: DataInput, pid: Identifier[S]): Identifier[S]
- Attributes
- protected
- Definition Classes
- TxnMixin
- final def readSource(in: DataInput, pid: Identifier[S]): Identifier[S]
- Attributes
- protected
- Definition Classes
- TxnMixin
- final def readTreeVertexLevel(term: Long): Int
- final def readVar[A](pid: Identifier[S], in: DataInput)(implicit ser: Serializer[S.Tx, Access[S], A]): Var[S, A]
- Definition Classes
- TxnMixin → Executor
- final def removeFromCache(id: Identifier[S]): Unit
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final val timeStamp: Long
System time stamp of the associated transaction.
System time stamp of the associated transaction. The format and offset corresponds to
System.currentTimeMillis.- Definition Classes
- TxnMixin → VersionInfo
- def toString(): String
- Definition Classes
- RegularTxnMixin → TxnMixin → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()