A composed key used in the key-value stores to persist model data. The key is composed of a key and an optional repositoryId. The repositoryId is set when an entry is scoped to the repository.

PendingChangeMessages

class PendingChangeMessages(notifier: (ObjectInRepository) -> Unit)

PostgresDialect

class PostgresDialect : BasicJdbcDialect

Ignite dialect for PostgreSQL

RepositoryScopedKeyListener

data class RepositoryScopedKeyListener(val listener: IGenericKeyListener<String>) : IGenericKeyListener<ObjectInRepository>

RepositoryScopedStoreClient

class RepositoryScopedStoreClient(repositoryId: RepositoryId, val client: IsolatingStore) : StoreClientAdapter

StoreClientAdapter

abstract class StoreClientAdapter(val client: IsolatingStore) : IStoreClient

Functions

forContextRepository

fun IsolatingStore.forContextRepository(): ContextScopedStoreClient

forGlobalRepository

fun IsolatingStore.forGlobalRepository(): GlobalStoreClient

forRepository

fun IStoreClient.forRepository(repository: RepositoryId): IStoreClient

fun IsolatingStore.forRepository(repository: RepositoryId): RepositoryScopedStoreClient

generateId

fun generateId(idStr: String?): Long

getGenericStore

fun IStoreClient.getGenericStore(): IsolatingStore

loadDump

fun IsolatingStore.loadDump(file: File): Int

pollEntry

suspend fun pollEntry(storeClient: IsolatingStore, key: ObjectInRepository, lastKnownValue: String?): String?

runTransactionSuspendable

suspend fun <T> IStoreClient.runTransactionSuspendable(body: () -> T): T

withGlobalRepository

fun <R> IStoreClient.withGlobalRepository(body: () -> R): R

withGlobalRepositoryInCoroutine

suspend fun <R> IStoreClient.withGlobalRepositoryInCoroutine(body: suspend () -> R): R

withRepository

fun <R> IStoreClient.withRepository(repository: RepositoryId?, body: () -> R): R

withRepositoryInCoroutine

suspend fun <R> IStoreClient.withRepositoryInCoroutine(repository: RepositoryId?, body: suspend () -> R): R

writeDump

@Synchronized

fun IsolatingStore.writeDump(file: File)