object param
- Alphabetic
- By Inheritance
- param
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- case class AttemptTTwitterUpgrade(upgrade: Boolean) extends Product with Serializable
A
Param
to control upgrading the thrift protocol to TTwitter.A
Param
to control upgrading the thrift protocol to TTwitter.- See also
The user guide for details on Twitter-upgrade Thrift.
- case class ClientId(clientId: Option[thrift.ClientId]) extends Product with Serializable
- case class Framed(enabled: Boolean) extends Product with Serializable
A
Param
to control whether a framed transport should be used.A
Param
to control whether a framed transport should be used. If this is set to false, a buffered transport is used. Framed transports are enabled by default.- enabled
Whether a framed transport should be used.
- case class MaxReusableBufferSize(maxReusableBufferSize: Int) extends Product with Serializable
A
Param
to set the max size of a reusable buffer for the thrift response.A
Param
to set the max size of a reusable buffer for the thrift response. If the buffer size exceeds the specified value, the buffer is not reused, and a new buffer is used for the next thrift response. The default max size is 16Kb.- maxReusableBufferSize
Max buffer size in bytes.
- case class PerEndpointStats(enabled: Boolean) extends Product with Serializable
A
Param
to control whether to record per-endpoint stats.A
Param
to control whether to record per-endpoint stats. If this is set to true, per-endpoint stats will be counted.- enabled
Whether to count per-endpoint stats
- case class ProtocolFactory(protocolFactory: TProtocolFactory) extends Product with Serializable
- final case class ServiceClass(clazz: Option[Class[_]]) extends Product with Serializable
A
Param
that captures a class of a Scrooge-generated service stub that's associated with a given client or server. - case class TReusableBufferFactory(tReusableBufferFactory: () => TReusableBuffer) extends Product with Serializable
A
Param
that sets a factory to create a TReusableBuffer, the TReusableBuffer can be shared with other client instances.A
Param
that sets a factory to create a TReusableBuffer, the TReusableBuffer can be shared with other client instances. If this is set, MaxReusableBufferSize will be ignored.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxThriftBufferSize: Int
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val protocolFactory: TProtocolFactory
The vanilla Thrift
Transporter
andListener
factories deviate from other protocols in the result of the netty pipeline: most other protocols expect to receive a framedBuf
while vanilla thrift produces anArray[Byte]
.The vanilla Thrift
Transporter
andListener
factories deviate from other protocols in the result of the netty pipeline: most other protocols expect to receive a framedBuf
while vanilla thrift produces anArray[Byte]
. This has two related motivations. First, the end result needed by the thrift implementations is anArray[Byte]
, which is relatively trivial to deal with and is a JVM native type so it's unnecessary to go through aBuf
. By avoiding an indirection throughBuf
we can avoid an unnecessary copy in the netty4 pipeline that would be required to ensure that the bytes were on the heap before entering the Finagle transport types. - final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- implicit object AttemptTTwitterUpgrade extends Param[AttemptTTwitterUpgrade] with Serializable
- implicit object ClientId extends Param[ClientId] with Serializable
- implicit object Framed extends Param[Framed] with Serializable
- implicit object MaxReusableBufferSize extends Param[MaxReusableBufferSize] with Serializable
- implicit object PerEndpointStats extends Param[PerEndpointStats] with Serializable
- implicit object ProtocolFactory extends Param[ProtocolFactory] with Serializable
- implicit object ServiceClass extends Param[ServiceClass] with Serializable
- implicit object TReusableBufferFactory extends Param[TReusableBufferFactory] with Serializable