Uses of Interface
com.google.code.yanf4j.core.WriteMessage
-
Packages that use WriteMessage Package Description com.google.code.yanf4j.core Networking core packagecom.google.code.yanf4j.core.impl com.google.code.yanf4j.nio Nio implementationcom.google.code.yanf4j.nio.impl net.rubyeye.xmemcached.command Memcached protocol implementationsnet.rubyeye.xmemcached.command.binary Memcached text protocol implementationsnet.rubyeye.xmemcached.command.kestrel Kestrel protocol implementationsnet.rubyeye.xmemcached.command.text Memcached text protocol implementationsnet.rubyeye.xmemcached.impl Manage tcp connection,memcached protocol optimized,and some MBeans for monitor. -
-
Uses of WriteMessage in com.google.code.yanf4j.core
Fields in com.google.code.yanf4j.core with type parameters of type WriteMessage Modifier and Type Field Description java.util.Queue<WriteMessage>
SessionConfig. queue
Constructor parameters in com.google.code.yanf4j.core with type arguments of type WriteMessage Constructor Description SessionConfig(Handler handler, CodecFactory codecFactory, Statistics statistics, java.util.Queue<WriteMessage> queue, Dispatcher dispatchMessageDispatcher, boolean handleReadWriteConcurrently, long sessionTimeout, long sessionIdelTimeout)
-
Uses of WriteMessage in com.google.code.yanf4j.core.impl
Classes in com.google.code.yanf4j.core.impl that implement WriteMessage Modifier and Type Class Description class
WriteMessageImpl
Write message implementation with a bufferFields in com.google.code.yanf4j.core.impl with type parameters of type WriteMessage Modifier and Type Field Description protected java.util.concurrent.atomic.AtomicReference<WriteMessage>
AbstractSession. currentMessage
protected java.util.Queue<WriteMessage>
AbstractSession. writeQueue
Methods in com.google.code.yanf4j.core.impl that return WriteMessage Modifier and Type Method Description protected WriteMessage
AbstractSession. preprocessWriteMessage(WriteMessage writeMessage)
Pre-Process WriteMessage before writing to channelprotected abstract WriteMessage
AbstractSession. wrapMessage(java.lang.Object msg, java.util.concurrent.Future<java.lang.Boolean> writeFuture)
Methods in com.google.code.yanf4j.core.impl that return types with arguments of type WriteMessage Modifier and Type Method Description protected java.util.Queue<WriteMessage>
AbstractController. buildQueue()
Build write queue for sessionjava.util.Queue<WriteMessage>
AbstractSession. getWriteQueue()
Methods in com.google.code.yanf4j.core.impl with parameters of type WriteMessage Modifier and Type Method Description protected WriteMessage
AbstractSession. preprocessWriteMessage(WriteMessage writeMessage)
Pre-Process WriteMessage before writing to channelabstract void
AbstractSession. writeFromUserCode(WriteMessage message)
-
Uses of WriteMessage in com.google.code.yanf4j.nio
Constructor parameters in com.google.code.yanf4j.nio with type arguments of type WriteMessage Constructor Description NioSessionConfig(java.nio.channels.SelectableChannel sc, Handler handler, SelectorManager reactor, CodecFactory codecFactory, Statistics statistics, java.util.Queue<WriteMessage> queue, Dispatcher dispatchMessageDispatcher, boolean handleReadWriteConcurrently, long sessionTimeout, long sessionIdleTimeout)
-
Uses of WriteMessage in com.google.code.yanf4j.nio.impl
Methods in com.google.code.yanf4j.nio.impl that return WriteMessage Modifier and Type Method Description protected WriteMessage
NioTCPSession. wrapMessage(java.lang.Object msg, java.util.concurrent.Future<java.lang.Boolean> writeFuture)
Methods in com.google.code.yanf4j.nio.impl with parameters of type WriteMessage Modifier and Type Method Description protected java.lang.Object
NioTCPSession. blockingWrite(java.nio.channels.SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer)
Blocking write using temp selectorprotected boolean
AbstractNioSession. schduleWriteMessage(WriteMessage writeMessage)
void
AbstractNioSession. writeFromUserCode(WriteMessage message)
protected abstract java.lang.Object
AbstractNioSession. writeToChannel(WriteMessage msg)
protected java.lang.Object
NioTCPSession. writeToChannel(WriteMessage message)
Method parameters in com.google.code.yanf4j.nio.impl with type arguments of type WriteMessage Modifier and Type Method Description protected NioSessionConfig
NioController. buildSessionConfig(java.nio.channels.SelectableChannel sc, java.util.Queue<WriteMessage> queue)
Build nio session config -
Uses of WriteMessage in net.rubyeye.xmemcached.command
Classes in net.rubyeye.xmemcached.command that implement WriteMessage Modifier and Type Class Description class
Command
Abstract Memcached Commandclass
VerbosityCommand
Abstract verbosity command for text protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.command.binary
Classes in net.rubyeye.xmemcached.command.binary that implement WriteMessage Modifier and Type Class Description class
BaseBinaryCommand
Base Binary command.class
BinaryAppendPrependCommand
Binary protocol for append,prependclass
BinaryAuthListMechanismsCommand
List auth mechanisms commandclass
BinaryAuthStartCommand
Auth start commandclass
BinaryAuthStepCommand
Auth step commandclass
BinaryAWSElasticCacheConfigCommand
AWS ElasticCache config commandclass
BinaryCASCommand
CAS binary protocol implementationclass
BinaryDeleteCommand
Binary delete commandclass
BinaryFlushAllCommand
Flush command for binary protocolclass
BinaryGetAndTouchCommand
Binary GAT/GATQ commandclass
BinaryGetCommand
Implements get/getq,getk/getkq protocolclass
BinaryGetMultiCommand
A command for holding getkq commandsclass
BinaryIncrDecrCommand
Binary incr/decr commandclass
BinaryNoopCommand
Implement noop protocolclass
BinaryQuitCommand
Quit command for binary protocolclass
BinarySetMultiCommand
A command for holding getkq commandsclass
BinaryStatsCommand
Stats command for binary protocolclass
BinaryStoreCommand
Base binary protocol implementationclass
BinaryTouchCommand
Binary touch commandclass
BinaryVerbosityCommand
Binary verbosity commandclass
BinaryVersionCommand
Version command for binary protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.command.kestrel
Classes in net.rubyeye.xmemcached.command.kestrel that implement WriteMessage Modifier and Type Class Description class
KestrelDeleteCommand
class
KestrelFlushAllCommand
Kestrel flush commandclass
KestrelGetCommand
Kestrel get commandclass
KestrelSetCommand
kestrel set command -
Uses of WriteMessage in net.rubyeye.xmemcached.command.text
Classes in net.rubyeye.xmemcached.command.text that implement WriteMessage Modifier and Type Class Description class
TextAWSElasticCacheConfigCommand
AWS ElasticCache config command, see Adding Auto Discovery To Your Client Library.class
TextCacheDumpCommand
class
TextCASCommand
CAS command for text protocolclass
TextDeleteCommand
Delete command for text protocolclass
TextFlushAllCommand
FlushAll command for text protocolclass
TextGetCommand
Abstract get command for text protocolclass
TextGetMultiCommand
Bulk-get command for text protocolclass
TextGetOneCommand
Get command for text protocolclass
TextIncrDecrCommand
Incr/Decr command for text protocolclass
TextQuitCommand
Quit command for text protocolclass
TextStatsCachedumpCommand
class
TextStatsCommand
Stats command for text protocolclass
TextStoreCommand
Store command for text protocolclass
TextTouchCommand
Touch command for touch protocol.class
TextVerbosityCommand
Verbosity command for text protocolclass
TextVersionCommand
Version command for text protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.impl
Methods in net.rubyeye.xmemcached.impl that return WriteMessage Modifier and Type Method Description WriteMessage
FlowControlLinkedTransferQueue. peek()
WriteMessage
FlowControlLinkedTransferQueue. poll()
WriteMessage
FlowControlLinkedTransferQueue. poll(long timeout, java.util.concurrent.TimeUnit unit)
protected WriteMessage
MemcachedTCPSession. preprocessWriteMessage(WriteMessage writeMessage)
WriteMessage
FlowControlLinkedTransferQueue. take()
protected WriteMessage
MemcachedTCPSession. wrapMessage(java.lang.Object msg, java.util.concurrent.Future<java.lang.Boolean> writeFuture)
Methods in net.rubyeye.xmemcached.impl that return types with arguments of type WriteMessage Modifier and Type Method Description protected java.util.Queue<WriteMessage>
MemcachedConnector. buildQueue()
Build write queue for sessionjava.util.Iterator<WriteMessage>
FlowControlLinkedTransferQueue. iterator()
Methods in net.rubyeye.xmemcached.impl with parameters of type WriteMessage Modifier and Type Method Description private void
FlowControlLinkedTransferQueue. checkPermits(WriteMessage e)
boolean
FlowControlLinkedTransferQueue. offer(WriteMessage e)
boolean
FlowControlLinkedTransferQueue. offer(WriteMessage e, long timeout, java.util.concurrent.TimeUnit unit)
protected WriteMessage
MemcachedTCPSession. preprocessWriteMessage(WriteMessage writeMessage)
void
FlowControlLinkedTransferQueue. put(WriteMessage e)
private void
FlowControlLinkedTransferQueue. releasePermit(WriteMessage rt)
void
FlowControlLinkedTransferQueue. transfer(WriteMessage e)
boolean
FlowControlLinkedTransferQueue. tryTransfer(WriteMessage e)
boolean
FlowControlLinkedTransferQueue. tryTransfer(WriteMessage e, long timeout, java.util.concurrent.TimeUnit unit)
Method parameters in net.rubyeye.xmemcached.impl with type arguments of type WriteMessage Modifier and Type Method Description int
FlowControlLinkedTransferQueue. drainTo(java.util.Collection<? super WriteMessage> c)
int
FlowControlLinkedTransferQueue. drainTo(java.util.Collection<? super WriteMessage> c, int maxElements)
-