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. final def !=(arg0: AnyRef): Boolean

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

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

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

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

    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. final def asInstanceOf[T0]: T0

    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. final def discardExpired(limit: Boolean = false): Int

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

  22. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  24. def evictWaiters(): Unit

  25. var expireQueue: Option[PersistentQueue]

  26. def finalize(): Unit

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

  28. def forceRewrite(): Unit

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

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

    Definition Classes
    AnyRef → Any
  31. val getItemsHit: AtomicLong

  32. val getItemsMiss: AtomicLong

  33. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  34. def inReadBehind: Boolean

  35. def isClosed: Boolean

  36. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  37. 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

  38. def journalSize: Long

  39. def journalTotalSize: Long

  40. def length: Long

  41. def maxMemoryBytes: Long

  42. def memoryBytes: Long

  43. def memoryLength: Long

  44. def metric(metricName: String): Unit

  45. val name: String

  46. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  47. final def notify(): Unit

    Definition Classes
    AnyRef
  48. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  49. def openTransactionCount: Int

  50. def pauseReads(): Unit

  51. def peek(): Option[QItem]

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

  52. val putBytes: AtomicLong

  53. val putItems: AtomicLong

  54. def remove(): Option[QItem]

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

  55. 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)

  56. def removeStats(): Unit

  57. def replayJournal(): Unit

  58. def resumeReads(): Unit

  59. def setup(): Unit

  60. def statNamed(statName: String): String

  61. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  62. def toString(): String

    Definition Classes
    AnyRef → Any
  63. val totalCanceledTransactions: Counter

  64. val totalDiscarded: Counter

  65. val totalExpired: Counter

  66. val totalFlushes: Counter

  67. val totalTransactions: Counter

  68. 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.

  69. final def wait(): Unit

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

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

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

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

  74. def waiterCount: Long

Inherited from AnyRef

Inherited from Any