Packages

object ThreadManagement

Singleton for registering and managing running queries.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ThreadManagement
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait LowLevelScanner[T] extends Closeable

    Low level scanner that can be closed to terminate a scan

    Low level scanner that can be closed to terminate a scan

    T

    type

  2. trait ManagedScan[T] extends CloseableIterator[T]

    Trait for scans that are managed, i.e.

    Trait for scans that are managed, i.e. tracked and terminated if they exceed a specified timeout

    T

    type

  3. case class Timeout(relative: Long, absolute: Long) extends Product with Serializable

    Timeout holder

    Timeout holder

    relative

    relative timeout, in millis

    absolute

    absolute timeout, in system millis since epoch

Value Members

  1. def register(scan: ManagedScan[_]): ScheduledFuture[_]

    Register a scan with the thread manager

    Register a scan with the thread manager

    scan

    scan to terminate

  2. object Timeout extends Serializable