K
- Key type.V
- Value type.public class RedisStateMachine<K,V> extends Object
Constructor and Description |
---|
RedisStateMachine()
Initialize a new instance.
|
Modifier and Type | Method and Description |
---|---|
boolean |
decode(ByteBuf buffer,
CommandOutput<K,V,?> output)
Decode a command using the input buffer.
|
boolean |
decode(ByteBuf buffer,
RedisCommand<K,V,?> command,
CommandOutput<K,V,?> output)
Attempt to decode a redis response and return a flag indicating whether a complete response was read.
|
void |
reset() |
protected void |
safeMulti(CommandOutput<K,V,?> output,
int count,
RedisCommand<K,V,?> command) |
protected void |
safeSet(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command) |
protected void |
safeSet(CommandOutput<K,V,?> output,
long integer,
RedisCommand<K,V,?> command) |
protected void |
safeSetError(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command) |
public boolean decode(ByteBuf buffer, CommandOutput<K,V,?> output)
buffer
- Buffer containing data from the server.output
- Current command output.public boolean decode(ByteBuf buffer, RedisCommand<K,V,?> command, CommandOutput<K,V,?> output)
buffer
- Buffer containing data from the server.command
- the command itselfoutput
- Current command output.protected void safeSet(CommandOutput<K,V,?> output, long integer, RedisCommand<K,V,?> command)
protected void safeSet(CommandOutput<K,V,?> output, ByteBuffer bytes, RedisCommand<K,V,?> command)
protected void safeMulti(CommandOutput<K,V,?> output, int count, RedisCommand<K,V,?> command)
protected void safeSetError(CommandOutput<K,V,?> output, ByteBuffer bytes, RedisCommand<K,V,?> command)
public void reset()
Copyright © 2016. All rights reserved.