class PartitioningParams[A <: Parameterized[A]] extends AnyRef
A collection of methods for configuring the PartitioningService of Thrift clients
- A
a Stack.Parameterized client to configure
- Alphabetic
- By Inheritance
- PartitioningParams
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PartitioningParams(self: Parameterized[A])
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()
- def ejectFailedHost(eject: Boolean): A
Whether to eject failing hosts from the hash ring based on failure accrual.
Whether to eject failing hosts from the hash ring based on failure accrual. By default, this is off.
The failing signal currently is gathered from com.twitter.finagle.partitioning.ConsistentHashingFailureAccrualFactory
- Note
When turning on, ejection is based on the failure accrual mentioned above, so your cluster may get different views of the same host. With partitioning strategy updates, this can introduce inter-process inconsistencies between hash rings. In many cases, it's better to eject failing host via a separate mechanism that's based on a global view.
- 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
- def keyHasher(hasher: KeyHasher): A
Defines the hash function to use for partitioned clients when mapping keys to partitions.
- 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()
- def numReps(reps: Int): A
Duplicate each node across the hash ring according to
reps
.Duplicate each node across the hash ring according to
reps
.- See also
com.twitter.hashing.ConsistentHashingDistributor for more details.
- def strategy(partitioningStrategy: PartitioningStrategy): A
Produce a Thrift or ThriftMux client with PartitioningStrategy.
Produce a Thrift or ThriftMux client with PartitioningStrategy.
- partitioningStrategy
- 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()