object
Kestrel
extends AnyRef
Type Members
-
class
FinagledClient
extends FinagleThriftClient with FutureIface
-
class
FinagledService
extends Service[Array[Byte], Array[Byte]] with FinagleThriftService
-
-
trait
Iface
extends AnyRef
-
trait
ThriftServer
extends Service with FutureIface
-
case class
abort_args
(queueName: String, ids: Set[Long]) extends ThriftStruct with Product with Serializable
-
case class
abort_result
(success: Option[Int]) extends ThriftStruct with Product with Serializable
-
case class
confirm_args
(queueName: String, ids: Set[Long]) extends ThriftStruct with Product with Serializable
-
case class
confirm_result
(success: Option[Int]) extends ThriftStruct with Product with Serializable
-
case class
deleteQueue_args
(queueName: String) extends ThriftStruct with Product with Serializable
-
case class
deleteQueue_result
() extends ThriftStruct with Product with Serializable
-
case class
flushAllQueues_args
() extends ThriftStruct with Product with Serializable
-
case class
flushAllQueues_result
() extends ThriftStruct with Product with Serializable
-
case class
flushQueue_args
(queueName: String) extends ThriftStruct with Product with Serializable
-
case class
flushQueue_result
() extends ThriftStruct with Product with Serializable
-
case class
getVersion_args
() extends ThriftStruct with Product with Serializable
-
case class
getVersion_result
(success: Option[String]) extends ThriftStruct with Product with Serializable
-
case class
get_args
(queueName: String, maxItems: Int, timeoutMsec: Int, autoAbortMsec: Int) extends ThriftStruct with Product with Serializable
-
case class
get_result
(success: Option[Seq[Item]]) extends ThriftStruct with Product with Serializable
-
case class
peek_args
(queueName: String) extends ThriftStruct with Product with Serializable
-
case class
peek_result
(success: Option[QueueInfo]) extends ThriftStruct with Product with Serializable
-
case class
put_args
(queueName: String, items: Seq[ByteBuffer], expirationMsec: Int) extends ThriftStruct with Product with Serializable
-
case class
put_result
(success: Option[Int]) extends ThriftStruct with Product with Serializable
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
object
abort_args
extends ThriftStructCodec[abort_args] with Serializable
-
object
abort_result
extends ThriftStructCodec[abort_result] with Serializable
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
object
confirm_args
extends ThriftStructCodec[confirm_args] with Serializable
-
object
confirm_result
extends ThriftStructCodec[confirm_result] with Serializable
-
object
deleteQueue_args
extends ThriftStructCodec[deleteQueue_args] with Serializable
-
object
deleteQueue_result
extends ThriftStructCodec[deleteQueue_result] with Serializable
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
object
flushAllQueues_args
extends ThriftStructCodec[flushAllQueues_args] with Serializable
-
object
flushAllQueues_result
extends ThriftStructCodec[flushAllQueues_result] with Serializable
-
object
flushQueue_args
extends ThriftStructCodec[flushQueue_args] with Serializable
-
object
flushQueue_result
extends ThriftStructCodec[flushQueue_result] with Serializable
-
def
getClass
(): java.lang.Class[_]
-
object
getVersion_args
extends ThriftStructCodec[getVersion_args] with Serializable
-
object
getVersion_result
extends ThriftStructCodec[getVersion_result] with Serializable
-
object
get_args
extends ThriftStructCodec[get_args] with Serializable
-
object
get_result
extends ThriftStructCodec[get_result] with Serializable
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
object
peek_args
extends ThriftStructCodec[peek_args] with Serializable
-
object
peek_result
extends ThriftStructCodec[peek_result] with Serializable
-
object
put_args
extends ThriftStructCodec[put_args] with Serializable
-
object
put_result
extends ThriftStructCodec[put_result] with Serializable
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any