net.lag

kestrel

package kestrel

Visibility
  1. Public
  2. All

Type Members

  1. class AliasedQueue extends AnyRef

  2. class AlreadyStartedException extends Exception

  3. class AvailabilityException extends Exception

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

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

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

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

  8. final class DeadlineWaitQueue extends AnyRef

    A wait queue where each item has a timeout.

  9. class EndpointsAlreadyConfigured extends Exception

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

  11. class ForbiddenStatusException extends Exception

  12. class InaccessibleQueuePath extends Exception

  13. class ItemIdList extends AnyRef

    Set of ids that maintains insert order.

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

  15. class Journal extends AnyRef

    Codes for working with the journal file for a PersistentQueue.

  16. abstract class JournalItem extends AnyRef

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

  18. class JournalPackerTask extends AnyRef

  19. class Kestrel extends Service

  20. abstract class KestrelHandler extends AnyRef

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

  21. class MemcacheHandler extends Service[MemcacheRequest, MemcacheResponse]

    Memcache protocol handler for a kestrel connection.

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

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

  24. class PeriodicSyncFile extends AnyRef

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

  25. abstract class PeriodicSyncTask extends Runnable

  26. class PersistentQueue extends AnyRef

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

  28. class QueueCollection extends AnyRef

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

  30. class ServerStatus extends AnyRef

  31. class ServerStatusNotConfiguredException extends Exception

  32. trait SimplePendingReads extends AnyRef

  33. sealed abstract class Status extends AnyRef

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

  35. class TextHandler extends Service[TextRequest, TextResponse]

    Simple text-line protocol handler for a kestrel connection.

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

  37. abstract class TextResponse extends Signalling

  38. class ThriftFinagledService extends FinagledService

  39. class ThriftHandler extends FutureIface

  40. trait ThriftPendingReads extends AnyRef

  41. class TooManyOpenReadsException extends Exception

  42. class UnknownStatusException extends Exception

  43. class ZooKeeperServerStatus extends ServerStatus

Value Members

  1. object Down extends Status with Product with Serializable

  2. object Journal extends AnyRef

  3. object JournalItem extends AnyRef

  4. object Kestrel extends AnyRef

  5. object QItem extends Serializable

  6. object QueueCollection extends AnyRef

  7. object Quiescent extends Status with Product with Serializable

  8. object ReadOnly extends Status with Product with Serializable

  9. object Status extends AnyRef

  10. object TextCodec extends AnyRef

  11. object TextResponse extends AnyRef

  12. object ThriftPendingReads extends AnyRef

  13. object TooManyOpenReadsException extends TooManyOpenReadsException

  14. object Up extends Status with Product with Serializable

  15. object ZooKeeperIP extends AnyRef

  16. object ZooKeeperServerStatus extends AnyRef

  17. package config

  18. package thrift

  19. package tools