com.couchbase.client.internal
Class ThrottleManager<T extends Throttler>
java.lang.Object
com.couchbase.client.internal.ThrottleManager<T>
public class ThrottleManager<T extends Throttler>
- extends java.lang.Object
The ThrottleManager handles Throttle instances which are bound to their
corresponding MemcachedNodes. It also handles automatic rebalance cleanup
and therefore acts as the managing frontend of the Throttle instances
which handle the actual throttling.
Constructor Summary |
ThrottleManager(java.util.List<java.net.InetSocketAddress> initialNodes,
java.lang.Class<T> throttler,
CouchbaseConnection conn,
net.spy.memcached.OperationFactory opFact)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ThrottleManager
public ThrottleManager(java.util.List<java.net.InetSocketAddress> initialNodes,
java.lang.Class<T> throttler,
CouchbaseConnection conn,
net.spy.memcached.OperationFactory opFact)
setThrottler
public final ThrottleManager setThrottler(java.net.InetSocketAddress node)
getThrottler
public T getThrottler(java.net.InetSocketAddress node)
removeThrottler
public void removeThrottler(java.net.InetSocketAddress node)
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.