package resource
- Alphabetic
- Public
- Protected
Type Members
- class CommunityDbMigrations extends DbMigrations with NamedLogging
- class CommunityDbMigrationsFactory extends DbMigrationsFactory
- class CommunityStorageFactory extends StorageFactory
- trait DbLock extends NamedLogging with FlagCloseable with HasCloseContext
Abstraction for an application-specific database lock.
Abstraction for an application-specific database lock.
The lock is identified by an integer and bound to the given database's session/connection.
If the connection is lost, the database releases the lock and the DbLock sets the lock state to Lost. The caller's connection management has to recreate and try to reacquire the lock with the given id. NOTE: The database must be configured with a single connection.
- sealed trait DbLockConfigError extends Product with Serializable with PrettyPrinting
- sealed abstract case class DbLockCounter extends PrettyPrinting with Product with Serializable
- sealed trait DbLockError extends Product with Serializable with PrettyPrinting
- final case class DbLockId extends PrettyPrinting with Product with Serializable
Common Wrapper for DB lock identifier
Common Wrapper for DB lock identifier
Oracle only supports lock ids up to unsigned 30bit, Postgres support 64bit.
- sealed trait DbLockMode extends Product with Serializable with PrettyPrinting
- class DbLockOracle extends DbLock
A Oracle DB lock using the DBMS_LOCK package.
- class DbLockPostgres extends DbLock
A Postgres DB lock using advisory locks
- class DbLockedConnection extends NamedLogging with FlagCloseable with HasCloseContext with StateMachine[State]
Maintains the combination of a persistent DB connection and a DB lock acquired on that connection.
Maintains the combination of a persistent DB connection and a DB lock acquired on that connection.
If the connection is closed or becomes invalid, it will try to rebuild the connection and re-acquire the lock.
- sealed trait DbLockedConnectionError extends Product with Serializable with PrettyPrinting
- class DbLockedConnectionPool extends JdbcDataSource with FlagCloseable with HasCloseContext with NamedLogging with StateMachine[State]
A pool of DbLockedConnection for writes guarded by a main lock.
A pool of DbLockedConnection for writes guarded by a main lock. It implements the slick.jdbc.JdbcDataSource trait to be used by slick.
The pool is considered active iff the main connection is active, i.e., the connection is healthy and the lock acquired. If the main connection becomes inactive, the pool of connections are ramped down and the pool periodically attempts to become active again. Once a pool becomes active, it waits for the other pool to ramp down by acquiring exclusive access to the pool's shared lock.
- sealed trait DbLockedConnectionPoolError extends Product with Serializable
- trait DbMigrations extends AnyRef
- trait DbMigrationsFactory extends AnyRef
- trait DbStorage extends Storage
- class DbStorageMulti extends DbStorage with NamedLogging with HasCloseContext
DB Storage implementation that allows multiple processes to access the underlying database and uses a pool of write connections which are guarded by an exclusive main lock to ensure a single writer instance.
DB Storage implementation that allows multiple processes to access the underlying database and uses a pool of write connections which are guarded by an exclusive main lock to ensure a single writer instance.
Periodically checks the activeness of the write connection pool and if the activeness changes executes the
onActive
oronPassive
callbacks. - class DbStorageSingle extends DbStorage with FlagCloseable with NamedLogging
DB Storage implementation that assumes a single process accessing the underlying database.
- trait DbStore extends FlagCloseable with NamedLogging with HasCloseContext
- class EnterpriseDbMigrations extends DbMigrations with NamedLogging
- class EnterpriseDbMigrationsFactory extends DbMigrationsFactory
- class EnterpriseReplicatedStorageFactory extends StorageFactory with NamedLogging
- class EnterpriseStorageFactory extends StorageFactory
- class KeepAliveConnection extends Connection
Connection wrapper to prevent closing of the connection.
- class MemoryStorage extends Storage with NamedLogging with FlagCloseable
- trait StateMachine[S] extends AnyRef
- sealed trait Storage extends CloseableHealthComponent with AtomicHealthComponent
Storage resources (e.g., a database connection pool) that must be released on shutdown.
Storage resources (e.g., a database connection pool) that must be released on shutdown.
The only common functionality defined is the shutdown through AutoCloseable. Using storage objects after shutdown is unsafe; thus, they should only be closed when they're ready for garbage collection.
- trait StorageFactory extends AnyRef
- sealed trait TransactionalStoreUpdate extends AnyRef
A store update operation that can be executed transactionally with other independent update operations.
A store update operation that can be executed transactionally with other independent update operations. Transactionality means that either all updates execute or none. The updates in a transactional execution must be independent of each other. During such an execution, partial updates may be observable by concurrent store accesses.
Useful for updating stores on multiple domains transactionally.
Value Members
- object DatabaseStorageError extends StorageErrorGroup
- object DbLock
- object DbLockCounter extends Serializable
- object DbLockCounters
We pre-allocate a set of counters that are used as part of the lock ID allocation.
- object DbLockError extends Serializable
- object DbLockId extends Serializable
- object DbLockMode extends Serializable
- object DbLockedConnection
- object DbLockedConnectionError extends Serializable
- object DbLockedConnectionPool
- object DbLockedConnectionPoolError extends Serializable
- object DbMigrations
- object DbStorage
- object DbStorageMulti
- object DbStorageSingle
- object DbVersionCheck extends HasLoggerName
- object IdempotentInsert
Utilities for safely and idempotently inserting records to a datastore.
- object KeepAliveConnection
- object OracleDbLock
- object PostgresDbLock
- object Storage
- object StorageDebug
Convenience method to extract the arguments of a sql query for debugging purposes
Convenience method to extract the arguments of a sql query for debugging purposes
Generally, we stuff our arguments into an SQLActionBuilder from where they can not be read. In order to support debugging, we can use the extractArguments method which will iterate through action builder and extract a string version of the argument.
- object StorageFactory
- object TransactionalStoreUpdate
- object WithDbLock