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. queueConstructor 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 classWriteMessageImplWrite 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. currentMessageprotected java.util.Queue<WriteMessage>AbstractSession. writeQueueMethods in com.google.code.yanf4j.core.impl that return WriteMessage Modifier and Type Method Description protected WriteMessageAbstractSession. preprocessWriteMessage(WriteMessage writeMessage)Pre-Process WriteMessage before writing to channelprotected abstract WriteMessageAbstractSession. 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 WriteMessageAbstractSession. preprocessWriteMessage(WriteMessage writeMessage)Pre-Process WriteMessage before writing to channelabstract voidAbstractSession. 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 WriteMessageNioTCPSession. 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.ObjectNioTCPSession. blockingWrite(java.nio.channels.SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer)Blocking write using temp selectorprotected booleanAbstractNioSession. schduleWriteMessage(WriteMessage writeMessage)voidAbstractNioSession. writeFromUserCode(WriteMessage message)protected abstract java.lang.ObjectAbstractNioSession. writeToChannel(WriteMessage msg)protected java.lang.ObjectNioTCPSession. writeToChannel(WriteMessage message)Method parameters in com.google.code.yanf4j.nio.impl with type arguments of type WriteMessage Modifier and Type Method Description protected NioSessionConfigNioController. 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 classCommandAbstract Memcached CommandclassVerbosityCommandAbstract 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 classBaseBinaryCommandBase Binary command.classBinaryAppendPrependCommandBinary protocol for append,prependclassBinaryAuthListMechanismsCommandList auth mechanisms commandclassBinaryAuthStartCommandAuth start commandclassBinaryAuthStepCommandAuth step commandclassBinaryAWSElasticCacheConfigCommandAWS ElasticCache config commandclassBinaryCASCommandCAS binary protocol implementationclassBinaryDeleteCommandBinary delete commandclassBinaryFlushAllCommandFlush command for binary protocolclassBinaryGetAndTouchCommandBinary GAT/GATQ commandclassBinaryGetCommandImplements get/getq,getk/getkq protocolclassBinaryGetMultiCommandA command for holding getkq commandsclassBinaryIncrDecrCommandBinary incr/decr commandclassBinaryNoopCommandImplement noop protocolclassBinaryQuitCommandQuit command for binary protocolclassBinarySetMultiCommandA command for holding getkq commandsclassBinaryStatsCommandStats command for binary protocolclassBinaryStoreCommandBase binary protocol implementationclassBinaryTouchCommandBinary touch commandclassBinaryVerbosityCommandBinary verbosity commandclassBinaryVersionCommandVersion 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 classKestrelDeleteCommandclassKestrelFlushAllCommandKestrel flush commandclassKestrelGetCommandKestrel get commandclassKestrelSetCommandkestrel 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 classTextAWSElasticCacheConfigCommandAWS ElasticCache config command, see Adding Auto Discovery To Your Client Library.classTextCacheDumpCommandclassTextCASCommandCAS command for text protocolclassTextDeleteCommandDelete command for text protocolclassTextFlushAllCommandFlushAll command for text protocolclassTextGetCommandAbstract get command for text protocolclassTextGetMultiCommandBulk-get command for text protocolclassTextGetOneCommandGet command for text protocolclassTextIncrDecrCommandIncr/Decr command for text protocolclassTextQuitCommandQuit command for text protocolclassTextStatsCachedumpCommandclassTextStatsCommandStats command for text protocolclassTextStoreCommandStore command for text protocolclassTextTouchCommandTouch command for touch protocol.classTextVerbosityCommandVerbosity command for text protocolclassTextVersionCommandVersion 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 WriteMessageFlowControlLinkedTransferQueue. peek()WriteMessageFlowControlLinkedTransferQueue. poll()WriteMessageFlowControlLinkedTransferQueue. poll(long timeout, java.util.concurrent.TimeUnit unit)protected WriteMessageMemcachedTCPSession. preprocessWriteMessage(WriteMessage writeMessage)WriteMessageFlowControlLinkedTransferQueue. take()protected WriteMessageMemcachedTCPSession. 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 voidFlowControlLinkedTransferQueue. checkPermits(WriteMessage e)booleanFlowControlLinkedTransferQueue. offer(WriteMessage e)booleanFlowControlLinkedTransferQueue. offer(WriteMessage e, long timeout, java.util.concurrent.TimeUnit unit)protected WriteMessageMemcachedTCPSession. preprocessWriteMessage(WriteMessage writeMessage)voidFlowControlLinkedTransferQueue. put(WriteMessage e)private voidFlowControlLinkedTransferQueue. releasePermit(WriteMessage rt)voidFlowControlLinkedTransferQueue. transfer(WriteMessage e)booleanFlowControlLinkedTransferQueue. tryTransfer(WriteMessage e)booleanFlowControlLinkedTransferQueue. 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 intFlowControlLinkedTransferQueue. drainTo(java.util.Collection<? super WriteMessage> c)intFlowControlLinkedTransferQueue. drainTo(java.util.Collection<? super WriteMessage> c, int maxElements)
-