Package net.rubyeye.xmemcached.command

Class TextCommandFactory

java.lang.Object

net.rubyeye.xmemcached.command.TextCommandFactory

All Implemented Interfaces:

CommandFactory

public class TextCommandFactory
extends java.lang.Object
implements CommandFactory

Command Factory for creating text protocol commands.

Constructor Summary

Constructors

Constructor	Description
TextCommandFactory()

Method Summary

Modifier and Type	Method	Description
Command	createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)	create a add command
Command	createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)	create a append command
Command	createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)	Create a command for listing authentication mechanisms
Command	createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)	Create command for starting authentication
Command	createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)	Create a command for stepping authentication
Command	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	createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)	Create a cas command
Command	createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)	create a delete command
Command	createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int exptime, boolean noreply)	create a flush_all command
Command	createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)	Create a get-and-touch command
Command	createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)	create a get/gets command
<T> Command	createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)	Create a multi-get command
Command	createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int exptime, CommandType cmdType, boolean noreply)	create a incr/decr command
Command	createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)	Create a prepend command
Command	createQuitCommand()	create a quit command
Command	createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)	create a replace command
Command	createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)	Create a set command
Command	createStatsCachedumpCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, int slabId, int limit)
Command	createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)	create a stats command
(package private) Command	createStoreCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, CommandType cmdType, boolean noreply, Transcoder transcoder)
Command	createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)	Create a touch command
Command	createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)	Create verbosity command
Command	createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)	create a version command
Protocol	getProtocol()	Get this client's protocol version
void	setBufferAllocator(BufferAllocator bufferAllocator)	set command factory's buffer allocator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TextCommandFactory

public TextCommandFactory()

Method Detail

createAWSElasticCacheConfigCommand

public Command createAWSElasticCacheConfigCommand(java.lang.String subCommand,
                                                  java.lang.String key)

Description copied from interface: CommandFactory

Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.

Specified by:

createAWSElasticCacheConfigCommand in interface CommandFactory

Returns:

See Also:

Adding Auto Discovery To Your Client Library

setBufferAllocator

public void setBufferAllocator(BufferAllocator bufferAllocator)

Description copied from interface: CommandFactory

set command factory's buffer allocator

Specified by:

setBufferAllocator in interface CommandFactory

createDeleteCommand

public final Command createDeleteCommand(java.lang.String key,
                                         byte[] keyBytes,
                                         int time,
                                         long cas,
                                         boolean noreply)

Description copied from interface: CommandFactory

create a delete command

Specified by:

createDeleteCommand in interface CommandFactory

Returns:

createVersionCommand

public final Command createVersionCommand(java.util.concurrent.CountDownLatch latch,
                                          java.net.InetSocketAddress server)

Description copied from interface: CommandFactory

create a version command

Specified by:

createVersionCommand in interface CommandFactory

Returns:

createFlushAllCommand

public final Command createFlushAllCommand(java.util.concurrent.CountDownLatch latch,
                                           int exptime,
                                           boolean noreply)

Description copied from interface: CommandFactory

create a flush_all command

Specified by:

createFlushAllCommand in interface CommandFactory

Returns:

createVerbosityCommand

public final Command createVerbosityCommand(java.util.concurrent.CountDownLatch latch,
                                            int level,
                                            boolean noreply)

Create verbosity command

Specified by:

createVerbosityCommand in interface CommandFactory

Parameters:

latch -

level -

noreply -

Returns:

createStatsCommand

public final Command createStatsCommand(java.net.InetSocketAddress server,
                                        java.util.concurrent.CountDownLatch latch,
                                        java.lang.String itemName)

Description copied from interface: CommandFactory

create a stats command

Specified by:

createStatsCommand in interface CommandFactory

Returns:

createStatsCachedumpCommand

public final Command createStatsCachedumpCommand(java.net.InetSocketAddress server,
                                                 java.util.concurrent.CountDownLatch latch,
                                                 int slabId,
                                                 int limit)

createCASCommand

public final Command createCASCommand(java.lang.String key,
                                      byte[] keyBytes,
                                      int exp,
                                      java.lang.Object value,
                                      long cas,
                                      boolean noreply,
                                      Transcoder transcoder)

Description copied from interface: CommandFactory

Create a cas command

Specified by:

createCASCommand in interface CommandFactory

Returns:

createSetCommand

public final Command createSetCommand(java.lang.String key,
                                      byte[] keyBytes,
                                      int exp,
                                      java.lang.Object value,
                                      boolean noreply,
                                      Transcoder transcoder)

Description copied from interface: CommandFactory

Create a set command

Specified by:

createSetCommand in interface CommandFactory

Returns:

createAddCommand

public final Command createAddCommand(java.lang.String key,
                                      byte[] keyBytes,
                                      int exp,
                                      java.lang.Object value,
                                      boolean noreply,
                                      Transcoder transcoder)

Description copied from interface: CommandFactory

create a add command

Specified by:

createAddCommand in interface CommandFactory

Returns:

createReplaceCommand

public final Command createReplaceCommand(java.lang.String key,
                                          byte[] keyBytes,
                                          int exp,
                                          java.lang.Object value,
                                          boolean noreply,
                                          Transcoder transcoder)

Description copied from interface: CommandFactory

create a replace command

Specified by:

createReplaceCommand in interface CommandFactory

Returns:

createAppendCommand

public final Command createAppendCommand(java.lang.String key,
                                         byte[] keyBytes,
                                         java.lang.Object value,
                                         boolean noreply,
                                         Transcoder transcoder)

Description copied from interface: CommandFactory

create a append command

Specified by:

createAppendCommand in interface CommandFactory

Returns:

createPrependCommand

public final Command createPrependCommand(java.lang.String key,
                                          byte[] keyBytes,
                                          java.lang.Object value,
                                          boolean noreply,
                                          Transcoder transcoder)

Description copied from interface: CommandFactory

Create a prepend command

Specified by:

createPrependCommand in interface CommandFactory

Returns:

createStoreCommand

final Command createStoreCommand(java.lang.String key,
                                 byte[] keyBytes,
                                 int exp,
                                 java.lang.Object value,
                                 CommandType cmdType,
                                 boolean noreply,
                                 Transcoder transcoder)

createGetCommand

public final Command createGetCommand(java.lang.String key,
                                      byte[] keyBytes,
                                      CommandType cmdType,
                                      Transcoder transcoder)

Description copied from interface: CommandFactory

create a get/gets command

Specified by:

createGetCommand in interface CommandFactory

cmdType - 命令类型

transcoder - TODO

Returns:

createGetMultiCommand

public final <T> Command createGetMultiCommand(java.util.Collection<java.lang.String> keys,
                                               java.util.concurrent.CountDownLatch latch,
                                               CommandType cmdType,
                                               Transcoder<T> transcoder)

Description copied from interface: CommandFactory

Create a multi-get command

Specified by:

createGetMultiCommand in interface CommandFactory

Returns:

createIncrDecrCommand

public final Command createIncrDecrCommand(java.lang.String key,
                                           byte[] keyBytes,
                                           long amount,
                                           long initial,
                                           int exptime,
                                           CommandType cmdType,
                                           boolean noreply)

Description copied from interface: CommandFactory

create a incr/decr command

Specified by:

createIncrDecrCommand in interface CommandFactory

Returns:

createAuthListMechanismsCommand

public Command createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)

Description copied from interface: CommandFactory

Create a command for listing authentication mechanisms

Specified by:

createAuthListMechanismsCommand in interface CommandFactory

Returns:

createAuthStartCommand

public Command createAuthStartCommand(java.lang.String mechanism,
                                      java.util.concurrent.CountDownLatch latch,
                                      byte[] authData)

Description copied from interface: CommandFactory

Create command for starting authentication

Specified by:

createAuthStartCommand in interface CommandFactory

Returns:

createAuthStepCommand

public Command createAuthStepCommand(java.lang.String mechanism,
                                     java.util.concurrent.CountDownLatch latch,
                                     byte[] authData)

Description copied from interface: CommandFactory

Create a command for stepping authentication

Specified by:

createAuthStepCommand in interface CommandFactory

Returns:

createGetAndTouchCommand

public Command createGetAndTouchCommand(java.lang.String key,
                                        byte[] keyBytes,
                                        java.util.concurrent.CountDownLatch latch,
                                        int exp,
                                        boolean noreply)

Description copied from interface: CommandFactory

Create a get-and-touch command

Specified by:

createGetAndTouchCommand in interface CommandFactory

latch - TODO

Returns:

createTouchCommand

public Command createTouchCommand(java.lang.String key,
                                  byte[] keyBytes,
                                  java.util.concurrent.CountDownLatch latch,
                                  int exp,
                                  boolean noreply)

Description copied from interface: CommandFactory

Create a touch command

Specified by:

createTouchCommand in interface CommandFactory

latch - TODO

Returns:

createQuitCommand

public Command createQuitCommand()

Description copied from interface: CommandFactory

create a quit command

Specified by:

createQuitCommand in interface CommandFactory

Returns:

getProtocol

public Protocol getProtocol()

Description copied from interface: CommandFactory

Get this client's protocol version

Specified by:

getProtocol in interface CommandFactory

Returns: