Interface Connector
- All Superinterfaces:
Controller
- All Known Implementing Classes:
MemcachedConnector
Connector which is used to connect to memcached server.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
addToWatingQueue
(ReconnectRequest request) connect
(InetSocketAddressWrapper addressWrapper) long
Returns the noreply operations flow control manager.getSessionByAddress
(InetSocketAddress address) void
Make all connection sending a quit command to memcachedvoid
removeReconnectRequest
(InetSocketAddress address) void
removeSession
(Session session) 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
(Map<SocketOption, Object> options) void
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 Details
-
setOptimizeMergeBuffer
void setOptimizeMergeBuffer(boolean optimiezeMergeBuffer) -
setMergeFactor
void setMergeFactor(int factor) -
setOptimizeGet
void setOptimizeGet(boolean optimizeGet) -
removeSession
-
getSessionByAddress
-
getStandbySessionListByMainNodeAddr
-
getSessionSet
-
setHealSessionInterval
void setHealSessionInterval(long interval) -
getHealSessionInterval
long getHealSessionInterval() -
send
- Throws:
MemcachedException
-
setConnectionPoolSize
void setConnectionPoolSize(int connectionPoolSize) -
setBufferAllocator
-
removeReconnectRequest
-
setEnableHealSession
void setEnableHealSession(boolean enableHealSession) -
addToWatingQueue
-
setSocketOptions
-
connect
- Throws:
IOException
-
updateSessions
void updateSessions() -
setSessionLocator
-
setSessionComparator
-
quitAllSessions
void quitAllSessions()Make all connection sending a quit command to memcached -
getReconnectRequestQueue
Queue<ReconnectRequest> getReconnectRequestQueue() -
setFailureMode
void setFailureMode(boolean failureMode) -
getNoReplyOpsFlowControl
FlowControl getNoReplyOpsFlowControl()Returns the noreply operations flow control manager.- Returns:
-