Uses of Class
net.rubyeye.xmemcached.command.Command
Packages that use Command
Package
Description
XMemcached's main classes and interfaces,use these classes/interfaces to interact with memcached servers.
Memcached 1.4.3 or later version has supported SASL authentication,these classes are used for that
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.
Networking layout to talk with memcached.
-
Uses of Command in net.rubyeye.xmemcached
Methods in net.rubyeye.xmemcached that return CommandModifier and TypeMethodDescriptionCommandFactory.createAddCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) create a add commandCommandFactory.createAppendCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) create a append commandCommandFactory.createAuthListMechanismsCommand
(CountDownLatch latch) Create a command for listing authentication mechanismsCommandFactory.createAuthStartCommand
(String mechanism, CountDownLatch latch, byte[] authData) Create command for starting authenticationCommandFactory.createAuthStepCommand
(String mechanism, CountDownLatch latch, byte[] authData) Create a command for stepping authenticationCommandFactory.createAWSElasticCacheConfigCommand
(String subCommand, String key) Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.CommandFactory.createCASCommand
(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder) Create a cas commandCommandFactory.createDeleteCommand
(String key, byte[] keyBytes, int time, long cas, boolean noreply) create a delete commandCommandFactory.createFlushAllCommand
(CountDownLatch latch, int delay, boolean noreply) create a flush_all commandCommandFactory.createGetAndTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) Create a get-and-touch commandCommandFactory.createGetCommand
(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder) create a get/gets command<T> Command
CommandFactory.createGetMultiCommand
(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder) Create a multi-get commandCommandFactory.createIncrDecrCommand
(String key, byte[] keyBytes, long delta, long initial, int expTime, CommandType cmdType, boolean noreply) create a incr/decr commandCommandFactory.createPrependCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) Create a prepend commandCommandFactory.createQuitCommand()
create a quit commandCommandFactory.createReplaceCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) create a replace commandCommandFactory.createSetCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) Create a set commandCommandFactory.createStatsCommand
(InetSocketAddress server, CountDownLatch latch, String itemName) create a stats commandCommandFactory.createTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) Create a touch commandCommandFactory.createVerbosityCommand
(CountDownLatch latch, int level, boolean noreply) Create a verbosity commandCommandFactory.createVersionCommand
(CountDownLatch latch, InetSocketAddress server) create a version commandMemcachedOptimizer.optimize
(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) private final <T> Command
XMemcachedClient.sendGetMultiCommand
(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder) Methods in net.rubyeye.xmemcached with parameters of type CommandModifier and TypeMethodDescriptionprotected void
XMemcachedClient.checkException
(Command command) protected void
MemcachedOptimizer.optimize
(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) protected final Session
XMemcachedClient.sendCommand
(Command cmd) private final <T> boolean
XMemcachedClient.sendStoreCommand
(Command command, long timeout) Method parameters in net.rubyeye.xmemcached with type arguments of type CommandModifier and TypeMethodDescriptionXMemcachedClient.reduceResult
(CommandType cmdType, Transcoder<T> transcoder, List<Command> commands) -
Uses of Command in net.rubyeye.xmemcached.auth
Methods in net.rubyeye.xmemcached.auth that return CommandMethods in net.rubyeye.xmemcached.auth with parameters of type CommandModifier and TypeMethodDescriptionprivate void
AuthTask.waitCommand
(Command cmd, AtomicBoolean done) -
Uses of Command in net.rubyeye.xmemcached.command
Subclasses of Command in net.rubyeye.xmemcached.commandModifier and TypeClassDescriptionclass
Abstract verbosity command for text protocolMethods in net.rubyeye.xmemcached.command that return CommandModifier and TypeMethodDescriptionBinaryCommandFactory.createAddCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createAddCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createAddCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createAppendCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createAppendCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createAppendCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createAuthListMechanismsCommand
(CountDownLatch latch) KestrelCommandFactory.createAuthListMechanismsCommand
(CountDownLatch latch) TextCommandFactory.createAuthListMechanismsCommand
(CountDownLatch latch) BinaryCommandFactory.createAuthStartCommand
(String mechanism, CountDownLatch latch, byte[] authData) KestrelCommandFactory.createAuthStartCommand
(String mechanism, CountDownLatch latch, byte[] authData) TextCommandFactory.createAuthStartCommand
(String mechanism, CountDownLatch latch, byte[] authData) BinaryCommandFactory.createAuthStepCommand
(String mechanism, CountDownLatch latch, byte[] authData) KestrelCommandFactory.createAuthStepCommand
(String mechanism, CountDownLatch latch, byte[] authData) TextCommandFactory.createAuthStepCommand
(String mechanism, CountDownLatch latch, byte[] authData) BinaryCommandFactory.createAWSElasticCacheConfigCommand
(String subCommand, String key) KestrelCommandFactory.createAWSElasticCacheConfigCommand
(String subCommand, String key) TextCommandFactory.createAWSElasticCacheConfigCommand
(String subCommand, String key) BinaryCommandFactory.createCASCommand
(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createCASCommand
(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createCASCommand
(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createDeleteCommand
(String key, byte[] keyBytes, int time, long cas, boolean noreply) KestrelCommandFactory.createDeleteCommand
(String key, byte[] keyBytes, int time, long cas, boolean noreply) final Command
TextCommandFactory.createDeleteCommand
(String key, byte[] keyBytes, int time, long cas, boolean noreply) BinaryCommandFactory.createFlushAllCommand
(CountDownLatch latch, int delay, boolean noreply) KestrelCommandFactory.createFlushAllCommand
(CountDownLatch latch, int delay, boolean noreply) final Command
TextCommandFactory.createFlushAllCommand
(CountDownLatch latch, int exptime, boolean noreply) BinaryCommandFactory.createGetAndTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) KestrelCommandFactory.createGetAndTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) TextCommandFactory.createGetAndTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) BinaryCommandFactory.createGetCommand
(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder) KestrelCommandFactory.createGetCommand
(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder) final Command
TextCommandFactory.createGetCommand
(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder) <T> Command
BinaryCommandFactory.createGetMultiCommand
(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder) <T> Command
KestrelCommandFactory.createGetMultiCommand
(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder) final <T> Command
TextCommandFactory.createGetMultiCommand
(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder) BinaryCommandFactory.createIncrDecrCommand
(String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply) KestrelCommandFactory.createIncrDecrCommand
(String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply) final Command
TextCommandFactory.createIncrDecrCommand
(String key, byte[] keyBytes, long amount, long initial, int exptime, CommandType cmdType, boolean noreply) BinaryCommandFactory.createPrependCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createPrependCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createPrependCommand
(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createQuitCommand()
KestrelCommandFactory.createQuitCommand()
TextCommandFactory.createQuitCommand()
BinaryCommandFactory.createReplaceCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createReplaceCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createReplaceCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createSetCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) KestrelCommandFactory.createSetCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createSetCommand
(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder) final Command
TextCommandFactory.createStatsCachedumpCommand
(InetSocketAddress server, CountDownLatch latch, int slabId, int limit) BinaryCommandFactory.createStatsCommand
(InetSocketAddress server, CountDownLatch latch, String itemName) KestrelCommandFactory.createStatsCommand
(InetSocketAddress server, CountDownLatch latch, String itemName) final Command
TextCommandFactory.createStatsCommand
(InetSocketAddress server, CountDownLatch latch, String itemName) (package private) final Command
BinaryCommandFactory.createStoreCommand
(String key, byte[] keyBytes, int exp, Object value, CommandType cmdType, boolean noreply, Transcoder transcoder) (package private) final Command
TextCommandFactory.createStoreCommand
(String key, byte[] keyBytes, int exp, Object value, CommandType cmdType, boolean noreply, Transcoder transcoder) BinaryCommandFactory.createTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) KestrelCommandFactory.createTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) TextCommandFactory.createTouchCommand
(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply) BinaryCommandFactory.createVerbosityCommand
(CountDownLatch latch, int level, boolean noreply) KestrelCommandFactory.createVerbosityCommand
(CountDownLatch latch, int level, boolean noreply) final Command
TextCommandFactory.createVerbosityCommand
(CountDownLatch latch, int level, boolean noreply) Create verbosity commandBinaryCommandFactory.createVersionCommand
(CountDownLatch latch, InetSocketAddress server) KestrelCommandFactory.createVersionCommand
(CountDownLatch latch, InetSocketAddress server) final Command
TextCommandFactory.createVersionCommand
(CountDownLatch latch, InetSocketAddress server) Methods in net.rubyeye.xmemcached.command that return types with arguments of type CommandModifier and TypeMethodDescriptionAssocCommandAware.getAssocCommands()
MergeCommandsAware.getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command with type arguments of type CommandModifier and TypeMethodDescriptionvoid
AssocCommandAware.setAssocCommands
(List<Command> assocCommands) void
MergeCommandsAware.setMergeCommands
(Map<Object, Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.command.binary
Subclasses of Command in net.rubyeye.xmemcached.command.binaryModifier 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 protocolFields in net.rubyeye.xmemcached.command.binary with type parameters of type CommandModifier and TypeFieldDescriptionBinaryGetCommand.assocCommands
BinaryGetMultiCommand.mergeCommands
BinarySetMultiCommand.mergeCommands
Methods in net.rubyeye.xmemcached.command.binary that return types with arguments of type CommandModifier and TypeMethodDescriptionBinaryGetCommand.getAssocCommands()
BinaryGetMultiCommand.getMergeCommands()
BinarySetMultiCommand.getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command.binary with type arguments of type CommandModifier and TypeMethodDescriptionfinal void
BinaryGetCommand.setAssocCommands
(List<Command> assocCommands) void
BinaryGetMultiCommand.setMergeCommands
(Map<Object, Command> mergeCommands) void
BinarySetMultiCommand.setMergeCommands
(Map<Object, Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.command.kestrel
Subclasses of Command in net.rubyeye.xmemcached.command.kestrelModifier and TypeClassDescriptionclass
class
Kestrel flush commandclass
Kestrel get commandclass
kestrel set command -
Uses of Command in net.rubyeye.xmemcached.command.text
Subclasses of Command in net.rubyeye.xmemcached.command.textModifier 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 protocolFields in net.rubyeye.xmemcached.command.text with type parameters of type CommandModifier and TypeFieldDescriptionTextGetCommand.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.TextGetCommand.mergeCommands
Methods in net.rubyeye.xmemcached.command.text that return types with arguments of type CommandModifier and TypeMethodDescriptionTextGetCommand.getAssocCommands()
TextGetCommand.getMergeCommands()
Method parameters in net.rubyeye.xmemcached.command.text with type arguments of type CommandModifier and TypeMethodDescriptionfinal void
TextGetCommand.setAssocCommands
(List<Command> assocCommands) final void
TextGetCommand.setMergeCommands
(Map<Object, Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.impl
Fields in net.rubyeye.xmemcached.impl declared as CommandModifier and TypeFieldDescription(package private) Command
Optimizer.BinaryGetQCollector.prevCommand
private final Command
MemcachedHandler.CheckHeartResultThread.versionCommand
Fields in net.rubyeye.xmemcached.impl with type parameters of type CommandModifier and TypeFieldDescriptionprotected BlockingQueue
<Command> MemcachedTCPSession.commandAlreadySent
Command which are already sentprivate final AtomicReference
<Command> MemcachedTCPSession.currentCommand
Optimizer.BinarySetQCollector.mergeCommands
private final ThreadLocal
<List<Command>> Optimizer.threadLocal
Methods in net.rubyeye.xmemcached.impl that return CommandModifier and TypeMethodDescriptionMemcachedTCPSession.getCurrentCommand()
private final Command
Optimizer.mergeBuffer
(Command firstCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) private final Command
Optimizer.mergeGetCommands
(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType) private final Command
Optimizer.mergeSetCommands
(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize) private Command
Optimizer.newMergedCommand
(Map<Object, Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType) final Command
Optimizer.optimiezeGet
(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand) Merge get operation to multi-get operationfinal Command
Optimizer.optimiezeMergeBuffer
(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) merge buffers to fit socket's send buffer sizefinal Command
Optimizer.optimiezeSet
(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize) Optimizer.optimize
(Command currentCommand, Queue writeQueue, 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 CommandMethods in net.rubyeye.xmemcached.impl with parameters of type CommandModifier and TypeMethodDescriptionvoid
MemcachedTCPSession.addCommand
(Command command) private final Command
Optimizer.mergeBuffer
(Command firstCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) private final Command
Optimizer.mergeGetCommands
(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType) private final Command
Optimizer.mergeSetCommands
(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize) final Command
Optimizer.optimiezeGet
(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand) Merge get operation to multi-get operationfinal Command
Optimizer.optimiezeMergeBuffer
(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) merge buffers to fit socket's send buffer sizefinal Command
Optimizer.optimiezeSet
(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize) Optimizer.optimize
(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize) void
MemcachedTCPSession.setCurrentCommand
(Command cmd) void
void
void
void
Method parameters in net.rubyeye.xmemcached.impl with type arguments of type CommandModifier and TypeMethodDescriptionprivate Command
Optimizer.newMergedCommand
(Map<Object, Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType) Constructors in net.rubyeye.xmemcached.impl with parameters of type Command -
Uses of Command in net.rubyeye.xmemcached.networking
Methods in net.rubyeye.xmemcached.networking with parameters of type Command