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 TypeClassDescriptionclass
Write message implementation with a bufferFields in com.google.code.yanf4j.core.impl with type parameters of type WriteMessageModifier and TypeFieldDescriptionprotected AtomicReference
<WriteMessage> AbstractSession.currentMessage
protected Queue
<WriteMessage> AbstractSession.writeQueue
Methods in com.google.code.yanf4j.core.impl that return WriteMessageModifier and TypeMethodDescriptionprotected WriteMessage
AbstractSession.preprocessWriteMessage
(WriteMessage writeMessage) Pre-Process WriteMessage before writing to channelprotected abstract WriteMessage
AbstractSession.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 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 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 WriteMessage
NioTCPSession.wrapMessage
(Object msg, Future<Boolean> writeFuture) Methods in com.google.code.yanf4j.nio.impl with parameters of type WriteMessageModifier and TypeMethodDescriptionprotected final Object
NioTCPSession.blockingWrite
(SelectableChannel channel, WriteMessage message, IoBuffer writeBuffer) Blocking write using temp selectorprotected boolean
AbstractNioSession.schduleWriteMessage
(WriteMessage writeMessage) void
AbstractNioSession.writeFromUserCode
(WriteMessage message) protected abstract Object
AbstractNioSession.writeToChannel
(WriteMessage msg) protected Object
NioTCPSession.writeToChannel
(WriteMessage message) Method parameters in com.google.code.yanf4j.nio.impl with type arguments of type WriteMessageModifier and TypeMethodDescriptionprotected final NioSessionConfig
NioController.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 TypeClassDescriptionclass
Abstract Memcached Commandclass
Abstract 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 TypeClassDescriptionclass
Base Binary command.class
Binary protocol for append,prependclass
List auth mechanisms commandclass
Auth start commandclass
Auth step commandclass
AWS ElasticCache config commandclass
CAS binary protocol implementationclass
Binary delete commandclass
Flush command for binary protocolclass
Binary GAT/GATQ commandclass
Implements get/getq,getk/getkq protocolclass
A command for holding getkq commandsclass
Binary incr/decr commandclass
Implement noop protocolclass
Quit command for binary protocolclass
A command for holding getkq commandsclass
Stats command for binary protocolclass
Base binary protocol implementationclass
Binary touch commandclass
Binary verbosity commandclass
Version command for binary protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.command.kestrel
Classes in net.rubyeye.xmemcached.command.kestrel that implement WriteMessageModifier and TypeClassDescriptionclass
class
Kestrel flush commandclass
Kestrel get commandclass
kestrel set command -
Uses of WriteMessage in net.rubyeye.xmemcached.command.text
Classes in net.rubyeye.xmemcached.command.text that implement WriteMessageModifier and TypeClassDescriptionclass
AWS ElasticCache config command, see Adding Auto Discovery To Your Client Library.class
class
CAS command for text protocolclass
Delete command for text protocolclass
FlushAll command for text protocolclass
Abstract get command for text protocolclass
Bulk-get command for text protocolclass
Get command for text protocolclass
Incr/Decr command for text protocolclass
Quit command for text protocolclass
class
Stats command for text protocolclass
Store command for text protocolclass
Touch command for touch protocol.class
Verbosity command for text protocolclass
Version command for text protocol -
Uses of WriteMessage in net.rubyeye.xmemcached.impl
Methods in net.rubyeye.xmemcached.impl that return WriteMessageModifier and TypeMethodDescriptionFlowControlLinkedTransferQueue.peek()
FlowControlLinkedTransferQueue.poll()
protected WriteMessage
MemcachedTCPSession.preprocessWriteMessage
(WriteMessage writeMessage) FlowControlLinkedTransferQueue.take()
protected final WriteMessage
MemcachedTCPSession.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 void
FlowControlLinkedTransferQueue.checkPermits
(WriteMessage e) boolean
FlowControlLinkedTransferQueue.offer
(WriteMessage e) boolean
FlowControlLinkedTransferQueue.offer
(WriteMessage e, long timeout, 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, TimeUnit unit) Method parameters in net.rubyeye.xmemcached.impl with type arguments of type WriteMessageModifier and TypeMethodDescriptionint
FlowControlLinkedTransferQueue.drainTo
(Collection<? super WriteMessage> c) int
FlowControlLinkedTransferQueue.drainTo
(Collection<? super WriteMessage> c, int maxElements)