net.lag.kestrel.thrift.Kestrel

FinagledClient

class FinagledClient extends FinagleThriftClient with FutureIface

Linear Supertypes
FutureIface, FinagleThriftClient, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. FinagledClient
  2. FutureIface
  3. FinagleThriftClient
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new FinagledClient (service: Service[ThriftClientRequest, Array[Byte]], protocolFactory: TProtocolFactory)

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def abort (queueName: String, ids: Set[Long]): Future[Int]

    Definition Classes
    FinagledClientFutureIface
  7. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  8. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  9. def confirm (queueName: String, ids: Set[Long]): Future[Int]

    Definition Classes
    FinagledClientFutureIface
  10. def decodeResponse [T] (resBytes: Array[Byte], decoder: (TProtocol) ⇒ T): Future[T]

    Attributes
    protected
    Definition Classes
    FinagleThriftClient
  11. def deleteQueue (queueName: String): Future[Unit]

    Definition Classes
    FinagledClientFutureIface
  12. def encodeRequest (name: String, args: ThriftStruct): Future[ThriftClientRequest]

    Attributes
    protected
    Definition Classes
    FinagleThriftClient
  13. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  14. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  15. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  16. def flushAllQueues (): Future[Unit]

    Definition Classes
    FinagledClientFutureIface
  17. def flushQueue (queueName: String): Future[Unit]

    Definition Classes
    FinagledClientFutureIface
  18. def get (queueName: String, maxItems: Int, timeoutMsec: Int = 0, autoAbortMsec: Int = 0): Future[Seq[Item]]

    Definition Classes
    FinagledClientFutureIface
  19. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  20. def getVersion (): Future[String]

    Definition Classes
    FinagledClientFutureIface
  21. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  22. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  23. def missingResult (name: String): Future[Nothing]

    Attributes
    protected
    Definition Classes
    FinagleThriftClient
  24. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  25. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  26. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  27. def peek (queueName: String): Future[QueueInfo]

    Definition Classes
    FinagledClientFutureIface
  28. val protocolFactory : TProtocolFactory

    Definition Classes
    FinagledClient → FinagleThriftClient
  29. def put (queueName: String, items: Seq[ByteBuffer], expirationMsec: Int = 0): Future[Int]

    Definition Classes
    FinagledClientFutureIface
  30. val service : Service[ThriftClientRequest, Array[Byte]]

    Definition Classes
    FinagledClient → FinagleThriftClient
  31. val serviceName : Option[String]

    Definition Classes
    FinagleThriftClient
  32. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  33. def toString (): String

    Definition Classes
    AnyRef → Any
  34. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  35. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  36. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from FutureIface

Inherited from FinagleThriftClient

Inherited from AnyRef

Inherited from Any