public class KetamaConnectionFactory extends DefaultConnectionFactory
This implementation piggy-backs on the functionality of the
DefaultConnectionFactory
in terms of connections and queue
handling. Where it differs is that it uses both the
KetamaNodeLocator
and the HashAlgorithm.KETAMA_HASH
to
provide consistent node hashing.
DEFAULT_FAILURE_MODE, DEFAULT_HASH, DEFAULT_MAX_RECONNECT_DELAY, DEFAULT_MAX_TIMEOUTEXCEPTION_THRESHOLD, DEFAULT_OP_QUEUE_LEN, DEFAULT_OP_QUEUE_MAX_BLOCK_TIME, DEFAULT_OPERATION_TIMEOUT, DEFAULT_READ_BUFFER_SIZE, opQueueLen
Constructor and Description |
---|
KetamaConnectionFactory()
Create a KetamaConnectionFactory with the default parameters.
|
KetamaConnectionFactory(int qLen,
int bufSize,
long opQueueMaxBlockTime)
Create a KetamaConnectionFactory with the given maximum operation
queue length, and the given read buffer size.
|
Modifier and Type | Method and Description |
---|---|
NodeLocator |
createLocator(java.util.List<MemcachedNode> nodes)
Create a NodeLocator instance for the given list of nodes.
|
createConnection, createMemcachedNode, createOperationQueue, createReadOperationQueue, createWriteOperationQueue, getAuthDescriptor, getDefaultTranscoder, getFailureMode, getHashAlg, getInitialObservers, getMaxReconnectDelay, getName, getOperationFactory, getOperationTimeout, getOpQueueLen, getOpQueueMaxBlockTime, getReadBufSize, getTimeoutExceptionThreshold, isDaemon, shouldOptimize, toString, useNagleAlgorithm
public KetamaConnectionFactory(int qLen, int bufSize, long opQueueMaxBlockTime)
opQueueMaxBlockTime
- the maximum time to block waiting for op
queue operations to complete, in millisecondspublic KetamaConnectionFactory()
public NodeLocator createLocator(java.util.List<MemcachedNode> nodes)
ConnectionFactory
createLocator
in interface ConnectionFactory
createLocator
in class DefaultConnectionFactory
Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.