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 that
net.rubyeye.xmemcached.command	Memcached protocol implementations
net.rubyeye.xmemcached.command.binary	Memcached text protocol implementations
net.rubyeye.xmemcached.command.kestrel	Kestrel protocol implementations
net.rubyeye.xmemcached.command.text	Memcached text protocol implementations
net.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(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)	create a add command
Command	CommandFactory.createAppendCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)	create a append command
Command	CommandFactory.createAuthListMechanismsCommand(CountDownLatch latch)	Create a command for listing authentication mechanisms
Command	CommandFactory.createAuthStartCommand(String mechanism, CountDownLatch latch, byte[] authData)	Create command for starting authentication
Command	CommandFactory.createAuthStepCommand(String mechanism, CountDownLatch latch, byte[] authData)	Create a command for stepping authentication
Command	CommandFactory.createAWSElasticCacheConfigCommand(String subCommand, String key)	Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.
Command	CommandFactory.createCASCommand(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder)	Create a cas command
Command	CommandFactory.createDeleteCommand(String key, byte[] keyBytes, int time, long cas, boolean noreply)	create a delete command
Command	CommandFactory.createFlushAllCommand(CountDownLatch latch, int delay, boolean noreply)	create a flush_all command
Command	CommandFactory.createGetAndTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)	Create a get-and-touch command
Command	CommandFactory.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 command
Command	CommandFactory.createIncrDecrCommand(String key, byte[] keyBytes, long delta, long initial, int expTime, CommandType cmdType, boolean noreply)	create a incr/decr command
Command	CommandFactory.createPrependCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)	Create a prepend command
Command	CommandFactory.createQuitCommand()	create a quit command
Command	CommandFactory.createReplaceCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)	create a replace command
Command	CommandFactory.createSetCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)	Create a set command
Command	CommandFactory.createStatsCommand(InetSocketAddress server, CountDownLatch latch, String itemName)	create a stats command
Command	CommandFactory.createTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)	Create a touch command
Command	CommandFactory.createVerbosityCommand(CountDownLatch latch, int level, boolean noreply)	Create a verbosity command
Command	CommandFactory.createVersionCommand(CountDownLatch latch, InetSocketAddress server)	create a version command
Command	MemcachedOptimizer.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 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, 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 Command

Modifier and Type	Method	Description
private <T> Map<String,T>	XMemcachedClient.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 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, 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 protocol

Methods in net.rubyeye.xmemcached.command that return Command

Modifier and Type	Method	Description
Command	BinaryCommandFactory.createAddCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createAppendCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createAuthListMechanismsCommand(CountDownLatch latch)
Command	KestrelCommandFactory.createAuthListMechanismsCommand(CountDownLatch latch)
Command	TextCommandFactory.createAuthListMechanismsCommand(CountDownLatch latch)
Command	BinaryCommandFactory.createAuthStartCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	KestrelCommandFactory.createAuthStartCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	TextCommandFactory.createAuthStartCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	BinaryCommandFactory.createAuthStepCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	KestrelCommandFactory.createAuthStepCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	TextCommandFactory.createAuthStepCommand(String mechanism, CountDownLatch latch, byte[] authData)
Command	BinaryCommandFactory.createAWSElasticCacheConfigCommand(String subCommand, String key)
Command	KestrelCommandFactory.createAWSElasticCacheConfigCommand(String subCommand, String key)
Command	TextCommandFactory.createAWSElasticCacheConfigCommand(String subCommand, String key)
Command	BinaryCommandFactory.createCASCommand(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createDeleteCommand(String key, byte[] keyBytes, int time, long cas, boolean noreply)
Command	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)
Command	BinaryCommandFactory.createFlushAllCommand(CountDownLatch latch, int delay, boolean noreply)
Command	KestrelCommandFactory.createFlushAllCommand(CountDownLatch latch, int delay, boolean noreply)
final Command	TextCommandFactory.createFlushAllCommand(CountDownLatch latch, int exptime, boolean noreply)
Command	BinaryCommandFactory.createGetAndTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	KestrelCommandFactory.createGetAndTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	TextCommandFactory.createGetAndTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	BinaryCommandFactory.createGetCommand(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createIncrDecrCommand(String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply)
Command	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)
Command	BinaryCommandFactory.createPrependCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createQuitCommand()
Command	KestrelCommandFactory.createQuitCommand()
Command	TextCommandFactory.createQuitCommand()
Command	BinaryCommandFactory.createReplaceCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createSetCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
Command	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)
Command	BinaryCommandFactory.createStatsCommand(InetSocketAddress server, CountDownLatch latch, String itemName)
Command	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)
Command	BinaryCommandFactory.createTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	KestrelCommandFactory.createTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	TextCommandFactory.createTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
Command	BinaryCommandFactory.createVerbosityCommand(CountDownLatch latch, int level, boolean noreply)
Command	KestrelCommandFactory.createVerbosityCommand(CountDownLatch latch, int level, boolean noreply)
final Command	TextCommandFactory.createVerbosityCommand(CountDownLatch latch, int level, boolean noreply)	Create verbosity command
Command	BinaryCommandFactory.createVersionCommand(CountDownLatch latch, InetSocketAddress server)
Command	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 Command

Modifier and Type	Method	Description
List<Command>	AssocCommandAware.getAssocCommands()
Map<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(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.binary

Modifier and Type	Class	Description
class	BaseBinaryCommand	Base Binary command.
class	BinaryAppendPrependCommand	Binary protocol for append,prepend
class	BinaryAuthListMechanismsCommand	List auth mechanisms command
class	BinaryAuthStartCommand	Auth start command
class	BinaryAuthStepCommand	Auth step command
class	BinaryAWSElasticCacheConfigCommand	AWS ElasticCache config command
class	BinaryCASCommand	CAS binary protocol implementation
class	BinaryDeleteCommand	Binary delete command
class	BinaryFlushAllCommand	Flush command for binary protocol
class	BinaryGetAndTouchCommand	Binary GAT/GATQ command
class	BinaryGetCommand	Implements get/getq,getk/getkq protocol
class	BinaryGetMultiCommand	A command for holding getkq commands
class	BinaryIncrDecrCommand	Binary incr/decr command
class	BinaryNoopCommand	Implement noop protocol
class	BinaryQuitCommand	Quit command for binary protocol
class	BinarySetMultiCommand	A command for holding getkq commands
class	BinaryStatsCommand	Stats command for binary protocol
class	BinaryStoreCommand	Base binary protocol implementation
class	BinaryTouchCommand	Binary touch command
class	BinaryVerbosityCommand	Binary verbosity command
class	BinaryVersionCommand	Version command for binary protocol

Fields in net.rubyeye.xmemcached.command.binary with type parameters of type Command

Modifier and Type	Field	Description
private List<Command>	BinaryGetCommand.assocCommands
private Map<Object,Command>	BinaryGetMultiCommand.mergeCommands
private Map<Object,Command>	BinarySetMultiCommand.mergeCommands

Methods in net.rubyeye.xmemcached.command.binary that return types with arguments of type Command

Modifier and Type	Method	Description
final List<Command>	BinaryGetCommand.getAssocCommands()
Map<Object,Command>	BinaryGetMultiCommand.getMergeCommands()
Map<Object,Command>	BinarySetMultiCommand.getMergeCommands()

Method parameters in net.rubyeye.xmemcached.command.binary with type arguments of type Command

Modifier and Type	Method	Description
final 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.kestrel

Modifier and Type	Class	Description
class	KestrelDeleteCommand
class	KestrelFlushAllCommand	Kestrel flush command
class	KestrelGetCommand	Kestrel get command
class	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 protocol
class	TextDeleteCommand	Delete command for text protocol
class	TextFlushAllCommand	FlushAll command for text protocol
class	TextGetCommand	Abstract get command for text protocol
class	TextGetMultiCommand	Bulk-get command for text protocol
class	TextGetOneCommand	Get command for text protocol
class	TextIncrDecrCommand	Incr/Decr command for text protocol
class	TextQuitCommand	Quit command for text protocol
class	TextStatsCachedumpCommand
class	TextStatsCommand	Stats command for text protocol
class	TextStoreCommand	Store command for text protocol
class	TextTouchCommand	Touch command for touch protocol.
class	TextVerbosityCommand	Verbosity command for text protocol
class	TextVersionCommand	Version command for text protocol

Fields in net.rubyeye.xmemcached.command.text with type parameters of type Command

Modifier and Type	Field	Description
protected 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 Map<Object,Command>	TextGetCommand.mergeCommands

Methods in net.rubyeye.xmemcached.command.text that return types with arguments of type Command

Modifier and Type	Method	Description
final List<Command>	TextGetCommand.getAssocCommands()
final Map<Object,Command>	TextGetCommand.getMergeCommands()

Method parameters in net.rubyeye.xmemcached.command.text with type arguments of type Command

Modifier and Type	Method	Description
final 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 Command

Modifier and Type	Field	Description
(package private) Command	Optimizer.BinaryGetQCollector.prevCommand
private final Command	MemcachedHandler.CheckHeartResultThread.versionCommand

Fields in net.rubyeye.xmemcached.impl with type parameters of type Command

Modifier and Type	Field	Description
protected BlockingQueue<Command>	MemcachedTCPSession.commandAlreadySent	Command which are already sent
private final AtomicReference<Command>	MemcachedTCPSession.currentCommand
(package private) Map<Object,Command>	Optimizer.BinarySetQCollector.mergeCommands
private final ThreadLocal<List<Command>>	Optimizer.threadLocal

Methods in net.rubyeye.xmemcached.impl that return Command

Modifier and Type	Method	Description
Command	MemcachedTCPSession.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 operation
final Command	Optimizer.optimiezeMergeBuffer(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)	merge buffers to fit socket's send buffer size
final Command	Optimizer.optimiezeSet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Command	Optimizer.optimize(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)
private Command	MemcachedTCPSession.takeExecutingCommand()	get current command from queue

Methods in net.rubyeye.xmemcached.impl that return types with arguments of type Command

Modifier and Type	Method	Description
final 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 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 operation
final Command	Optimizer.optimiezeMergeBuffer(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)	merge buffers to fit socket's send buffer size
final Command	Optimizer.optimiezeSet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Command	Optimizer.optimize(Command currentCommand, Queue writeQueue, 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(Map<Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)

Constructors in net.rubyeye.xmemcached.impl with parameters of type Command

Modifier	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)