org.infinispan.client.hotrod.impl.operations
Class OperationsFactory

java.lang.Object
  org.infinispan.client.hotrod.impl.operations.OperationsFactory

All Implemented Interfaces:

HotRodConstants

@Immutable
public class OperationsFactory
extends Object
implements HotRodConstants

Factory for HotRodOperation objects.

Since:

4.1

Author:

Mircea.Markus@jboss.com

Field Summary

Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

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, HOTROD_VERSION, 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

Constructor Summary

OperationsFactory(TransportFactory transportFactory, String cacheName, AtomicInteger topologyId, boolean forceReturnValue)

Method Summary

BulkGetOperation	newBulkGetOperation(int size)
ClearOperation	newClearOperation()
ContainsKeyOperation	newContainsKeyOperation(byte[] key)
GetOperation	newGetKeyOperation(byte[] key)
GetWithVersionOperation	newGetWithVersionOperation(byte[] key)
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationsFactory

public OperationsFactory(TransportFactory transportFactory,
                         String cacheName,
                         AtomicInteger topologyId,
                         boolean forceReturnValue)

Method Detail

newGetKeyOperation

public GetOperation newGetKeyOperation(byte[] key)

newRemoveOperation

public RemoveOperation newRemoveOperation(byte[] key)

newRemoveIfUnmodifiedOperation

public RemoveIfUnmodifiedOperation newRemoveIfUnmodifiedOperation(byte[] key,
                                                                  long version)

newReplaceIfUnmodifiedOperation

public ReplaceIfUnmodifiedOperation newReplaceIfUnmodifiedOperation(byte[] key,
                                                                    byte[] value,
                                                                    int lifespanSeconds,
                                                                    int maxIdleTimeSeconds,
                                                                    long version)

newGetWithVersionOperation

public GetWithVersionOperation newGetWithVersionOperation(byte[] key)

newStatsOperation

public StatsOperation newStatsOperation()

newPutKeyValueOperation

public PutOperation newPutKeyValueOperation(byte[] key,
                                            byte[] value,
                                            int lifespanSecs,
                                            int maxIdleSecs)

newPutIfAbsentOperation

public PutIfAbsentOperation newPutIfAbsentOperation(byte[] key,
                                                    byte[] value,
                                                    int lifespanSecs,
                                                    int maxIdleSecs)

newReplaceOperation

public ReplaceOperation newReplaceOperation(byte[] key,
                                            byte[] values,
                                            int lifespanSecs,
                                            int maxIdleSecs)

newContainsKeyOperation

public ContainsKeyOperation newContainsKeyOperation(byte[] key)

newClearOperation

public ClearOperation newClearOperation()

newBulkGetOperation

public BulkGetOperation newBulkGetOperation(int size)

setFlags

public void setFlags(Flag[] flags)