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
-
-
-
class
Kestrel
extends Service
-
-
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
-
-
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
-
class
TextResponse
extends Signalling
-
-
-
-