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

void	addToWatingQueue(ReconnectRequest request)
java.util.concurrent.Future<java.lang.Boolean>	connect(InetSocketAddressWrapper addressWrapper)
long	getHealSessionInterval()
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 memcached
void	removeReconnectRequest(java.net.InetSocketAddress address)
void	removeSession(Session session)
void	send(Command packet)
void	setBufferAllocator(BufferAllocator bufferAllocator)
void	setConnectionPoolSize(int connectionPoolSize)
void	setFailureMode(boolean failureMode)
void	setHealSessionInterval(long interval)
void	setMergeFactor(int factor)
void	setOptimizeGet(boolean optimizeGet)
void	setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)
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

void send(Command packet)
          throws MemcachedException

Throws:

MemcachedException

setConnectionPoolSize

void setConnectionPoolSize(int connectionPoolSize)

setBufferAllocator

void setBufferAllocator(BufferAllocator bufferAllocator)

removeReconnectRequest

void removeReconnectRequest(java.net.InetSocketAddress address)

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)

quitAllSessions

void quitAllSessions()

Make all connection sending a quit command to memcached

getReconnectRequestQueue

java.util.Queue<ReconnectRequest> getReconnectRequestQueue()

setFailureMode

void setFailureMode(boolean failureMode)