@Immutable public class OperationsFactory extends Object implements HotRodConstants
HotRodOperation
objects.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, CONTAINS_KEY_REQUEST, CONTAINS_KEY_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_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, 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, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_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, 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
Constructor and Description |
---|
OperationsFactory(TransportFactory transportFactory,
Codec codec,
ExecutorService executorService,
Configuration cfg) |
OperationsFactory(TransportFactory transportFactory,
String cacheName,
boolean forceReturnValue,
Codec codec,
ClientListenerNotifier listenerNotifier,
ExecutorService executorService,
Configuration cfg) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasCompatibility, hasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isSuccess
public OperationsFactory(TransportFactory transportFactory, String cacheName, boolean forceReturnValue, Codec codec, ClientListenerNotifier listenerNotifier, ExecutorService executorService, Configuration cfg)
public OperationsFactory(TransportFactory transportFactory, Codec codec, ExecutorService executorService, Configuration cfg)
public ClientListenerNotifier getListenerNotifier()
public byte[] getCacheName()
public <V> GetOperation<V> newGetKeyOperation(Object key, byte[] keyBytes)
public <K,V> GetAllParallelOperation<K,V> newGetAllOperation(Set<byte[]> keys)
public <V> RemoveOperation<V> newRemoveOperation(Object key, byte[] keyBytes)
public <V> RemoveIfUnmodifiedOperation<V> newRemoveIfUnmodifiedOperation(Object key, byte[] keyBytes, long version)
public ReplaceIfUnmodifiedOperation newReplaceIfUnmodifiedOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit, long version)
public <V> GetWithVersionOperation<V> newGetWithVersionOperation(Object key, byte[] keyBytes)
public <V> GetWithMetadataOperation<V> newGetWithMetadataOperation(Object key, byte[] keyBytes)
public StatsOperation newStatsOperation()
public <V> PutOperation<V> newPutKeyValueOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
public PutAllParallelOperation newPutAllOperation(Map<byte[],byte[]> map, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
public <V> PutIfAbsentOperation<V> newPutIfAbsentOperation(Object key, byte[] keyBytes, byte[] value, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)
public <V> ReplaceOperation<V> newReplaceOperation(Object key, byte[] keyBytes, byte[] values, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
public ContainsKeyOperation newContainsKeyOperation(Object key, byte[] keyBytes)
public ClearOperation newClearOperation()
public <K,V> BulkGetOperation<K,V> newBulkGetOperation(int size)
public <K> BulkGetKeysOperation<K> newBulkGetKeysOperation(int scope)
public AddClientListenerOperation newAddClientListenerOperation(Object listener)
public AddClientListenerOperation newAddClientListenerOperation(Object listener, byte[][] filterFactoryParams, byte[][] converterFactoryParams)
public RemoveClientListenerOperation newRemoveClientListenerOperation(Object listener)
public PingOperation newPingOperation(Transport transport)
transport
- represents the node to which the operation is directedpublic FaultTolerantPingOperation newFaultTolerantPingOperation()
public QueryOperation newQueryOperation(RemoteQuery remoteQuery)
public SizeOperation newSizeOperation()
public <T> ExecuteOperation<T> newExecuteOperation(String taskName, Map<String,byte[]> marshalledParams)
public int flags()
public void setFlags(Flag[] flags)
public void setFlags(int intFlags)
public void addFlag(Flag flag)
public boolean hasFlag(Flag flag)
public CacheTopologyInfo getCacheTopologyInfo()
public IterationStartOperation newIterationStartOperation(String filterConverterFactory, byte[][] filterParameters, Set<Integer> segments, int batchSize, boolean metadata)
public IterationEndOperation newIterationEndOperation(String iterationId, Transport transport)
public <K,V> IterationNextOperation newIterationNextOperation(String iterationId, Transport transport, KeyTracker segmentKeyTracker)
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.