public interface CommandFactory
Modifier and Type | Method and Description |
---|---|
Command |
createAddCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
create a add command
|
Command |
createAppendCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder)
create a append command
|
Command |
createAuthListMechanismsCommand(CountDownLatch latch)
Create a command for listing authentication mechanisms
|
Command |
createAuthStartCommand(String mechanism,
CountDownLatch latch,
byte[] authData)
Create command for starting authentication
|
Command |
createAuthStepCommand(String mechanism,
CountDownLatch latch,
byte[] authData)
Create a command for stepping authentication
|
Command |
createAWSElasticCacheConfigCommand(String subCommand,
String key)
Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.
|
Command |
createCASCommand(String key,
byte[] keyBytes,
int exp,
Object value,
long cas,
boolean noreply,
Transcoder transcoder)
Create a cas command
|
Command |
createDeleteCommand(String key,
byte[] keyBytes,
int time,
long cas,
boolean noreply)
create a delete command
|
Command |
createFlushAllCommand(CountDownLatch latch,
int delay,
boolean noreply)
create a flush_all command
|
Command |
createGetAndTouchCommand(String key,
byte[] keyBytes,
CountDownLatch latch,
int exp,
boolean noreply)
Create a get-and-touch command
|
Command |
createGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
Transcoder transcoder)
create a get/gets command
|
<T> Command |
createGetMultiCommand(Collection<String> keys,
CountDownLatch latch,
CommandType cmdType,
Transcoder<T> transcoder)
Create a multi-get command
|
Command |
createIncrDecrCommand(String key,
byte[] keyBytes,
long delta,
long initial,
int expTime,
CommandType cmdType,
boolean noreply)
create a incr/decr command
|
Command |
createPrependCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder)
Create a prepend command
|
Command |
createQuitCommand()
create a quit command
|
Command |
createReplaceCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
create a replace command
|
Command |
createSetCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
Create a set command
|
Command |
createStatsCommand(InetSocketAddress server,
CountDownLatch latch,
String itemName)
create a stats command
|
Command |
createTouchCommand(String key,
byte[] keyBytes,
CountDownLatch latch,
int exp,
boolean noreply)
Create a touch command
|
Command |
createVerbosityCommand(CountDownLatch latch,
int level,
boolean noreply)
Create a verbosity command
|
Command |
createVersionCommand(CountDownLatch latch,
InetSocketAddress server)
create a version command
|
Protocol |
getProtocol()
Get this client's protocol version
|
void |
setBufferAllocator(BufferAllocator bufferAllocator)
set command factory's buffer allocator
|
void setBufferAllocator(BufferAllocator bufferAllocator)
bufferAllocator
- Command createDeleteCommand(String key, byte[] keyBytes, int time, long cas, boolean noreply)
key
- time
- Command createVersionCommand(CountDownLatch latch, InetSocketAddress server)
Command createFlushAllCommand(CountDownLatch latch, int delay, boolean noreply)
Command createStatsCommand(InetSocketAddress server, CountDownLatch latch, String itemName)
Command createGetCommand(String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)
key
- keyBytes
- cmdType
- 命令类型transcoder
- TODOcmdBytes
- 命令的字节数组,如"get".getBytes()<T> Command createGetMultiCommand(Collection<String> keys, CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)
T
- keys
- latch
- result
- cmdBytes
- cmdType
- transcoder
- Command createIncrDecrCommand(String key, byte[] keyBytes, long delta, long initial, int expTime, CommandType cmdType, boolean noreply)
key
- keyBytes
- delta
- initial
- expTime
- cmdType
- noreply
- Command createCASCommand(String key, byte[] keyBytes, int exp, Object value, long cas, boolean noreply, Transcoder transcoder)
key
- keyBytes
- exp
- value
- cas
- noreply
- transcoder
- Command createSetCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
key
- keyBytes
- exp
- value
- noreply
- transcoder
- Command createAddCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
key
- keyBytes
- exp
- value
- noreply
- transcoder
- Command createReplaceCommand(String key, byte[] keyBytes, int exp, Object value, boolean noreply, Transcoder transcoder)
key
- keyBytes
- exp
- value
- noreply
- transcoder
- Command createAppendCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)
key
- keyBytes
- value
- noreply
- transcoder
- Command createPrependCommand(String key, byte[] keyBytes, Object value, boolean noreply, Transcoder transcoder)
key
- keyBytes
- value
- noreply
- transcoder
- Command createVerbosityCommand(CountDownLatch latch, int level, boolean noreply)
latch
- level
- noreply
- Command createAuthListMechanismsCommand(CountDownLatch latch)
latch
- Command createAuthStartCommand(String mechanism, CountDownLatch latch, byte[] authData)
mechanism
- latch
- authData
- Command createAuthStepCommand(String mechanism, CountDownLatch latch, byte[] authData)
mechanism
- latch
- authData
- Command createQuitCommand()
Command createTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
key
- keyBytes
- latch
- TODOexp
- noreply
- Command createGetAndTouchCommand(String key, byte[] keyBytes, CountDownLatch latch, int exp, boolean noreply)
key
- keyBytes
- latch
- TODOexp
- noreply
- Command createAWSElasticCacheConfigCommand(String subCommand, String key)
subCommand
- key
- Protocol getProtocol()
Copyright © 2021. All rights reserved.