package
kestrel
Type Members
-
-
-
-
case class
BrokenItemException(lastValidPosition: Long, cause: Throwable) extends IOException with Product with Serializable
-
case class
Checkpoint(filename: String, reservedItems: Seq[QItem]) extends Product with Serializable
-
class
ConcurrentHashMap[K, V] extends ConcurrentHashMap[K, V]
-
case class
CountResponse(count: Long) extends TextResponse with Product with Serializable
-
-
-
case class
ErrorResponse(message: String) extends TextResponse with Product with Serializable
-
-
-
class
ItemIdList extends AnyRef
-
case class
ItemResponse(data: Option[Array[Byte]]) extends TextResponse with Product with Serializable
-
class
Journal extends AnyRef
-
abstract
class
JournalItem extends AnyRef
-
-
-
class
Kestrel extends Service
-
abstract
class
KestrelHandler extends AnyRef
-
class
MemcacheHandler extends Service[MemcacheRequest, MemcacheResponse]
-
case class
NoResponse() extends TextResponse with Product with Serializable
-
case class
PackRequest(journal: Journal, checkpoint: Checkpoint, openItems: Iterable[QItem], pentUpDeletes: Int, queueState: Iterable[QItem]) extends Product with Serializable
-
-
-
-
case class
QItem(addTime: Time, expiry: Option[Time], data: Array[Byte], xid: Int) extends Product with Serializable
-
-
case class
QueueTransaction(name: String, xid: Int, timerTask: Option[TimerTask]) extends Product with Serializable
-
-
-
-
sealed abstract
class
Status extends AnyRef
-
case class
StringResponse(message: String) extends TextResponse with Product with Serializable
-
class
TextHandler extends Service[TextRequest, TextResponse]
-
case class
TextRequest(command: String, args: List[String], items: List[Array[Byte]]) extends Product with Serializable
-
abstract
class
TextResponse extends Signalling
-
-
-
-
-
-
Value Members
-
object
Down extends Status with Product with Serializable
-
object
Journal extends AnyRef
-
-
object
Kestrel extends AnyRef
-
object
QItem extends Serializable
-
-
object
Quiescent extends Status with Product with Serializable
-
object
ReadOnly extends Status with Product with Serializable
-
object
Status extends AnyRef
-
object
TextCodec extends AnyRef
-
-
-
-
object
Up extends Status with Product with Serializable
-
-
-
-
-