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 forHotRodOperation
objects.- Since:
- 4.1
- Author:
- Mircea.Markus@jboss.com
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants
HotRodConstants.Names
-
-
Field Summary
-
Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants
ADD_CLIENT_LISTENER_REQUEST, ADD_CLIENT_LISTENER_RESPONSE, AUTH_MECH_LIST_REQUEST, AUTH_MECH_LIST_RESPONSE, AUTH_REQUEST, AUTH_RESPONSE, BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CACHE_ENTRY_CREATED_EVENT_RESPONSE, CACHE_ENTRY_EXPIRED_EVENT_RESPONSE, CACHE_ENTRY_MODIFIED_EVENT_RESPONSE, CACHE_ENTRY_REMOVED_EVENT_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, COMMAND_TIMEOUT_STATUS, COMMIT_REQUEST, COMMIT_RESPONSE, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, COUNTER_ADD_AND_GET_REQUEST, COUNTER_ADD_AND_GET_RESPONSE, COUNTER_ADD_LISTENER_REQUEST, COUNTER_ADD_LISTENER_RESPONSE, COUNTER_CAS_REQUEST, COUNTER_CAS_RESPONSE, COUNTER_CREATE_REQUEST, COUNTER_CREATE_RESPONSE, COUNTER_EVENT_RESPONSE, COUNTER_GET_CONFIGURATION_REQUEST, COUNTER_GET_CONFIGURATION_RESPONSE, COUNTER_GET_NAMES_REQUEST, COUNTER_GET_NAMES_RESPONSE, COUNTER_GET_REQUEST, COUNTER_GET_RESPONSE, COUNTER_IS_DEFINED_REQUEST, COUNTER_IS_DEFINED_RESPONSE, COUNTER_REMOVE_LISTENER_REQUEST, COUNTER_REMOVE_LISTENER_RESPONSE, COUNTER_REMOVE_REQUEST, COUNTER_REMOVE_RESPONSE, COUNTER_RESET_REQUEST, COUNTER_RESET_RESPONSE, DEFAULT_CACHE_NAME_BYTES, DEFAULT_CACHE_TOPOLOGY, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_STREAM_REQUEST, GET_STREAM_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, ILLEGAL_OP_CODE, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_ITERATION, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, ITERATION_END_REQUEST, ITERATION_END_RESPONSE, ITERATION_NEXT_REQUEST, ITERATION_NEXT_RESPONSE, ITERATION_START_REQUEST, ITERATION_START_RESPONSE, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NO_ERROR_STATUS_COMPAT, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_COMPAT, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PREPARE_REQUEST, PREPARE_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, PUT_STREAM_REQUEST, PUT_STREAM_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_CLIENT_LISTENER_REQUEST, REMOVE_CLIENT_LISTENER_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, ROLLBACK_REQUEST, ROLLBACK_RESPONSE, SERVER_ERROR_STATUS, SIZE_REQUEST, SIZE_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_COMPAT, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12, VERSION_13, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25, VERSION_26, VERSION_27, VERSION_28
-
-
Constructor Summary
Constructors Constructor Description OperationsFactory(ChannelFactory channelFactory, String cacheName, boolean forceReturnValue, Codec codec, ClientListenerNotifier listenerNotifier, Configuration cfg)
OperationsFactory(ChannelFactory channelFactory, Codec codec, Configuration cfg, ClientListenerNotifier listenerNotifier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
flags()
String
getCacheName()
CacheTopologyInfo
getCacheTopologyInfo()
Codec
getCodec()
ClientListenerNotifier
getListenerNotifier()
boolean
hasFlag(Flag flag)
AddClientListenerOperation
newAddClientListenerOperation(Object listener, byte[][] filterFactoryParams, byte[][] converterFactoryParams, DataFormat dataFormat)
AddClientListenerOperation
newAddClientListenerOperation(Object listener, DataFormat dataFormat)
AdminOperation
newAdminOperation(String taskName, Map<String,byte[]> marshalledParams)
AuthMechListOperation
newAuthMechListOperation(io.netty.channel.Channel channel)
AuthOperation
newAuthOperation(io.netty.channel.Channel channel, String saslMechanism, byte[] response)
<K> BulkGetKeysOperation<K>
newBulkGetKeysOperation(int scope)
<K,V>
BulkGetOperation<K,V>newBulkGetOperation(int size)
ClearOperation
newClearOperation()
CompleteTransactionOperation
newCompleteTransactionOperation(Xid xid, boolean commit)
ContainsKeyOperation
newContainsKeyOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
<T> ExecuteOperation<T>
newExecuteOperation(String taskName, Map<String,byte[]> marshalledParams, Object key)
FaultTolerantPingOperation
newFaultTolerantPingOperation()
Construct a fault tolerant ping request.<K,V>
GetAllParallelOperation<K,V>newGetAllOperation(Set<byte[]> keys, DataFormat dataFormat)
<V> GetOperation<V>
newGetKeyOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
<K> GetStreamOperation
newGetStreamOperation(K key, byte[] keyBytes, int offset)
<V> GetWithMetadataOperation<V>
newGetWithMetadataOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
<V> GetWithVersionOperation<V>
newGetWithVersionOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
IterationEndOperation
newIterationEndOperation(byte[] iterationId, io.netty.channel.Channel channel)
<E> IterationNextOperation<E>
newIterationNextOperation(byte[] iterationId, io.netty.channel.Channel channel, KeyTracker segmentKeyTracker, DataFormat dataFormat)
IterationStartOperation
newIterationStartOperation(String filterConverterFactory, byte[][] filterParameters, Set<Integer> segments, int batchSize, boolean metadata, DataFormat dataFormat)
PingOperation
newPingOperation(boolean releaseChannel)
Construct a ping request directed to a particular node.PrepareTransactionOperation
newPrepareTransactionOperation(Xid xid, boolean onePhaseCommit, Collection<Modification> modifications)
PutAllParallelOperation
newPutAllOperation(Map<byte[],byte[]> map, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
<V> PutIfAbsentOperation<V>
newPutIfAbsentOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
<K> PutStreamOperation
newPutIfAbsentStreamOperation(K key, byte[] keyBytes, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
<V> PutOperation<V>
newPutKeyValueOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
<K> PutStreamOperation
newPutStreamOperation(K key, byte[] keyBytes, long version, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
<K> PutStreamOperation
newPutStreamOperation(K key, byte[] keyBytes, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
QueryOperation
newQueryOperation(RemoteQuery remoteQuery)
RemoveClientListenerOperation
newRemoveClientListenerOperation(Object listener)
<V> RemoveIfUnmodifiedOperation<V>
newRemoveIfUnmodifiedOperation(Object key, byte[] keyBytes, long version, DataFormat dataFormat)
<V> RemoveOperation<V>
newRemoveOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
ReplaceIfUnmodifiedOperation
newReplaceIfUnmodifiedOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, long version, DataFormat dataFormat)
<V> ReplaceOperation<V>
newReplaceOperation(Object key, byte[] keyBytes, byte[] values, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
SizeOperation
newSizeOperation()
StatsOperation
newStatsOperation()
void
setFlags(int intFlags)
void
setFlags(Flag[] flags)
-
-
-
Constructor Detail
-
OperationsFactory
public OperationsFactory(ChannelFactory channelFactory, String cacheName, boolean forceReturnValue, Codec codec, ClientListenerNotifier listenerNotifier, Configuration cfg)
-
OperationsFactory
public OperationsFactory(ChannelFactory channelFactory, Codec codec, Configuration cfg, ClientListenerNotifier listenerNotifier)
-
-
Method Detail
-
getListenerNotifier
public ClientListenerNotifier getListenerNotifier()
-
getCacheName
public String getCacheName()
-
getCodec
public Codec getCodec()
-
newGetKeyOperation
public <V> GetOperation<V> newGetKeyOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
-
newGetAllOperation
public <K,V> GetAllParallelOperation<K,V> newGetAllOperation(Set<byte[]> keys, DataFormat dataFormat)
-
newRemoveOperation
public <V> RemoveOperation<V> newRemoveOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
-
newRemoveIfUnmodifiedOperation
public <V> RemoveIfUnmodifiedOperation<V> newRemoveIfUnmodifiedOperation(Object key, byte[] keyBytes, long version, DataFormat dataFormat)
-
newReplaceIfUnmodifiedOperation
public ReplaceIfUnmodifiedOperation newReplaceIfUnmodifiedOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, long version, DataFormat dataFormat)
-
newGetWithVersionOperation
public <V> GetWithVersionOperation<V> newGetWithVersionOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
-
newGetWithMetadataOperation
public <V> GetWithMetadataOperation<V> newGetWithMetadataOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
-
newStatsOperation
public StatsOperation newStatsOperation()
-
newPutKeyValueOperation
public <V> PutOperation<V> newPutKeyValueOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
-
newPutAllOperation
public PutAllParallelOperation newPutAllOperation(Map<byte[],byte[]> map, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
-
newPutIfAbsentOperation
public <V> PutIfAbsentOperation<V> newPutIfAbsentOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
-
newReplaceOperation
public <V> ReplaceOperation<V> newReplaceOperation(Object key, byte[] keyBytes, byte[] values, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, DataFormat dataFormat)
-
newContainsKeyOperation
public ContainsKeyOperation newContainsKeyOperation(Object key, byte[] keyBytes, DataFormat dataFormat)
-
newClearOperation
public ClearOperation newClearOperation()
-
newBulkGetOperation
public <K,V> BulkGetOperation<K,V> newBulkGetOperation(int size)
-
newBulkGetKeysOperation
public <K> BulkGetKeysOperation<K> newBulkGetKeysOperation(int scope)
-
newAddClientListenerOperation
public AddClientListenerOperation newAddClientListenerOperation(Object listener, DataFormat dataFormat)
-
newAddClientListenerOperation
public AddClientListenerOperation newAddClientListenerOperation(Object listener, byte[][] filterFactoryParams, byte[][] converterFactoryParams, DataFormat dataFormat)
-
newRemoveClientListenerOperation
public RemoveClientListenerOperation newRemoveClientListenerOperation(Object listener)
-
newPingOperation
public PingOperation newPingOperation(boolean releaseChannel)
Construct a ping request directed to a particular node.- Parameters:
releaseChannel
-- 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)
-
newSizeOperation
public SizeOperation newSizeOperation()
-
newExecuteOperation
public <T> ExecuteOperation<T> newExecuteOperation(String taskName, Map<String,byte[]> marshalledParams, Object key)
-
newAdminOperation
public AdminOperation newAdminOperation(String taskName, Map<String,byte[]> marshalledParams)
-
flags
public int flags()
-
setFlags
public void setFlags(Flag[] flags)
-
setFlags
public void setFlags(int intFlags)
-
hasFlag
public boolean hasFlag(Flag flag)
-
getCacheTopologyInfo
public CacheTopologyInfo getCacheTopologyInfo()
-
newIterationStartOperation
public IterationStartOperation newIterationStartOperation(String filterConverterFactory, byte[][] filterParameters, Set<Integer> segments, int batchSize, boolean metadata, DataFormat dataFormat)
-
newIterationEndOperation
public IterationEndOperation newIterationEndOperation(byte[] iterationId, io.netty.channel.Channel channel)
-
newIterationNextOperation
public <E> IterationNextOperation<E> newIterationNextOperation(byte[] iterationId, io.netty.channel.Channel channel, KeyTracker segmentKeyTracker, DataFormat dataFormat)
-
newGetStreamOperation
public <K> GetStreamOperation newGetStreamOperation(K key, byte[] keyBytes, int offset)
-
newPutStreamOperation
public <K> PutStreamOperation newPutStreamOperation(K key, byte[] keyBytes, long version, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
-
newPutStreamOperation
public <K> PutStreamOperation newPutStreamOperation(K key, byte[] keyBytes, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
-
newPutIfAbsentStreamOperation
public <K> PutStreamOperation newPutIfAbsentStreamOperation(K key, byte[] keyBytes, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
-
newAuthMechListOperation
public AuthMechListOperation newAuthMechListOperation(io.netty.channel.Channel channel)
-
newAuthOperation
public AuthOperation newAuthOperation(io.netty.channel.Channel channel, String saslMechanism, byte[] response)
-
newPrepareTransactionOperation
public PrepareTransactionOperation newPrepareTransactionOperation(Xid xid, boolean onePhaseCommit, Collection<Modification> modifications)
-
newCompleteTransactionOperation
public CompleteTransactionOperation newCompleteTransactionOperation(Xid xid, boolean commit)
-
-