com.twitter.finagle.exp.zookeeper.client

RepDispatcher

class RepDispatcher extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RepDispatcher
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RepDispatcher(trans: Transport[Buf, Buf])

Type Members

  1. class Reader extends AnyRef

  2. sealed case class RequestRecord(opCode: Int, xid: Option[Int]) extends Product with Serializable

  3. sealed case class ResponsePacket(header: Option[ReplyHeader], body: Option[Response]) extends Product with Serializable

  4. class Writer extends AnyRef

    Should be used to write a ReqPacket on the transport.

Value Members

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

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def checkAssociation(reqRecord: RequestRecord, repHeader: ReplyHeader): Unit

    Checks an association between a request and a ReplyHeader

    Checks an association between a request and a ReplyHeader

    reqRecord

    expected request details

    repHeader

    freshly decoded ReplyHeader

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  9. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  10. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  11. def failDispatcher(exc: Throwable): Unit

    Fails the dispatcher, stops sending ping, invalids the connection.

    Fails the dispatcher, stops sending ping, invalids the connection.

    exc

    the failure cause

  12. def failPendingResponses(exc: Throwable): Unit

    Fails all pending responses with an exception.

    Fails all pending responses with an exception.

    exc

    the failure cause

  13. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  14. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  15. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  16. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  17. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  18. final def notify(): Unit

    Definition Classes
    AnyRef

  19. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  20. def read(): Future[Unit]

    Reads a Buf from the transport and decodes it.

    Reads a Buf from the transport and decodes it.

    returns

    Future.Done when reading and decoding is done

  21. def readLoop(): Future[Unit]

    Reads from the transport until the session is closed or the connection is invalid.

    Reads from the transport until the session is closed or the connection is invalid.

    returns

    Future.Done when reading is stopped

  22. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  23. def toString(): String

    Definition Classes
    AnyRef → Any

  24. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  25. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  27. def write(req: ReqPacket): Future[RepPacket]

    We make decisions depending on request type, a request record of the Packet is added to the queue, then the packet is finally written to the transport.

    We make decisions depending on request type, a request record of the Packet is added to the queue, then the packet is finally written to the transport.

    req

    the request to send

    returns

    a Future[Unit] when the request is finally written

Inherited from AnyRef

Inherited from Any

Ungrouped