Uses of Interface
com.google.code.yanf4j.core.WriteMessage
Packages that use WriteMessage
Package
Description
Networking core package
Nio implementation
Memcached protocol implementations
Memcached text protocol implementations
Kestrel protocol implementations
Memcached text protocol implementations
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 WriteMessageConstructor parameters in com.google.code.yanf4j.core with type arguments of type WriteMessageModifierConstructorDescriptionSessionConfig(Handler handler, CodecFactory codecFactory, Statistics statistics, 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 WriteMessageModifier and TypeClassDescriptionclassWrite message implementation with a bufferFields in com.google.code.yanf4j.core.impl with type parameters of type WriteMessageModifier and TypeFieldDescriptionprotected AtomicReference<WriteMessage> AbstractSession.currentMessageprotected Queue<WriteMessage> AbstractSession.writeQueueMethods in com.google.code.yanf4j.core.impl that return WriteMessageModifier and TypeMethodDescriptionprotected WriteMessageAbstractSession.preprocessWriteMessage(WriteMessage writeMessage) Pre-Process WriteMessage before writing to channelprotected abstract WriteMessageAbstractSession.wrapMessage(Object msg, Future<Boolean> writeFuture) Methods in com.google.code.yanf4j.core.impl that return types with arguments of type WriteMessageModifier and TypeMethodDescriptionprotected Queue<WriteMessage> AbstractController.buildQueue()Build write queue for sessionAbstractSession.getWriteQueue()Methods in com.google.code.yanf4j.core.impl with parameters of type WriteMessageModifier and TypeMethodDescriptionprotected 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 WriteMessageModifierConstructorDescriptionNioSessionConfig(SelectableChannel sc, Handler handler, SelectorManager reactor, CodecFactory codecFactory, Statistics statistics, 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 WriteMessageModifier and TypeMethodDescriptionprotected WriteMessageNioTCPSession.wrapMessage(Object msg, Future<Boolean> writeFuture) Methods in com.google.code.yanf4j.nio.impl with parameters of type WriteMessageModifier and TypeMethodDescriptionprotected final ObjectNioTCPSession.blockingWrite(SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer) Blocking write using temp selectorprotected booleanAbstractNioSession.schduleWriteMessage(WriteMessage writeMessage) voidAbstractNioSession.writeFromUserCode(WriteMessage message) protected abstract ObjectAbstractNioSession.writeToChannel(WriteMessage msg) protected ObjectNioTCPSession.writeToChannel(WriteMessage message) Method parameters in com.google.code.yanf4j.nio.impl with type arguments of type WriteMessageModifier and TypeMethodDescriptionprotected final NioSessionConfigNioController.buildSessionConfig(SelectableChannel sc, Queue<WriteMessage> queue) Build nio session config -
Uses of WriteMessage in net.rubyeye.xmemcached.command
Classes in net.rubyeye.xmemcached.command that implement WriteMessageModifier and TypeClassDescriptionclassAbstract Memcached CommandclassAbstract verbosity command for text protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.command.binary
Classes in net.rubyeye.xmemcached.command.binary that implement WriteMessageModifier and TypeClassDescriptionclassBase Binary command.classBinary protocol for append,prependclassList auth mechanisms commandclassAuth start commandclassAuth step commandclassAWS ElasticCache config commandclassCAS binary protocol implementationclassBinary delete commandclassFlush command for binary protocolclassBinary GAT/GATQ commandclassImplements get/getq,getk/getkq protocolclassA command for holding getkq commandsclassBinary incr/decr commandclassImplement noop protocolclassQuit command for binary protocolclassA command for holding getkq commandsclassStats command for binary protocolclassBase binary protocol implementationclassBinary touch commandclassBinary verbosity commandclassVersion command for binary protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.command.kestrel
Classes in net.rubyeye.xmemcached.command.kestrel that implement WriteMessageModifier and TypeClassDescriptionclassclassKestrel flush commandclassKestrel get commandclasskestrel set command -
Uses of WriteMessage in net.rubyeye.xmemcached.command.text
Classes in net.rubyeye.xmemcached.command.text that implement WriteMessageModifier and TypeClassDescriptionclassAWS ElasticCache config command, see Adding Auto Discovery To Your Client Library.classclassCAS command for text protocolclassDelete command for text protocolclassFlushAll command for text protocolclassAbstract get command for text protocolclassBulk-get command for text protocolclassGet command for text protocolclassIncr/Decr command for text protocolclassQuit command for text protocolclassclassStats command for text protocolclassStore command for text protocolclassTouch command for touch protocol.classVerbosity command for text protocolclassVersion command for text protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.impl
Subclasses with type arguments of type WriteMessage in net.rubyeye.xmemcached.implMethods in net.rubyeye.xmemcached.impl that return WriteMessageModifier and TypeMethodDescriptionFlowControlLinkedTransferQueue.peek()FlowControlLinkedTransferQueue.poll()protected WriteMessageMemcachedTCPSession.preprocessWriteMessage(WriteMessage writeMessage) FlowControlLinkedTransferQueue.take()protected final WriteMessageMemcachedTCPSession.wrapMessage(Object msg, Future<Boolean> writeFuture) Methods in net.rubyeye.xmemcached.impl that return types with arguments of type WriteMessageModifier and TypeMethodDescriptionprotected Queue<WriteMessage> MemcachedConnector.buildQueue()Build write queue for sessionFlowControlLinkedTransferQueue.iterator()Methods in net.rubyeye.xmemcached.impl with parameters of type WriteMessageModifier and TypeMethodDescriptionprivate voidFlowControlLinkedTransferQueue.checkPermits(WriteMessage e) booleanFlowControlLinkedTransferQueue.offer(WriteMessage e) booleanFlowControlLinkedTransferQueue.offer(WriteMessage e, long timeout, 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, TimeUnit unit) Method parameters in net.rubyeye.xmemcached.impl with type arguments of type WriteMessageModifier and TypeMethodDescriptionintFlowControlLinkedTransferQueue.drainTo(Collection<? super WriteMessage> c) intFlowControlLinkedTransferQueue.drainTo(Collection<? super WriteMessage> c, int maxElements)