net.lag.kestrel

PersistentQueue

class PersistentQueue extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. PersistentQueue
  2. AnyRef
  3. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PersistentQueue (name: String, persistencePath: String, config: QueueConfig, timer: Timer, journalSyncScheduler: ScheduledExecutorService)

  2. new PersistentQueue (name: String, persistencePath: String, config: QueueConfig, timer: Timer, journalSyncScheduler: ScheduledExecutorService, queueLookup: Option[(String) ⇒ Option[PersistentQueue]])

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def add (value: Array[Byte], expiry: Option[Time]): Boolean

  7. def add (value: Array[Byte]): Boolean

  8. def add (value: Array[Byte], expiry: Option[Time], xid: Option[Int], addTime: Time): Boolean

    Add a value to the end of the queue, transactionally.

  9. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  10. def bytes : Long

  11. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  12. def close (): Unit

    Close the queue's journal file.

    Close the queue's journal file. Not safe to call on an active queue.

  13. var config : QueueConfig

  14. def confirmRemove (xid: Int): Unit

  15. def continue (xid: Int, value: Array[Byte], expiry: Option[Time]): Boolean

  16. def continue (xid: Int, value: Array[Byte]): Boolean

  17. def createTime : Long

  18. def currentAge : Duration

  19. def destroyJournal (): Unit

  20. def discardExpired (limit: Boolean = false): Int

    Attributes
    final
  21. def dumpStats (): Array[(String, String)]

  22. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  23. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  24. var expireQueue : Option[PersistentQueue]

  25. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  26. def flush (): Unit

  27. def forceRewrite (): Unit

  28. def gauge (gaugeName: String, value: ⇒ Double): Unit

  29. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  30. val getItemsHit : AtomicLong

  31. val getItemsMiss : AtomicLong

  32. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  33. def inReadBehind : Boolean

  34. def isClosed : Boolean

  35. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  36. def isReadyForExpiration : Boolean

    Check if this Queue is eligible for expiration by way of it being empty and its age being greater than or equal to maxQueueAge

  37. def journalSize : Long

  38. def journalTotalSize : Long

  39. def length : Long

  40. def maxMemoryBytes : Long

  41. def memoryBytes : Long

  42. def memoryLength : Long

  43. def metric (metricName: String): Unit

  44. val name : String

  45. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  46. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  47. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  48. def openTransactionCount : Int

  49. def pauseReads (): Unit

  50. def peek (): Option[QItem]

    Peek at the head item in the queue, if there is one.

  51. val putBytes : AtomicLong

  52. val putItems : AtomicLong

  53. def remove (): Option[QItem]

    Remove and return an item from the queue, if there is one.

  54. def remove (transaction: Boolean): Option[QItem]

    Remove and return an item from the queue, if there is one.

    Remove and return an item from the queue, if there is one.

    transaction

    true if this should be considered the first part of a transaction, to be committed or rolled back (put back at the head of the queue)

  55. def removeStats (): Unit

  56. def replayJournal (): Unit

  57. def resumeReads (): Unit

  58. def setup (): Unit

  59. def statNamed (statName: String): String

  60. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  61. def toString (): String

    Definition Classes
    AnyRef → Any
  62. val totalCanceledTransactions : Counter

  63. val totalDiscarded : Counter

  64. val totalExpired : Counter

  65. val totalFlushes : Counter

  66. val totalTransactions : Counter

  67. def unremove (xid: Int): Unit

    Return a transactionally-removed item to the queue.

    Return a transactionally-removed item to the queue. This is a rolled- back transaction.

  68. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  69. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  70. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  71. def waitPeek (deadline: Option[Time]): Future[Option[QItem]]

    Attributes
    final
  72. def waitRemove (deadline: Option[Time], transaction: Boolean): Future[Option[QItem]]

    Attributes
    final
  73. def waiterCount : Long

Inherited from AnyRef

Inherited from Any