Uses of Class
net.rubyeye.xmemcached.command.Command
-
Packages that use Command Package Description net.rubyeye.xmemcached XMemcached's main classes and interfaces,use these classes/interfaces to interact with memcached servers.net.rubyeye.xmemcached.auth Memcached 1.4.3 or later version has supported SASL authentication,these classes are used for thatnet.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.net.rubyeye.xmemcached.networking Networking layout to talk with memcached. -
-
Uses of Command in net.rubyeye.xmemcached
Methods in net.rubyeye.xmemcached that return Command Modifier and Type Method Description Command
CommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
create a add commandCommand
CommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
create a append commandCommand
CommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)
Create a command for listing authentication mechanismsCommand
CommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Create command for starting authenticationCommand
CommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Create a command for stepping authenticationCommand
CommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)
Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.Command
CommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)
Create a cas commandCommand
CommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)
create a delete commandCommand
CommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)
create a flush_all commandCommand
CommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Create a get-and-touch commandCommand
CommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
create a get/gets command<T> Command
CommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
Create a multi-get commandCommand
CommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long delta, long initial, int expTime, CommandType cmdType, boolean noreply)
create a incr/decr commandCommand
CommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Create a prepend commandCommand
CommandFactory. createQuitCommand()
create a quit commandCommand
CommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
create a replace commandCommand
CommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Create a set commandCommand
CommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)
create a stats commandCommand
CommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Create a touch commandCommand
CommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)
Create a verbosity commandCommand
CommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)
create a version commandCommand
MemcachedOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
private <T> Command
XMemcachedClient. sendGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
Methods in net.rubyeye.xmemcached with parameters of type Command Modifier and Type Method Description protected void
XMemcachedClient. checkException(Command command)
protected void
XMemcachedClient. latchWait(Command cmd, long timeout, Session session)
Command
MemcachedOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
protected Session
XMemcachedClient. sendCommand(Command cmd)
private <T> boolean
XMemcachedClient. sendStoreCommand(Command command, long timeout)
Method parameters in net.rubyeye.xmemcached with type arguments of type Command Modifier and Type Method Description private <T> java.util.Map<java.lang.String,T>
XMemcachedClient. reduceResult(CommandType cmdType, Transcoder<T> transcoder, java.util.List<Command> commands)
-
Uses of Command in net.rubyeye.xmemcached.auth
Methods in net.rubyeye.xmemcached.auth that return Command Modifier and Type Method Description private Command
AuthTask. startAuth()
Methods in net.rubyeye.xmemcached.auth with parameters of type Command Modifier and Type Method Description private void
AuthTask. waitCommand(Command cmd, java.util.concurrent.atomic.AtomicBoolean done)
-
Uses of Command in net.rubyeye.xmemcached.command
Subclasses of Command in net.rubyeye.xmemcached.command Modifier and Type Class Description class
VerbosityCommand
Abstract verbosity command for text protocolMethods in net.rubyeye.xmemcached.command that return Command Modifier and Type Method Description Command
BinaryCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)
Command
KestrelCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)
Command
TextCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)
Command
BinaryCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
KestrelCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
TextCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
BinaryCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
KestrelCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
TextCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)
Command
BinaryCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)
Command
KestrelCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)
Command
TextCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)
Command
BinaryCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)
Command
KestrelCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)
Command
TextCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)
Command
BinaryCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)
Command
KestrelCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)
Command
TextCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int exptime, boolean noreply)
Command
BinaryCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
KestrelCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
TextCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
BinaryCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
Command
KestrelCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
Command
TextCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
<T> Command
BinaryCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
<T> Command
KestrelCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
<T> Command
TextCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
Command
BinaryCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply)
Command
KestrelCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply)
Command
TextCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int exptime, CommandType cmdType, boolean noreply)
Command
BinaryCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createQuitCommand()
Command
KestrelCommandFactory. createQuitCommand()
Command
TextCommandFactory. createQuitCommand()
Command
BinaryCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
KestrelCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)
Command
TextCommandFactory. createStatsCachedumpCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, int slabId, int limit)
Command
BinaryCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)
Command
KestrelCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)
Command
TextCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)
(package private) Command
BinaryCommandFactory. createStoreCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, CommandType cmdType, boolean noreply, Transcoder transcoder)
(package private) Command
TextCommandFactory. createStoreCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, CommandType cmdType, boolean noreply, Transcoder transcoder)
Command
BinaryCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
KestrelCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
TextCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)
Command
BinaryCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)
Command
KestrelCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)
Command
TextCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)
Create verbosity commandCommand
BinaryCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)
Command
KestrelCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)
Command
TextCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)
Methods in net.rubyeye.xmemcached.command that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>
AssocCommandAware. getAssocCommands()
java.util.Map<java.lang.Object,Command>
MergeCommandsAware. getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command with type arguments of type Command Modifier and Type Method Description void
AssocCommandAware. setAssocCommands(java.util.List<Command> assocCommands)
void
MergeCommandsAware. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
-
Uses of Command in net.rubyeye.xmemcached.command.binary
Subclasses of Command in net.rubyeye.xmemcached.command.binary 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 protocolFields in net.rubyeye.xmemcached.command.binary with type parameters of type Command Modifier and Type Field Description private java.util.List<Command>
BinaryGetCommand. assocCommands
private java.util.Map<java.lang.Object,Command>
BinaryGetMultiCommand. mergeCommands
private java.util.Map<java.lang.Object,Command>
BinarySetMultiCommand. mergeCommands
Methods in net.rubyeye.xmemcached.command.binary that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>
BinaryGetCommand. getAssocCommands()
java.util.Map<java.lang.Object,Command>
BinaryGetMultiCommand. getMergeCommands()
java.util.Map<java.lang.Object,Command>
BinarySetMultiCommand. getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command.binary with type arguments of type Command Modifier and Type Method Description void
BinaryGetCommand. setAssocCommands(java.util.List<Command> assocCommands)
void
BinaryGetMultiCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
void
BinarySetMultiCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
-
Uses of Command in net.rubyeye.xmemcached.command.kestrel
Subclasses of Command in net.rubyeye.xmemcached.command.kestrel Modifier and Type Class Description class
KestrelDeleteCommand
class
KestrelFlushAllCommand
Kestrel flush commandclass
KestrelGetCommand
Kestrel get commandclass
KestrelSetCommand
kestrel set command -
Uses of Command in net.rubyeye.xmemcached.command.text
Subclasses of Command in net.rubyeye.xmemcached.command.text 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 protocolFields in net.rubyeye.xmemcached.command.text with type parameters of type Command Modifier and Type Field Description protected java.util.List<Command>
TextGetCommand. assocCommands
When MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.protected java.util.Map<java.lang.Object,Command>
TextGetCommand. mergeCommands
Methods in net.rubyeye.xmemcached.command.text that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>
TextGetCommand. getAssocCommands()
java.util.Map<java.lang.Object,Command>
TextGetCommand. getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command.text with type arguments of type Command Modifier and Type Method Description void
TextGetCommand. setAssocCommands(java.util.List<Command> assocCommands)
void
TextGetCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
-
Uses of Command in net.rubyeye.xmemcached.impl
Fields in net.rubyeye.xmemcached.impl declared as Command Modifier and Type Field Description (package private) Command
Optimizer.BinaryGetQCollector. prevCommand
private Command
MemcachedHandler.CheckHeartResultThread. versionCommand
Fields in net.rubyeye.xmemcached.impl with type parameters of type Command Modifier and Type Field Description protected java.util.concurrent.BlockingQueue<Command>
MemcachedTCPSession. commandAlreadySent
Command which are already sentprivate java.util.concurrent.atomic.AtomicReference<Command>
MemcachedTCPSession. currentCommand
(package private) java.util.Map<java.lang.Object,Command>
Optimizer.BinarySetQCollector. mergeCommands
private java.lang.ThreadLocal<java.util.List<Command>>
Optimizer. threadLocal
Methods in net.rubyeye.xmemcached.impl that return Command Modifier and Type Method Description Command
MemcachedTCPSession. getCurrentCommand()
private Command
Optimizer. mergeBuffer(Command firstCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
private Command
Optimizer. mergeGetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType)
private Command
Optimizer. mergeSetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize)
private Command
Optimizer. newMergedCommand(java.util.Map<java.lang.Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)
Command
Optimizer. optimiezeGet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand)
Merge get operation to multi-get operationCommand
Optimizer. optimiezeMergeBuffer(Command optimiezeCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
merge buffers to fit socket's send buffer sizeCommand
Optimizer. optimiezeSet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Command
Optimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
private Command
MemcachedTCPSession. takeExecutingCommand()
get current command from queueMethods in net.rubyeye.xmemcached.impl that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>
Optimizer. getLocalList()
Methods in net.rubyeye.xmemcached.impl with parameters of type Command Modifier and Type Method Description void
MemcachedTCPSession. addCommand(Command command)
private Command
Optimizer. mergeBuffer(Command firstCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
private Command
Optimizer. mergeGetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType)
private Command
Optimizer. mergeSetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize)
Command
Optimizer. optimiezeGet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand)
Merge get operation to multi-get operationCommand
Optimizer. optimiezeMergeBuffer(Command optimiezeCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
merge buffers to fit socket's send buffer sizeCommand
Optimizer. optimiezeSet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Command
Optimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)
Session
MemcachedConnector. send(Command msg)
void
MemcachedTCPSession. setCurrentCommand(Command cmd)
void
Optimizer.BinaryGetQCollector. visit(Command command)
void
Optimizer.BinarySetQCollector. visit(Command command)
void
Optimizer.CommandCollector. visit(Command command)
void
Optimizer.KeyStringCollector. visit(Command command)
Method parameters in net.rubyeye.xmemcached.impl with type arguments of type Command Modifier and Type Method Description private Command
Optimizer. newMergedCommand(java.util.Map<java.lang.Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)
Constructors in net.rubyeye.xmemcached.impl with parameters of type Command Constructor Description CheckHeartResultThread(Command versionCommand, Session session)
-
Uses of Command in net.rubyeye.xmemcached.networking
Methods in net.rubyeye.xmemcached.networking with parameters of type Command Modifier and Type Method Description Session
Connector. send(Command packet)
-