class DistributedDatabaseDef[F[_]] extends BasicDatabaseDef[F]
- Alphabetic
- By Inheritance
- DistributedDatabaseDef
- BasicDatabaseDef
- AnyDatabaseDef
- Closeable
- AutoCloseable
- AnyRef
- Any
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DistributedDatabaseDef(dbs: Vector[AnyDatabaseDef], controls: Controls[F], actionListener: ActionListener[F] = ActionListener.noop[F])(implicit asyncF: Async[F])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def ->[B](y: B): (DistributedDatabaseDef[F], B)
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toArrowAssoc[DistributedDatabaseDef[F]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val actionListener: ActionListener[F]
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef
- final def admissionControl: AdmissionControl[F]
- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- implicit val asyncF: Async[F]
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
Free all resources allocated by Slick for this Database.
Free all resources allocated by Slick for this Database.
Implementations must be idempotent (safe to call more than once) and thread-safe (safe to call concurrently from multiple threads). A second or concurrent call must not throw an exception and must not corrupt the state of any remaining resources.
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef → Closeable → AutoCloseable
- def commitTransaction(session: Session, previousIsolationLevel: Option[Int]): Unit
Commit the transaction on the session, restoring the given isolation level if provided.
Commit the transaction on the session, restoring the given isolation level if provided. Override in JdbcBackend.
- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- final def connectionArbiter: ConnectionArbiter[F]
- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- final def controlStatus: F[ControlStatus]
- Definition Classes
- BasicDatabaseDef
- val controls: Controls[F]
Concurrency controls for admission and connection-slot arbitration.
Concurrency controls for admission and connection-slot arbitration.
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef
- def createSession(): Session
Create a new session.
Create a new session. The session needs to be closed explicitly by calling its close() method.
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef → AnyDatabaseDef
- val dbs: Vector[AnyDatabaseDef]
- def ensuring(cond: (DistributedDatabaseDef[F]) => Boolean, msg: => Any): DistributedDatabaseDef[F]
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toEnsuring[DistributedDatabaseDef[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (DistributedDatabaseDef[F]) => Boolean): DistributedDatabaseDef[F]
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toEnsuring[DistributedDatabaseDef[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): DistributedDatabaseDef[F]
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toEnsuring[DistributedDatabaseDef[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): DistributedDatabaseDef[F]
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toEnsuring[DistributedDatabaseDef[F]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- 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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def interpret[R](a: DBIOAction[R, NoStream, Nothing], ctx: Ref[F, DistributedBackend.ExecState]): F[R]
The core recursive interpreter for
DBIOActionvalues.The core recursive interpreter for
DBIOActionvalues.-
SynchronousDatabaseActionsteps run inF.blockingon the CE3 blocking pool. - No explicit stack-level tracking: CE3flatMapis stack-safe. - Execution state (session, transaction depth, pinning) is tracked in aRef[F, ExecState]. - Cancellation triggers rollback viaguaranteeCase.- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- def interpretStream[T](a: DBIOAction[_, Streaming[T], Nothing], ctx: Ref[F, DistributedBackend.ExecState]): F[(CloseableIterator[T], (Option[Throwable]) => F[Unit])]
- Attributes
- protected
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef
- 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def rollbackTransaction(session: Session, previousIsolationLevel: Option[Int]): Unit
Rollback the transaction on the session, restoring the given isolation level if provided.
Rollback the transaction on the session, restoring the given isolation level if provided. Override in JdbcBackend.
- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- final def run[R](a: DBIOAction[R, NoStream, Nothing]): F[R]
Run a DBIOAction and return the result in F[R].
Run a DBIOAction and return the result in F[R].
- Definition Classes
- BasicDatabaseDef
- def sessionAsContext(session: Session, state: DistributedBackend.ExecState): Context
DistributedBackend always uses cats.effect.IO as its effect type.
DistributedBackend always uses cats.effect.IO as its effect type.
- Attributes
- protected
- Definition Classes
- DistributedDatabaseDef → BasicDatabaseDef
- def setupTransaction(session: Session, isolationLevel: Option[Int]): Option[Int]
Set up a transaction on a freshly-acquired connection.
Set up a transaction on a freshly-acquired connection. Returns the previous isolation level (to be restored after the transaction ends), or None if the isolation level was not changed. Override in JdbcBackend.
- Attributes
- protected
- Definition Classes
- BasicDatabaseDef
- final def stream[T](a: DBIOAction[_, Streaming[T], Nothing]): Resource[F, Iterator[T]]
Open a streaming DBIOAction as a Resource-backed Iterator.
Open a streaming DBIOAction as a Resource-backed Iterator.
Finalizer order is: 1) iterator.close() 2) transactional / pin-scope cleanup 3) session / permit release 4) inflight-release
- Definition Classes
- BasicDatabaseDef
- 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
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toStringFormat[DistributedDatabaseDef[F]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)instead ofvalue.formatted(formatString), or use thef""string interpolator. In Java 15 and later,formattedresolves to the new method in String which has reversed parameters.
- def →[B](y: B): (DistributedDatabaseDef[F], B)
- Implicit
- This member is added by an implicit conversion from DistributedDatabaseDef[F] toArrowAssoc[DistributedDatabaseDef[F]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.
edit this text on github
Scala Language-Integrated Connection Kit
This is the API documentation for the Slick database library. It should be used as an additional resource to the user manual.
Further documentation for Slick can be found on the documentation pages.
To the slick package list...