net.lag

kestrel

package kestrel

Visibility
  1. Public
  2. All

Type Members

  1. class AliasedQueue extends AnyRef

  2. case class BrokenItemException (lastValidPosition: Long, cause: Throwable) extends IOException with Product with Serializable

  3. case class Checkpoint (filename: String, reservedItems: Seq[QItem]) extends Product with Serializable

  4. class ConcurrentHashMap [K, V] extends ConcurrentHashMap[K, V]

  5. case class CountResponse (count: Long) extends TextResponse with Product with Serializable

  6. class DeadlineWaitQueue extends AnyRef

    A wait queue where each item has a timeout.

  7. case class ErrorResponse (message: String) extends TextResponse with Product with Serializable

  8. class InaccessibleQueuePath extends Exception

  9. class ItemIdList extends AnyRef

    Set of ids that maintains insert order.

  10. case class ItemResponse (data: Option[Array[Byte]]) extends TextResponse with Product with Serializable

  11. class Journal extends AnyRef

    Codes for working with the journal file for a PersistentQueue.

  12. class JournalItem extends AnyRef

    Attributes
    abstract
  13. class JournalPacker extends AnyRef

    Pack one or more journal files into a single new file that only consists of the queue's current contents, as of the end of the last journal file processed.

  14. class Kestrel extends Service

  15. class KestrelHandler extends AnyRef

    Common implementations of kestrel commands that don't depend on which protocol you're using.

  16. class MemcacheHandler extends Service[MemcacheRequest, MemcacheResponse]

    Memcache protocol handler for a kestrel connection.

  17. case class NoResponse () extends TextResponse with Product with Serializable

  18. case class PackRequest (journal: Journal, checkpoint: Checkpoint, openItems: Iterable[QItem], pentUpDeletes: Int, queueState: Iterable[QItem]) extends Product with Serializable

  19. class PeriodicSyncFile extends AnyRef

    Open a file for writing, and fsync it on a schedule.

  20. class PeriodicSyncTask extends Runnable

    Attributes
    abstract
  21. class PersistentQueue extends AnyRef

  22. case class QItem (addTime: Time, expiry: Option[Time], data: Array[Byte], xid: Int) extends Product with Serializable

  23. class QueueCollection extends AnyRef

  24. case class QueueTransaction (name: String, xid: Int, timerTask: Option[TimerTask]) extends Product with Serializable

  25. trait SimplePendingReads extends AnyRef

  26. case class StringResponse (message: String) extends TextResponse with Product with Serializable

  27. class TextHandler extends Service[TextRequest, TextResponse]

    Simple text-line protocol handler for a kestrel connection.

  28. case class TextRequest (command: String, args: List[String], items: List[Array[Byte]]) extends Product with Serializable

  29. class TextResponse extends Signalling

    Attributes
    abstract
  30. class ThriftFinagledService extends FinagledService

  31. class ThriftHandler extends FutureIface

  32. trait ThriftPendingReads extends AnyRef

  33. class TooManyOpenReadsException extends Exception

Value Members

  1. object Journal extends AnyRef

  2. object JournalItem extends AnyRef

  3. object Kestrel extends AnyRef

  4. object QItem extends Serializable

  5. object QueueCollection extends AnyRef

  6. object TextCodec extends AnyRef

  7. object TextResponse extends AnyRef

  8. object ThriftPendingReads extends AnyRef

  9. object TooManyOpenReadsException extends TooManyOpenReadsException

  10. package config

  11. package thrift

  12. package tools