Package dev.getelements.elements.rt.transact

Class JournalTransactionalResourceServicePersistenceEnvironment

java.lang.Object

dev.getelements.elements.rt.transact.JournalTransactionalResourceServicePersistenceEnvironment

All Implemented Interfaces:

PersistenceEnvironment, TransactionalResourceServicePersistence

public class JournalTransactionalResourceServicePersistenceEnvironment
extends Object
implements PersistenceEnvironment, TransactionalResourceServicePersistence

Constructor Summary

Constructors

Constructor	Description
JournalTransactionalResourceServicePersistenceEnvironment(jakarta.inject.Provider<Snapshot.Builder> snapshotBuilderProvider, DataStore dataStore, TransactionJournal transactionJournal, JournalTransactionalPersistenceDriver journalTransactionalPersistenceDriver)

Method Summary

Modifier and Type	Method	Description
ReadOnlyTransaction.Builder<ReadOnlyTransaction>	buildRO(NodeId nodeId)	Starts building an instance of ReadOnlyTransaction against the underlying data store.
ReadOnlyTransaction.Builder<ReadWriteTransaction>	buildRW(NodeId nodeId)	Starts building an instance of ReadWriteTransaction against the underlying data store.
DataStore	getDataStore()
JournalTransactionalPersistenceDriver	getJournalTransactionalPersistenceDriver()
jakarta.inject.Provider<Snapshot.Builder>	getSnapshotBuilderProvider()
TransactionJournal	getTransactionJournal()
ExclusiveReadWriteTransaction	openExclusiveRW()	Opens a ExclusiveReadWriteTransaction which will lock the entire underlying data storage such that certain operations may be performed against the whole dataset.
void	start()	Starts the PersistenceEnvironment instance and obtains all resources necessary to begin accessing the underlying data store.
void	stop()	Closes this PersistenceEnvironment instance and releases any underlying connections to the data storage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JournalTransactionalResourceServicePersistenceEnvironment

@Inject
public JournalTransactionalResourceServicePersistenceEnvironment(jakarta.inject.Provider<Snapshot.Builder> snapshotBuilderProvider,
 DataStore dataStore,
 TransactionJournal transactionJournal,
 JournalTransactionalPersistenceDriver journalTransactionalPersistenceDriver)

Method Details

start

public void start()

Description copied from interface: PersistenceEnvironment

Starts the PersistenceEnvironment instance and obtains all resources necessary to begin accessing the underlying data store.

Specified by:

start in interface PersistenceEnvironment

stop

public void stop()

Description copied from interface: PersistenceEnvironment

Closes this PersistenceEnvironment instance and releases any underlying connections to the data storage. Outstanding transactions may be forcibly closed if this is called.

Specified by:

stop in interface PersistenceEnvironment

buildRO

public ReadOnlyTransaction.Builder<ReadOnlyTransaction> buildRO(NodeId nodeId)

Description copied from interface: TransactionalResourceServicePersistence

Starts building an instance of ReadOnlyTransaction against the underlying data store.

Specified by:

buildRO in interface TransactionalResourceServicePersistence

Parameters:

nodeId - the NodeId to use for the transaction context.

Returns:

the ReadOnlyTransaction

buildRW

public ReadOnlyTransaction.Builder<ReadWriteTransaction> buildRW(NodeId nodeId)

Description copied from interface: TransactionalResourceServicePersistence

Starts building an instance of ReadWriteTransaction against the underlying data store.

Specified by:

buildRW in interface TransactionalResourceServicePersistence

Parameters:

nodeId - the NodeId to use for the transaction context.

Returns:

the ReadOnlyTransaction

openExclusiveRW

public ExclusiveReadWriteTransaction openExclusiveRW()

Description copied from interface: TransactionalResourceServicePersistence

Opens a ExclusiveReadWriteTransaction which will lock the entire underlying data storage such that certain operations may be performed against the whole dataset. Generally this should be avoided as it incurs a steep performance penalty.

Specified by:

openExclusiveRW in interface TransactionalResourceServicePersistence

Returns:

the ExclusiveReadWriteTransaction

getSnapshotBuilderProvider

public jakarta.inject.Provider<Snapshot.Builder> getSnapshotBuilderProvider()

getDataStore

public DataStore getDataStore()

getTransactionJournal

public TransactionJournal getTransactionJournal()

getJournalTransactionalPersistenceDriver

public JournalTransactionalPersistenceDriver getJournalTransactionalPersistenceDriver()