net.rubyeye.xmemcached.networking

Interface Connector

All Superinterfaces:

Controller

All Known Implementing Classes:

MemcachedConnector

public interface Connector
extends Controller

Connector which is used to connect to memcached server.

Author:

dennis

Method Summary

Methods

Modifier and Type	Method and Description
void	addToWatingQueue(ReconnectRequest request)
Future<Boolean>	connect(InetSocketAddressWrapper addressWrapper)
long	getHealSessionInterval()
FlowControl	getNoReplyOpsFlowControl() Returns the noreply operations flow control manager.
Queue<ReconnectRequest>	getReconnectRequestQueue()
Queue<Session>	getSessionByAddress(InetSocketAddress address)
Set<Session>	getSessionSet()
List<Session>	getStandbySessionListByMainNodeAddr(InetSocketAddress address)
void	quitAllSessions() Make all connection sending a quit command to memcached
void	removeReconnectRequest(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(Map<SocketOption,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

Queue<Session> getSessionByAddress(InetSocketAddress address)

getStandbySessionListByMainNodeAddr

List<Session> getStandbySessionListByMainNodeAddr(InetSocketAddress address)

getSessionSet

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(InetSocketAddress address)

setEnableHealSession

void setEnableHealSession(boolean enableHealSession)

addToWatingQueue

void addToWatingQueue(ReconnectRequest request)

setSocketOptions

void setSocketOptions(Map<SocketOption,Object> options)

connect

Future<Boolean> connect(InetSocketAddressWrapper addressWrapper)
                        throws IOException

Throws:

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

Queue<ReconnectRequest> getReconnectRequestQueue()

setFailureMode

void setFailureMode(boolean failureMode)

getNoReplyOpsFlowControl

FlowControl getNoReplyOpsFlowControl()

Returns the noreply operations flow control manager.

Returns: