@Immutable public class OperationsFactory extends Object implements HotRodConstants
HotRodOperation
objects.BULK_GET_REQUEST, BULK_GET_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, COMMAND_TIMEOUT_STATUS, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, DEFAULT_CACHE_NAME_BYTES, ERROR_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, REMOVE_IF_UNMODIFIED_REQUEST, REMOVE_IF_UNMODIFIED_RESPONSE, REMOVE_REQUEST, REMOVE_RESPONSE, REPLACE_IF_UNMODIFIED_REQUEST, REPLACE_IF_UNMODIFIED_RESPONSE, REPLACE_REQUEST, REPLACE_RESPONSE, REQUEST_MAGIC, REQUEST_PARSING_ERROR_STATUS, RESPONSE_MAGIC, SERVER_ERROR_STATUS, STATS_REQUEST, STATS_RESPONSE, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11
Constructor and Description |
---|
OperationsFactory(TransportFactory transportFactory,
String cacheName,
AtomicInteger topologyId,
boolean forceReturnValue,
Codec codec) |
Modifier and Type | Method and Description |
---|---|
BulkGetOperation |
newBulkGetOperation(int size) |
ClearOperation |
newClearOperation() |
ContainsKeyOperation |
newContainsKeyOperation(byte[] key) |
GetOperation |
newGetKeyOperation(byte[] key) |
GetWithVersionOperation |
newGetWithVersionOperation(byte[] key) |
PingOperation |
newPingOperation(Transport transport) |
PutIfAbsentOperation |
newPutIfAbsentOperation(byte[] key,
byte[] value,
int lifespanSecs,
int maxIdleSecs) |
PutOperation |
newPutKeyValueOperation(byte[] key,
byte[] value,
int lifespanSecs,
int maxIdleSecs) |
RemoveIfUnmodifiedOperation |
newRemoveIfUnmodifiedOperation(byte[] key,
long version) |
RemoveOperation |
newRemoveOperation(byte[] key) |
ReplaceIfUnmodifiedOperation |
newReplaceIfUnmodifiedOperation(byte[] key,
byte[] value,
int lifespanSeconds,
int maxIdleTimeSeconds,
long version) |
ReplaceOperation |
newReplaceOperation(byte[] key,
byte[] values,
int lifespanSecs,
int maxIdleSecs) |
StatsOperation |
newStatsOperation() |
void |
setFlags(Flag[] flags) |
public OperationsFactory(TransportFactory transportFactory, String cacheName, AtomicInteger topologyId, boolean forceReturnValue, Codec codec)
public GetOperation newGetKeyOperation(byte[] key)
public RemoveOperation newRemoveOperation(byte[] key)
public RemoveIfUnmodifiedOperation newRemoveIfUnmodifiedOperation(byte[] key, long version)
public ReplaceIfUnmodifiedOperation newReplaceIfUnmodifiedOperation(byte[] key, byte[] value, int lifespanSeconds, int maxIdleTimeSeconds, long version)
public GetWithVersionOperation newGetWithVersionOperation(byte[] key)
public StatsOperation newStatsOperation()
public PutOperation newPutKeyValueOperation(byte[] key, byte[] value, int lifespanSecs, int maxIdleSecs)
public PutIfAbsentOperation newPutIfAbsentOperation(byte[] key, byte[] value, int lifespanSecs, int maxIdleSecs)
public ReplaceOperation newReplaceOperation(byte[] key, byte[] values, int lifespanSecs, int maxIdleSecs)
public ContainsKeyOperation newContainsKeyOperation(byte[] key)
public ClearOperation newClearOperation()
public BulkGetOperation newBulkGetOperation(int size)
public PingOperation newPingOperation(Transport transport)
public void setFlags(Flag[] flags)
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.