Interface Connector
-
- All Superinterfaces:
Controller
- All Known Implementing Classes:
MemcachedConnector
public interface Connector extends Controller
Connector which is used to connect to memcached server.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addToWatingQueue(ReconnectRequest request)
java.util.concurrent.Future<java.lang.Boolean>
connect(InetSocketAddressWrapper addressWrapper)
long
getHealSessionInterval()
FlowControl
getNoReplyOpsFlowControl()
Returns the noreply operations flow control manager.java.util.Queue<ReconnectRequest>
getReconnectRequestQueue()
java.util.Queue<Session>
getSessionByAddress(java.net.InetSocketAddress address)
java.util.Set<Session>
getSessionSet()
java.util.List<Session>
getStandbySessionListByMainNodeAddr(java.net.InetSocketAddress address)
void
quitAllSessions()
Make all connection sending a quit command to memcachedvoid
removeReconnectRequest(java.net.InetSocketAddress address)
void
removeSession(Session session)
Session
send(Command packet)
void
setBufferAllocator(BufferAllocator bufferAllocator)
void
setConnectionPoolSize(int connectionPoolSize)
void
setEnableHealSession(boolean enableHealSession)
void
setFailureMode(boolean failureMode)
void
setHealSessionInterval(long interval)
void
setMergeFactor(int factor)
void
setOptimizeGet(boolean optimizeGet)
void
setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)
void
setSessionComparator(MemcachedSessionComparator sessionComparator)
void
setSessionLocator(MemcachedSessionLocator sessionLocator)
void
setSocketOptions(java.util.Map<SocketOption,java.lang.Object> options)
void
updateSessions()
-
Methods inherited from interface com.google.code.yanf4j.core.Controller
addStateListener, getCodecFactory, getDispatchMessageThreadCount, getHandler, getLocalSocketAddress, getPort, getReadThreadCount, getReceiveThroughputLimit, getSendThroughputLimit, getSessionIdleTimeout, getSessionTimeout, getSoTimeout, getStatistics, getWriteThreadCount, isHandleReadWriteConcurrently, isStarted, removeStateListener, setCodecFactory, setDispatchMessageThreadCount, setHandler, setHandleReadWriteConcurrently, setLocalSocketAddress, setReadThreadCount, setReceiveThroughputLimit, setSendThroughputLimit, setSessionIdleTimeout, setSessionTimeout, setSocketOption, setSoTimeout, setWriteThreadCount, start, stop
-
-
-
-
Method Detail
-
setOptimizeMergeBuffer
void setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)
-
setMergeFactor
void setMergeFactor(int factor)
-
setOptimizeGet
void setOptimizeGet(boolean optimizeGet)
-
removeSession
void removeSession(Session session)
-
getSessionByAddress
java.util.Queue<Session> getSessionByAddress(java.net.InetSocketAddress address)
-
getStandbySessionListByMainNodeAddr
java.util.List<Session> getStandbySessionListByMainNodeAddr(java.net.InetSocketAddress address)
-
getSessionSet
java.util.Set<Session> getSessionSet()
-
setHealSessionInterval
void setHealSessionInterval(long interval)
-
getHealSessionInterval
long getHealSessionInterval()
-
send
Session send(Command packet) throws MemcachedException
- Throws:
MemcachedException
-
setConnectionPoolSize
void setConnectionPoolSize(int connectionPoolSize)
-
setBufferAllocator
void setBufferAllocator(BufferAllocator bufferAllocator)
-
removeReconnectRequest
void removeReconnectRequest(java.net.InetSocketAddress address)
-
setEnableHealSession
void setEnableHealSession(boolean enableHealSession)
-
addToWatingQueue
void addToWatingQueue(ReconnectRequest request)
-
setSocketOptions
void setSocketOptions(java.util.Map<SocketOption,java.lang.Object> options)
-
connect
java.util.concurrent.Future<java.lang.Boolean> connect(InetSocketAddressWrapper addressWrapper) throws java.io.IOException
- Throws:
java.io.IOException
-
updateSessions
void updateSessions()
-
setSessionLocator
void setSessionLocator(MemcachedSessionLocator sessionLocator)
-
setSessionComparator
void setSessionComparator(MemcachedSessionComparator sessionComparator)
-
quitAllSessions
void quitAllSessions()
Make all connection sending a quit command to memcached
-
getReconnectRequestQueue
java.util.Queue<ReconnectRequest> getReconnectRequestQueue()
-
setFailureMode
void setFailureMode(boolean failureMode)
-
getNoReplyOpsFlowControl
FlowControl getNoReplyOpsFlowControl()
Returns the noreply operations flow control manager.- Returns:
-
-