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_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, 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_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, INFINITE_LIFESPAN, INFINITE_MAXIDLE, 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, QUERY_REQUEST, QUERY_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, VERSION_12

Constructor Summary

Constructors

Constructor and Description
OperationsFactory(TransportFactory transportFactory, String cacheName, AtomicInteger topologyId, boolean forceReturnValue, Codec codec)

Method Summary

Methods

Modifier and Type	Method and Description
void	addFlags(Flag... flags)
BulkGetKeysOperation	newBulkGetKeysOperation(int scope)
BulkGetOperation	newBulkGetOperation(int size)
ClearOperation	newClearOperation()
ContainsKeyOperation	newContainsKeyOperation(byte[] key)
FaultTolerantPingOperation	newFaultTolerantPingOperation() Construct a fault tolerant ping request.
GetOperation	newGetKeyOperation(byte[] key)
GetWithMetadataOperation	newGetWithMetadataOperation(byte[] key)
GetWithVersionOperation	newGetWithVersionOperation(byte[] key)
PingOperation	newPingOperation(Transport transport) Construct a ping request directed to a particular node.
PutIfAbsentOperation	newPutIfAbsentOperation(byte[] key, byte[] value, int lifespanSecs, int maxIdleSecs)
PutOperation	newPutKeyValueOperation(byte[] key, byte[] value, int lifespanSecs, int maxIdleSecs)
QueryOperation	newQueryOperation(RemoteQuery remoteQuery)
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,
                 Codec codec)

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)

newGetWithMetadataOperation

public GetWithMetadataOperation newGetWithMetadataOperation(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)

newBulkGetKeysOperation

public BulkGetKeysOperation newBulkGetKeysOperation(int scope)

newPingOperation

public PingOperation newPingOperation(Transport transport)

Construct a ping request directed to a particular node.

Parameters:

transport - represents the node to which the operation is directed

Returns:

a ping operation for a particular node

newFaultTolerantPingOperation

public FaultTolerantPingOperation newFaultTolerantPingOperation()

Construct a fault tolerant ping request. This operation should be capable to deal with nodes being down, so it will find the first node successful node to respond to the ping.

Returns:

a ping operation for the cluster

newQueryOperation

public QueryOperation newQueryOperation(RemoteQuery remoteQuery)

setFlags

public void setFlags(Flag[] flags)

addFlags

public void addFlags(Flag... flags)