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

java.lang.Object
  extended by 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, 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 Summary
OperationsFactory(TransportFactory transportFactory, String cacheName, AtomicInteger topologyId, boolean forceReturnValue, Codec codec)
           
 
Method Summary
 BulkGetOperation newBulkGetOperation(int size)
           
 ClearOperation newClearOperation()
           
 ContainsKeyOperation newContainsKeyOperation(byte[] key)
           
 FaultTolerantPingOperation newFaultTolerantPingOperation()
          Construct a fault tolerant ping request.
 GetOperation newGetKeyOperation(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)
           
 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)

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)

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

setFlags

public void setFlags(Flag[] flags)

-->

Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.