Package | Description |
---|---|
com.google.code.yanf4j.core |
Networking core package
|
com.google.code.yanf4j.core.impl | |
com.google.code.yanf4j.nio |
Nio implementation
|
com.google.code.yanf4j.nio.impl | |
net.rubyeye.xmemcached |
XMemcached's main classes and interfaces,use these
classes/interfaces to interact with memcached servers.
|
net.rubyeye.xmemcached.codec |
Memcached protocol codec
|
net.rubyeye.xmemcached.command |
Memcached protocol implementations
|
net.rubyeye.xmemcached.impl |
Manage tcp connection,memcached protocol optimized,and some
MBeans for monitor.
|
net.rubyeye.xmemcached.networking |
Networking layout to talk with memcached.
|
Modifier and Type | Method and Description |
---|---|
Object |
CodecFactory.Decoder.decode(IoBuffer buff,
Session session) |
IoBuffer |
CodecFactory.Encoder.encode(Object message,
Session session) |
void |
Handler.onExceptionCaught(Session session,
Throwable throwable) |
void |
Handler.onMessageReceived(Session session,
Object msg) |
void |
Handler.onMessageSent(Session session,
Object msg) |
void |
Handler.onSessionClosed(Session session) |
void |
Handler.onSessionConnected(Session session) |
void |
Handler.onSessionCreated(Session session) |
void |
Handler.onSessionExpired(Session session) |
void |
Handler.onSessionIdle(Session session) |
void |
Handler.onSessionStarted(Session session) |
void |
SessionManager.registerSession(Session session)
Register session to controller
|
void |
SessionManager.unregisterSession(Session session)
Unregister session
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSession
Base connection
|
Modifier and Type | Field and Description |
---|---|
protected Set<Session> |
AbstractController.sessionSet
Connected session set
|
Modifier and Type | Method and Description |
---|---|
Set<Session> |
AbstractController.getSessionSet() |
Modifier and Type | Method and Description |
---|---|
Object |
ByteBufferCodecFactory.ByteBufferDecoder.decode(IoBuffer buff,
Session session) |
IoBuffer |
ByteBufferCodecFactory.ByteBufferEncoder.encode(Object message,
Session session) |
void |
HandlerAdapter.onExceptionCaught(Session session,
Throwable throwable) |
void |
HandlerAdapter.onMessageReceived(Session session,
Object message) |
void |
HandlerAdapter.onMessageSent(Session session,
Object message) |
void |
HandlerAdapter.onSessionClosed(Session session) |
void |
HandlerAdapter.onSessionConnected(Session session) |
void |
HandlerAdapter.onSessionCreated(Session session) |
void |
HandlerAdapter.onSessionExpired(Session session) |
void |
HandlerAdapter.onSessionIdle(Session session) |
void |
HandlerAdapter.onSessionStarted(Session session) |
void |
AbstractController.registerSession(Session session) |
void |
AbstractController.unregisterSession(Session session) |
Modifier and Type | Interface and Description |
---|---|
interface |
NioSession
Nio connection
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractNioSession
Abstract nio session
|
class |
NioTCPSession
Nio tcp connection
|
Modifier and Type | Method and Description |
---|---|
void |
SelectorManager.registerSession(Session session,
EventType event)
Register session
|
void |
Reactor.registerSession(Session session,
EventType event) |
Constructor and Description |
---|
Reactor.RegisterEvent(Session session,
EventType eventType) |
Modifier and Type | Method and Description |
---|---|
Session |
MemcachedSessionLocator.getSessionByKey(String key)
Returns a session by special key.
|
Modifier and Type | Method and Description |
---|---|
void |
MemcachedSessionLocator.updateSessions(Collection<Session> list)
Update sessions when session was added or removed.
|
Modifier and Type | Method and Description |
---|---|
Object |
MemcachedDecoder.decode(IoBuffer buffer,
Session origSession) |
IoBuffer |
MemcachedEncoder.encode(Object message,
Session session) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Command.decodeError(Session session,
ByteBuffer buffer) |
Modifier and Type | Class and Description |
---|---|
class |
ClosedMemcachedTCPSession
Closed session
|
class |
MemcachedTCPSession
Connected session for a memcached server
|
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<InetSocketAddress,Queue<Session>> |
MemcachedConnector.sessionMap |
Modifier and Type | Method and Description |
---|---|
Session |
MemcachedConnector.findSessionByKey(String key) |
Session |
LibmemcachedMemcachedSessionLocator.getSessionByHash(long hash) |
Session |
KetamaMemcachedSessionLocator.getSessionByHash(long hash) |
Session |
RoundRobinMemcachedSessionLocator.getSessionByKey(String key) |
Session |
RandomMemcachedSessionLocaltor.getSessionByKey(String key) |
Session |
PHPMemcacheSessionLocator.getSessionByKey(String key) |
Session |
LibmemcachedMemcachedSessionLocator.getSessionByKey(String key) |
Session |
KetamaMemcachedSessionLocator.getSessionByKey(String key) |
Session |
ElectionMemcachedSessionLocator.getSessionByKey(String key) |
Session |
ArrayMemcachedSessionLocator.getSessionByKey(String key) |
Session |
MemcachedConnector.send(Command msg) |
Modifier and Type | Method and Description |
---|---|
Queue<Session> |
MemcachedConnector.getSessionByAddress(InetSocketAddress addr)
Get session by InetSocketAddress
|
List<Session> |
MemcachedConnector.getSessionListBySocketAddress(InetSocketAddress inetSocketAddress) |
Set<Session> |
MemcachedConnector.getSessionSet() |
List<Session> |
MemcachedConnector.getStandbySessionListByMainNodeAddr(InetSocketAddress addr)
Returns main node's standby session list.
|
Modifier and Type | Method and Description |
---|---|
void |
MemcachedConnector.addSession(Session session) |
int |
MemcachedSessionComparator.compare(Session o1,
Session o2) |
void |
MemcachedHandler.onExceptionCaught(Session session,
Throwable throwable) |
void |
MemcachedHandler.onMessageReceived(Session session,
Object msg)
On receive message from memcached server
|
void |
MemcachedHandler.onMessageSent(Session session,
Object msg)
put command which have been sent to queue
|
void |
MemcachedHandler.onSessionClosed(Session session)
Check if have to reconnect on session closed
|
void |
MemcachedHandler.onSessionIdle(Session session)
Do a heartbeat action
|
void |
MemcachedHandler.onSessionStarted(Session session)
On session started
|
void |
MemcachedConnector.removeSession(Session session) |
Modifier and Type | Method and Description |
---|---|
void |
RoundRobinMemcachedSessionLocator.updateSessions(Collection<Session> list) |
void |
RandomMemcachedSessionLocaltor.updateSessions(Collection<Session> list) |
void |
PHPMemcacheSessionLocator.updateSessions(Collection<Session> list) |
void |
LibmemcachedMemcachedSessionLocator.updateSessions(Collection<Session> list) |
void |
KetamaMemcachedSessionLocator.updateSessions(Collection<Session> list) |
void |
ElectionMemcachedSessionLocator.updateSessions(Collection<Session> list) |
void |
ArrayMemcachedSessionLocator.updateSessions(Collection<Session> list) |
Constructor and Description |
---|
KetamaMemcachedSessionLocator(List<Session> list,
HashAlgorithm alg) |
Modifier and Type | Interface and Description |
---|---|
interface |
MemcachedSession
Abstract interface for memcached connection.
|
Modifier and Type | Method and Description |
---|---|
Session |
Connector.send(Command packet) |
Modifier and Type | Method and Description |
---|---|
Queue<Session> |
Connector.getSessionByAddress(InetSocketAddress address) |
Set<Session> |
Connector.getSessionSet() |
List<Session> |
Connector.getStandbySessionListByMainNodeAddr(InetSocketAddress address) |
Modifier and Type | Method and Description |
---|---|
void |
Connector.removeSession(Session session) |
Copyright © 2016. All rights reserved.