datomisca

Connection

Related Docs: object Connection | package datomisca

final class Connection extends AnyVal

Source
Connection.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Connection
  2. AnyVal
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Connection(connection: datomic.Connection)

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  2. final def ##(): Int

    Definition Classes
    Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from Connection to any2stringadd[Connection] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (Connection, B)

    Implicit information
    This member is added by an implicit conversion from Connection to ArrowAssoc[Connection] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. val connection: datomic.Connection

  8. def database(): Database

    Retrieves a value of the database for reading.

    Retrieves a value of the database for reading.

    Does not communicate with the transactor, nor block.

    returns

    the current value of the database.

  9. def ensuring(cond: (Connection) ⇒ Boolean, msg: ⇒ Any): Connection

    Implicit information
    This member is added by an implicit conversion from Connection to Ensuring[Connection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  10. def ensuring(cond: (Connection) ⇒ Boolean): Connection

    Implicit information
    This member is added by an implicit conversion from Connection to Ensuring[Connection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  11. def ensuring(cond: Boolean, msg: ⇒ Any): Connection

    Implicit information
    This member is added by an implicit conversion from Connection to Ensuring[Connection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  12. def ensuring(cond: Boolean): Connection

    Implicit information
    This member is added by an implicit conversion from Connection to Ensuring[Connection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  13. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from Connection to StringFormat[Connection] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  14. def gcStorage(olderThan: Date): Unit

  15. def getClass(): Class[_ <: AnyVal]

    Definition Classes
    AnyVal → Any
  16. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  17. def log(): Log

    Retrieves a value of the log for reading.

    Retrieves a value of the log for reading.

    Note: the mem db has no log, and thus for it log will return null.

    (Copied from Datomic docs.)

    returns

    the current value of the log.

  18. def release(): Unit

    Request the release of resources associated with this connection.

    Request the release of resources associated with this connection. Copied from Datomic Javadoc: Method returns immediately, resources will be released asynchronously. This method should only be called when the entire process is no longer interested in the connection. Note that Datomic connections do not adhere to an acquire/use/release pattern. They are thread-safe, cached, and long lived. Many processes (e.g. application servers) will never call release.

  19. def removeTxReportQueue(): Unit

  20. def requestIndex(): Boolean

  21. def sync(t: Long)(implicit exec: ExecutionContext): Future[Database]

    Used to coordinate with other peers.

    Used to coordinate with other peers.

    Returns a future that will acquire a database value with basisT >= t.

    database() is the preferred way to get a database value, as it does not need to wait nor block. Only use sync(t) when coordination is required, and prefer over sync() when you have a basis t.

    Does not communicate with the transactor, so the future may be available immediately. The future can take arbitrarily long to complete. Waiters should specify a timeout.

    t

    a basis t.

    exec

    an implicit execution context.

    returns

    Returns a future that will acquire a database value guaranteed to include all transactions that were complete at the time sync was called.

  22. def sync()(implicit exec: ExecutionContext): Future[Database]

    Used to coordinate with other peers.

    Used to coordinate with other peers.

    Returns a future that will acquire a database value guaranteed to include all transactions that were complete at the time sync was called. Communicates with the transactor.

    database() is the preferred way to get a database value, as it does not need to wait nor block. Only use sync() when coordination is required, and you don't have a basis t.

    Communicates with the transactor. The future can take arbitrarily long to complete. Waiters should specify a timeout.

    exec

    an implicit execution context.

    returns

    Returns a future that will acquire a database value guaranteed to include all transactions that were complete at the time sync was called.

  23. def syncExcise(t: Long)(implicit exec: ExecutionContext): Future[Database]

    Used to coordinate with background excision.

    Used to coordinate with background excision.

    Returns a future that will aquire a database value that is aware of excisions through time <= t.

    Does not communicate with the transactor, so the future may be available immediately. The future can take arbitrarily long to complete. Waiters should specify a timeout.

    t

    a basis t.

    exec

    an implicit execution context.

    returns

    Returns a future that will acquire a database value that is aware of excisions through time <= t.

  24. def syncIndex(t: Long)(implicit exec: ExecutionContext): Future[Database]

    Used to coordinate with background indexing jobs.

    Used to coordinate with background indexing jobs.

    Returns a future that will acquire a database value that is indexed through time <= t.

    Does not communicate with the transactor, so the future may be available immediately. The future can take arbitrarily long to complete. Waiters should specify a timeout.

    t

    a basis t.

    exec

    an implicit execution context.

    returns

    Returns a future that will acquire a database value that is indexed through time <= t.

  25. def syncSchema(t: Long)(implicit exec: ExecutionContext): Future[Database]

    Used to coordinate with background schema changes.

    Used to coordinate with background schema changes.

    Returns a future that will acquire a database value that is aware of all schema changes through time <= t.

    Does not communicate with the transactor, so the future may be available immediately. The future can take arbitrarily long to complete. Waiters should specify a timeout.

    t

    a basis t.

    exec

    an implicit execution context.

    returns

    Returns a future that will acquire a database value that is aware of all schema changes through time <= t.

  26. def toString(): String

    Definition Classes
    Any
  27. def transact(ops: TraversableOnce[TxData])(implicit ex: ExecutionContext): Future[TxReport]

  28. def txReportQueue(): TxReportQueue

  29. def [B](y: B): (Connection, B)

    Implicit information
    This member is added by an implicit conversion from Connection to ArrowAssoc[Connection] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from AnyVal

Inherited from Any

Inherited by implicit conversion any2stringadd from Connection to any2stringadd[Connection]

Inherited by implicit conversion StringFormat from Connection to StringFormat[Connection]

Inherited by implicit conversion Ensuring from Connection to Ensuring[Connection]

Inherited by implicit conversion ArrowAssoc from Connection to ArrowAssoc[Connection]

Ungrouped